tide

Documentation

Index

• Variables
• type NodeInfo
• type NodePoolWrapper
  • func NewNodePoolWrapper(nodePool *apis.TideNodePool) NodePoolWrapper
• type NodeUsage
• type OnlinePodChecker
• type Tide
  • func NewTide(ctx context.Context, controlCtx *katalystbase.GenericContext, ...) (*Tide, error)
  • func (t *Tide) GetNodePoolInfo(nodes []*corev1.Node, onlinePodChecker OnlinePodChecker) (simulator.ClusterSnapshot, []*corev1.Pod, error)
  • func (t *Tide) Reconcile(ctx context.Context, tideNodePool *apis.TideNodePool) error
  • func (t *Tide) Run()
  • func (t *Tide) RunOnce(ctx context.Context, onlinePodChecker OnlinePodChecker, ...) error
  • func (t *Tide) UpdateStatusByNodes(ctx context.Context, tideNodePool *apis.TideNodePool, ...) error

Variables

var (
	AnnotationNodePoolUpdate = labelPrefix + "/" + "update"

	LabelPodTypeKey     = labelPrefix + "/" + "pod-type"
	LabelOnlinePodValue = "online"

	LabelNodePoolKey = labelPrefix + "/" + "node-pool"

	LabelNodeTypeKey      = labelPrefix + "/" + "node-type"
	LabelOnlineNodeValue  = "online"
	LabelOfflineNodeValue = "offline"
	LabelTideNode         = labelPrefix + "/" + "tide"
	LabelReserveNode      = labelPrefix + "/" + "reserve"

	TaintEvictOnlinePodKey  = labelPrefix + "/" + "online-not-used"
	TaintEvictOfflinePodKey = labelPrefix + "/" + "offline-not-used"

	// NodePoolFinalizer is the finalizer name for LogRule operator
	NodePoolFinalizer = labelPrefix + "/" + "finalizer"
)

Types

type NodeInfo

type NodeInfo struct {
	NodeUsage
}

type NodePoolWrapper

type NodePoolWrapper interface {
	GetOnlineReserveNodeSelector() labels.Selector
	GetOfflineReserveNodeSelector() labels.Selector
	GetOnlineTideNodeSelector() labels.Selector
	GetOfflineTideNodeSelector() labels.Selector
	GetTideNodeSelector() labels.Selector
	GetNodePoolSelector() *labels.Requirement

	SetNodeToOnlineReserve(node *corev1.Node)
	SetNodeToOfflineReserve(node *corev1.Node)
	SetNodeToTide(node *corev1.Node)
	SetNodeToTideOnline(node *corev1.Node)

	GetEvictOnlinePodTaint() apis.TaintOption
	GetEvictOfflinePodTaint() apis.TaintOption
	GetOnlineLabel() apis.LabelOption
	GetOfflineLabel() apis.LabelOption
	GetTideLabel() apis.LabelOption
	GetNodeSelector() map[string]string

	metav1.Object
}

func NewNodePoolWrapper

func NewNodePoolWrapper(nodePool *apis.TideNodePool) NodePoolWrapper

type NodeUsage

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

NodeUsage stores a node's info, pods on it, thresholds and its resource usage

type OnlinePodChecker

type OnlinePodChecker func(pod *corev1.Pod) bool

type Tide

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

func NewTide

func NewTide(ctx context.Context,
	controlCtx *katalystbase.GenericContext,
	_ *generic.GenericConfiguration,
	_ *controller.GenericControllerConfiguration,
) (*Tide, error)

func (*Tide) GetNodePoolInfo

func (t *Tide) GetNodePoolInfo(nodes []*corev1.Node, onlinePodChecker OnlinePodChecker) (simulator.ClusterSnapshot, []*corev1.Pod, error)

func (*Tide) Reconcile

func (t *Tide) Reconcile(ctx context.Context, tideNodePool *apis.TideNodePool) error

func (*Tide) Run

func (t *Tide) Run()

func (*Tide) RunOnce

func (t *Tide) RunOnce(ctx context.Context, onlinePodChecker OnlinePodChecker, tideNodePool NodePoolWrapper) error

func (*Tide) UpdateStatusByNodes

func (t *Tide) UpdateStatusByNodes(ctx context.Context, tideNodePool *apis.TideNodePool, reserveOnlineNodes, reserveOfflineNodes, tideNodes []*corev1.Node) error