jaeger

Documentation

Index

• type Client
  • func NewClient(token string) (*Client, error)
  • func (in *Client) GetErrorTraces(ns string, srv string, interval string) (errorTraces int, err error)
  • func (in *Client) GetJaegerInfo() (*JaegerInfo, int, error)
  • func (in *Client) GetJaegerServices() (services []string, code int, err error)
  • func (in *Client) GetSpans(namespace, service, startMicros, endMicros string) ([]Span, error)
  • func (in *Client) GetTraceDetail(traceId string) (trace *JaegerResponse, code int, err error)
  • func (in *Client) GetTraces(namespace string, service string, rawQuery string) (traces *JaegerResponse, code int, err error)
• type ClientInterface
• type JaegerInfo
• type JaegerResponse
• type JaegerServices
• type Span

Types

type Client

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

Client for Jaeger API. It hides the way we query Prometheus offering a layer with a high level defined API.

func NewClient

func NewClient(token string) (*Client, error)

func (*Client) GetErrorTraces

func (in *Client) GetErrorTraces(ns string, srv string, interval string) (errorTraces int, err error)

GetErrorTraces jaeger to fetch a traces of a specific service requests for errors traces

Returns (errorTraces, error)

func (*Client) GetJaegerInfo

func (in *Client) GetJaegerInfo() (*JaegerInfo, int, error)

GetJaegerInfo return the information about Jaeger info for Jaeger Service. Returns (*JaegerInfo, int, error)

func (*Client) GetJaegerServices

func (in *Client) GetJaegerServices() (services []string, code int, err error)

GetNamespaceServicesRequestRates queries Prometheus to fetch request counter rates, over a time interval, limited to requests for services in the namespace. Returns (rates, error)

func (*Client) GetSpans

func (in *Client) GetSpans(namespace, service, startMicros, endMicros string) ([]Span, error)

GetSpans fetches Jaeger traces of a service and extract related spans Returns (spans, error)

func (*Client) GetTraceDetail

func (in *Client) GetTraceDetail(traceId string) (trace *JaegerResponse, code int, err error)

GetTraceDetail jaeger to fetch a specific trace requests for a specific trace detail

Returns (traces, code, error)

func (*Client) GetTraces

func (in *Client) GetTraces(namespace string, service string, rawQuery string) (traces *JaegerResponse, code int, err error)

GetTraces Jaeger to fetch traces of a service requests for traces of a service Returns (traces, code, error)

type ClientInterface

type ClientInterface interface {
	GetJaegerServices() (services []string, code int, err error)
	GetSpans(namespace, service, startMicros, endMicros string) ([]Span, error)
	GetJaegerInfo() (*JaegerInfo, int, error)
	GetTraces(namespace string, service string, rawQuery string) (traces *JaegerResponse, code int, err error)
	GetTraceDetail(traceId string) (trace *JaegerResponse, code int, err error)
	GetErrorTraces(ns string, srv string, interval string) (errorTraces int, err error)
}

ClientInterface for mocks (only mocked function are necessary here)

type JaegerInfo

type JaegerInfo struct {
	URL                  string   `json:"url"`
	NamespaceSelector    bool     `json:"namespaceSelector"`
	Integration          bool     `json:"integration"`
	IntegrationMessage   string   `json:"integrationMessage"`
	WhiteListIstioSystem []string `json:"whiteListIstioSystem"`
}

type JaegerResponse

type JaegerResponse struct {
	Data   []jaegerModels.Trace `json:"data"`
	Errors []structuredError    `json:"errors"`
}

type JaegerServices

type JaegerServices struct {
	Data []string `json:"data"`
}

type Span

type Span struct {
	jaegerModels.Span
	TraceSize int `json:"traceSize"`
}