Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApplyMapFunc ¶
type ApplyMapFunc func(context.Context, []*isb.ReadMessage) ([]isb.ReadWriteMessagePair, error)
ApplyMapFunc utility function used to create a MapApplier implementation
func (ApplyMapFunc) ApplyMap ¶
func (f ApplyMapFunc) ApplyMap(ctx context.Context, message []*isb.ReadMessage) ([]isb.ReadWriteMessagePair, error)
type ApplyMapStreamFunc ¶
type ApplyMapStreamFunc func(context.Context, *isb.ReadMessage, chan<- isb.WriteMessage) error
ApplyMapStreamFunc utility function used to create a MapStreamApplier implementation
func (ApplyMapStreamFunc) ApplyMapStream ¶
func (f ApplyMapStreamFunc) ApplyMapStream(ctx context.Context, message *isb.ReadMessage, writeMessageCh chan<- isb.WriteMessage) error
type BatchMapApplier ¶ added in v1.3.0
type BatchMapApplier interface {
ApplyBatchMap(ctx context.Context, messages []*isb.ReadMessage) ([]isb.ReadWriteMessagePair, error)
}
BatchMapApplier applies the batch map UDF on the read messages and gives back the responses for the whole batch
type BatchMapFunc ¶ added in v1.3.0
type BatchMapFunc func(ctx context.Context, messages []*isb.ReadMessage) ([]isb.ReadWriteMessagePair, error)
BatchMapFunc utility function used to create a BatchMapApplier implementation
func (BatchMapFunc) ApplyBatchMap ¶ added in v1.3.0
func (f BatchMapFunc) ApplyBatchMap(ctx context.Context, messages []*isb.ReadMessage) ([]isb.ReadWriteMessagePair, error)
type MapApplier ¶
type MapApplier interface {
ApplyMap(ctx context.Context, message []*isb.ReadMessage) ([]isb.ReadWriteMessagePair, error)
}
MapApplier applies the map UDF 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.
type MapStreamApplier ¶
type MapStreamApplier interface {
ApplyMapStream(ctx context.Context, message *isb.ReadMessage, writeMessageCh chan<- isb.WriteMessage) error
}
MapStreamApplier applies the map stream udf on the read message and gives back response. Any UserError will be retried here, while InternalErr can be returned and could be retried by the callee.
Source Files