applier

Documentation

Index

• Variables
• type ApplyMapFunc
  • func (a ApplyMapFunc) ApplyMap(ctx context.Context, message *isb.ReadMessage) ([]*isb.WriteMessage, error)
• type MapApplier

Variables

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

Types

type ApplyMapFunc

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

ApplyMapFunc utility function used to create an Applier implementation

func (ApplyMapFunc) ApplyMap

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

type MapApplier

type MapApplier interface {
	ApplyMap(ctx context.Context, message *isb.ReadMessage) ([]*isb.WriteMessage, 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.