decoder

Documentation

Index

• Constants
• type Counter
• type Decoder
  • func NewDecoder(index int, eventType common.EventType, inQueue queue.QueueReader, ...) *Decoder
  • func (d *Decoder) GetCounter() interface{}
  • func (d *Decoder) Run()
  • func (d *Decoder) WriteK8sEvent(vtapId uint16, e *pb.KubernetesEvent)
  • func (d *Decoder) WritePerfEvent(vtapId uint16, e *pb.ProcEvent)

Constants

const (
	BUFFER_SIZE = 1024
	SEPARATOR   = ", "
)

Types

type Counter

type Counter struct {
	InCount    int64 `statsd:"in-count"`
	OutCount   int64 `statsd:"out-count"`
	ErrorCount int64 `statsd:"err-count"`
}

type Decoder

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

func NewDecoder

func NewDecoder(
	index int,
	eventType common.EventType,
	inQueue queue.QueueReader,
	eventWriter *dbwriter.EventWriter,
	platformData *grpc.PlatformInfoTable,
	exporters *exporters.Exporters,
	config *config.Config,
) *Decoder

func (*Decoder) GetCounter

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

func (*Decoder) Run

func (d *Decoder) Run()

func (*Decoder) WriteK8sEvent

func (d *Decoder) WriteK8sEvent(vtapId uint16, e *pb.KubernetesEvent)

func (*Decoder) WritePerfEvent

func (d *Decoder) WritePerfEvent(vtapId uint16, e *pb.ProcEvent)