http

Documentation

Index

• func New(vertex *dfv1.Vertex, writers []isb.BufferWriter, opts ...Option) (*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(vertex *dfv1.Vertex, writers []isb.BufferWriter, 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