services

package
v0.1.3 Latest Latest
Warning

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

Go to latest
Published: Mar 24, 2018 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source
const (
	HealthzAddress   = "localhost"
	HealthzEndpoint  = "/healthz"
	HTTPProtoPrefix  = "http://"
	HTTPSProtoPrefix = "https://"
)
View Source
const (
	NginxProxyImage   = "rancher/rke-nginx-proxy:0.1.0"
	NginxProxyEnvName = "CP_HOSTS"
)
View Source
const (
	ETCDRole    = "etcd"
	ControlRole = "controlplane"
	WorkerRole  = "worker"

	SidekickServiceName   = "sidekick"
	RBACAuthorizationMode = "rbac"

	KubeAPIContainerName        = "kube-apiserver"
	KubeletContainerName        = "kubelet"
	KubeproxyContainerName      = "kube-proxy"
	KubeControllerContainerName = "kube-controller-manager"
	SchedulerContainerName      = "kube-scheduler"
	EtcdContainerName           = "etcd"
	NginxProxyContainerName     = "nginx-proxy"
	SidekickContainerName       = "service-sidekick"
	LogLinkContainerName        = "rke-log-linker"
	LogCleanerContainerName     = "rke-log-cleaner"

	KubeAPIPort        = 6443
	SchedulerPort      = 10251
	KubeControllerPort = 10252
	KubeletPort        = 10250
	KubeproxyPort      = 10256

	RKELogsPath = "/var/lib/rancher/rke/log"
)
View Source
const (
	EtcdHealthCheckURL = "https://127.0.0.1:2379/health"
)

Variables

This section is empty.

Functions

func AddEtcdMember

func AddEtcdMember(ctx context.Context, toAddEtcdHost *hosts.Host, etcdHosts []*hosts.Host, localConnDialerFactory hosts.DialerFactory, cert, key []byte) error

func GetEtcdConnString

func GetEtcdConnString(hosts []*hosts.Host) string

func GetEtcdInitialCluster added in v0.1.2

func GetEtcdInitialCluster(hosts []*hosts.Host) string

func GetHealthCheckURL added in v0.1.2

func GetHealthCheckURL(useTLS bool, port int) string

func GetProcessConfig added in v0.1.2

func GetProcessConfig(process v3.Process) (*container.Config, *container.HostConfig, string)

func IsEtcdMember added in v0.1.2

func IsEtcdMember(ctx context.Context, etcdHost *hosts.Host, etcdHosts []*hosts.Host, localConnDialerFactory hosts.DialerFactory, cert, key []byte) (bool, error)

func ReloadEtcdCluster

func ReloadEtcdCluster(ctx context.Context, readyEtcdHosts []*hosts.Host, localConnDialerFactory hosts.DialerFactory, cert, key []byte, prsMap map[string]v3.PrivateRegistry, etcdProcessHostMap map[*hosts.Host]v3.Process, alpineImage string) error

func RemoveControlPlane

func RemoveControlPlane(ctx context.Context, controlHosts []*hosts.Host, force bool) error

func RemoveEtcdMember

func RemoveEtcdMember(ctx context.Context, etcdHost *hosts.Host, etcdHosts []*hosts.Host, localConnDialerFactory hosts.DialerFactory, cert, key []byte) error

func RemoveEtcdPlane

func RemoveEtcdPlane(ctx context.Context, etcdHosts []*hosts.Host, force bool) error

func RemoveWorkerPlane

func RemoveWorkerPlane(ctx context.Context, workerHosts []*hosts.Host, force bool) error

func RunControlPlane

func RunControlPlane(ctx context.Context, controlHosts []*hosts.Host, localConnDialerFactory hosts.DialerFactory, prsMap map[string]v3.PrivateRegistry, processMap map[string]v3.Process, updateWorkersOnly bool, alpineImage string) error

func RunEtcdPlane

func RunEtcdPlane(ctx context.Context, etcdHosts []*hosts.Host, etcdProcessHostMap map[*hosts.Host]v3.Process, localConnDialerFactory hosts.DialerFactory, prsMap map[string]v3.PrivateRegistry, updateWorkersOnly bool, alpineImage string) error

func RunWorkerPlane

func RunWorkerPlane(ctx context.Context, allHosts []*hosts.Host, localConnDialerFactory hosts.DialerFactory, prsMap map[string]v3.PrivateRegistry, processMap map[string]v3.Process, kubeletProcessHostMap map[*hosts.Host]v3.Process, certMap map[string]pki.CertificatePKI, updateWorkersOnly bool, alpineImage string) error

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL