store

Documentation

Index

• Variables
• type Callback
• type ConnectionType
• type Edge
• type Store
  • func NewStore(ttl time.Duration, maxItems int, onComplete, onExpire Callback) Store

Variables

var (
	ErrTooManyItems = errors.New("too many items")
)

Types

type Callback

type Callback func(e *Edge)

type ConnectionType

type ConnectionType string

const (
	Unknown         ConnectionType = ""
	MessagingSystem ConnectionType = "messaging_system"
	Database        ConnectionType = "database"
)

type Edge

type Edge struct {
	TraceID                            pcommon.TraceID
	ConnectionType                     ConnectionType
	ServerService, ClientService       string
	ServerLatencySec, ClientLatencySec float64

	// If either the client or the server spans have status code error,
	// the Edge will be considered as failed.
	Failed bool

	// Additional dimension to add to the metrics
	Dimensions map[string]string
	// contains filtered or unexported fields
}

Edge is an Edge between two nodes in the graph

type Store

type Store interface {
	// UpsertEdge inserts or updates an edge.
	UpsertEdge(key string, update Callback) (isNew bool, err error)
	// Expire evicts expired edges from the store.
	Expire()
}

Store is an interface for building service graphs.

func NewStore

func NewStore(ttl time.Duration, maxItems int, onComplete, onExpire Callback) Store

NewStore creates a Store to build service graphs. The store caches edges, each representing a request between two services. Once an edge is complete its metrics can be collected. Edges that have not found their pair are deleted after ttl time.