diff options
Diffstat (limited to 'core/record.go')
| -rw-r--r-- | core/record.go | 12 |
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, } |