otlpmetricsv1

Documentation

Index

• Constants
• type Forwarder
  • func (f *Forwarder) DefaultConfig() string
  • func (f *Forwarder) Description() string
  • func (f *Forwarder) Forward(batch event.BatchEvents) error
  • func (f *Forwarder) ForwardType() v1.SniffType
  • func (f *Forwarder) Name() string
  • func (f *Forwarder) Prepare(connection interface{}) error
  • func (f *Forwarder) ShowName() string
  • func (f *Forwarder) SupportedSyncInvoke() bool
  • func (f *Forwarder) SyncForward(*v1.SniffData) (*v1.SniffData, grpc.ClientStream, error)

Constants

const (
	Name     = "otlp-metrics-v1-grpc-forwarder"
	ShowName = "OpenTelemetry Metrics v1 GRPC Forwarder"
)

Types

type Forwarder

type Forwarder struct {
	config.CommonFields
	// The label key of the routing data, multiple keys are split by ","
	RoutingLabelKeys string `mapstructure:"routing_label_keys"`
	// The LRU policy cache size for hosting routine rules of service instance.
	RoutingRuleLRUCacheSize int `mapstructure:"routing_rule_lru_cache_size"`
	// The TTL of the LRU cache size for hosting routine rules of service instance.
	RoutingRuleLRUCacheTTL int `mapstructure:"routing_rule_lru_cache_ttl"`
	// contains filtered or unexported fields
}

func (*Forwarder) DefaultConfig

func (f *Forwarder) DefaultConfig() string

func (*Forwarder) Description

func (f *Forwarder) Description() string

func (*Forwarder) Forward

func (f *Forwarder) Forward(batch event.BatchEvents) error

func (*Forwarder) ForwardType

func (f *Forwarder) ForwardType() v1.SniffType

func (*Forwarder) Name

func (f *Forwarder) Name() string

func (*Forwarder) Prepare

func (f *Forwarder) Prepare(connection interface{}) error

func (*Forwarder) ShowName

func (f *Forwarder) ShowName() string

func (*Forwarder) SupportedSyncInvoke

func (f *Forwarder) SupportedSyncInvoke() bool

func (*Forwarder) SyncForward

func (f *Forwarder) SyncForward(*v1.SniffData) (*v1.SniffData, grpc.ClientStream, error)