redisstreams

Documentation

Index

• func New(vertexInstance *dfv1.VertexInstance, writers map[string][]isb.BufferWriter, ...) (*redisStreamsSource, error)
• type Option
  • func WithLogger(l *zap.SugaredLogger) Option
  • func WithReadTimeOut(t time.Duration) Option

Functions

func New

func New(
	vertexInstance *dfv1.VertexInstance,
	writers map[string][]isb.BufferWriter,
	fsd forward.ToWhichStepDecider,
	mapApplier applier.MapApplier,
	fetchWM fetch.Fetcher,
	publishWM map[string]publish.Publisher,
	publishWMStores store.WatermarkStorer,
	opts ...Option) (*redisStreamsSource, error)

Types

type Option

type Option func(*redisStreamsSource) error

func WithLogger

func WithLogger(l *zap.SugaredLogger) Option

WithLogger is used to return logger information

func WithReadTimeOut

func WithReadTimeOut(t time.Duration) Option

WithReadTimeOut sets the read timeout