nats

Documentation

Index

• func New(vertexInstance *dfv1.VertexInstance, writers map[string][]isb.BufferWriter, ...) (sourcer.Sourcer, error)
• type Option
  • func WithBufferSize(s int) 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 forwarder.ToWhichStepDecider,
	transformerApplier applier.SourceTransformApplier,
	fetchWM fetch.SourceFetcher,
	toVertexPublisherStores map[string]store.WatermarkStore,
	publishWMStores store.WatermarkStore,
	idleManager wmb.IdleManager,
	opts ...Option) (sourcer.Sourcer, error)

Types

type Option

type Option func(*natsSource) error

func WithBufferSize

func WithBufferSize(s int) Option

WithBufferSize sets the buffer size for storing the messages from nats

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