app

Documentation

Index

• Constants
• type ClientTracer
  • 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
  • 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
• type TraceServiceClient
• type TraceServiceImpl
  • 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)

Constants

const (
	TRACE        string = "trace"
	SPAN         string = "span"
	DATABASESPAN string = "database_span"
	ITEMS        string = "items"
)

const (
	DefaultAddress string = "localhost:50052"
)

Types

type ClientTracer

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

func NewClientTracer

func NewClientTracer() *ClientTracer

func (*ClientTracer) CloseTrace

func (c *ClientTracer) CloseTrace(ctx context.Context, request *pb.CloseTraceRequest) (*pb.TraceResponse, error)

func (*ClientTracer) DatabaseSpan

func (c *ClientTracer) DatabaseSpan(ctx context.Context, request *pb.DatabaseSpanRequest) (*pb.TraceResponse, error)

func (*ClientTracer) HealthCheck

func (c *ClientTracer) HealthCheck(ctx context.Context, request *pb.Empty) (*pb.HealthCheckResponse, error)

func (*ClientTracer) Span

func (c *ClientTracer) Span(ctx context.Context, request *pb.SpanRequest) (*pb.TraceResponse, error)

func (*ClientTracer) StartNewSpan

func (c *ClientTracer) StartNewSpan(ctx context.Context, request *pb.StartSpanRequest) (*pb.TraceResponse, error)

func (*ClientTracer) StartTrace

func (c *ClientTracer) StartTrace(ctx context.Context, request *pb.StartTraceRequest) (*pb.TraceResponse, error)

func (*ClientTracer) Trace

func (c *ClientTracer) Trace(ctx context.Context, request *pb.TraceRequest) (*pb.TraceResponse, error)

func (*ClientTracer) WaitForHealthyState

func (c *ClientTracer) WaitForHealthyState() bool

type MockTraceService

type MockTraceService struct {
	mock.Mock
}

MockTraceService is a mock implementation of the TraceService interface

func (*MockTraceService) CloseTrace

func (m *MockTraceService) CloseTrace(ctx context.Context, request *pb.CloseTraceRequest) (*pb.TraceResponse, error)

func (*MockTraceService) DatabaseSpan

func (m *MockTraceService) DatabaseSpan(ctx context.Context, request *pb.DatabaseSpanRequest) (*pb.TraceResponse, error)

func (*MockTraceService) HealthCheck

func (m *MockTraceService) HealthCheck(ctx context.Context, request *pb.Empty) (*pb.HealthCheckResponse, error)

func (*MockTraceService) Span

func (m *MockTraceService) Span(ctx context.Context, request *pb.SpanRequest) (*pb.TraceResponse, error)

func (*MockTraceService) StartNewSpan

func (m *MockTraceService) StartNewSpan(ctx context.Context, request *pb.StartSpanRequest) (*pb.TraceResponse, error)

func (*MockTraceService) StartTrace

func (m *MockTraceService) StartTrace(ctx context.Context, request *pb.StartTraceRequest) (*pb.TraceResponse, error)

func (*MockTraceService) Trace

func (m *MockTraceService) Trace(ctx context.Context, request *pb.TraceRequest) (*pb.TraceResponse, error)

func (*MockTraceService) WaitForHealthyState

func (m *MockTraceService) WaitForHealthyState() bool

type TraceService

type TraceService interface {
	HealthCheck(ctx context.Context, start *pb.Empty) (*pb.HealthCheckResponse, error)
	StartTrace(ctx context.Context, request *pb.StartTraceRequest) (*pb.TraceResponse, error)
	Trace(ctx context.Context, request *pb.TraceRequest) (*pb.TraceResponse, error)
	StartNewSpan(ctx context.Context, request *pb.StartSpanRequest) (*pb.TraceResponse, error)
	Span(ctx context.Context, request *pb.SpanRequest) (*pb.TraceResponse, error)
	DatabaseSpan(ctx context.Context, request *pb.DatabaseSpanRequest) (*pb.TraceResponse, error)
	CloseTrace(ctx context.Context, request *pb.CloseTraceRequest) (*pb.TraceResponse, error)
	WaitForHealthyState() bool
}

type TraceServiceClient

type TraceServiceClient struct {
	Impl TraceService
}

type TraceServiceImpl

type TraceServiceImpl struct {
	PodName      string
	Namespace    string
	Index        string
	Elastic      aristoteles.Client
	StartTimeMap map[string]time.Time
	pb.UnimplementedTraceServiceServer
	// contains filtered or unexported fields
}

func NewTraceServiceImpl

func NewTraceServiceImpl(env string) (*TraceServiceImpl, error)

func (*TraceServiceImpl) CloseTrace

func (t *TraceServiceImpl) CloseTrace(ctx context.Context, stop *pb.CloseTraceRequest) (*pb.TraceResponse, error)

func (*TraceServiceImpl) DatabaseSpan

func (t *TraceServiceImpl) DatabaseSpan(ctx context.Context, spanRequest *pb.DatabaseSpanRequest) (*pb.TraceResponse, error)

func (*TraceServiceImpl) HealthCheck

func (t *TraceServiceImpl) HealthCheck(ctx context.Context, start *pb.Empty) (*pb.HealthCheckResponse, error)

func (*TraceServiceImpl) Span

func (t *TraceServiceImpl) Span(ctx context.Context, spanRequest *pb.SpanRequest) (*pb.TraceResponse, error)

func (*TraceServiceImpl) StartNewSpan

func (t *TraceServiceImpl) StartNewSpan(ctx context.Context, start *pb.StartSpanRequest) (*pb.TraceResponse, error)

func (*TraceServiceImpl) StartTrace

func (t *TraceServiceImpl) StartTrace(ctx context.Context, start *pb.StartTraceRequest) (*pb.TraceResponse, error)

func (*TraceServiceImpl) Trace

func (t *TraceServiceImpl) Trace(ctx context.Context, traceRequest *pb.TraceRequest) (*pb.TraceResponse, error)

func (*TraceServiceImpl) UpdateDocumentWithRetry

func (t *TraceServiceImpl) UpdateDocumentWithRetry(traceID, itemName string, data []byte) (string, error)