nodeagent

Documentation

Index

• Variables
• func GetPodSpec(ctx context.Context, kubeClient kubernetes.Interface, namespace string) (*v1.PodSpec, error)
• func IsRunning(ctx context.Context, kubeClient kubernetes.Interface, namespace string) error
• func IsRunningInNode(ctx context.Context, namespace string, nodeName string, ...) error
• type Configs
  • func GetConfigs(ctx context.Context, namespace string, kubeClient kubernetes.Interface) (*Configs, error)
• type LoadConcurrency
• type RuledConfigs

Variables

var (
	ErrDaemonSetNotFound = errors.New("daemonset not found")
)

Functions

func GetPodSpec

func GetPodSpec(ctx context.Context, kubeClient kubernetes.Interface, namespace string) (*v1.PodSpec, error)

func IsRunning

func IsRunning(ctx context.Context, kubeClient kubernetes.Interface, namespace string) error

IsRunning checks if the node agent daemonset is running properly. If not, return the error found

func IsRunningInNode

func IsRunningInNode(ctx context.Context, namespace string, nodeName string, crClient ctrlclient.Client) error

IsRunningInNode checks if the node agent pod is running properly in a specified node. If not, return the error found

Types

type Configs

type Configs struct {
	// LoadConcurrency is the config for data path load concurrency per node.
	LoadConcurrency *LoadConcurrency `json:"loadConcurrency,omitempty"`
}

func GetConfigs

func GetConfigs(ctx context.Context, namespace string, kubeClient kubernetes.Interface) (*Configs, error)

type LoadConcurrency

type LoadConcurrency struct {
	// GlobalConfig specifies the concurrency number to all nodes for which per-node config is not specified
	GlobalConfig int `json:"globalConfig,omitempty"`

	// PerNodeConfig specifies the concurrency number to nodes matched by rules
	PerNodeConfig []RuledConfigs `json:"perNodeConfig,omitempty"`
}

type RuledConfigs

type RuledConfigs struct {
	// NodeSelector specifies the label selector to match nodes
	NodeSelector metav1.LabelSelector `json:"nodeSelector"`

	// Number specifies the number value associated to the matched nodes
	Number int `json:"number"`
}