processor

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 22, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package processor is a generated GoMock package.

Index

Constants

View Source 
const Subsystem = "processor"

Variables

This section is empty.

Functions

This section is empty.

Types

type Dispatcher 

type Dispatcher interface {
	Dispatch(event domain.NetworkEvent) bool
}

type EventDispatcher 

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

func NewEventDispatcher 

func NewEventDispatcher(nodeEventHandler *NodeEventProcessor, linkEventHandler *LinkEventProcessor, prefixEventHandler *PrefixEventProcessor, sidEventHandler *SidEventProcessor) *EventDispatcher

func (*EventDispatcher) Dispatch 

func (dispatcher *EventDispatcher) Dispatch(event domain.NetworkEvent) bool

type EventHandler 

type EventHandler interface {
	HandleEvent(event domain.NetworkEvent) bool
}

type EventOptions 

type EventOptions struct {
	NodeEventProcessor   NodeProcessor
	LinkEventProcessor   LinkProcessor
	PrefixEventProcessor PrefixProcessor
	SidEventProcessor    SidProcessor
	EventDispatcher      *EventDispatcher
}

type LinkEventProcessor 

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

func NewLinkEventProcessor 

func NewLinkEventProcessor(graph graph.Graph, cache cache.Cache) *LinkEventProcessor

func (*LinkEventProcessor) HandleEvent 

func (processor *LinkEventProcessor) HandleEvent(event domain.NetworkEvent) bool
func (processor *LinkEventProcessor) ProcessLinks(links []domain.Link) error

type LinkProcessor 

type LinkProcessor interface {
	ProcessLinks([]domain.Link) error
}

type MockLinkProcessor 

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

MockLinkProcessor is a mock of LinkProcessor interface.

func NewMockLinkProcessor 

func NewMockLinkProcessor(ctrl *gomock.Controller) *MockLinkProcessor

NewMockLinkProcessor creates a new mock instance.

func (*MockLinkProcessor) EXPECT 

func (m *MockLinkProcessor) EXPECT() *MockLinkProcessorMockRecorder

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

func (m *MockLinkProcessor) ProcessLinks(arg0 []domain.Link) error

ProcessLinks mocks base method.

type MockLinkProcessorMockRecorder 

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

MockLinkProcessorMockRecorder is the mock recorder for MockLinkProcessor. 

func (mr *MockLinkProcessorMockRecorder) ProcessLinks(arg0 any) *gomock.Call

ProcessLinks indicates an expected call of ProcessLinks.

type MockNodeProcessor 

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

MockNodeProcessor is a mock of NodeProcessor interface.

func NewMockNodeProcessor 

func NewMockNodeProcessor(ctrl *gomock.Controller) *MockNodeProcessor

NewMockNodeProcessor creates a new mock instance.

func (*MockNodeProcessor) EXPECT 

func (m *MockNodeProcessor) EXPECT() *MockNodeProcessorMockRecorder

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

func (*MockNodeProcessor) ProcessNodes 

func (m *MockNodeProcessor) ProcessNodes(arg0 []domain.Node)

ProcessNodes mocks base method.

type MockNodeProcessorMockRecorder 

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

MockNodeProcessorMockRecorder is the mock recorder for MockNodeProcessor.

func (*MockNodeProcessorMockRecorder) ProcessNodes 

func (mr *MockNodeProcessorMockRecorder) ProcessNodes(arg0 any) *gomock.Call

ProcessNodes indicates an expected call of ProcessNodes.

type MockPrefixProcessor 

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

MockPrefixProcessor is a mock of PrefixProcessor interface.

func NewMockPrefixProcessor 

func NewMockPrefixProcessor(ctrl *gomock.Controller) *MockPrefixProcessor

NewMockPrefixProcessor creates a new mock instance.

func (*MockPrefixProcessor) EXPECT 

func (m *MockPrefixProcessor) EXPECT() *MockPrefixProcessorMockRecorder

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

func (*MockPrefixProcessor) ProcessPrefixes 

func (m *MockPrefixProcessor) ProcessPrefixes(arg0 []domain.Prefix)

ProcessPrefixes mocks base method.

type MockPrefixProcessorMockRecorder 

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

MockPrefixProcessorMockRecorder is the mock recorder for MockPrefixProcessor.

func (*MockPrefixProcessorMockRecorder) ProcessPrefixes 

func (mr *MockPrefixProcessorMockRecorder) ProcessPrefixes(arg0 any) *gomock.Call

ProcessPrefixes indicates an expected call of ProcessPrefixes.

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 (m *MockProcessor) ProcessLinks(arg0 []domain.Link) error

ProcessLinks mocks base method.

func (*MockProcessor) ProcessNodes 

func (m *MockProcessor) ProcessNodes(arg0 []domain.Node)

ProcessNodes mocks base method.

func (*MockProcessor) ProcessPrefixes 

func (m *MockProcessor) ProcessPrefixes(arg0 []domain.Prefix)

ProcessPrefixes mocks base method.

func (*MockProcessor) ProcessSids 

func (m *MockProcessor) ProcessSids(arg0 []domain.Sid)

ProcessSids mocks base method.

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 (mr *MockProcessorMockRecorder) ProcessLinks(arg0 any) *gomock.Call

ProcessLinks indicates an expected call of ProcessLinks.

func (*MockProcessorMockRecorder) ProcessNodes 

func (mr *MockProcessorMockRecorder) ProcessNodes(arg0 any) *gomock.Call

ProcessNodes indicates an expected call of ProcessNodes.

func (*MockProcessorMockRecorder) ProcessPrefixes 

func (mr *MockProcessorMockRecorder) ProcessPrefixes(arg0 any) *gomock.Call

ProcessPrefixes indicates an expected call of ProcessPrefixes.

func (*MockProcessorMockRecorder) ProcessSids 

func (mr *MockProcessorMockRecorder) ProcessSids(arg0 any) *gomock.Call

ProcessSids indicates an expected call of ProcessSids.

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 MockSidProcessor 

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

MockSidProcessor is a mock of SidProcessor interface.

func NewMockSidProcessor 

func NewMockSidProcessor(ctrl *gomock.Controller) *MockSidProcessor

NewMockSidProcessor creates a new mock instance.

func (*MockSidProcessor) EXPECT 

func (m *MockSidProcessor) EXPECT() *MockSidProcessorMockRecorder

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

func (*MockSidProcessor) ProcessSids 

func (m *MockSidProcessor) ProcessSids(arg0 []domain.Sid)

ProcessSids mocks base method.

type MockSidProcessorMockRecorder 

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

MockSidProcessorMockRecorder is the mock recorder for MockSidProcessor.

func (*MockSidProcessorMockRecorder) ProcessSids 

func (mr *MockSidProcessorMockRecorder) ProcessSids(arg0 any) *gomock.Call

ProcessSids indicates an expected call of ProcessSids.

type NetworkProcessor 

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

func NewNetworkProcessor 

func NewNetworkProcessor(graph graph.Graph, cache cache.Cache, eventChan chan domain.NetworkEvent, updateChan chan struct{}, eventOptions EventOptions) *NetworkProcessor
func (processor *NetworkProcessor) ProcessLinks(links []domain.Link) error

func (*NetworkProcessor) ProcessNodes 

func (processor *NetworkProcessor) ProcessNodes(nodes []domain.Node)

func (*NetworkProcessor) ProcessPrefixes 

func (processor *NetworkProcessor) ProcessPrefixes(prefixes []domain.Prefix)

func (*NetworkProcessor) ProcessSids 

func (processor *NetworkProcessor) ProcessSids(sids []domain.Sid)

func (*NetworkProcessor) Start 

func (processor *NetworkProcessor) Start()

func (*NetworkProcessor) Stop 

func (processor *NetworkProcessor) Stop()

type NodeEventProcessor 

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

func NewNodeEventProcessor 

func NewNodeEventProcessor(graph graph.Graph, cache cache.Cache) *NodeEventProcessor

func (*NodeEventProcessor) HandleEvent 

func (processor *NodeEventProcessor) HandleEvent(event domain.NetworkEvent) bool

func (*NodeEventProcessor) ProcessNodes 

func (processor *NodeEventProcessor) ProcessNodes(nodes []domain.Node)

type NodeProcessor 

type NodeProcessor interface {
	ProcessNodes([]domain.Node)
}

type PrefixEventProcessor 

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

func NewPrefixEventProcessor 

func NewPrefixEventProcessor(graph graph.Graph, cache cache.Cache) *PrefixEventProcessor

func (*PrefixEventProcessor) HandleEvent 

func (processor *PrefixEventProcessor) HandleEvent(event domain.NetworkEvent) bool

func (*PrefixEventProcessor) ProcessPrefixes 

func (processor *PrefixEventProcessor) ProcessPrefixes(prefixes []domain.Prefix)

type PrefixProcessor 

type PrefixProcessor interface {
	ProcessPrefixes([]domain.Prefix)
}

type Processor 

type Processor interface {
	ProcessNodes([]domain.Node)
	ProcessLinks([]domain.Link) error
	ProcessPrefixes([]domain.Prefix)
	ProcessSids([]domain.Sid)
	Start()
	Stop()
}

type SidEventProcessor 

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

func NewSidEventProcessor 

func NewSidEventProcessor(graph graph.Graph, cache cache.Cache) *SidEventProcessor

func (*SidEventProcessor) HandleEvent 

func (processor *SidEventProcessor) HandleEvent(event domain.NetworkEvent) bool

func (*SidEventProcessor) ProcessSids 

func (processor *SidEventProcessor) ProcessSids(sids []domain.Sid)

type SidProcessor 

type SidProcessor interface {
	ProcessSids([]domain.Sid)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.