tempoproxy

Documentation

Overview

Package tempoproxy provides Tempo proxy for observability and research.

Index

• type Server
  • func NewServer(api *tempoapi.Client) *Server
  • func (s *Server) BuildInfo(ctx context.Context) (*tempoapi.PrometheusVersion, error)
  • func (s *Server) Echo(ctx context.Context) (tempoapi.EchoOK, error)
  • func (s *Server) NewError(ctx context.Context, err error) *tempoapi.ErrorStatusCode
  • func (s *Server) Search(ctx context.Context, params tempoapi.SearchParams) (*tempoapi.Traces, error)
  • func (s *Server) SearchTagValues(ctx context.Context, params tempoapi.SearchTagValuesParams) (*tempoapi.TagValues, error)
  • func (s *Server) SearchTagValuesV2(ctx context.Context, params tempoapi.SearchTagValuesV2Params) (*tempoapi.TagValuesV2, error)
  • func (s *Server) SearchTags(ctx context.Context, params tempoapi.SearchTagsParams) (*tempoapi.TagNames, error)
  • func (s *Server) SearchTagsV2(ctx context.Context, params tempoapi.SearchTagsV2Params) (*tempoapi.TagNamesV2, error)
  • func (s *Server) TraceByID(ctx context.Context, params tempoapi.TraceByIDParams) (tempoapi.TraceByIDRes, error)

Types

type Server

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

Server implement proxy server.

func NewServer

func NewServer(api *tempoapi.Client) *Server

NewServer initializes new proxy Server from openapi client.

func (*Server) BuildInfo

func (s *Server) BuildInfo(ctx context.Context) (*tempoapi.PrometheusVersion, error)

BuildInfo implements buildInfo operation.

Returns Tempo buildinfo, in the same format as Prometheus `/api/v1/status/buildinfo`. Used by Grafana to check Tempo API version.

GET /api/status/buildinfo

func (*Server) Echo

func (s *Server) Echo(ctx context.Context) (tempoapi.EchoOK, error)

Echo implements echo operation. Echo request for testing, issued by Grafana.

GET /api/echo

func (*Server) NewError

func (s *Server) NewError(ctx context.Context, err error) *tempoapi.ErrorStatusCode

NewError creates *ErrorStatusCode from error returned by handler.

Used for common default response.

func (*Server) Search

func (s *Server) Search(ctx context.Context, params tempoapi.SearchParams) (*tempoapi.Traces, error)

Search implements search operation.

Execute TraceQL query.

GET /api/search

func (*Server) SearchTagValues

func (s *Server) SearchTagValues(ctx context.Context, params tempoapi.SearchTagValuesParams) (*tempoapi.TagValues, error)

SearchTagValues implements search_tag_values operation.

This endpoint retrieves all discovered values for the given tag, which can be used in search.

GET /api/search/tag/{tag_name}/values

func (*Server) SearchTagValuesV2

func (s *Server) SearchTagValuesV2(ctx context.Context, params tempoapi.SearchTagValuesV2Params) (*tempoapi.TagValuesV2, error)

SearchTagValuesV2 implements search_tag_values_v2 operation.

This endpoint retrieves all discovered values and their data types for the given TraceQL identifier.

GET /api/v2/search/tag/{tag_name}/values

func (*Server) SearchTags

func (s *Server) SearchTags(ctx context.Context, params tempoapi.SearchTagsParams) (*tempoapi.TagNames, error)

SearchTags implements search_tags operation.

This endpoint retrieves all discovered tag names that can be used in search.

GET /api/search/tags

func (*Server) SearchTagsV2

func (s *Server) SearchTagsV2(ctx context.Context, params tempoapi.SearchTagsV2Params) (*tempoapi.TagNamesV2, error)

SearchTagsV2 implements searchTagsV2 operation.

This endpoint retrieves all discovered tag names that can be used in search.

GET /api/v2/search/tags

func (*Server) TraceByID

func (s *Server) TraceByID(ctx context.Context, params tempoapi.TraceByIDParams) (tempoapi.TraceByIDRes, error)

TraceByID implements traceByID operation.

Querying traces by id.

GET /api/traces/{traceID}