decoder

Documentation

Index

• Constants
• func StatsToExtMetrics(vtapID uint16, s *pb.Stats) *dbwriter.ExtMetrics
• type Counter
• type Decoder
  • func NewDecoder(index int, msgType datatype.MessageType, platformData *grpc.PlatformInfoTable, ...) *Decoder
  • func (d *Decoder) GetCounter() interface{}
  • func (d *Decoder) PointToExtMetrics(vtapID uint16, point models.Point) (*dbwriter.ExtMetrics, error)
  • func (d *Decoder) Run()

Constants

const (
	BUFFER_SIZE            = 128 // An ext_metrics message is usually very large, so use a smaller value than usual
	TELEGRAF_POD           = "pod_name"
	VTABLE_PREFIX_TELEGRAF = "influxdb."
)

Functions

func StatsToExtMetrics

func StatsToExtMetrics(vtapID uint16, s *pb.Stats) *dbwriter.ExtMetrics

Types

type Counter

type Counter struct {
	InCount                int64 `statsd:"in-count"`
	OutCount               int64 `statsd:"out-count"`
	ErrorCount             int64 `statsd:"err-count"`
	ErrMetrics             int64 `statsd:"err-metrics"`
	DropUnsupportedMetrics int64 `statsd:"drop-unsupported-metrics"`
}

type Decoder

type Decoder struct {
	utils.Closable
	// contains filtered or unexported fields
}

func NewDecoder

func NewDecoder(
	index int, msgType datatype.MessageType,
	platformData *grpc.PlatformInfoTable,
	inQueue queue.QueueReader,
	extMetricsWriter *dbwriter.ExtMetricsWriter,
	config *config.Config,
) *Decoder

func (*Decoder) GetCounter

func (d *Decoder) GetCounter() interface{}

func (*Decoder) PointToExtMetrics

func (d *Decoder) PointToExtMetrics(vtapID uint16, point models.Point) (*dbwriter.ExtMetrics, error)

func (*Decoder) Run

func (d *Decoder) Run()