schedcache

Documentation

Index

• Constants
• func GetUpdaterFingerprintStatus(env *Env, podNamespace, podName, cntName string) (podfingerprint.Status, error)
• func HasSynced(env *Env, nodeNames []string) (bool, map[string]sets.Set[string], error)
• func ReplicaHasSynced(env *Env, pod *corev1.Pod, nodeNames []string) (map[string]sets.Set[string], error)
• func ReplicaHasSyncedForNode(env *Env, pod *corev1.Pod, nodeName string) (bool, sets.Set[string], error)
• type Env

Constants

const (
	TracingDirectory = "/run/pfpstatus"
)

Functions

func GetUpdaterFingerprintStatus

func GetUpdaterFingerprintStatus(env *Env, podNamespace, podName, cntName string) (podfingerprint.Status, error)

func HasSynced

func HasSynced(env *Env, nodeNames []string) (bool, map[string]sets.Set[string], error)

func ReplicaHasSynced

func ReplicaHasSynced(env *Env, pod *corev1.Pod, nodeNames []string) (map[string]sets.Set[string], error)

func ReplicaHasSyncedForNode

func ReplicaHasSyncedForNode(env *Env, pod *corev1.Pod, nodeName string) (bool, sets.Set[string], error)

Types

type Env

type Env struct {
	Ctx    context.Context
	Cli    client.Client
	K8sCli kubernetes.Interface
	Log    logr.Logger
}