jaeger

Documentation

Index

• type JaegerGRPCClient
  • func (jc JaegerGRPCClient) FindTraces(ctx context.Context, serviceName string, q models.TracingQuery) (response *model.TracingResponse, err error)
  • func (jc JaegerGRPCClient) GetServices(ctxSrv context.Context) (bool, error)
  • func (jc JaegerGRPCClient) GetTrace(ctx context.Context, strTraceID string) (*model.TracingSingleTrace, error)
• type JaegerHTTPClient
  • func (jc JaegerHTTPClient) GetAppTracesHTTP(client http.Client, baseURL *url.URL, serviceName string, ...) (response *model.TracingResponse, err error)
  • func (jc JaegerHTTPClient) GetServiceStatusHTTP(client http.Client, baseURL *url.URL) (bool, error)
  • func (jc JaegerHTTPClient) GetTraceDetailHTTP(client http.Client, endpoint *url.URL, traceID string) (*model.TracingSingleTrace, error)
• type SpansStreamer

Types

type JaegerGRPCClient

type JaegerGRPCClient struct {
	JaegergRPCClient model.QueryServiceClient
}

func (JaegerGRPCClient) FindTraces

func (jc JaegerGRPCClient) FindTraces(ctx context.Context, serviceName string, q models.TracingQuery) (response *model.TracingResponse, err error)

FindTraces

func (JaegerGRPCClient) GetServices

func (jc JaegerGRPCClient) GetServices(ctxSrv context.Context) (bool, error)

GetServices

func (JaegerGRPCClient) GetTrace

func (jc JaegerGRPCClient) GetTrace(ctx context.Context, strTraceID string) (*model.TracingSingleTrace, error)

type JaegerHTTPClient

type JaegerHTTPClient struct {
}

func (JaegerHTTPClient) GetAppTracesHTTP

func (jc JaegerHTTPClient) GetAppTracesHTTP(client http.Client, baseURL *url.URL, serviceName string, q models.TracingQuery) (response *model.TracingResponse, err error)

func (JaegerHTTPClient) GetServiceStatusHTTP

func (jc JaegerHTTPClient) GetServiceStatusHTTP(client http.Client, baseURL *url.URL) (bool, error)

func (JaegerHTTPClient) GetTraceDetailHTTP

func (jc JaegerHTTPClient) GetTraceDetailHTTP(client http.Client, endpoint *url.URL, traceID string) (*model.TracingSingleTrace, error)

type SpansStreamer

type SpansStreamer interface {
	Recv() (*model.SpansResponseChunk, error)
	grpc.ClientStream
}