example

Documentation

Index

• Variables
• func WordCount() runtime.Runtime
• func WordCountPersistenceId(ctx context.Context, m message.Message[string, string]) (string, error)
• func WordCountStatefulFunction(c context.Context, m message.Message[string, string], ...) (*message.Message[string, string], stateful.SingleState[*WordCountState], error)
• func WordJoin() runtime.Runtime
• 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 WordJoinWordFunction(c context.Context, m message.Message[string, string], ...) (*message.Message[string, string], stateful.SingleState[*WordJoinState], error)
• func WordMaterialise() runtime.Runtime
• func WordRemap() runtime.Runtime
• func WordRemapStatelessFunction(c context.Context, m message.Message[string, string]) (*message.Message[string, string], error)
• type FlowsMaterialised
  • func FlowsMaterialisedMap(c context.Context, m message.Message[string, string]) ([]FlowsMaterialised, error)
• type TestResponse
• type WordCountState
  • func (*WordCountState) Descriptor() ([]byte, []int)
  • func (x *WordCountState) GetCount() int64
  • func (*WordCountState) ProtoMessage()
  • func (x *WordCountState) ProtoReflect() protoreflect.Message
  • func (x *WordCountState) Reset()
  • func (x *WordCountState) String() string
• type WordJoinState
  • func (*WordJoinState) Descriptor() ([]byte, []int)
  • func (x *WordJoinState) GetCount() int64
  • func (x *WordJoinState) GetWord() string
  • func (*WordJoinState) ProtoMessage()
  • func (x *WordJoinState) ProtoReflect() protoreflect.Message
  • func (x *WordJoinState) Reset()
  • func (x *WordJoinState) String() string

Variables

var File_example_state_proto protoreflect.FileDescriptor

Functions

func WordCount

func WordCount() runtime.Runtime

func WordCountPersistenceId

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

func WordCountStatefulFunction

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

func WordJoin

func WordJoin() runtime.Runtime

func WordJoinCountFunction

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

func WordJoinPersistenceId

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

func WordJoinWordFunction

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

func WordMaterialise

func WordMaterialise() runtime.Runtime

func WordRemap

func WordRemap() runtime.Runtime

func WordRemapStatelessFunction

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

Types

type FlowsMaterialised

type FlowsMaterialised struct {
	bun.BaseModel `bun:"table:flows_materialised"`
	Id            string `bun:",pk"`
	KeyContent    string
	ValueContent  string
	TimestampMs   int64
}

func FlowsMaterialisedMap

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

type TestResponse

type TestResponse struct {
	Message string
}

type WordCountState

type WordCountState struct {
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*WordCountState) Descriptor

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

Deprecated: Use WordCountState.ProtoReflect.Descriptor instead.

func (*WordCountState) GetCount

func (x *WordCountState) GetCount() int64

func (*WordCountState) ProtoMessage

func (*WordCountState) ProtoMessage()

func (*WordCountState) ProtoReflect

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

func (*WordCountState) Reset

func (x *WordCountState) Reset()

func (*WordCountState) String

func (x *WordCountState) String() string

type WordJoinState

type WordJoinState struct {
	Count int64  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Word  string `protobuf:"bytes,2,opt,name=word,proto3" json:"word,omitempty"`
	// contains filtered or unexported fields
}

func (*WordJoinState) Descriptor

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

Deprecated: Use WordJoinState.ProtoReflect.Descriptor instead.

func (*WordJoinState) GetCount

func (x *WordJoinState) GetCount() int64

func (*WordJoinState) GetWord

func (x *WordJoinState) GetWord() string

func (*WordJoinState) ProtoMessage

func (*WordJoinState) ProtoMessage()

func (*WordJoinState) ProtoReflect

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

func (*WordJoinState) Reset

func (x *WordJoinState) Reset()

func (*WordJoinState) String

func (x *WordJoinState) String() string