services

Documentation

Index

• func InitializeCassandraSchema(session cassandra.Session, schemaFile, keyspace string) error
• type AgentService
  • func NewAgentService(url string, logger *zap.Logger) AgentService
• type QueryService
  • func NewQueryService(url string, logger *zap.Logger) QueryService
• type TraceHandler
  • func NewTraceHandler(query QueryService, agent AgentService, logger *zap.Logger) *TraceHandler
  • func (h *TraceHandler) EndToEndTest(t crossdock.T)

Functions

func InitializeCassandraSchema

func InitializeCassandraSchema(session cassandra.Session, schemaFile, keyspace string) error

InitializeCassandraSchema applies a schema to the cassandra keyspace

Types

type AgentService

type AgentService interface {
	GetSamplingRate(service, operation string) (float64, error)
}

AgentService is the service used to report traces to the collector.

func NewAgentService

func NewAgentService(url string, logger *zap.Logger) AgentService

NewAgentService returns an instance of AgentService.

type QueryService

type QueryService interface {
	GetTraces(serviceName, operation string, tags map[string]string) ([]*ui.Trace, error)
}

QueryService is the service used to query cassandra tables for traces

func NewQueryService

func NewQueryService(url string, logger *zap.Logger) QueryService

NewQueryService returns an instance of QueryService.

type TraceHandler

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

TraceHandler handles creating traces and verifying them

func NewTraceHandler

func NewTraceHandler(query QueryService, agent AgentService, logger *zap.Logger) *TraceHandler

NewTraceHandler returns a TraceHandler that can create traces and verify them

func (*TraceHandler) EndToEndTest

func (h *TraceHandler) EndToEndTest(t crossdock.T)

EndToEndTest creates a trace by hitting a client service and validates the trace