loader

Documentation

Index

• Variables
• type Loader
  • func NewLoader(conn net.Conn, reporter types.LoaderReporter, timeout time.Duration, ...) (*Loader, error)
  • func (l *Loader) DoRequest(req types.Req)
  • func (l *Loader) Flush(context.Context)
  • func (l *Loader) Run(ctx context.Context) error
  • func (l *Loader) Shutdown(ctx context.Context) (err error)
  • func (l *Loader) WaitResponses(ctx context.Context)
• type TimeoutQueue
  • func NewTimeoutSliceQueue(timeout time.Duration) TimeoutQueue

Variables

var NewTimeoutQueue = NewTimeoutSliceQueue

Types

type Loader

type Loader struct {
	// contains filtered or unexported fields
}

func NewLoader

func NewLoader(
	conn net.Conn,
	reporter types.LoaderReporter,
	timeout time.Duration,
	disableSendBatching bool,
	log *zap.Logger,
) (*Loader, error)

func (*Loader) DoRequest

func (l *Loader) DoRequest(req types.Req)

func (*Loader) Flush

func (l *Loader) Flush(context.Context)

func (*Loader) Run

func (l *Loader) Run(ctx context.Context) error

func (*Loader) Shutdown

func (l *Loader) Shutdown(ctx context.Context) (err error)

func (*Loader) WaitResponses

func (l *Loader) WaitResponses(ctx context.Context)

type TimeoutQueue

type TimeoutQueue interface {
	Add(streamID uint32)
	Next() (uint32, bool)
	Close()
}

func NewTimeoutSliceQueue

func NewTimeoutSliceQueue(timeout time.Duration) TimeoutQueue