From 0958e46c3651f2c8b6d76bcffbd8820063647d59 Mon Sep 17 00:00:00 2001 From: SangTran-127 Date: Sat, 8 Aug 2026 17:24:01 +0700 Subject: refactor: add context support to transport operators and runtime task management --- core/record.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'core/record.go') 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, } -- cgit v1.2.3