services

package
v0.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 4, 2017 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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) AdaptiveSamplingTest

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

AdaptiveSamplingTest creates traces by hitting a client service and validates that the sampling probability has changed.

The test creates a stream of traces which gets the adaptive sampler processor to start calculating the probability. The test will wait until the sampling rates are calculated before creating a large amount of traces with the hopes that at least one trace will be sampled with the new sampling probability. The test will make sure the new traces were indeed sampled with a calculated probability by checking span tags.

func (*TraceHandler) EndToEndTest

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL