sender

package
v0.0.0-...-170def7 Latest Latest
Warning

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

Go to latest
Published: Aug 29, 2018 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)

type Stream

type Stream struct {
	Ctx context.Context
	Cb  gostatsd.SendCallback
	Buf <-chan *bytes.Buffer
}

Jump to

Keyboard shortcuts

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