client

type Destination interface {
	// Whether or not destination is used for Multi-Region Failover mode
	IsMRF() bool

	// Destination target (e.g. https://agent-intake.logs.datadoghq.com)
	Target() string

	// Metadata returns the metadata of the destination
	Metadata() *DestinationMetadata

	// Start starts the destination send loop. close the intput to stop listening for payloads. stopChan is
	// signaled when the destination has fully shutdown and all buffered payloads have been flushed. isRetrying is
	// signaled when the retry state changes. isRetrying can be nil if you don't need to handle retries.
	Start(input chan *message.Payload, output chan *message.Payload, isRetrying chan bool) (stopChan <-chan struct{})
}

type DestinationMetadata struct {
	ReportingEnabled bool
	// contains filtered or unexported fields
}

type Destinations struct {
	Reliable   []Destination
	Unreliable []Destination
}

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

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