client

package

v0.0.0-...-5655933 Latest Latest Go to latest Published: Oct 20, 2023 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Destination interface {
	Send(payload []byte) error
	SendAsync(payload []byte)
}

Destination sends a payload to a specific endpoint over a given network protocol.

type Destinations struct {
	Main        Destination
	Additionals []Destination
}

Destinations holds the main destination and additional ones to send logs to.

func NewDestinations(main Destination, additionals []Destination) *Destinations

NewDestinations returns a new destinations composite.

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

A DestinationsContext manages senders and allows us to "unclog" the pipeline when trying to stop it and failing to send messages.

func NewDestinationsContext() *DestinationsContext

NewDestinationsContext returns an initialized DestinationsContext

func (dc *DestinationsContext) Context() context.Context

Context allows one to access the current context of this DestinationsContext.

func (dc *DestinationsContext) Start()

Start creates a context that will be cancelled on Stop()

func (dc *DestinationsContext) Stop()

Stop cancels the context that should be used by all senders.

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

RetryableError represents an error that can occur when sending a payload.

func NewRetryableError(err error) *RetryableError

NewRetryableError returns a new destination error.

func (e *RetryableError) Error() string

RetryableError returns the message of the error.