kri

type NodeProvider interface {
	// Ping checks if the node is still active.
	// This is intended to be lightweight as it will be called periodically as a
	// heartbeat to keep the node marked as ready in Kubernetes.
	Ping(context.Context) error

	// ConfigureNode enables a provider to configure the node object that
	// will be used for Kubernetes.
	ConfigureNode(context.Context, string) *v1.Node

	// RefreshNodeStatus return if the node status changes
	RefreshNodeStatus(ctx context.Context, nodeStatus *v1.NodeStatus) bool

	// SetStatusUpdateCallback is used to asynchronously monitor the node.
	// The passed in callback should be called any time there is a change to the
	// node's status.
	// This will generally trigger a call to the Kubernetes API server to update
	// the status.
	//
	// SetStatusUpdateCallback should not block callers.
	SetStatusUpdateCallback(ctx context.Context, cb func(*v1.Node))
}

type PodLifecycleHandler interface {
	SyncPod(ctx context.Context, pod *v1.Pod, podStatus *pkgcontainer.PodStatus, reasonCache *ReasonCache) error

	KillPod(ctx context.Context, pod *v1.Pod, runningPod pkgcontainer.Pod, gracePeriodOverride *int64) error

	// DeletePod Pod object in master is gone, so just delete pod in provider and no need to call NotifyPods
	// after deletion.
	DeletePod(ctx context.Context, pod *v1.Pod) error

	CleanupPods(ctx context.Context, pods []*v1.Pod, runningPods []*pkgcontainer.Pod, possiblyRunningPods map[types.UID]sets.Empty) error

	RefreshPodStatus(pod *v1.Pod, podStatus *v1.PodStatus)

	GetPodStatus(ctx context.Context, pod *v1.Pod) (*pkgcontainer.PodStatus, error)

	GetPods(ctx context.Context, all bool) ([]*pkgcontainer.Pod, error)

	// Start sync loop
	Start(ctx context.Context) error

	// Stop sync loop
	Stop()
}

type PodProvider interface {
	PodLifecycleHandler
}

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

type ReasonItem struct {
	Err     error
	Message string
}