Documentation
¶
Overview ¶
Package tcp provides TCP connection management for log clients
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ConnectionManager ¶
type ConnectionManager struct {
// contains filtered or unexported fields
}
A ConnectionManager manages connections
func NewConnectionManager ¶
func NewConnectionManager(endpoint config.Endpoint, status statusinterface.Status) *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 ¶
NewConnection returns an initialized connection to the intake. It blocks until a connection is available
func (*ConnectionManager) ShouldReset ¶
func (cm *ConnectionManager) ShouldReset(connCreationTime time.Time) bool
ShouldReset returns whether the connection should be reset, depending on the endpoint's config and the passed connection creation time.
type Delimiter ¶
type Delimiter interface {
// contains filtered or unexported methods
}
Delimiter is responsible for adding delimiters to the frames being sent.
type Destination ¶
type Destination struct {
// contains filtered or unexported fields
}
Destination is responsible for shipping logs to a remote server over TCP.
func NewDestination ¶
func NewDestination(endpoint config.Endpoint, useProto bool, destinationsContext *client.DestinationsContext, shouldRetry bool, status statusinterface.Status) *Destination
NewDestination returns a new destination.
func (*Destination) IsMRF ¶ added in v0.54.0
func (d *Destination) IsMRF() bool
IsMRF indicates that this destination is a Multi-Region Failover destination.
func (*Destination) Metadata ¶ added in v0.61.0
func (d *Destination) Metadata() *client.DestinationMetadata
Metadata is not supported for TCP destinations
func (*Destination) Start ¶
func (d *Destination) Start(input chan *message.Payload, output chan *message.Payload, isRetrying chan bool) (stopChan <-chan struct{})
Start reads from the input, transforms a message into a frame and sends it to a remote server,
func (*Destination) Target ¶
func (d *Destination) Target() string
Target is the address of the destination.
Source Files