chqservicegraphexporter

Documentation

Index

• func NewFactory() exporter.Factory
• type Config
• type Edge
• type EdgeCache
  • func NewEdgeCache(interval time.Duration, timeProvider func() int64) *EdgeCache
  • func (e *EdgeCache) Add(edge Edge)

Functions

func NewFactory

func NewFactory() exporter.Factory

Types

type Config

type Config struct {
	confighttp.ClientConfig `mapstructure:",squash"`
}

type Edge

type Edge struct {
	Client         string `json:"client"`
	Server         string `json:"server"`
	ConnectionType string `json:"connection_type"`
}

Edge represents an edge in the system

type EdgeCache

type EdgeCache struct {
	sync.Mutex

	Edges map[Edge]int64
	// contains filtered or unexported fields
}

EdgeCache holds edges and provides Add and Flush methods

func NewEdgeCache

func NewEdgeCache(interval time.Duration, timeProvider func() int64) *EdgeCache

NewEdgeCache initializes and returns a new EdgeCache with default time provider

func (*EdgeCache) Add

func (e *EdgeCache) Add(edge Edge)

Add adds an Edge to the cache if it doesn't already exist