Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dependency ¶
type Dependency struct {
Parent string `cql:"parent"`
Child string `cql:"child"`
CallCount int64 `cql:"call_count"` // always unsigned, but we cannot explicitly read uint64 from Cassandra
Source string `cql:"source"`
}
Dependency is the UDT representation of a Jaeger Dependency.
func (*Dependency) MarshalUDT ¶
MarshalUDT handles marshalling a Dependency.
func (*Dependency) UnmarshalUDT ¶
UnmarshalUDT handles unmarshalling a Dependency.
type DependencyStore ¶
type DependencyStore struct {
// contains filtered or unexported fields
}
DependencyStore handles all queries and insertions to Cassandra dependencies
func NewDependencyStore ¶
func NewDependencyStore( session cassandra.Session, metricsFactory metrics.Factory, logger *zap.Logger, version Version, ) (*DependencyStore, error)
NewDependencyStore returns a DependencyStore
func (*DependencyStore) GetDependencies ¶
func (s *DependencyStore) GetDependencies(endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)
GetDependencies returns all interservice dependencies
func (*DependencyStore) WriteDependencies ¶
func (s *DependencyStore) WriteDependencies(ts time.Time, dependencies []model.DependencyLink) error
WriteDependencies implements dependencystore.Writer#WriteDependencies.
type Version ¶ added in v1.10.0
type Version int
Version determines which version of the dependencies table to use.
func GetDependencyVersion ¶ added in v1.10.1
GetDependencyVersion attempts to determine the version of the dependencies table. TODO: Remove this once we've migrated to V2 permanently. https://github.com/jaegertracing/jaeger/issues/1344
Source Files
Click to show internal directories.
Click to hide internal directories.