sink

Documentation

Index

• Constants
• Variables
• func NewTLSClient(conf config.TLSConfig) (*http.Client, error)
• type Doer
• type HTTPSink
  • func New(options HTTPSinkOptions) (*HTTPSink, error)
  • func (h HTTPSink) Write(p []byte) (n int, err error)
• type HTTPSinkOptions

Constants

const (
	// DefaultAgentForwarderhost holds the default endpoint of the agent forwarder.
	DefaultAgentForwarderhost = "localhost"
	DefaultAgentForwarderPath = "/v1/data"
)

Variables

var ErrCAAppend = errors.New("appending certs to pool")

Functions

func NewTLSClient

func NewTLSClient(conf config.TLSConfig) (*http.Client, error)

Types

type Doer

type Doer interface {
	Do(req *http.Request) (*http.Response, error)
}

Doer is the interface that HTTPSink client should satisfy.

type HTTPSink

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

HTTPSink holds the configuration of the HTTP sink used by the integration.

func New

func New(options HTTPSinkOptions) (*HTTPSink, error)

New initialize HTTPSink struct.

func (HTTPSink) Write

func (h HTTPSink) Write(p []byte) (n int, err error)

Write is the function signature needed by the infrastructure SDK package.

type HTTPSinkOptions

type HTTPSinkOptions struct {
	URL    string
	Client Doer
}

HTTPSinkOptions holds the configuration of the HTTP sink used by the integration.