Documentation ¶
Index ¶
- Variables
- type OdigosMetricsConsumer
- func (c *OdigosMetricsConsumer) Capabilities() consumer.Capabilities
- func (c *OdigosMetricsConsumer) ConsumeMetrics(ctx context.Context, md pmetric.Metrics) error
- func (c *OdigosMetricsConsumer) GetDestinationsMetrics() map[string]trafficMetrics
- func (c *OdigosMetricsConsumer) GetSingleDestinationMetrics(dID string) (trafficMetrics, bool)
- func (c *OdigosMetricsConsumer) GetSingleSourceMetrics(sID common.SourceID) (trafficMetrics, bool)
- func (c *OdigosMetricsConsumer) GetSourcesMetrics() map[common.SourceID]trafficMetrics
- func (c *OdigosMetricsConsumer) Run(ctx context.Context, odigosNS string)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ServiceNameKey = strings.ReplaceAll(string(semconv.ServiceNameKey), ".", "_") K8SNamespaceNameKey = strings.ReplaceAll(string(semconv.K8SNamespaceNameKey), ".", "_") K8SDeploymentNameKey = strings.ReplaceAll(string(semconv.K8SDeploymentNameKey), ".", "_") K8SStatefulSetNameKey = strings.ReplaceAll(string(semconv.K8SStatefulSetNameKey), ".", "_") K8SDaemonSetNameKey = strings.ReplaceAll(string(semconv.K8SDaemonSetNameKey), ".", "_") )
Functions ¶
This section is empty.
Types ¶
type OdigosMetricsConsumer ¶
type OdigosMetricsConsumer struct {
// contains filtered or unexported fields
}
func NewOdigosMetrics ¶
func NewOdigosMetrics() *OdigosMetricsConsumer
func (*OdigosMetricsConsumer) Capabilities ¶
func (c *OdigosMetricsConsumer) Capabilities() consumer.Capabilities
func (*OdigosMetricsConsumer) ConsumeMetrics ¶
func (*OdigosMetricsConsumer) GetDestinationsMetrics ¶
func (c *OdigosMetricsConsumer) GetDestinationsMetrics() map[string]trafficMetrics
func (*OdigosMetricsConsumer) GetSingleDestinationMetrics ¶
func (c *OdigosMetricsConsumer) GetSingleDestinationMetrics(dID string) (trafficMetrics, bool)
func (*OdigosMetricsConsumer) GetSingleSourceMetrics ¶
func (c *OdigosMetricsConsumer) GetSingleSourceMetrics(sID common.SourceID) (trafficMetrics, bool)
func (*OdigosMetricsConsumer) GetSourcesMetrics ¶
func (c *OdigosMetricsConsumer) GetSourcesMetrics() map[common.SourceID]trafficMetrics
Click to show internal directories.
Click to hide internal directories.