Help us shape the future of Go! Take the 2026 Go Developer Survey

dependencystore

package
v1.9.0 Latest Latest
Warning

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

Go to latest
Published: Jan 21, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

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
}

Dependency is the UDT representation of a Jaeger Dependency.

func (*Dependency) MarshalUDT

func (d *Dependency) MarshalUDT(name string, info gocql.TypeInfo) ([]byte, error)

MarshalUDT handles marshalling a Dependency.

func (*Dependency) UnmarshalUDT

func (d *Dependency) UnmarshalUDT(name string, info gocql.TypeInfo, data []byte) error

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,
) *DependencyStore

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.

Jump to

Keyboard shortcuts

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