sender

Documentation

Index

• type ConnectionManager
  • func NewConnectionManager(ddURL string, ddPort int, devModeNoSSL bool) *ConnectionManager
  • func (cm *ConnectionManager) CloseConnection(conn net.Conn)
  • func (cm *ConnectionManager) NewConnection() net.Conn
• type Sender
  • func New(inputChan, outputChan chan message.Message, connManager *ConnectionManager) *Sender
  • func (s *Sender) Start()

Types

type ConnectionManager

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

A ConnectionManager manages connections

func NewConnectionManager

func NewConnectionManager(ddURL string, ddPort int, devModeNoSSL 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