join

Documentation

Index

• Variables
• func NewIntermediateToJoinMap(configurations ...runtime.Configuration[*IntermediateToJoinMap]) stateless.SingleFunction
• func NewSourceToIntermediateMap(configurations ...runtime.Configuration[*SourceToIntermediateMap]) stateless.SingleFunction
• func WithIntermediateToJoinMapTransactionWrappedFunction(f stateless.SingleFunction) runtime.Configuration[*IntermediateToJoinMap]
• func WithSourceToIntermediateMapIntermediateTopic(intermediateTopic string) runtime.Configuration[*SourceToIntermediateMap]
• func WithSourceToIntermediateMapPersistenceIdFunction(f stateful.PersistenceIdFunction[[]byte, []byte]) runtime.Configuration[*SourceToIntermediateMap]
• type IntermediateToJoinMap
  • func (r *IntermediateToJoinMap) Apply(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)
• type SourceToIntermediateMap
  • func (r *SourceToIntermediateMap) Apply(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

Variables

var ErrorIntermediateToJoinDeserialiseMessage = errors.New("error deserialising message")

var IntermediateKeyFormat = format.Protobuf[*protobuf.JoinKey]()

var IntermediateValueFormat = message.Format()

Functions

func NewIntermediateToJoinMap

func NewIntermediateToJoinMap(configurations ...runtime.Configuration[*IntermediateToJoinMap]) stateless.SingleFunction

constructor

func NewSourceToIntermediateMap

func NewSourceToIntermediateMap(configurations ...runtime.Configuration[*SourceToIntermediateMap]) stateless.SingleFunction

func WithIntermediateToJoinMapTransactionWrappedFunction

func WithIntermediateToJoinMapTransactionWrappedFunction(f stateless.SingleFunction) runtime.Configuration[*IntermediateToJoinMap]

configuration

func WithSourceToIntermediateMapIntermediateTopic

func WithSourceToIntermediateMapIntermediateTopic(intermediateTopic string) runtime.Configuration[*SourceToIntermediateMap]

configuration

func WithSourceToIntermediateMapPersistenceIdFunction

func WithSourceToIntermediateMapPersistenceIdFunction(f stateful.PersistenceIdFunction[[]byte, []byte]) runtime.Configuration[*SourceToIntermediateMap]

Types

type IntermediateToJoinMap

type IntermediateToJoinMap struct {
	// contains filtered or unexported fields
}

implementation

func (*IntermediateToJoinMap) Apply

func (r *IntermediateToJoinMap) Apply(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

type SourceToIntermediateMap

type SourceToIntermediateMap struct {
	// contains filtered or unexported fields
}

implementation

func (*SourceToIntermediateMap) Apply

func (r *SourceToIntermediateMap) Apply(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)