rotatecerts

Documentation

Index

• func PauseClusterAutoscaler(client internal.KubeClient) (func() error, error)
• func RotateServiceAccountTokens(client internal.KubeClient) error
• func WaitForAllInNamespaceReady(client internal.KubeClient, namespace string, interval, timeout time.Duration, ...) error
• func WaitForNodesReady(client internal.KubeClient, requiredNodes []string, ...) error
• func WaitForReady(client internal.KubeClient, namespace string, pods []string, ...) error
• func WaitForVMsRunning(client internal.ARMClient, resourceGroupName string, requiredVMs []string, ...) error
• type ARMClientWrapper
  • func NewARMClientWrapper(client armhelpers.AKSEngineClient, interval, timeout time.Duration) *ARMClientWrapper
  • func (arm *ARMClientWrapper) GetVirtualMachinePowerState(resourceGroup, vmName string) (string, error)
  • func (arm *ARMClientWrapper) RestartVirtualMachine(resourceGroup, vmName string) error

Functions

func PauseClusterAutoscaler

func PauseClusterAutoscaler(client internal.KubeClient) (func() error, error)

PauseClusterAutoscaler scales to zero the replica count of the cluster autoscaler deployment and returns a function that scales back to the original replica count.

It NOPs if the original replica count is zero.

func RotateServiceAccountTokens

func RotateServiceAccountTokens(client internal.KubeClient) error

RotateServiceAccountTokens deletes all service account tokens and triggers a forced rollout of all daemonsets and deployments.

Service account tokens are signed by the cluster CA, deleting them after the CA is rotated ensures that KCM will regenerate tokens signed by the new CA.

func WaitForAllInNamespaceReady

func WaitForAllInNamespaceReady(client internal.KubeClient, namespace string, interval, timeout time.Duration, nodes map[string]*ssh.RemoteHost) error

WaitForAllInNamespaceReady returns true if all containers in a given namespace reached the Ready state

func WaitForNodesReady

func WaitForNodesReady(client internal.KubeClient, requiredNodes []string, interval, timeout time.Duration) error

WaitForNodesReady returns true if all requiredNodes reached the Ready state

func WaitForReady

func WaitForReady(client internal.KubeClient, namespace string, pods []string, interval, timeout time.Duration, nodes map[string]*ssh.RemoteHost) error

WaitForReady returns true if all containers in a given pod list reached the Ready state

func WaitForVMsRunning

func WaitForVMsRunning(client internal.ARMClient, resourceGroupName string, requiredVMs []string, interval, timeout time.Duration) error

WaitForVMsRunning checks that all requiredVMs are running

Types

type ARMClientWrapper

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

ARMClientWrapper is an ARM client with simple retry logic

func NewARMClientWrapper

func NewARMClientWrapper(client armhelpers.AKSEngineClient, interval, timeout time.Duration) *ARMClientWrapper

NewARMClientWrapper returns an ARM client with simple retry logic

func (*ARMClientWrapper) GetVirtualMachinePowerState

func (arm *ARMClientWrapper) GetVirtualMachinePowerState(resourceGroup, vmName string) (string, error)

GetVirtualMachinePowerState restarts the specified virtual machine.

func (*ARMClientWrapper) RestartVirtualMachine

func (arm *ARMClientWrapper) RestartVirtualMachine(resourceGroup, vmName string) error

RestartVirtualMachine returns the virtual machine's Power state