backends

Documentation

Index

• type ConnFactory
• type Sender
  • func (s *Sender) GetBuffer() *bytes.Buffer
  • func (s *Sender) PutBuffer(buf *bytes.Buffer)
  • func (s *Sender) Run(ctx context.Context) error
• type Stream

Types

type ConnFactory

type ConnFactory func() (net.Conn, error)

type Sender

type Sender struct {
	ConnFactory  ConnFactory
	Sink         chan Stream
	BufPool      sync.Pool
	WriteTimeout time.Duration
}

func (*Sender) GetBuffer

func (s *Sender) GetBuffer() *bytes.Buffer

func (*Sender) PutBuffer

func (s *Sender) PutBuffer(buf *bytes.Buffer)

func (*Sender) Run

func (s *Sender) Run(ctx context.Context) error

type Stream

type Stream struct {
	Cb  backendTypes.SendCallback
	Buf chan *bytes.Buffer
}