Documentation
¶
Index ¶
- func AuthMethodFromPrivateKey(key string) ssh.AuthMethod
- func AuthMethodFromPrivateKeyFile(file string) ssh.AuthMethod
- func FileExists(name string) bool
- func GetNodeProviderID(serverIdentifier string, node *apiv1.Node) string
- func LocalStoragePodFilter(p apiv1.Pod) (bool, error)
- func MaxInt(x, y int) int
- func MaxInt64(x, y int64) int64
- 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 NodeGroupIDFromProviderID(serverIdentifier string, providerID string) (string, error)
- func NodeNameFromProviderID(serverIdentifier string, providerID string) (string, error)
- func Scp(connect *types.AutoScalerServerSSH, host, src, dst string) error
- func Shell(args ...string) error
- func Sudo(connect *types.AutoScalerServerSSH, host string, ...) (string, error)
- func ToJSON(v interface{}) string
- func UnprotectedPodFilter(annotations ...string) types.PodFilterFunc
- func UnreplicatedPodFilter(p apiv1.Pod) (bool, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AuthMethodFromPrivateKey ¶
func AuthMethodFromPrivateKey(key string) ssh.AuthMethod
AuthMethodFromPrivateKey read public key
func AuthMethodFromPrivateKeyFile ¶
func AuthMethodFromPrivateKeyFile(file string) ssh.AuthMethod
AuthMethodFromPrivateKeyFile read public key
func GetNodeProviderID ¶
GetNodeProviderID func
func LocalStoragePodFilter ¶ added in v1.20.5
LocalStoragePodFilter returns true if the supplied pod does not have local storage, i.e. does not use any 'empty dir' volumes.
func MirrorPodFilter ¶ added in v1.20.5
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 ¶ added in v1.20.5
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 ¶ added in v1.20.5
func NewPodFilters(filters ...types.PodFilterFunc) types.PodFilterFunc
NewPodFilters returns a FilterFunc that returns true if all of the supplied FilterFuncs return true.
func NewRequestContext ¶ added in v1.20.15
func NewStatefulSetPodFilter ¶ added in v1.20.5
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 ¶
NodeFromJSON deserialize a string to apiv1.Node
func NodeGroupIDFromProviderID ¶
NodeGroupIDFromProviderID returns group node name from provider
func NodeNameFromProviderID ¶
NodeNameFromProviderID return node name from provider ID
func Sudo ¶
func Sudo(connect *types.AutoScalerServerSSH, host string, timeoutInSeconds time.Duration, command ...string) (string, error)
Sudo exec ssh command as sudo
func UnprotectedPodFilter ¶ added in v1.20.5
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
Types ¶
This section is empty.
Source Files