receiver

Documentation

Index

• func New(receiverCfg map[string]interface{}, pusher BatchPusher, middleware Middleware, ...) (services.Service, error)
• type BatchPusher
• type ConsumeTracesFunc
  • func (f ConsumeTracesFunc) Capabilities() consumer.Capabilities
  • func (f ConsumeTracesFunc) ConsumeTraces(ctx context.Context, td pdata.Traces) error
• type Middleware
  • func FakeTenantMiddleware() Middleware
  • func Merge(middlesware ...Middleware) Middleware
  • func MultiTenancyMiddleware() Middleware
• type MiddlewareFunc
  • func (tc MiddlewareFunc) Wrap(next consumer.Traces) consumer.Traces

Functions

func New

func New(receiverCfg map[string]interface{}, pusher BatchPusher, middleware Middleware, logLevel logging.Level) (services.Service, error)

Types

type BatchPusher

type BatchPusher interface {
	PushBatches(ctx context.Context, batches []*v1.ResourceSpans) (*tempopb.PushResponse, error)
}

type ConsumeTracesFunc

type ConsumeTracesFunc func(context.Context, pdata.Traces) error

func (ConsumeTracesFunc) Capabilities

func (f ConsumeTracesFunc) Capabilities() consumer.Capabilities

func (ConsumeTracesFunc) ConsumeTraces

func (f ConsumeTracesFunc) ConsumeTraces(ctx context.Context, td pdata.Traces) error

type Middleware

type Middleware interface {
	Wrap(consumer.Traces) consumer.Traces
}

func FakeTenantMiddleware

func FakeTenantMiddleware() Middleware

func Merge

func Merge(middlesware ...Middleware) Middleware

Merge produces a middleware that applies multiple middlesware in turn; ie Merge(f,g,h).Wrap(handler) == f.Wrap(g.Wrap(h.Wrap(handler)))

func MultiTenancyMiddleware

func MultiTenancyMiddleware() Middleware

type MiddlewareFunc

type MiddlewareFunc func(consumer.Traces) consumer.Traces

func (MiddlewareFunc) Wrap

func (tc MiddlewareFunc) Wrap(next consumer.Traces) consumer.Traces

Wrap implements Interface