refactor: add context support to transport operators and runtime task management

1 files changed, 6 insertions, 6 deletions

diff --git a/core/record.go b/core/record.go
index cb160b2..e18e58d 100644
--- a/core/record.go
+++ b/core/record.go
@@ -16,8 +16,8 @@ type StreamRecord[T any] struct {
 	Type      RecordType
 }
 
-func NewDataRecord[T any](key string, val T, timestamp int64) *StreamRecord[T] {
-	return &StreamRecord[T]{
+func NewDataRecord[T any](key string, val T, timestamp int64) StreamRecord[T] {
+	return StreamRecord[T]{
 		Value:     val,
 		Key:       key,
 		Timestamp: timestamp,
@@ -25,15 +25,15 @@ func NewDataRecord[T any](key string, val T, timestamp int64) *StreamRecord[T] {
 	}
 }
 
-func NewWatermarkRecord[T any](timestamp int64) *StreamRecord[T] {
-	return &StreamRecord[T]{
+func NewWatermarkRecord[T any](timestamp int64) StreamRecord[T] {
+	return StreamRecord[T]{
 		Type:      RecordWatermark,
 		Timestamp: timestamp,
 	}
 }
 
-func NewBarrierRecord[T any](barrierID uint64) *StreamRecord[T] {
-	return &StreamRecord[T]{
+func NewBarrierRecord[T any](barrierID uint64) StreamRecord[T] {
+	return StreamRecord[T]{
 		Type:      RecordBarrier,
 		BarrierID: barrierID,
 	}