http

Documentation

Index

• func New(vertexInstance *dfv1.VertexInstance, writers []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 []isb.BufferWriter, 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