example

package
v0.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 27, 2023 License: GPL-3.0 Imports: 26 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_example_state_proto protoreflect.FileDescriptor

Functions

func WordCollect added in v0.1.3 

func WordCollect() runtime.Runtime

func WordCollectAggregator added in v0.1.3 

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

func WordCollectCollector added in v0.1.3 

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

func WordCollectPersistenceId added in v0.1.3 

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

func WordCount added in v0.0.4 

func WordCount() runtime.Runtime

func WordCountPersistenceId 

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

func WordCountStatefulFunction 

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

func WordJoin added in v0.0.4 

func WordJoin() runtime.Runtime

func WordJoinCountFunction 

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

func WordJoinPersistenceId 

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

func WordJoinWordFunction 

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

func WordMaterialise added in v0.0.4 

func WordMaterialise() runtime.Runtime

func WordRemap added in v0.0.4 

func WordRemap() runtime.Runtime

func WordRemapStatelessFunction 

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

Types

type FlowsMaterialised added in v0.0.4 

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

func FlowsMaterialisedMap added in v0.0.4 

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

type TestResponse 

type TestResponse struct {
	Message string
}

type WordCollectState added in v0.1.3 

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

func (*WordCollectState) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use WordCollectState.ProtoReflect.Descriptor instead.

func (*WordCollectState) GetCount added in v0.1.3 

func (x *WordCollectState) GetCount() int64

func (*WordCollectState) GetWord added in v0.1.3 

func (x *WordCollectState) GetWord() string

func (*WordCollectState) ProtoMessage added in v0.1.3 

func (*WordCollectState) ProtoMessage()

func (*WordCollectState) ProtoReflect added in v0.1.3 

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

func (*WordCollectState) Reset added in v0.1.3 

func (x *WordCollectState) Reset()

func (*WordCollectState) String added in v0.1.3 

func (x *WordCollectState) String() 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 deprecated 

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 deprecated 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.