applier

Nov 18, 2022

Changes in this version

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

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

+ type ApplyReduceFunc func(context.Context, *partition.ID, <-chan *isb.ReadMessage) ([]*isb.Message, error)

+ func (a ApplyReduceFunc) ApplyReduce(ctx context.Context, partitionID *partition.ID, ...) ([]*isb.Message, error)

+ type MapApplier interface

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

+ type ReduceApplier interface

+ ApplyReduce func(ctx context.Context, partitionID *partition.ID, ...) ([]*isb.Message, error)

Sep 20, 2022

Changes in this version

+ func NewUDSGRPCBasedUDF() (*udsGRPCBasedUDF, error)

Jun 1, 2022

Changes in this version

+ var Terminal = ApplyFunc(...)

+ type Applier interface

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

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

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

+ type ApplyUDFErr struct

+ Message string

+ UserUDFErr bool

+ func (e ApplyUDFErr) Error() string

+ func (e ApplyUDFErr) IsInternalErr() bool

+ func (e ApplyUDFErr) IsUserUDFErr() bool

+ type InternalErr struct

+ Flag bool

+ MainCarDown bool

+ type Option interface

+ func WithHTTPClientTimeout(t time.Duration) Option

+ type UDSHTTPBasedUDF struct

+ func NewUDSHTTPBasedUDF(socketPath string, opts ...Option) *UDSHTTPBasedUDF

+ func (u *UDSHTTPBasedUDF) Apply(ctx context.Context, readMessage *isb.ReadMessage) ([]*isb.Message, error)

+ func (u *UDSHTTPBasedUDF) WaitUntilReady(ctx context.Context) error