http

Documentation

Index

• Constants
• func CheckConnectivity(endpoint config.Endpoint, cfg pkgconfigmodel.Reader) config.HTTPConnectivity
• func CheckConnectivityDiagnose(endpoint config.Endpoint, cfg pkgconfigmodel.Reader) (url string, err error)
• type Destination
  • func NewDestination(endpoint config.Endpoint, contentType string, ...) *Destination
  • func (d *Destination) IsMRF() bool
  • func (d *Destination) Start(input chan *message.Payload, output chan *message.Payload, ...) (stopChan <-chan struct{})
  • func (d *Destination) Target() string
• type StatusCodeContainer
• type SyncDestination
  • func NewSyncDestination(endpoint config.Endpoint, contentType string, ...) *SyncDestination
  • func (d *SyncDestination) IsMRF() bool
  • func (d *SyncDestination) Start(input chan *message.Payload, output chan *message.Payload, _ chan bool) (stopChan <-chan struct{})
  • func (d *SyncDestination) Target() string
• type TestServer
  • func NewTestServer(statusCode int, cfg pkgconfigmodel.Reader) *TestServer
  • func NewTestServerWithOptions(statusCode int, senders int, retryDestination bool, respondChan chan int, ...) *TestServer
  • func (s *TestServer) ChangeStatus(statusCode int)
  • func (s *TestServer) Stop()

Constants

const (
	TextContentType     = "text/plain"
	JSONContentType     = "application/json"
	ProtobufContentType = "application/x-protobuf"
)

ContentType options,

Functions

func CheckConnectivity

func CheckConnectivity(endpoint config.Endpoint, cfg pkgconfigmodel.Reader) config.HTTPConnectivity

CheckConnectivity check if sending logs through HTTP works

func CheckConnectivityDiagnose

func CheckConnectivityDiagnose(endpoint config.Endpoint, cfg pkgconfigmodel.Reader) (url string, err error)

Types

type Destination

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

Destination sends a payload over HTTP.

func NewDestination

func NewDestination(endpoint config.Endpoint,
	contentType string,
	destinationsContext *client.DestinationsContext,
	maxConcurrentBackgroundSends int,
	shouldRetry bool,
	telemetryName string,
	cfg pkgconfigmodel.Reader) *Destination

NewDestination returns a new Destination. If `maxConcurrentBackgroundSends` > 0, then at most that many background payloads will be sent concurrently, else there is no concurrency and the background sending pipeline will block while sending each payload. TODO: add support for SOCKS5

func (*Destination) IsMRF

func (d *Destination) IsMRF() bool

IsMRF indicates that this destination is a Multi-Region Failover destination.

func (*Destination) Start

func (d *Destination) Start(input chan *message.Payload, output chan *message.Payload, isRetrying chan bool) (stopChan <-chan struct{})

Start starts reading the input channel

func (*Destination) Target

func (d *Destination) Target() string

Target is the address of the destination.

type StatusCodeContainer

type StatusCodeContainer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

StatusCodeContainer is a lock around the status code to return

type SyncDestination

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

SyncDestination sends a payload over HTTP and does not retry. In Serverless, the retry and backoff logic is handled by the serverless flush strategy

func NewSyncDestination

func NewSyncDestination(endpoint config.Endpoint,
	contentType string,
	destinationsContext *client.DestinationsContext,
	senderDoneChan chan *sync.WaitGroup,
	telemetryName string,
	cfg pkgconfigmodel.Reader) *SyncDestination

NewSyncDestination returns a new synchronous Destination.

func (*SyncDestination) IsMRF

func (d *SyncDestination) IsMRF() bool

IsMRF indicates that this destination is a Multi-Region Failover destination.

func (*SyncDestination) Start

func (d *SyncDestination) Start(input chan *message.Payload, output chan *message.Payload, _ chan bool) (stopChan <-chan struct{})

Start starts reading the input channel

func (*SyncDestination) Target

func (d *SyncDestination) Target() string

Target is the address of the destination.

type TestServer

type TestServer struct {
	DestCtx     *client.DestinationsContext
	Destination *Destination
	Endpoint    config.Endpoint
	// contains filtered or unexported fields
}

TestServer a test server

func NewTestServer

func NewTestServer(statusCode int, cfg pkgconfigmodel.Reader) *TestServer

NewTestServer creates a new test server

func NewTestServerWithOptions

func NewTestServerWithOptions(statusCode int, senders int, retryDestination bool, respondChan chan int, cfg pkgconfigmodel.Reader) *TestServer

NewTestServerWithOptions creates a new test server with concurrency and response control

func (*TestServer) ChangeStatus

func (s *TestServer) ChangeStatus(statusCode int)

ChangeStatus changes the status to return

func (*TestServer) Stop

func (s *TestServer) Stop()

Stop stops the server