consumer

Documentation

Overview

Package consumer is a generated GoMock package.

Index

• type BandwidthMessage
• type Consumer
• type DelayMessage
• type KafkaConsumer
  • func NewKafkaConsumer(kafkaBroker, kafkaTopic string, msgChan chan Message) *KafkaConsumer
  • func (consumer *KafkaConsumer) Init() error
  • func (consumer *KafkaConsumer) Start()
  • func (consumer *KafkaConsumer) Stop() error
  • func (consumer *KafkaConsumer) UnmarshalBandwidthMessage(telemetryMessage TelemetryMessage) (*BandwidthMessage, error)
  • func (consumer *KafkaConsumer) UnmarshalDelayMessage(telemetryMessage TelemetryMessage) (*DelayMessage, error)
  • func (consumer *KafkaConsumer) UnmarshalIsisMessage(telemetryMessage TelemetryMessage) ([]Message, error)
  • func (consumer *KafkaConsumer) UnmarshalLossMessage(telemetryMessage TelemetryMessage) (*LossMessage, error)
  • func (consumer *KafkaConsumer) UnmarshalTelemetryMessage(message *sarama.ConsumerMessage) (*TelemetryMessage, error)
• type LossMessage
• type Message
• type MessageTags
• type MockConsumer
  • func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
  • func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder
  • func (m *MockConsumer) Init() error
  • func (m *MockConsumer) Start()
  • func (m *MockConsumer) Stop() error
• type MockConsumerMockRecorder
  • func (mr *MockConsumerMockRecorder) Init() *gomock.Call
  • func (mr *MockConsumerMockRecorder) Start() *gomock.Call
  • func (mr *MockConsumerMockRecorder) Stop() *gomock.Call
• type TelemetryMessage

Types

type BandwidthMessage

type BandwidthMessage struct {
	TelemetryMessage
	Bandwidth float64 `json:"interface_status_and_data/enabled/bandwidth,omitempty"`
}

type Consumer

type Consumer interface {
	Init() error
	Start()
	Stop() error
}

type DelayMessage

type DelayMessage struct {
	TelemetryMessage
	Average  uint32 `json:"delay_measurement_session/last_advertisement_information/advertised_values/average,omitempty"`
	Maximum  uint32 `json:"delay_measurement_session/last_advertisement_information/advertised_values/maximum,omitempty"`
	Minimum  uint32 `json:"delay_measurement_session/last_advertisement_information/advertised_values/minimum,omitempty"`
	Variance uint32 `json:"delay_measurement_session/last_advertisement_information/advertised_values/variance,omitempty"`
}

type KafkaConsumer

type KafkaConsumer struct {
	// contains filtered or unexported fields
}

func NewKafkaConsumer

func NewKafkaConsumer(kafkaBroker, kafkaTopic string, msgChan chan Message) *KafkaConsumer

func (*KafkaConsumer) Init

func (consumer *KafkaConsumer) Init() error

func (*KafkaConsumer) Start

func (consumer *KafkaConsumer) Start()

func (*KafkaConsumer) Stop

func (consumer *KafkaConsumer) Stop() error

func (*KafkaConsumer) UnmarshalBandwidthMessage

func (consumer *KafkaConsumer) UnmarshalBandwidthMessage(telemetryMessage TelemetryMessage) (*BandwidthMessage, error)

func (*KafkaConsumer) UnmarshalDelayMessage

func (consumer *KafkaConsumer) UnmarshalDelayMessage(telemetryMessage TelemetryMessage) (*DelayMessage, error)

func (*KafkaConsumer) UnmarshalIsisMessage

func (consumer *KafkaConsumer) UnmarshalIsisMessage(telemetryMessage TelemetryMessage) ([]Message, error)

func (*KafkaConsumer) UnmarshalLossMessage

func (consumer *KafkaConsumer) UnmarshalLossMessage(telemetryMessage TelemetryMessage) (*LossMessage, error)

func (*KafkaConsumer) UnmarshalTelemetryMessage

func (consumer *KafkaConsumer) UnmarshalTelemetryMessage(message *sarama.ConsumerMessage) (*TelemetryMessage, error)

type LossMessage

type LossMessage struct {
	TelemetryMessage
	LossPercentage float64 `json:"interface_status_and_data/enabled/packet_loss_percentage,omitempty"`
}

type Message

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

type MessageTags

type MessageTags struct {
	Host          string `json:"host,omitempty"`
	InterfaceName string `json:"interface_name,omitempty"`
	Node          string `json:"node"`
	Path          string `json:"path,omitempty"`
	Source        string `json:"source,omitempty"`
	Subscription  string `json:"subscription,omitempty"`
}

type MockConsumer

type MockConsumer struct {
	// contains filtered or unexported fields
}

MockConsumer is a mock of Consumer interface.

func NewMockConsumer

func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer

NewMockConsumer creates a new mock instance.

func (*MockConsumer) EXPECT

func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConsumer) Init

func (m *MockConsumer) Init() error

Init mocks base method.

func (*MockConsumer) Start

func (m *MockConsumer) Start()

Start mocks base method.

func (*MockConsumer) Stop

func (m *MockConsumer) Stop() error

Stop mocks base method.

type MockConsumerMockRecorder

type MockConsumerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConsumerMockRecorder is the mock recorder for MockConsumer.

func (*MockConsumerMockRecorder) Init

func (mr *MockConsumerMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockConsumerMockRecorder) Start

func (mr *MockConsumerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockConsumerMockRecorder) Stop

func (mr *MockConsumerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type TelemetryMessage

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