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 WaitForVMSSIntancesRunning(client internal.ARMClient, resourceGroupName, vmssName string, count int, ...) 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) GetVirtualMachineScaleSetInstancePowerState(resourceGroup, vmssName, instanceID string) (string, error)
  • func (arm *ARMClientWrapper) RestartVirtualMachine(resourceGroup, vmName string) error
  • func (arm *ARMClientWrapper) RestartVirtualMachineScaleSets(resourceGroup, vmssName 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 WaitForVMSSIntancesRunning

func WaitForVMSSIntancesRunning(client internal.ARMClient, resourceGroupName, vmssName string, count int, interval, timeout time.Duration) error

WaitForVMSSIntancesRunning checks that all required scale set VMs are running

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) GetVirtualMachineScaleSetInstancePowerState

func (arm *ARMClientWrapper) GetVirtualMachineScaleSetInstancePowerState(resourceGroup, vmssName, instanceID string) (string, error)

GetVirtualMachineScaleSetInstancePowerState restarts the specified scale set virtual machine instance

func (*ARMClientWrapper) RestartVirtualMachine

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

RestartVirtualMachine returns the virtual machine's Power state

func (*ARMClientWrapper) RestartVirtualMachineScaleSets

func (arm *ARMClientWrapper) RestartVirtualMachineScaleSets(resourceGroup, vmssName string) error

RestartVirtualMachineScaleSets returns the scale set virtual machine instance's Power state