example

Documentation

Index

• Variables
• 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
• 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 WordCountPersistenceId

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

func WordCountRun

func WordCountRun() 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 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 WordJoinRun

func WordJoinRun() 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 WordRemapRun

func WordRemapRun() error

func WordRemapStatelessFunction

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

Types

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