applier

Documentation

Index

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

Types

type ApplySourceTransformFunc

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

ApplySourceTransformFunc is a function type that implements SourceTransformApplier interface.

func (ApplySourceTransformFunc) ApplyTransform

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

ApplyTransform implements SourceTransformApplier interface.

type SourceTransformApplier

type SourceTransformApplier interface {
	ApplyTransform(ctx context.Context, messages []*isb.ReadMessage) ([]isb.ReadWriteMessagePair, 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.