services

package

v0.1.6 Latest Latest Go to latest Published: Apr 27, 2018 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/thxcode/rancher-rke

Documentation ¶

Index ¶

Constants
func AddEtcdMember(ctx context.Context, toAddEtcdHost *hosts.Host, etcdHosts []*hosts.Host, ...) error
func GetEtcdConnString(hosts []*hosts.Host) string
func GetEtcdInitialCluster(hosts []*hosts.Host) string
func GetHealthCheckURL(useTLS bool, port int) string
func GetProcessConfig(process v3.Process) (*container.Config, *container.HostConfig, string)
func IsEtcdMember(ctx context.Context, etcdHost *hosts.Host, etcdHosts []*hosts.Host, ...) (bool, error)
func ReloadEtcdCluster(ctx context.Context, readyEtcdHosts []*hosts.Host, ...) error
func RemoveControlPlane(ctx context.Context, controlHosts []*hosts.Host, force bool) error
func RemoveEtcdMember(ctx context.Context, etcdHost *hosts.Host, etcdHosts []*hosts.Host, ...) error
func RemoveEtcdPlane(ctx context.Context, etcdHosts []*hosts.Host, force bool) error
func RemoveWorkerPlane(ctx context.Context, workerHosts []*hosts.Host, force bool) error
func RunControlPlane(ctx context.Context, controlHosts []*hosts.Host, ...) error
func RunEtcdPlane(ctx context.Context, etcdHosts []*hosts.Host, ...) error
func RunWorkerPlane(ctx context.Context, allHosts []*hosts.Host, ...) error

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

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, etcdNodePlanMap map[string]v3.RKEConfigNodePlan, 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, cpNodePlanMap map[string]v3.RKEConfigNodePlan, updateWorkersOnly bool, alpineImage string) error

func RunEtcdPlane ¶

func RunEtcdPlane(ctx context.Context, etcdHosts []*hosts.Host, etcdNodePlanMap map[string]v3.RKEConfigNodePlan, 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, workerNodePlanMap map[string]v3.RKEConfigNodePlan, certMap map[string]pki.CertificatePKI, updateWorkersOnly bool, alpineImage string) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

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