comedy

Documentation

Index

• Constants
• func CreateCombinedId(trace *pb.TraceBare) string
• func GenerateSpanID() string
• func TraceFromCtx(ctx context.Context) *pb.TraceBare
• type Adapter
  • func Trace(tracer pb.TraceService_ChorusClient) Adapter
  • func TraceWithLogAndSpan(tracer pb.TraceService_ChorusClient) Adapter
• type ClientTracer
  • func NewClientTracer(serviceAddress string) (*ClientTracer, error)
  • func (c *ClientTracer) Chorus(ctx context.Context) (pb.TraceService_ChorusClient, error)
  • func (c *ClientTracer) HealthCheck(ctx context.Context, request *pb.Empty) (*pb.HealthCheckResponse, error)
  • func (c *ClientTracer) WaitForHealthyState() bool
• type MapCommand
• type MapResponse
• type TraceService
• type TraceServiceClient
• type TraceServiceImpl
  • func NewTraceServiceImpl() (*TraceServiceImpl, error)
  • func (t *TraceServiceImpl) Chorus(stream pb.TraceService_ChorusServer) error
  • func (t *TraceServiceImpl) CloseTrace(close *pb.ParabasisRequest_CloseTrace, traceID, ParentSpanID string)
  • func (t *TraceServiceImpl) DatabaseSpan(in *pb.ParabasisRequest_DatabaseSpan, traceID, ParentSpanID string)
  • func (t *TraceServiceImpl) HealthCheck(ctx context.Context, start *pb.Empty) (*pb.HealthCheckResponse, error)
  • func (t *TraceServiceImpl) ManageStartTimeMap()
  • func (t *TraceServiceImpl) Span(in *pb.ParabasisRequest_Span, traceID, ParentSpanID string)
  • func (t *TraceServiceImpl) StartTrace(start *pb.ParabasisRequest_StartTrace, traceID, ParentSpanID string)
  • func (t *TraceServiceImpl) Trace(in *pb.ParabasisRequest_Trace, traceID, ParentSpanID, spanID string)
  • func (t *TraceServiceImpl) UpdateDocumentWithRetry(traceID, itemName string, data []byte) (string, error)

Constants

const (
	TRACE        string = "trace"
	SPAN         string = "span"
	TRACESTART   string = "trace_start"
	TRACECLOSE   string = "trace_close"
	DATABASESPAN string = "database_span"
	ITEMS        string = "items"
)

const (
	DefaultAddress string = "localhost:50052"
)

Functions

func CreateCombinedId

func CreateCombinedId(trace *pb.TraceBare) string

func GenerateSpanID

func GenerateSpanID() string

func TraceFromCtx

func TraceFromCtx(ctx context.Context) *pb.TraceBare

Types

type Adapter

type Adapter func(http.HandlerFunc) http.HandlerFunc

func Trace

func Trace(tracer pb.TraceService_ChorusClient) Adapter

func TraceWithLogAndSpan

func TraceWithLogAndSpan(tracer pb.TraceService_ChorusClient) Adapter

type ClientTracer

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

func NewClientTracer

func NewClientTracer(serviceAddress string) (*ClientTracer, error)

func (*ClientTracer) Chorus

func (c *ClientTracer) Chorus(ctx context.Context) (pb.TraceService_ChorusClient, error)

func (*ClientTracer) HealthCheck

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

func (*ClientTracer) WaitForHealthyState

func (c *ClientTracer) WaitForHealthyState() bool

type MapCommand

type MapCommand struct {
	Action   string
	TraceID  string
	Time     time.Time
	Response chan<- MapResponse
}

type MapResponse

type MapResponse struct {
	Time  time.Time
	Found bool
}

type TraceService

type TraceService interface {
	HealthCheck(ctx context.Context, start *pb.Empty) (*pb.HealthCheckResponse, error)
	Chorus(ctx context.Context) (pb.TraceService_ChorusClient, error)
	WaitForHealthyState() bool
}

type TraceServiceClient

type TraceServiceClient struct {
	Impl TraceService
}

type TraceServiceImpl

type TraceServiceImpl struct {
	PodName       string
	Namespace     string
	Index         string
	Elastic       aristoteles.Client
	Metrics       *sophokles.ClientMetrics
	GatherMetrics bool

	pb.UnimplementedTraceServiceServer
	// contains filtered or unexported fields
}

func NewTraceServiceImpl

func NewTraceServiceImpl() (*TraceServiceImpl, error)

func (*TraceServiceImpl) Chorus

func (t *TraceServiceImpl) Chorus(stream pb.TraceService_ChorusServer) error

func (*TraceServiceImpl) CloseTrace

func (t *TraceServiceImpl) CloseTrace(close *pb.ParabasisRequest_CloseTrace, traceID, ParentSpanID string)

func (*TraceServiceImpl) DatabaseSpan

func (t *TraceServiceImpl) DatabaseSpan(in *pb.ParabasisRequest_DatabaseSpan, traceID, ParentSpanID string)

func (*TraceServiceImpl) HealthCheck

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

func (*TraceServiceImpl) ManageStartTimeMap

func (t *TraceServiceImpl) ManageStartTimeMap()

func (*TraceServiceImpl) Span

func (t *TraceServiceImpl) Span(in *pb.ParabasisRequest_Span, traceID, ParentSpanID string)

func (*TraceServiceImpl) StartTrace

func (t *TraceServiceImpl) StartTrace(start *pb.ParabasisRequest_StartTrace, traceID, ParentSpanID string)

func (*TraceServiceImpl) Trace

func (t *TraceServiceImpl) Trace(in *pb.ParabasisRequest_Trace, traceID, ParentSpanID, spanID string)

func (*TraceServiceImpl) UpdateDocumentWithRetry

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