client

Documentation

Index

• Constants
• func OCStatusCodeFromHTTP(code int32) int32
• type Client
  • func New(opts ...Option) (*Client, error)
  • func (sa *Client) Export(ctx context.Context, batches []*jaegerpb.Batch) error
  • func (sa *Client) Stop()
• type ErrSend
  • func (e *ErrSend) Error() string
• type Option
  • func WithAccessToken(t string) Option
  • func WithEndpoint(endpoint string) Option
  • func WithHTTPClient(c *http.Client) Option
  • func WithMaxConnections(n uint) Option
  • func WithWorkers(n uint) Option

Constants

const (
	OCOK                 = 0
	OCCancelled          = 1
	OCUnknown            = 2
	OCInvalidArgument    = 3
	OCDeadlineExceeded   = 4
	OCNotFound           = 5
	OCAlreadyExists      = 6
	OCPermissionDenied   = 7
	OCResourceExhausted  = 8
	OCFailedPrecondition = 9
	OCAborted            = 10
	OCOutOfRange         = 11
	OCUnimplemented      = 12
	OCInternal           = 13
	OCUnavailable        = 14
	OCDataLoss           = 15
	OCUnauthenticated    = 16
)

https://github.com/googleapis/googleapis/blob/bee79fbe03254a35db125dc6d2f1e9b752b390fe/google/rpc/code.proto#L33-L186

Functions

func OCStatusCodeFromHTTP

func OCStatusCodeFromHTTP(code int32) int32

OCStatusCodeFromHTTP takes an HTTP status code and return the appropriate OpenTelemetry status code See: https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/data-http.md

Types

type Client

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

Client implements an HTTP sender for the SAPM protocol

func New

func New(opts ...Option) (*Client, error)

New creates a new SAPM Client

func (*Client) Export

func (sa *Client) Export(ctx context.Context, batches []*jaegerpb.Batch) error

Export takes a Jaeger batches and uses one of the available workers to export it synchronously. It returns an error in case a request cannot be processed. It's up to the caller to retry.

func (*Client) Stop

func (sa *Client) Stop()

Stop waits for all inflight requests to finish and then drains the worker pool so no more work can be done. It returns once all workers are drained from the pool. Note that the client can accept new requests while Stop() waits for other requests to finish.

type ErrSend

type ErrSend struct {
	Err               error
	StatusCode        int
	Permanent         bool
	RetryDelaySeconds int
}

ErrSend is returned by the HTTP sender when it fails to complete a request for any reason.

func (*ErrSend) Error

func (e *ErrSend) Error() string

type Option

type Option func(*Client) error

Option takes a reference to a Client and sets relevant config fields on it.

func WithAccessToken

func WithAccessToken(t string) Option

WithAccessToken allows to pass an authentication token to the client. The auth token is set to X-SF-TOKEN HTTP header.

func WithEndpoint

func WithEndpoint(endpoint string) Option

WithEndpoint takes an HTTP endpoint as a string in the format scheme://address:port/path and configures the client to export all requests to this endpoint.

func WithHTTPClient

func WithHTTPClient(c *http.Client) Option

WithHTTPClient allows to pass a custom HTTP Client instance to SAPM Client

func WithMaxConnections

func WithMaxConnections(n uint) Option

WithMaxConnections allows to specify the max number of open HTTP connections the client should keep at any time.

func WithWorkers

func WithWorkers(n uint) Option

WithWorkers configures the client to use N number of workers.