From acc0b6fbaace61a3befd7f726f9d80fb69391126 Mon Sep 17 00:00:00 2001 From: SangTran-127 Date: Sat, 8 Aug 2026 12:54:43 +0700 Subject: implement core transport and processing operators with receiver, emitter, filter, and map functionalities --- core/operator.go | 11 +++++++++++ 1 file changed, 11 insertions(+) create mode 100644 core/operator.go (limited to 'core/operator.go') diff --git a/core/operator.go b/core/operator.go new file mode 100644 index 0000000..40d0ca6 --- /dev/null +++ b/core/operator.go @@ -0,0 +1,11 @@ +package core + +type Emitter[OUT any] interface { + Emit(record StreamRecord[OUT]) error +} + +type Operator[IN, OUT any] interface { + Open() error + Process(record StreamRecord[IN], out Emitter[OUT]) error + Close() error +} -- cgit v1.2.3