applier

Documentation

Index

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

Variables

var (
	// Terminal Applier do not make any change to the message
	Terminal = ApplyMapFunc{
		// contains filtered or unexported fields
	}
)

Types

type ApplyMapFunc

type ApplyMapFunc struct {
	// contains filtered or unexported fields
}

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)

func (ApplyMapFunc) ApplyMapStream

func (a ApplyMapFunc) 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)
	ApplyMapStream(ctx context.Context, message *isb.ReadMessage, writeMessageCh chan<- 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.