forward

Nov 8, 2024

Changes in this version

type Option

+ func WithUDFMap(f applier.MapApplier) Option

Aug 19, 2024

Changes in this version

type Option

+ func WithCallbackUploader(cp *callback.Uploader) Option

+ func WithUDFBatchMap(f applier.BatchMapApplier) Option

+ func WithUDFStreamingMap(f applier.MapStreamApplier) Option

+ func WithUDFUnaryMap(f applier.MapApplier) Option

Dec 18, 2023

Changes in this version

+ func DefaultOptions() *options

+ type InterStepDataForward struct

+ FSD forwarder.ToWhichStepDecider

+ func NewInterStepDataForward(vertexInstance *dfv1.VertexInstance, fromStep isb.BufferReader, ...) (*InterStepDataForward, error)

+ func (isdf *InterStepDataForward) ForceStop()

+ func (isdf *InterStepDataForward) IsShuttingDown() (bool, error)

+ func (isdf *InterStepDataForward) Start() <-chan struct{}

+ func (isdf *InterStepDataForward) Stop()

+ type Option func(*options) error

+ func WithLogger(l *zap.SugaredLogger) Option

+ func WithReadBatchSize(f int64) Option

+ func WithRetryInterval(f time.Duration) Option

+ func WithUDFConcurrency(f int) Option

+ func WithUDFStreaming(f bool) Option

+ type Shutdown struct

+ func (s *Shutdown) String() string