applier

Documentation

Index

• type ApplyReduceFunc
  • func (a ApplyReduceFunc) ApplyReduce(ctx context.Context, partitionID *partition.ID, ...) ([]*isb.Message, error)
• type ReduceApplier

Types

type ApplyReduceFunc

type ApplyReduceFunc func(context.Context, *partition.ID, <-chan *isb.ReadMessage) ([]*isb.Message, error)

ApplyReduceFunc utility function used to create a Reducer implementation

func (ApplyReduceFunc) ApplyReduce

func (a ApplyReduceFunc) ApplyReduce(ctx context.Context, partitionID *partition.ID, messageStream <-chan *isb.ReadMessage) ([]*isb.Message, error)

type ReduceApplier

type ReduceApplier interface {
	ApplyReduce(ctx context.Context, partitionID *partition.ID, messageStream <-chan *isb.ReadMessage) ([]*isb.Message, error)
}

ReduceApplier applies the HTTPBasedUDF on the read message and gives back a new message. Any UserError will be retried here, while InternalErr can be returned and could be retried by the callee.