remote

Documentation

Index

• type Endpoint
  • func NewEndpoint(ports PortsConfig, start func(context.Context) error, ...) *Endpoint
  • func (e *Endpoint) GetTraceByID(ctx context.Context, id string) ([]byte, error)
  • func (e *Endpoint) RunPromQL(ctx context.Context, promQL string) ([]byte, error)
  • func (e *Endpoint) SearchLoki(query string) ([]byte, error)
  • func (e *Endpoint) SearchTags(ctx context.Context, tags map[string]string) ([]byte, error)
  • func (e *Endpoint) SearchTempo(ctx context.Context, query string) ([]byte, error)
  • func (e *Endpoint) Start(ctx context.Context) error
  • func (e *Endpoint) Stop(ctx context.Context) error
  • func (e *Endpoint) TracerProvider(ctx context.Context, r *resource.Resource) (*trace.TracerProvider, error)
• type PortsConfig

Types

type Endpoint

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

func NewEndpoint

func NewEndpoint(ports PortsConfig, start func(context.Context) error, stop func(context.Context) error) *Endpoint

func (*Endpoint) GetTraceByID

func (e *Endpoint) GetTraceByID(ctx context.Context, id string) ([]byte, error)

func (*Endpoint) RunPromQL

func (e *Endpoint) RunPromQL(ctx context.Context, promQL string) ([]byte, error)

func (*Endpoint) SearchLoki

func (e *Endpoint) SearchLoki(query string) ([]byte, error)

func (*Endpoint) SearchTags

func (e *Endpoint) SearchTags(ctx context.Context, tags map[string]string) ([]byte, error)

func (*Endpoint) SearchTempo

func (e *Endpoint) SearchTempo(ctx context.Context, query string) ([]byte, error)

func (*Endpoint) Start

func (e *Endpoint) Start(ctx context.Context) error

func (*Endpoint) Stop

func (e *Endpoint) Stop(ctx context.Context) error

func (*Endpoint) TracerProvider

func (e *Endpoint) TracerProvider(ctx context.Context, r *resource.Resource) (*trace.TracerProvider, error)

type PortsConfig

type PortsConfig struct {
	TracesGRPCPort     int
	TracesHTTPPort     int
	TempoHTTPPort      int
	MimirHTTPPort      int
	PrometheusHTTPPort int
	LokiHttpPort       int
}