k8s

Documentation

Index

• func APIServerBootOp(nodes, cps []*cke.Node, serviceSubnet, domain string, ...) cke.Operator
• func APIServerParams(controlPlanes []*cke.Node, advertiseAddress, serviceSubnet string, ...) cke.ServiceParams
• func APIServerRestartOp(nodes, cps []*cke.Node, serviceSubnet string, params cke.APIServerParams) cke.Operator
• func ControllerManagerBootOp(nodes []*cke.Node, cluster string, serviceSubnet string, ...) cke.Operator
• func ControllerManagerParams(clusterName, serviceSubnet string) cke.ServiceParams
• func ControllerManagerRestartOp(nodes []*cke.Node, cluster, serviceSubnet string, params cke.ServiceParams) cke.Operator
• func KubeProxyBootOp(nodes []*cke.Node, cluster string, params cke.ServiceParams) cke.Operator
• func KubeProxyRestartOp(nodes []*cke.Node, cluster string, params cke.ServiceParams) cke.Operator
• func KubeletBootOp(nodes, registeredNodes []*cke.Node, apiServer *cke.Node, ...) cke.Operator
• func KubeletRestartOp(nodes []*cke.Node, cluster, podSubnet string, params cke.KubeletParams) cke.Operator
• func KubeletServiceParams(n *cke.Node, params cke.KubeletParams) cke.ServiceParams
• func ProxyParams(n *cke.Node) cke.ServiceParams
• func RiversBootOp(nodes, upstreams []*cke.Node, params cke.ServiceParams) cke.Operator
• func RiversParams(upstreams []*cke.Node) cke.ServiceParams
• func RiversRestartOp(nodes, upstreams []*cke.Node, params cke.ServiceParams) cke.Operator
• func SchedulerBootOp(nodes []*cke.Node, cluster string, params cke.ServiceParams) cke.Operator
• func SchedulerParams() cke.ServiceParams
• func SchedulerRestartOp(nodes []*cke.Node, cluster string, params cke.ServiceParams) cke.Operator
• type KubeletAuthentication
  • func (a KubeletAuthentication) MarshalJSON() ([]byte, error)
  • func (a KubeletAuthentication) MarshalYAML() (interface{}, error)
• type KubeletConfiguration

Functions

func APIServerBootOp

func APIServerBootOp(nodes, cps []*cke.Node, serviceSubnet, domain string, params cke.APIServerParams) cke.Operator

APIServerBootOp returns an Operator to bootstrap kube-apiserver

func APIServerParams

func APIServerParams(controlPlanes []*cke.Node, advertiseAddress, serviceSubnet string, auditLogEnabeled bool, auditLogPolicy string) cke.ServiceParams

APIServerParams returns parameters for API server.

func APIServerRestartOp

func APIServerRestartOp(nodes, cps []*cke.Node, serviceSubnet string, params cke.APIServerParams) cke.Operator

APIServerRestartOp returns an Operator to restart kube-apiserver

func ControllerManagerBootOp

func ControllerManagerBootOp(nodes []*cke.Node, cluster string, serviceSubnet string, params cke.ServiceParams) cke.Operator

ControllerManagerBootOp returns an Operator to bootstrap kube-controller-manager

func ControllerManagerParams

func ControllerManagerParams(clusterName, serviceSubnet string) cke.ServiceParams

ControllerManagerParams returns parameters for kube-controller-manager.

func ControllerManagerRestartOp

func ControllerManagerRestartOp(nodes []*cke.Node, cluster, serviceSubnet string, params cke.ServiceParams) cke.Operator

ControllerManagerRestartOp returns an Operator to restart kube-controller-manager

func KubeProxyBootOp

func KubeProxyBootOp(nodes []*cke.Node, cluster string, params cke.ServiceParams) cke.Operator

KubeProxyBootOp returns an Operator to boot kube-proxy.

func KubeProxyRestartOp

func KubeProxyRestartOp(nodes []*cke.Node, cluster string, params cke.ServiceParams) cke.Operator

KubeProxyRestartOp returns an Operator to restart kube-proxy.

func KubeletBootOp

func KubeletBootOp(nodes, registeredNodes []*cke.Node, apiServer *cke.Node, cluster, podSubnet string, params cke.KubeletParams) cke.Operator

KubeletBootOp returns an Operator to boot kubelet.

func KubeletRestartOp

func KubeletRestartOp(nodes []*cke.Node, cluster, podSubnet string, params cke.KubeletParams) cke.Operator

KubeletRestartOp returns an Operator to restart kubelet

func KubeletServiceParams

func KubeletServiceParams(n *cke.Node, params cke.KubeletParams) cke.ServiceParams

KubeletServiceParams returns parameters for kubelet.

func ProxyParams

func ProxyParams(n *cke.Node) cke.ServiceParams

ProxyParams returns parameters for kube-proxy.

func RiversBootOp

func RiversBootOp(nodes, upstreams []*cke.Node, params cke.ServiceParams) cke.Operator

RiversBootOp returns an Operator to bootstrap rivers.

func RiversParams

func RiversParams(upstreams []*cke.Node) cke.ServiceParams

RiversParams returns parameters for rivers.

func RiversRestartOp

func RiversRestartOp(nodes, upstreams []*cke.Node, params cke.ServiceParams) cke.Operator

RiversRestartOp returns an Operator to restart rivers.

func SchedulerBootOp

func SchedulerBootOp(nodes []*cke.Node, cluster string, params cke.ServiceParams) cke.Operator

SchedulerBootOp returns an Operator to bootstrap kube-scheduler

func SchedulerParams

func SchedulerParams() cke.ServiceParams

SchedulerParams returns parameters for kube-scheduler.

func SchedulerRestartOp

func SchedulerRestartOp(nodes []*cke.Node, cluster string, params cke.ServiceParams) cke.Operator

SchedulerRestartOp returns an Operator to restart kube-scheduler

Types

type KubeletAuthentication

type KubeletAuthentication struct {
	ClientCAFile string
}

KubeletAuthentication is a simplified version of the struct defined in https://github.com/kubernetes/kubernetes/blob/master/pkg/kubelet/apis/config/types.go

Rationate: kubernetes repository is too large and not intended for client usage.

func (KubeletAuthentication) MarshalJSON

func (a KubeletAuthentication) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler.

func (KubeletAuthentication) MarshalYAML

func (a KubeletAuthentication) MarshalYAML() (interface{}, error)

MarshalYAML implements yaml.Marshaler.

type KubeletConfiguration

type KubeletConfiguration struct {
	APIVersion        string `json:"apiVersion,omitempty" yaml:"apiVersion,omitempty"`
	Kind              string `json:"kind,omitempty" yaml:"kind,omitempty"`
	Address           string `json:"address,omitempty" yaml:"address,omitempty"`
	Port              int32  `json:"port,omitempty" yaml:"port,omitempty"`
	ReadOnlyPort      int32  `json:"readOnlyPort" yaml:"readOnlyPort"`
	TLSCertFile       string `json:"tlsCertFile" yaml:"tlsCertFile"`
	TLSPrivateKeyFile string `json:"tlsPrivateKeyFile" yaml:"tlsPrivateKeyFile"`

	Authentication KubeletAuthentication `json:"authentication" yaml:"authentication"`
	Authorization  kubeletAuthorization  `json:"authorization" yaml:"authorization"`

	HealthzPort           int32    `json:"healthzPort,omitempty" yaml:"healthzPort,omitempty"`
	HealthzBindAddress    string   `json:"healthzBindAddress,omitempty" yaml:"healthzBindAddress,omitempty"`
	OOMScoreAdj           int32    `json:"oomScoreAdj" yaml:"oomScoreAdj"`
	ClusterDomain         string   `json:"clusterDomain,omitempty" yaml:"clusterDomain,omitempty"`
	ClusterDNS            []string `json:"clusterDNS,omitempty" yaml:"clusterDNS,omitempty"`
	PodCIDR               string   `json:"podCIDR,omitempty" yaml:"podCIDR,omitempty"`
	RuntimeRequestTimeout string   `json:"runtimeRequestTimeout,omitempty" yaml:"runtimeRequestTimeout,omitempty"`

	FeatureGates map[string]bool `json:"featureGates,omitempty" yaml:"featureGates,omitempty"`
	FailSwapOn   bool            `json:"failSwapOn" yaml:"failSwapOn"`

	ContainerLogMaxSize  string `json:"containerLogMaxSize,omitempty" yaml:"containerLogMaxSize,omitempty"`
	ContainerLogMaxFiles int32  `json:"containerLogMaxFiles,omitempty" yaml:"containerLogMaxFiles,omitempty"`
}

KubeletConfiguration is a simplified version of the struct defined in https://github.com/kubernetes/kubernetes/blob/master/pkg/kubelet/apis/config/types.go

Rationate: kubernetes repository is too large and not intended for client usage.