op

package
v1.14.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 11, 2019 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
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"
	// EtcdRiversContainerName is container name of etcd-rivers
	EtcdRiversContainerName = "etcd-rivers"

	// RiversUpstreamPort is upstream port of rivers container
	RiversUpstreamPort = 6443
	// RiversListenPort is listen port of rivers container
	RiversListenPort = 16443
	// EtcdRiversUpstreamPort is upstream port of etcd-rivers container
	EtcdRiversUpstreamPort = 2379
	// EtcdRiversListenPort is listen port of etcd-rivers container
	EtcdRiversListenPort = 12379

	// 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"

	// PolicyConfigPath is a path for scheduler extender policy
	PolicyConfigPath = "/etc/kubernetes/scheduler/policy.cfg"
	// SchedulerConfigPath is a path for scheduler extender config
	SchedulerConfigPath = "/etc/kubernetes/scheduler/config.yml"
)

Variables

This section is empty.

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 EtcdRiversStopOp added in v1.14.1 

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

EtcdRiversStopOp returns an Operator to stop etcd-rivers

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 GuessMemberName added in v1.14.1 

func GuessMemberName(m *etcdserverpb.Member) (string, error)

GuessMemberName returns etcd member's ip address

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 KubeWaitOp 

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

KubeWaitOp returns an Operator to wait for Kubernetes resources gets initialized

func ResourceApplyOp added in v1.13.9 

func ResourceApplyOp(apiServer *cke.Node, resource cke.ResourceDefinition) cke.Operator

ResourceApplyOp creates or updates a Kubernetes object.

func RiversBootOp added in v1.14.1 

func RiversBootOp(nodes, upstreams []*cke.Node, params cke.ServiceParams, name string, upstreamPort, listenPort int) cke.Operator

RiversBootOp returns an Operator to bootstrap rivers.

func RiversParams added in v1.14.1 

func RiversParams(upstreams []*cke.Node, upstreamPort, listenPort int) cke.ServiceParams

RiversParams returns parameters for rivers.

func RiversRestartOp added in v1.14.1 

func RiversRestartOp(nodes, upstreams []*cke.Node, params cke.ServiceParams, name string, upstreamPort, listenPort int) cke.Operator

RiversRestartOp returns an Operator to restart rivers.

func SchedulerStopOp 

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

SchedulerStopOp returns an Operator to stop kube-scheduler

Types

This section is empty.

Source Files

View all Source files

Directories

Path Synopsis
Package common provides generic commands shared by many Operators.
 Package common provides generic commands shared by many Operators.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.