processor

Documentation

Overview

Package processor is a generated GoMock package.

Index

• Constants
• type DefaultProcessorManager
  • func NewDefaultProcessorManager(config config.Config, inputManager input.InputManager, ...) DefaultProcessorManager
  • func (manager *DefaultProcessorManager) Init() error
  • func (manager *DefaultProcessorManager) StartProcessors()
  • func (manager *DefaultProcessorManager) StopProcessors()
• type KafkaOpenConfigProcessor
  • func NewKafkaOpenConfigProcessor() *KafkaOpenConfigProcessor
  • func (processor *KafkaOpenConfigProcessor) GetLocalLinkIp(tags map[string]string) (string, error)
  • func (processor *KafkaOpenConfigProcessor) Start(name string, commandChan chan message.Command, resultChan chan message.Result)
  • func (processor *KafkaOpenConfigProcessor) Stop()
• type KafkaProcessor
• type MinMaxNormalizer
  • func NewMinMaxNormalizer() *MinMaxNormalizer
  • func (normalizer *MinMaxNormalizer) AddDataToNormalize(fieldName string, value float64)
  • func (normalizer *MinMaxNormalizer) NormalizeValues(updates map[string]message.ArangoUpdate, inputField, normalizationField string) (*StatisticalData, error)
  • func (normalizer *MinMaxNormalizer) ResetNormalizationData()
• type MockProcessor
  • func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor
  • func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder
  • func (m *MockProcessor) Start()
  • func (m *MockProcessor) Stop()
• type MockProcessorMockRecorder
  • func (mr *MockProcessorMockRecorder) Start() *gomock.Call
  • func (mr *MockProcessorMockRecorder) Stop() *gomock.Call
• type Normalizer
• type Processor
• type ProcessorManager
• type StatisticalData
  • func NewStatisticalData(q1, q3, iqr, lowerFence, upperFence float64) *StatisticalData
• type TelemetryToArangoProcessor
  • func NewTelemetryToArangoProcessor(config config.TelemetryToArangoProcessorConfig, ...) *TelemetryToArangoProcessor
  • func (processor *TelemetryToArangoProcessor) Start()
  • func (processor *TelemetryToArangoProcessor) Stop()

Constants

const Subsystem = "processors"

Types

type DefaultProcessorManager

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

func NewDefaultProcessorManager

func NewDefaultProcessorManager(config config.Config, inputManager input.InputManager, outputManager output.OutputManager) DefaultProcessorManager

func (*DefaultProcessorManager) Init

func (manager *DefaultProcessorManager) Init() error

func (*DefaultProcessorManager) StartProcessors

func (manager *DefaultProcessorManager) StartProcessors()

func (*DefaultProcessorManager) StopProcessors

func (manager *DefaultProcessorManager) StopProcessors()

type KafkaOpenConfigProcessor

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

func NewKafkaOpenConfigProcessor

func NewKafkaOpenConfigProcessor() *KafkaOpenConfigProcessor

func (*KafkaOpenConfigProcessor) GetLocalLinkIp

func (processor *KafkaOpenConfigProcessor) GetLocalLinkIp(tags map[string]string) (string, error)

func (*KafkaOpenConfigProcessor) Start

func (processor *KafkaOpenConfigProcessor) Start(name string, commandChan chan message.Command, resultChan chan message.Result)

func (*KafkaOpenConfigProcessor) Stop

func (processor *KafkaOpenConfigProcessor) Stop()

type KafkaProcessor

type KafkaProcessor interface {
	Start(string, chan message.Command, chan message.Result)
	GetLocalLinkIp(map[string]string) (string, error)
	Stop()
}

type MinMaxNormalizer

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

func NewMinMaxNormalizer

func NewMinMaxNormalizer() *MinMaxNormalizer

func (*MinMaxNormalizer) AddDataToNormalize

func (normalizer *MinMaxNormalizer) AddDataToNormalize(fieldName string, value float64)

func (*MinMaxNormalizer) NormalizeValues

func (normalizer *MinMaxNormalizer) NormalizeValues(updates map[string]message.ArangoUpdate, inputField, normalizationField string) (*StatisticalData, error)

func (*MinMaxNormalizer) ResetNormalizationData

func (normalizer *MinMaxNormalizer) ResetNormalizationData()

type MockProcessor

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

MockProcessor is a mock of Processor interface.

func NewMockProcessor

func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor

NewMockProcessor creates a new mock instance.

func (*MockProcessor) EXPECT

func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder

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

func (*MockProcessor) Start

func (m *MockProcessor) Start()

Start mocks base method.

func (*MockProcessor) Stop

func (m *MockProcessor) Stop()

Stop mocks base method.

type MockProcessorMockRecorder

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

MockProcessorMockRecorder is the mock recorder for MockProcessor.

func (*MockProcessorMockRecorder) Start

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

Start indicates an expected call of Start.

func (*MockProcessorMockRecorder) Stop

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

Stop indicates an expected call of Stop.

type Normalizer

type Normalizer interface {
	NormalizeValues(map[string]message.ArangoUpdate, string, string) (*StatisticalData, error)
	AddDataToNormalize(string, float64)
	ResetNormalizationData()
}

type Processor

type Processor interface {
	Start()
	Stop()
}

type ProcessorManager

type ProcessorManager interface {
	Init() error
	StartProcessors()
	StopProcessors()
}

type StatisticalData

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

func NewStatisticalData

func NewStatisticalData(q1, q3, iqr, lowerFence, upperFence float64) *StatisticalData

type TelemetryToArangoProcessor

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

func NewTelemetryToArangoProcessor

func NewTelemetryToArangoProcessor(config config.TelemetryToArangoProcessorConfig, inputResources map[string]input.InputResource, outputResources map[string]output.OutputResource, kafkaOpenConfigProcessor KafkaProcessor, normalizer Normalizer) *TelemetryToArangoProcessor

func (*TelemetryToArangoProcessor) Start

func (processor *TelemetryToArangoProcessor) Start()

func (*TelemetryToArangoProcessor) Stop

func (processor *TelemetryToArangoProcessor) Stop()