sender

package
v0.0.0-...-e3fb0e6 Latest Latest
Warning

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

Go to latest
Published: Dec 12, 2017 License: Apache-2.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectionManager

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

A ConnectionManager manages connections

func NewConnectionManager

func NewConnectionManager(ddUrl string, ddPort int, skip_ssl_validation bool) *ConnectionManager

NewConnectionManager returns an initialized ConnectionManager

func (*ConnectionManager) CloseConnection

func (cm *ConnectionManager) CloseConnection(conn net.Conn)

CloseConnection closes a connection on the client side

func (*ConnectionManager) NewConnection

func (cm *ConnectionManager) NewConnection() net.Conn

NewConnection returns an initialized connection to the intake. It blocks until a connection is available

type Sender

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

A Sender sends messages from an inputChan to datadog's intake, handling connections and retries

func New

func New(inputChan, outputChan chan message.Message, connManager *ConnectionManager) *Sender

New returns an initialized Sender

func (*Sender) Start

func (s *Sender) Start()

Start starts the Sender

Jump to

Keyboard shortcuts

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