applier

Documentation

Index

• type ApplyMapFunc
  • func (f ApplyMapFunc) ApplyMap(ctx context.Context, message *isb.ReadMessage) ([]*isb.WriteMessage, error)
• type ApplyMapStreamFunc
  • func (f ApplyMapStreamFunc) ApplyMapStream(ctx context.Context, message *isb.ReadMessage, ...) error
• type MapApplier
• type MapStreamApplier

Types

type ApplyMapFunc

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

ApplyMapFunc utility function used to create a MapApplier implementation

func (ApplyMapFunc) ApplyMap

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

type ApplyMapStreamFunc

type ApplyMapStreamFunc func(context.Context, *isb.ReadMessage, chan<- isb.WriteMessage) error

ApplyMapStreamFunc utility function used to create a MapStreamApplier implementation

func (ApplyMapStreamFunc) ApplyMapStream

func (f ApplyMapStreamFunc) ApplyMapStream(ctx context.Context, message *isb.ReadMessage, writeMessageCh chan<- isb.WriteMessage) error

type MapApplier

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

MapApplier applies the map 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 MapStreamApplier

type MapStreamApplier interface {
	ApplyMapStream(ctx context.Context, message *isb.ReadMessage, writeMessageCh chan<- isb.WriteMessage) error
}

MapStreamApplier applies the map stream udf on the read message and gives back response. Any UserError will be retried here, while InternalErr can be returned and could be retried by the callee.