Versions in this module Expand all Collapse all v0 v0.3.0 Nov 29, 2023 Changes in this version + const DATABASESPAN + const DefaultAddress + const ITEMS + const SPAN + const TRACE + type ClientTracer struct + func NewClientTracer() *ClientTracer + func (c *ClientTracer) CloseTrace(ctx context.Context, request *pb.CloseTraceRequest) (*pb.TraceResponse, error) + func (c *ClientTracer) DatabaseSpan(ctx context.Context, request *pb.DatabaseSpanRequest) (*pb.TraceResponse, error) + func (c *ClientTracer) HealthCheck(ctx context.Context, request *pb.Empty) (*pb.HealthCheckResponse, error) + func (c *ClientTracer) Span(ctx context.Context, request *pb.SpanRequest) (*pb.TraceResponse, error) + func (c *ClientTracer) StartNewSpan(ctx context.Context, request *pb.StartSpanRequest) (*pb.TraceResponse, error) + func (c *ClientTracer) StartTrace(ctx context.Context, request *pb.StartTraceRequest) (*pb.TraceResponse, error) + func (c *ClientTracer) Trace(ctx context.Context, request *pb.TraceRequest) (*pb.TraceResponse, error) + func (c *ClientTracer) WaitForHealthyState() bool + type MockTraceService struct + func (m *MockTraceService) CloseTrace(ctx context.Context, request *pb.CloseTraceRequest) (*pb.TraceResponse, error) + func (m *MockTraceService) DatabaseSpan(ctx context.Context, request *pb.DatabaseSpanRequest) (*pb.TraceResponse, error) + func (m *MockTraceService) HealthCheck(ctx context.Context, request *pb.Empty) (*pb.HealthCheckResponse, error) + func (m *MockTraceService) Span(ctx context.Context, request *pb.SpanRequest) (*pb.TraceResponse, error) + func (m *MockTraceService) StartNewSpan(ctx context.Context, request *pb.StartSpanRequest) (*pb.TraceResponse, error) + func (m *MockTraceService) StartTrace(ctx context.Context, request *pb.StartTraceRequest) (*pb.TraceResponse, error) + func (m *MockTraceService) Trace(ctx context.Context, request *pb.TraceRequest) (*pb.TraceResponse, error) + func (m *MockTraceService) WaitForHealthyState() bool + type TraceService interface + CloseTrace func(ctx context.Context, request *pb.CloseTraceRequest) (*pb.TraceResponse, error) + DatabaseSpan func(ctx context.Context, request *pb.DatabaseSpanRequest) (*pb.TraceResponse, error) + HealthCheck func(ctx context.Context, start *pb.Empty) (*pb.HealthCheckResponse, error) + Span func(ctx context.Context, request *pb.SpanRequest) (*pb.TraceResponse, error) + StartNewSpan func(ctx context.Context, request *pb.StartSpanRequest) (*pb.TraceResponse, error) + StartTrace func(ctx context.Context, request *pb.StartTraceRequest) (*pb.TraceResponse, error) + Trace func(ctx context.Context, request *pb.TraceRequest) (*pb.TraceResponse, error) + WaitForHealthyState func() bool + type TraceServiceClient struct + Impl TraceService + type TraceServiceImpl struct + Elastic aristoteles.Client + Index string + Namespace string + PodName string + StartTimeMap map[string]time.Time + func NewTraceServiceImpl(env string) (*TraceServiceImpl, error) + func (t *TraceServiceImpl) CloseTrace(ctx context.Context, stop *pb.CloseTraceRequest) (*pb.TraceResponse, error) + func (t *TraceServiceImpl) DatabaseSpan(ctx context.Context, spanRequest *pb.DatabaseSpanRequest) (*pb.TraceResponse, error) + func (t *TraceServiceImpl) HealthCheck(ctx context.Context, start *pb.Empty) (*pb.HealthCheckResponse, error) + func (t *TraceServiceImpl) Span(ctx context.Context, spanRequest *pb.SpanRequest) (*pb.TraceResponse, error) + func (t *TraceServiceImpl) StartNewSpan(ctx context.Context, start *pb.StartSpanRequest) (*pb.TraceResponse, error) + func (t *TraceServiceImpl) StartTrace(ctx context.Context, start *pb.StartTraceRequest) (*pb.TraceResponse, error) + func (t *TraceServiceImpl) Trace(ctx context.Context, traceRequest *pb.TraceRequest) (*pb.TraceResponse, error) + func (t *TraceServiceImpl) UpdateDocumentWithRetry(traceID, itemName string, data []byte) (string, error) Other modules containing this package github.com/odysseia-greek/attike
Go to main page