throughputagent

Documentation

Index

• func CreateBulkInsert(client *elastic.Client, vdcName string) *elastic.BulkService
• func InsertIntoElastic(msg TrafficMessage, bulkInsert *elastic.BulkService)
• func SetLog(entty *logrus.Entry)
• func SetLogger(nLogger *logrus.Logger)
• type ComponentMatcher
  • func (m *ComponentMatcher) Match(ip string) bool
• type ThroughputAgent
  • func NewThroughputAgent() (*ThroughputAgent, error)
  • func (ta *ThroughputAgent) Run()
• type TrafficMessage

Functions

func CreateBulkInsert

func CreateBulkInsert(client *elastic.Client, vdcName string) *elastic.BulkService

CreateBulkInsert creates a BulkIndexInsertService for trafficData

func InsertIntoElastic

func InsertIntoElastic(msg TrafficMessage, bulkInsert *elastic.BulkService)

InsertIntoElastic Adds a TrafficMessage into the bulkInsert

func SetLog

func SetLog(entty *logrus.Entry)

func SetLogger

func SetLogger(nLogger *logrus.Logger)

Types

type ComponentMatcher

type ComponentMatcher struct {
	Name string
	// contains filtered or unexported fields
}

func (*ComponentMatcher) Match

func (m *ComponentMatcher) Match(ip string) bool

type ThroughputAgent

type ThroughputAgent struct {
	ElasticSearchURL string

	Interface string

	VDCName string
	// contains filtered or unexported fields
}

func NewThroughputAgent

func NewThroughputAgent() (*ThroughputAgent, error)

func (*ThroughputAgent) Run

func (ta *ThroughputAgent) Run()

type TrafficMessage

type TrafficMessage struct {
	Timestamp time.Time `json:"@timestamp,omitempty"`
	Component string    `json:"traffic.component,omitempty"`
	Send      int       `json:"traffic.send,omitempty"`
	Recived   int       `json:"traffic.recived,omitempty"`
	Total     int       `json:"traffic.total,omitempty"`
}