example

Aug 24, 2023

Changes in this version

+ func WordCollect() runtime.Runtime

+ func WordCollectAggregator(c context.Context, m message.Message[string, string], ...) (stateful.State[*WordCollectState], error)

+ func WordCollectCollector(c context.Context, persistenceId string, s stateful.State[*WordCollectState]) (*message.Message[string, string], error)

+ func WordCollectPersistenceId(ctx context.Context, m message.Message[string, string]) (string, error)

+ type WordCollectState struct

+ Count int64

+ Word string

+ func (*WordCollectState) Descriptor() ([]byte, []int)

+ func (*WordCollectState) ProtoMessage()

+ func (x *WordCollectState) GetCount() int64

+ func (x *WordCollectState) GetWord() string

+ func (x *WordCollectState) ProtoReflect() protoreflect.Message

+ func (x *WordCollectState) Reset()

+ func (x *WordCollectState) String() string

May 4, 2023

Changes in this version

+ func WordCount() runtime.Runtime

+ func WordJoin() runtime.Runtime

+ func WordMaterialise() runtime.Runtime

+ func WordRemap() runtime.Runtime

+ type FlowsMaterialised struct

+ Id string

+ KeyContent string

+ TimestampMs int64

+ ValueContent string

+ func FlowsMaterialisedMap(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]FlowsMaterialised, error)

Apr 27, 2023

Changes in this version

+ var File_example_state_proto protoreflect.FileDescriptor

+ func WordCountPersistenceId(ctx context.Context, m message.Message[string, string]) (string, error)

+ func WordCountRun() error

+ func WordCountStatefulFunction(c context.Context, m message.Message[string, string], ...) (*message.Message[string, string], stateful.SingleState[*WordCountState], error)

+ func WordJoinCountFunction(c context.Context, m message.Message[string, string], ...) (*message.Message[string, string], stateful.SingleState[*WordJoinState], error)

+ func WordJoinPersistenceId(ctx context.Context, m message.Message[string, string]) (string, error)

+ func WordJoinRun() error

+ func WordJoinWordFunction(c context.Context, m message.Message[string, string], ...) (*message.Message[string, string], stateful.SingleState[*WordJoinState], error)

+ func WordRemapRun() error

+ func WordRemapStatelessFunction(c context.Context, m message.Message[string, string]) (*message.Message[string, string], error)

+ type TestResponse struct

+ Message string

+ type WordCountState struct

+ Count int64

+ func (*WordCountState) Descriptor() ([]byte, []int)

+ func (*WordCountState) ProtoMessage()

+ func (x *WordCountState) GetCount() int64

+ func (x *WordCountState) ProtoReflect() protoreflect.Message

+ func (x *WordCountState) Reset()

+ func (x *WordCountState) String() string

+ type WordJoinState struct

+ Count int64

+ Word string

+ func (*WordJoinState) Descriptor() ([]byte, []int)

+ func (*WordJoinState) ProtoMessage()

+ func (x *WordJoinState) GetCount() int64

+ func (x *WordJoinState) GetWord() string

+ func (x *WordJoinState) ProtoReflect() protoreflect.Message

+ func (x *WordJoinState) Reset()

+ func (x *WordJoinState) String() string