jetstream

Documentation

Index

• func New(ctx context.Context, vertexInstance *dfv1.VertexInstance, opts ...Option) (sourcer.SourceReader, error)
• type Option
  • func WithBufferSize(s int) Option
  • func WithLogger(l *zap.SugaredLogger) Option
  • func WithReadTimeout(t time.Duration) Option
  • func WithServingEnabled() Option

Functions

func New

func New(ctx context.Context, vertexInstance *dfv1.VertexInstance, opts ...Option) (sourcer.SourceReader, error)

New creates a Jetstream source reader.

Types

type Option

type Option func(*jsSource) 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

func WithServingEnabled

func WithServingEnabled() Option

WithServingEnabled sets the serving enabled flag