utils

Documentation

Index

• func AuthMethodFromPrivateKey(key string) (ssh.AuthMethod, error)
• func AuthMethodFromPrivateKeyFile(file string) (ssh.AuthMethod, error)
• func DirExistAndReadable(name string) bool
• func FileExistAndReadable(name string) bool
• func FileExists(name string) bool
• func LocalStoragePodFilter(p apiv1.Pod) (bool, error)
• func MaxInt(x, y int) int
• func MaxInt64(x, y int64) int64
• func MergeKubernetesLabel(labels ...types.KubernetesLabel) types.KubernetesLabel
• func MinInt(x, y int) int
• func MinInt64(x, y int64) int64
• func MirrorPodFilter(p apiv1.Pod) (bool, error)
• func NewDaemonSetPodFilter(ctx context.Context, client kubernetes.Interface) types.PodFilterFunc
• func NewPodFilters(filters ...types.PodFilterFunc) types.PodFilterFunc
• func NewRequestContext(requestTimeout time.Duration) *context.Context
• func NewStatefulSetPodFilter(ctx context.Context, client kubernetes.Interface) types.PodFilterFunc
• func NodeFromJSON(s string) (*apiv1.Node, error)
• func PollImmediate(interval, timeout time.Duration, condition wait.ConditionFunc) error
• func Scp(connect *types.AutoScalerServerSSH, host, src, dst string) error
• func Shell(args ...string) error
• func ShouldTestFeature(name string) bool
• func Sudo(connect *types.AutoScalerServerSSH, host string, ...) (string, error)
• func ToJSON(v interface{}) string
• func ToYAML(v interface{}) string
• func UnprotectedPodFilter(annotations ...string) types.PodFilterFunc
• func UnreplicatedPodFilter(p apiv1.Pod) (bool, error)
• func Values[M ~map[K]V, K comparable, V any](m M) []V

Functions

func AuthMethodFromPrivateKey

func AuthMethodFromPrivateKey(key string) (ssh.AuthMethod, error)

AuthMethodFromPrivateKey read public key

func AuthMethodFromPrivateKeyFile

func AuthMethodFromPrivateKeyFile(file string) (ssh.AuthMethod, error)

AuthMethodFromPrivateKeyFile read public key

func DirExistAndReadable

func DirExistAndReadable(name string) bool

func FileExistAndReadable

func FileExistAndReadable(name string) bool

func FileExists

func FileExists(name string) bool

FileExists Check if FileExists

func LocalStoragePodFilter

func LocalStoragePodFilter(p apiv1.Pod) (bool, error)

LocalStoragePodFilter returns true if the supplied pod does not have local storage, i.e. does not use any 'empty dir' volumes.

func MaxInt

func MaxInt(x, y int) int

MaxInt max(a,b)

func MaxInt64

func MaxInt64(x, y int64) int64

MaxInt64 max(a,b)

func MergeKubernetesLabel

func MergeKubernetesLabel(labels ...types.KubernetesLabel) types.KubernetesLabel

MergeKubernetesLabel merge kubernetes map in one

func MinInt

func MinInt(x, y int) int

MinInt min(a,b)

func MinInt64

func MinInt64(x, y int64) int64

MinInt64 min(a,b)

func MirrorPodFilter

func MirrorPodFilter(p apiv1.Pod) (bool, error)

MirrorPodFilter returns true if the supplied pod is not a mirror pod, i.e. a pod created by a manifest on the node rather than the API server.

func NewDaemonSetPodFilter

func NewDaemonSetPodFilter(ctx context.Context, client kubernetes.Interface) types.PodFilterFunc

NewDaemonSetPodFilter returns a FilterFunc that returns true if the supplied pod is not managed by an extant DaemonSet.

func NewPodFilters

func NewPodFilters(filters ...types.PodFilterFunc) types.PodFilterFunc

NewPodFilters returns a FilterFunc that returns true if all of the supplied FilterFuncs return true.

func NewRequestContext

func NewRequestContext(requestTimeout time.Duration) *context.Context

func NewStatefulSetPodFilter

func NewStatefulSetPodFilter(ctx context.Context, client kubernetes.Interface) types.PodFilterFunc

NewStatefulSetPodFilter returns a FilterFunc that returns true if the supplied pod is not managed by an extant StatefulSet.

func NodeFromJSON

func NodeFromJSON(s string) (*apiv1.Node, error)

NodeFromJSON deserialize a string to apiv1.Node

func PollImmediate

func PollImmediate(interval, timeout time.Duration, condition wait.ConditionFunc) error

func Scp

func Scp(connect *types.AutoScalerServerSSH, host, src, dst string) error

Scp copy file

func Shell

func Shell(args ...string) error

Shell execute local command ignore output

func ShouldTestFeature

func ShouldTestFeature(name string) bool

ShouldTestFeature check if test must be done

func Sudo

func Sudo(connect *types.AutoScalerServerSSH, host string, timeoutInSeconds time.Duration, command ...string) (string, error)

Sudo exec ssh command as sudo

func ToJSON

func ToJSON(v interface{}) string

ToJSON serialize interface to json

func ToYAML

func ToYAML(v interface{}) string

ToYAML serialize interface to yaml

func UnprotectedPodFilter

func UnprotectedPodFilter(annotations ...string) types.PodFilterFunc

UnprotectedPodFilter returns a FilterFunc that returns true if the supplied pod does not have any of the user-specified annotations for protection from eviction

func UnreplicatedPodFilter

func UnreplicatedPodFilter(p apiv1.Pod) (bool, error)

UnreplicatedPodFilter returns true if the pod is replicated, i.e. is managed by a controller (deployment, daemonset, statefulset, etc) of some sort.

func Values

func Values[M ~map[K]V, K comparable, V any](m M) []V

Values returns the values of the map m. The values will be in an indeterminate order.