op

Documentation

Index

• Constants
• func APIServerStopOp(nodes []*cke.Node) cke.Operator
• func ControllerManagerStopOp(nodes []*cke.Node) cke.Operator
• func EtcdPKIPath(p string) string
• func EtcdStopOp(nodes []*cke.Node) cke.Operator
• func EtcdVolumeName(e cke.EtcdParams) string
• func GetEtcdClusterStatus(ctx context.Context, inf cke.Infrastructure, nodes []*cke.Node) (cke.EtcdClusterStatus, error)
• func GetKubernetesClusterStatus(ctx context.Context, inf cke.Infrastructure, n *cke.Node, cluster *cke.Cluster) (cke.KubernetesClusterStatus, error)
• func GetNodeStatus(ctx context.Context, inf cke.Infrastructure, node *cke.Node, ...) (*cke.NodeStatus, error)
• func K8sPKIPath(p string) string
• func KubeEtcdEndpointsCreateOp(apiserver *cke.Node, cpNodes []*cke.Node) cke.Operator
• func KubeEtcdEndpointsUpdateOp(apiserver *cke.Node, cpNodes []*cke.Node) cke.Operator
• func KubeNodeRemoveOp(apiserver *cke.Node, nodes []*corev1.Node) cke.Operator
• func KubeNodeUpdateOp(apiserver *cke.Node, nodes []*corev1.Node) cke.Operator
• func KubeRBACRoleInstallOp(apiserver *cke.Node, roleExists bool) cke.Operator
• func KubeWaitOp(apiserver *cke.Node) cke.Operator
• func SchedulerStopOp(nodes []*cke.Node) cke.Operator

Constants

const (
	// EtcdContainerName is container name of etcd
	EtcdContainerName = "etcd"
	// KubeAPIServerContainerName is name of kube-apiserver
	KubeAPIServerContainerName = "kube-apiserver"
	// KubeControllerManagerContainerName is name of kube-controller-manager
	KubeControllerManagerContainerName = "kube-controller-manager"
	// KubeProxyContainerName is container name of kube-proxy
	KubeProxyContainerName = "kube-proxy"
	// KubeSchedulerContainerName is container name of kube-scheduler
	KubeSchedulerContainerName = "kube-scheduler"
	// KubeletContainerName is container name of kubelet
	KubeletContainerName = "kubelet"
	// RiversContainerName is container name of rivers
	RiversContainerName = "rivers"

	// ClusterDNSRBACRoleName is role name of cluster DNS
	ClusterDNSRBACRoleName = "system:cluster-dns"
	// ClusterDNSAppName is app name of cluster DNS
	ClusterDNSAppName = "cluster-dns"
	// NodeDNSAppName is app name of node-dns
	NodeDNSAppName = "node-dns"

	// DefaultEtcdVolumeName is etcd default volume name
	DefaultEtcdVolumeName = "etcd-cke"

	// TimeoutDuration is default timeout duration
	TimeoutDuration = 5 * time.Second

	// CKELabelAppName is application name
	CKELabelAppName = "cke.cybozu.com/appname"
	// EtcdBackupAppName is application name for etcdbackup
	EtcdBackupAppName = "etcdbackup"
)

Functions

func APIServerStopOp

func APIServerStopOp(nodes []*cke.Node) cke.Operator

APIServerStopOp returns an Operator to stop API server

func ControllerManagerStopOp

func ControllerManagerStopOp(nodes []*cke.Node) cke.Operator

ControllerManagerStopOp returns an Operator to stop kube-controller-manager

func EtcdPKIPath

func EtcdPKIPath(p string) string

EtcdPKIPath returns a certificate file path for k8s.

func EtcdStopOp

func EtcdStopOp(nodes []*cke.Node) cke.Operator

EtcdStopOp returns an Operator to stop etcd

func EtcdVolumeName

func EtcdVolumeName(e cke.EtcdParams) string

EtcdVolumeName returns etcd volume name

func GetEtcdClusterStatus

func GetEtcdClusterStatus(ctx context.Context, inf cke.Infrastructure, nodes []*cke.Node) (cke.EtcdClusterStatus, error)

GetEtcdClusterStatus returns EtcdClusterStatus

func GetKubernetesClusterStatus

func GetKubernetesClusterStatus(ctx context.Context, inf cke.Infrastructure, n *cke.Node, cluster *cke.Cluster) (cke.KubernetesClusterStatus, error)

GetKubernetesClusterStatus returns KubernetesClusterStatus

func GetNodeStatus

func GetNodeStatus(ctx context.Context, inf cke.Infrastructure, node *cke.Node, cluster *cke.Cluster) (*cke.NodeStatus, error)

GetNodeStatus returns NodeStatus.

func K8sPKIPath

func K8sPKIPath(p string) string

K8sPKIPath returns a certificate file path for k8s.

func KubeEtcdEndpointsCreateOp

func KubeEtcdEndpointsCreateOp(apiserver *cke.Node, cpNodes []*cke.Node) cke.Operator

KubeEtcdEndpointsCreateOp returns an Operator to create Endpoints resource for etcd.

func KubeEtcdEndpointsUpdateOp

func KubeEtcdEndpointsUpdateOp(apiserver *cke.Node, cpNodes []*cke.Node) cke.Operator

KubeEtcdEndpointsUpdateOp returns an Operator to update Endpoints resource for etcd.

func KubeNodeRemoveOp

func KubeNodeRemoveOp(apiserver *cke.Node, nodes []*corev1.Node) cke.Operator

KubeNodeRemoveOp removes k8s Node resources.

func KubeNodeUpdateOp

func KubeNodeUpdateOp(apiserver *cke.Node, nodes []*corev1.Node) cke.Operator

KubeNodeUpdateOp updates k8s Node resources.

func KubeRBACRoleInstallOp

func KubeRBACRoleInstallOp(apiserver *cke.Node, roleExists bool) cke.Operator

KubeRBACRoleInstallOp returns an Operator to install ClusterRole and binding for RBAC.

func KubeWaitOp

func KubeWaitOp(apiserver *cke.Node) cke.Operator

KubeWaitOp returns an Operator to wait for Kubernetes resources gets initialized

func SchedulerStopOp

func SchedulerStopOp(nodes []*cke.Node) cke.Operator

SchedulerStopOp returns an Operator to stop kube-scheduler