Documentation
¶
Index ¶
Constants ¶
This section is empty.
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") )
Functions ¶
This section is empty.
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
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
type SpanWriter ¶
type SpanWriter struct {
// contains filtered or unexported fields
}
SpanWriter handles all writes to Cassandra for the Jaeger data model
Source Files
Directories