Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller is responsible for setting up Openflow entries and injecting traceflow packet into the switch for traceflow request.
func NewTraceflowController ¶
func NewTraceflowController( kubeClient clientset.Interface, informerFactory informers.SharedInformerFactory, traceflowClient clientsetversioned.Interface, traceflowInformer opsinformers.TraceflowInformer, client openflow.Client, ovsBridgeClient ovsconfig.OVSBridgeClient, interfaceStore interfacestore.InterfaceStore, networkConfig *config.NetworkConfig, nodeConfig *config.NodeConfig, serviceCIDR *net.IPNet) *Controller
NewTraceflowController instantiates a new Controller object which will process Traceflow events.
func (*Controller) GetRunningTraceflowCRD ¶
func (c *Controller) GetRunningTraceflowCRD(tag uint8) (*opsv1alpha1.Traceflow, error)
getTraceflowCRD gets traceflow CRD by data plane tag.
func (*Controller) HandlePacketIn ¶
func (c *Controller) HandlePacketIn(pktIn *ofctrl.PacketIn) error
func (*Controller) Run ¶
func (c *Controller) Run(stopCh <-chan struct{})
Run will create defaultWorkers workers (go routines) which will process the Traceflow events from the workqueue.
Click to show internal directories.
Click to hide internal directories.