applier

Documentation

Index

• Variables
• type ApplyMapFunc
  • func (a ApplyMapFunc) ApplyMap(ctx context.Context, message *isb.ReadMessage) ([]*isb.Message, error)
• type ApplyReduceFunc
  • func (a ApplyReduceFunc) ApplyReduce(ctx context.Context, partitionID *partition.ID, ...) ([]*isb.Message, error)
• type MapApplier
• type ReduceApplier

Variables

var (
	// Terminal Applier do not make any change to the message
	Terminal = ApplyMapFunc(func(ctx context.Context, msg *isb.ReadMessage) ([]*isb.Message, error) {
		return []*isb.Message{&msg.Message}, nil
	})
)

Types

type ApplyMapFunc

type ApplyMapFunc func(context.Context, *isb.ReadMessage) ([]*isb.Message, error)

ApplyMapFunc utility function used to create an Applier implementation

func (ApplyMapFunc) ApplyMap

func (a ApplyMapFunc) ApplyMap(ctx context.Context, message *isb.ReadMessage) ([]*isb.Message, error)

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 MapApplier

type MapApplier interface {
	ApplyMap(ctx context.Context, message *isb.ReadMessage) ([]*isb.Message, error)
}

MapApplier applies the UDF 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.

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.