applier

Documentation

Index

• Variables
• type ApplySourceTransformFunc
  • func (f ApplySourceTransformFunc) ApplyTransform(ctx context.Context, message *isb.ReadMessage) ([]*isb.WriteMessage, error)
• type SourceTransformApplier

Variables

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

Types

type ApplySourceTransformFunc

type ApplySourceTransformFunc func(ctx context.Context, message *isb.ReadMessage) ([]*isb.WriteMessage, error)

ApplySourceTransformFunc is a function type that implements SourceTransformApplier interface.

func (ApplySourceTransformFunc) ApplyTransform

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

ApplyTransform implements SourceTransformApplier interface.

type SourceTransformApplier

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

SourceTransformApplier applies the source transform 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.