flowconfig

Documentation

Index

• func GetDCFClient() flowapi.FlowServiceClient
• func NewDCFError(msg string) error
• func NewRteFlowError(msg string) error
• type DCFError
  • func (re *DCFError) Error() string
• type FlowConfigNodeAgentDeploymentReconciler
  • func (r *FlowConfigNodeAgentDeploymentReconciler) CreatePod(templatePod *corev1.Pod, instance *flowconfigv1.FlowConfigNodeAgentDeployment, ...) error
  • func (r *FlowConfigNodeAgentDeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *FlowConfigNodeAgentDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NodeFlowConfigReconciler
  • func GetNodeFlowConfigReconciler(k8sClient client.Client, logger logr.Logger, scheme *runtime.Scheme, ...) *NodeFlowConfigReconciler
  • func (r *NodeFlowConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeFlowConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RteFlowError
  • func (re *RteFlowError) Error() string

Functions

func GetDCFClient

func GetDCFClient() flowapi.FlowServiceClient

GetDCFClient return an instance of DCF FlowServiceClient

func NewDCFError

func NewDCFError(msg string) error

NewDCFError returns a new instance of DCFError

func NewRteFlowError

func NewRteFlowError(msg string) error

NewRteFlowError retuns a new instance of RteFlowError

Types

type DCFError

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

DCFError is custom error struct for DCF gRPC related errors

func (*DCFError) Error

func (re *DCFError) Error() string

type FlowConfigNodeAgentDeploymentReconciler

type FlowConfigNodeAgentDeploymentReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

FlowConfigNodeAgentDeploymentReconciler reconciles a FlowConfigNodeAgentDeployment object

func (*FlowConfigNodeAgentDeploymentReconciler) CreatePod

func (r *FlowConfigNodeAgentDeploymentReconciler) CreatePod(templatePod *corev1.Pod, instance *flowconfigv1.FlowConfigNodeAgentDeployment, node corev1.Node, vfPoolName corev1.ResourceName, uftContainerIndex int) error

func (*FlowConfigNodeAgentDeploymentReconciler) Reconcile

func (r *FlowConfigNodeAgentDeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*FlowConfigNodeAgentDeploymentReconciler) SetupWithManager

func (r *FlowConfigNodeAgentDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type NodeFlowConfigReconciler

type NodeFlowConfigReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

NodeFlowConfigReconciler reconciles a NodeFlowConfig object

func GetNodeFlowConfigReconciler

func GetNodeFlowConfigReconciler(k8sClient client.Client, logger logr.Logger, scheme *runtime.Scheme, fs *flowsets.FlowSets,
	fc flowapi.FlowServiceClient, nodeName string) *NodeFlowConfigReconciler

GetNodeFlowConfigReconciler returns an instance of NodeFlowConfigReconciler

func (*NodeFlowConfigReconciler) Reconcile

func (r *NodeFlowConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reads that state of the cluster for a NodeFlowConfig object and makes changes based on the state read and what is in the NodeFlowConfig.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

func (*NodeFlowConfigReconciler) SetupWithManager

func (r *NodeFlowConfigReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type RteFlowError

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

RteFlowError is custom error struct for Rte flow related errors

func (*RteFlowError) Error

func (re *RteFlowError) Error() string