traces

Documentation

Index

• func NewTraceBatch() *traceBatch
• type LMTraceIngest
  • func NewLMTraceIngest(ctx context.Context, opts ...Option) (*LMTraceIngest, error)
  • func (traceIngest *LMTraceIngest) SendTraces(ctx context.Context, td ptrace.Traces, o ...SendTracesOptionalParameters) (*SendTraceResponse, error)
• type LMTraceIngestResponse
• type Option
  • func WithAuthentication(authProvider utils.AuthParams) Option
  • func WithCollectorID(collectorID string) Option
  • func WithEndpoint(endpoint string) Option
  • func WithGzipCompression(gzip bool) Option
  • func WithHTTPClient(client *http.Client) Option
  • func WithRateLimit(requestCount int, spanCount int, spanCountPerRequest int) Option
  • func WithTraceBatchingDisabled() Option
  • func WithTraceBatchingInterval(batchingInterval time.Duration) Option
  • func WithUserAgent(userAgent string) Option
• type SendTraceResponse
• type SendTracesOptionalParameters
  • func NewSendTracesOptionalParameters() *SendTracesOptionalParameters

Functions

func NewTraceBatch

func NewTraceBatch() *traceBatch

Types

type LMTraceIngest

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

func NewLMTraceIngest

func NewLMTraceIngest(ctx context.Context, opts ...Option) (*LMTraceIngest, error)

NewLMTraceIngest initializes LMTraceIngest

func (*LMTraceIngest) SendTraces

func (traceIngest *LMTraceIngest) SendTraces(ctx context.Context, td ptrace.Traces, o ...SendTracesOptionalParameters) (*SendTraceResponse, error)

SendTraces is the entry point for receiving trace data

type LMTraceIngestResponse

type LMTraceIngestResponse struct {
	Success bool   `json:"success"`
	Message string `json:"message"`
}

type Option

type Option func(*LMTraceIngest) error

func WithAuthentication

func WithAuthentication(authProvider utils.AuthParams) Option

WithAuthentication is used for passing authentication token if not set in environment variables.

func WithCollectorID

func WithCollectorID(collectorID string) Option

WithCollectorID sets collectorID which will be passed in request header

func WithEndpoint

func WithEndpoint(endpoint string) Option

WithEndpoint is used to set Endpoint URL to export traces

func WithGzipCompression

func WithGzipCompression(gzip bool) Option

WithGzipCompression can be used to enable/disable gzip compression of Trace payload Note: By default, gzip compression is enabled.

func WithHTTPClient

func WithHTTPClient(client *http.Client) Option

WithHTTPClient is used to set HTTP client

func WithRateLimit

func WithRateLimit(requestCount int, spanCount int, spanCountPerRequest int) Option

WithRateLimit is used to limit the Trace request count per minute

func WithTraceBatchingDisabled

func WithTraceBatchingDisabled() Option

WithTraceBatchingDisabled is used for disabling Trace batching.

func WithTraceBatchingInterval

func WithTraceBatchingInterval(batchingInterval time.Duration) Option

WithTraceBatchingInterval is used for passing batch time interval.

func WithUserAgent

func WithUserAgent(userAgent string) Option

WithUserAgent sets the provided user agent

type SendTraceResponse

type SendTraceResponse struct {
	StatusCode int    `json:"statusCode"`
	Success    bool   `json:"success"`
	Message    string `json:"message"`

	RetryAfter int `json:"retryAfter"`

	Error       error `json:"error"`
	MultiStatus []struct {
		Code  float64 `json:"code"`
		Error string  `json:"error"`
	} `json:"multiStatus"`
}

type SendTracesOptionalParameters

type SendTracesOptionalParameters struct {
}

func NewSendTracesOptionalParameters

func NewSendTracesOptionalParameters() *SendTracesOptionalParameters