backends

package
v0.0.0-...-2b0a6a7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 28, 2016 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL