chqservicegraphexporter

Documentation

Index

• func NewFactory() exporter.Factory
• func OrgIdFromResource(resource pcommon.Map) string
• 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

func OrgIdFromResource

func OrgIdFromResource(resource pcommon.Map) string

Types

type Config

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

type Edge

type Edge struct {
	ClientClusterName string `json:"client_cluster_name"`
	ClientNamespace   string `json:"client_namespace_name"`
	ServerClusterName string `json:"server_cluster_name"`
	ServerNamespace   string `json:"server_namespace_name"`
	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