message

type ArangoEventNotificationMessage struct {
	BaseResultMessage
	EventMessages []EventMessage
	Action        string
}

type ArangoNormalizationMessage struct {
	BaseResultMessage
	Measurement           string
	NormalizationMessages []NormalizationMessage
}

type ArangoUpdate struct {
	Tags   map[string]string
	Fields []string
	Values []float64
}

type ArangoUpdateCommand struct {
	BaseCommand
	Collection      string
	StatisticalData map[string]float64
	Updates         map[string]ArangoUpdate
}

type BaseCommand struct{}

type BaseResultMessage struct{}

type Command interface {
	// contains filtered or unexported methods
}

type EventMessage struct {
	Key       string
	Id        string
	TopicType int
}

type IPv6Fields struct {
	Delete       bool   `mapstructure:"delete"`
	IPv6         string `mapstructure:"state/ip" validate:"required"`
	Origin       string `mapstructure:"state/origin" validate:"required"`
	PrefixLength int    `mapstructure:"state/prefix_length" validate:"required"`
	Status       string `mapstructure:"state/status" validate:"required"`
}

type IPv6Message struct {
	TelemetryMessage
	Fields IPv6Fields
}

type InfluxQueryCommand struct {
	BaseCommand
	Measurement    string
	Field          string
	Method         string
	Transformation *config.Transformation
	GroupBy        []string
	Interval       uint
	OutputOptions  map[string]config.OutputOption
}

type InfluxResult struct {
	Tags  map[string]string
	Value float64
}

type InfluxResultMessage struct {
	BaseResultMessage
	OutputOptions map[string]config.OutputOption
	Results       []InfluxResult
}

type InterfaceStatusFields struct {
	AdminStatus             string `mapstructure:"admin_status" validate:"required"`
	CarrierTransitionsCount int    `mapstructure:"counters/carrier_transitions" validate:"min=0"`
	CPU                     string `mapstructure:"cpu" validate:"required"`
	Delete                  bool   `mapstructure:"delete"`
	Description             string `mapstructure:"description" validate:"required"`
	Enabled                 string `mapstructure:"enabled" validate:"required"`
	InterfaceIndex          int    `mapstructure:"ifindex" validate:"min=0"`
	LastChange              int64  `mapstructure:"last_change" validate:"required"`
	Logical                 string `mapstructure:"logical" validate:"required"`
	LoopbackMode            string `mapstructure:"loopback_mode" validate:"required"`
	Management              string `mapstructure:"management" validate:"required"`
	MTU                     int    `mapstructure:"mtu" validate:"required"`
	Name                    string `mapstructure:"name" validate:"required"`
	OperStatus              string `mapstructure:"oper_status" validate:"required"`
	Type                    string `mapstructure:"type" validate:"required"`
}

type InterfaceStatusMessage struct {
	TelemetryMessage
	Fields InterfaceStatusFields
}

type KafkaEventCommand struct {
	BaseCommand
	Updates []KafkaEventMessage
}

type KafkaEventMessage struct {
	TopicType int    `json:"TopicType"`
	Key       string `json:"_key"`
	Id        string `json:"_id"`
	Action    string `json:"action"`
}

type KafkaListeningCommand struct{ BaseCommand }

type KafkaNormalizationCommand struct {
	BaseCommand
	Updates []KafkaNormalizationMessage
}

type KafkaNormalizationMessage struct {
	Measurement string
	Tags        map[string]string
	Fields      map[string]float64
}

type MessageTags struct {
	Host          string `json:"host,omitempty"`
	Index         string `json:"index"`
	IP            string `json:"ip"`
	InterfaceName string `json:"name,omitempty"`
	Node          string `json:"node"`
	Path          string `json:"path,omitempty"`
	Source        string `json:"source,omitempty"`
	Subscription  string `json:"subscription,omitempty"`
}

type NormalizationMessage struct {
	Tags   map[string]string
	Fields map[string]float64
}

type Result interface {
	// contains filtered or unexported methods
}

type TelemetryMessage struct {
	BaseResultMessage
	Fields    map[string]interface{} `json:"fields,omitempty"`
	Name      string                 `json:"name,omitempty"`
	Tags      MessageTags            `json:"tags,omitempty"`
	Timestamp int64                  `json:"timestamp,omitempty"`
}

type UpdateLinkMessage struct {
	arango.LSLink
	NormalizedUnidirLinkDelay      float64 `json:"normalized_unidir_link_delay,omitempty"`
	NormalizedUnidirDelayVariation float64 `json:"normalized_unidir_delay_variation,omitempty"`
	NormalizedUnidirPacketLoss     float64 `json:"normalized_unidir_packet_loss,omitempty"`
	UnidirPacketLossPercentage     float64 `json:"undir_packet_loss_percentage,omitempty"`
}