applier

Sep 6, 2023

Changes in this version

+ var TerminalMapStream = ApplyMapStreamFunc(func(ctx context.Context, msg *isb.ReadMessage, ...) error { ... })

+ type ApplyMapStreamFunc func(context.Context, *isb.ReadMessage, chan<- isb.WriteMessage) error

+ func (f ApplyMapStreamFunc) ApplyMapStream(ctx context.Context, message *isb.ReadMessage, ...) error

+ type MapStreamApplier interface

+ ApplyMapStream func(ctx context.Context, message *isb.ReadMessage, ...) error

May 30, 2023

Changes in this version

type ApplyMapFunc

+ func (a ApplyMapFunc) ApplyMapStream(ctx context.Context, message *isb.ReadMessage, ...) error

type MapApplier

+ ApplyMapStream func(ctx context.Context, message *isb.ReadMessage, ...) error

Feb 14, 2023

Changes in this version

+ var Terminal = ApplyMapFunc(...)

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

+ func (a ApplyMapFunc) ApplyMap(ctx context.Context, message *isb.ReadMessage) ([]*isb.Message, error)

+ type MapApplier interface

+ ApplyMap func(ctx context.Context, message *isb.ReadMessage) ([]*isb.Message, error)