pipeline

Feb 21, 2023

Changes in this version

+ type Manager struct

+ func NewManager(topo topo.Store, conns p4rtclient.ConnManager, ...) *Manager

+ func (m *Manager) Start() error

Aug 18, 2022

Changes in this version

+ func ToConfigAction(action topoapi.P4PipelineInfo_ConfigurationAction) p4rtapi.ConfigurationAction

+ func ToSetPipelineConfigReqAction(configAction p4rtapi.ConfigurationAction) p4api.SetForwardingPipelineConfigRequest_Action

Aug 17, 2022

Changes in this version

+ func NewController(topo topo.Store, pipelineConfigs pipelineConfigStore.Store, ...) *controller.Controller

+ type Reconciler struct

+ func (r *Reconciler) Reconcile(id controller.ID) (controller.Result, error)

+ type TopoWatcher struct

+ func (w *TopoWatcher) Start(ch chan<- controller.ID) error

+ func (w *TopoWatcher) Stop()

+ type Watcher struct

+ func (w *Watcher) Start(ch chan<- controller.ID) error

+ func (w *Watcher) Stop()