http

Documentation

Index

• func New(vertexInstance *dfv1.VertexInstance, writers map[string][]isb.BufferWriter, ...) (*httpSource, 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 forward.ToWhichStepDecider,
	mapApplier applier.MapApplier,
	fetchWM fetch.Fetcher,
	publishWM map[string]publish.Publisher,
	publishWMStores store.WatermarkStorer,
	opts ...Option) (*httpSource, error)

Types

type Option

type Option func(*httpSource) error

func WithBufferSize

func WithBufferSize(s int) Option

func WithLogger

func WithLogger(l *zap.SugaredLogger) Option

WithLogger is used to return logger information

func WithReadTimeout

func WithReadTimeout(t time.Duration) Option

WithReadTimeout is used to set the read timeout for the from buffer