applier

Documentation

Index

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

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.