applier

Documentation

Index

• Variables
• type Applier
• type ApplyFunc
  • func (a ApplyFunc) Apply(ctx context.Context, message *isb.ReadMessage) ([]*isb.Message, error)

Variables

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

Types

type Applier

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

Applier 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.

type ApplyFunc

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

ApplyFunc utility function used to create an Applier implementation

func (ApplyFunc) Apply

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