Documentation ¶
Index ¶
- type Deps
- type SFCProcessor
- func (sp *SFCProcessor) AfterInit() error
- func (sp *SFCProcessor) Close() error
- func (sp *SFCProcessor) Init() error
- func (sp *SFCProcessor) RegisterRenderer(renderer renderer.SFCRendererAPI) error
- func (sp *SFCProcessor) Resync(kubeStateData controller.KubeStateData) error
- func (sp *SFCProcessor) Update(event controller.Event) error
- type SFCProcessorAPI
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Deps ¶
type Deps struct { Log logging.Logger ServiceLabel servicelabel.ReaderAPI ContivConf contivconf.API NodeSync nodesync.API PodManager podmanager.API IPAM ipam.API IPNet ipnet.API }
Deps lists dependencies of SFC Processor.
type SFCProcessor ¶
type SFCProcessor struct { Deps // contains filtered or unexported fields }
SFCProcessor implements SFCProcessorAPI.
func (*SFCProcessor) AfterInit ¶
func (sp *SFCProcessor) AfterInit() error
AfterInit does nothing for the SFC processor.
func (*SFCProcessor) Close ¶
func (sp *SFCProcessor) Close() error
Close does nothing for the SFC processor.
func (*SFCProcessor) RegisterRenderer ¶
func (sp *SFCProcessor) RegisterRenderer(renderer renderer.SFCRendererAPI) error
RegisterRenderer registers a new SFC renderer. The renderer will be receiving updates for all SFCs on the cluster.
func (*SFCProcessor) Resync ¶
func (sp *SFCProcessor) Resync(kubeStateData controller.KubeStateData) error
Resync processes a resync event. The cache content is fully replaced and all registered renderers receive a full snapshot of Contiv SFCs at the present state to be (re)installed.
func (*SFCProcessor) Update ¶
func (sp *SFCProcessor) Update(event controller.Event) error
Update is called for:
- KubeStateChange for SFC-related an pod-related data
type SFCProcessorAPI ¶
type SFCProcessorAPI interface { // Update processes a datasync change event associated with the state data // of K8s pods and SFC and custom network CRDs. // The data change is stored into the cache and all registered renderers // are notified about any changes related to service function chains // that need to be reflected in the underlying network stack(s). Update(dataChngEv datasync.ChangeEvent) error // Resync processes a datasync resync event associated with the state data // of K8s pods and SFC and custom network CRDs. // The cache content is fully replaced and all registered renderers // receive a full snapshot of service function chains at the present // state to be (re)installed. Resync(resyncEv datasync.ResyncEvent) error // RegisterRenderer registers a new service function chain renderer. // The renderer will be receiving updates for all SFCs on the cluster. RegisterRenderer(renderer renderer.SFCRendererAPI) error }
SFCProcessorAPI defines the API of the Service Function Chain Processor.
Click to show internal directories.
Click to hide internal directories.