spanstore

Documentation

Index

• Variables
• type OperationNamesStorage
  • func NewOperationNamesStorage(session cassandra.Session, writeCacheTTL time.Duration, ...) *OperationNamesStorage
  • func (s *OperationNamesStorage) GetOperations(service string) ([]string, error)
  • func (s *OperationNamesStorage) Write(serviceName string, operationName string) error
• type Option
  • func TagFilter(tagFilter dbmodel.TagFilter) Option
• type Options
• type ServiceNamesStorage
  • func NewServiceNamesStorage(session cassandra.Session, writeCacheTTL time.Duration, ...) *ServiceNamesStorage
  • func (s *ServiceNamesStorage) GetServices() ([]string, error)
  • func (s *ServiceNamesStorage) Write(serviceName string) error
• type SpanReader
  • func NewSpanReader(session cassandra.Session, metricsFactory metrics.Factory, logger *zap.Logger) *SpanReader
  • func (s *SpanReader) FindTraces(traceQuery *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (s *SpanReader) GetOperations(service string) ([]string, error)
  • func (s *SpanReader) GetServices() ([]string, error)
  • func (s *SpanReader) GetTrace(traceID model.TraceID) (*model.Trace, error)
• type SpanWriter
  • func NewSpanWriter(session cassandra.Session, writeCacheTTL time.Duration, ...) *SpanWriter
  • func (s *SpanWriter) Close() error
  • func (s *SpanWriter) WriteSpan(span *model.Span) error

Variables

var (
	// ErrServiceNameNotSet occurs when attempting to query with an empty service name
	ErrServiceNameNotSet = errors.New("Service Name must be set")

	// ErrStartTimeMinGreaterThanMax occurs when start time min is above start time max
	ErrStartTimeMinGreaterThanMax = errors.New("Start Time Minimum is above Maximum")

	// ErrDurationMinGreaterThanMax occurs when duration min is above duration max
	ErrDurationMinGreaterThanMax = errors.New("Duration Minimum is above Maximum")

	// ErrMalformedRequestObject occurs when a request object is nil
	ErrMalformedRequestObject = errors.New("Malformed request object")

	// ErrDurationAndTagQueryNotSupported occurs when duration and tags are both set
	ErrDurationAndTagQueryNotSupported = errors.New("Cannot query for duration and tags simultaneously")

	// ErrStartAndEndTimeNotSet occurs when start time and end time are not set
	ErrStartAndEndTimeNotSet = errors.New("Start and End Time must be set")
)

Types

type OperationNamesStorage

type OperationNamesStorage struct {
	// CQL statements are public so that Cassandra2 storage can override them
	InsertStmt string
	QueryStmt  string
	// contains filtered or unexported fields
}

OperationNamesStorage stores known operation names by service.

func NewOperationNamesStorage

func NewOperationNamesStorage(
	session cassandra.Session,
	writeCacheTTL time.Duration,
	metricsFactory metrics.Factory,
	logger *zap.Logger,
) *OperationNamesStorage

NewOperationNamesStorage returns a new OperationNamesStorage

func (*OperationNamesStorage) GetOperations

func (s *OperationNamesStorage) GetOperations(service string) ([]string, error)

GetOperations returns all operations for a specific service traced by Jaeger

func (*OperationNamesStorage) Write

func (s *OperationNamesStorage) Write(serviceName string, operationName string) error

Write saves Operation and Service name tuples

type Option

type Option func(c *Options)

Option is a function that sets some option on the writer.

func TagFilter

func TagFilter(tagFilter dbmodel.TagFilter) Option

TagFilter can be provided to filter any tags that should not be indexed.

type Options

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

Options control behavior of the writer.

type ServiceNamesStorage

type ServiceNamesStorage struct {
	InsertStmt string
	QueryStmt  string
	// contains filtered or unexported fields
}

ServiceNamesStorage stores known service names.

func NewServiceNamesStorage

func NewServiceNamesStorage(
	session cassandra.Session,
	writeCacheTTL time.Duration,
	metricsFactory metrics.Factory,
	logger *zap.Logger,
) *ServiceNamesStorage

NewServiceNamesStorage returns a new ServiceNamesStorage

func (*ServiceNamesStorage) GetServices

func (s *ServiceNamesStorage) GetServices() ([]string, error)

GetServices returns all services traced by Jaeger

func (*ServiceNamesStorage) Write

func (s *ServiceNamesStorage) Write(serviceName string) error

Write saves a single service name

type SpanReader

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

SpanReader can query for and load traces from Cassandra.

func NewSpanReader

func NewSpanReader(
	session cassandra.Session,
	metricsFactory metrics.Factory,
	logger *zap.Logger,
) *SpanReader

NewSpanReader returns a new SpanReader.

func (*SpanReader) FindTraces

func (s *SpanReader) FindTraces(traceQuery *spanstore.TraceQueryParameters) ([]*model.Trace, error)

FindTraces retrieves traces that match the traceQuery

func (*SpanReader) GetOperations

func (s *SpanReader) GetOperations(service string) ([]string, error)

GetOperations returns all operations for a specific service traced by Jaeger

func (*SpanReader) GetServices

func (s *SpanReader) GetServices() ([]string, error)

GetServices returns all services traced by Jaeger

func (*SpanReader) GetTrace

func (s *SpanReader) GetTrace(traceID model.TraceID) (*model.Trace, error)

GetTrace takes a traceID and returns a Trace associated with that traceID

type SpanWriter

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

SpanWriter handles all writes to Cassandra for the Jaeger data model

func NewSpanWriter

func NewSpanWriter(
	session cassandra.Session,
	writeCacheTTL time.Duration,
	metricsFactory metrics.Factory,
	logger *zap.Logger,
	options ...Option,
) *SpanWriter

NewSpanWriter returns a SpanWriter

func (*SpanWriter) Close

func (s *SpanWriter) Close() error

Close closes SpanWriter

func (*SpanWriter) WriteSpan

func (s *SpanWriter) WriteSpan(span *model.Span) error

WriteSpan saves the span into Cassandra