executor

Documentation

Index

• func APIServer(ctx context.Context, etcdReady <-chan struct{}, args []string) error
• func APIServerHandlers(ctx context.Context) (authenticator.Request, http.Handler, error)
• func Bootstrap(ctx context.Context, nodeConfig *daemonconfig.Node, cfg cmds.Agent) error
• func CloudControllerManager(ctx context.Context, ccmRBACReady <-chan struct{}, args []string) error
• func Containerd(ctx context.Context, config *daemonconfig.Node) error
• func ControllerManager(ctx context.Context, apiReady <-chan struct{}, args []string) error
• func Docker(ctx context.Context, config *daemonconfig.Node) error
• func ETCD(ctx context.Context, args ETCDConfig, extraArgs []string) error
• func Kubelet(ctx context.Context, args []string) error
• func Scheduler(ctx context.Context, apiReady <-chan struct{}, args []string) error
• func Set(driver Executor)
• type ETCDConfig
  • func (e ETCDConfig) ToConfigFile(extraArgs []string) (string, error)
• type Embedded
  • func (*Embedded) APIServer(ctx context.Context, etcdReady <-chan struct{}, args []string) error
  • func (*Embedded) APIServerHandlers(ctx context.Context) (authenticator.Request, http.Handler, error)
  • func (e *Embedded) Bootstrap(ctx context.Context, nodeConfig *daemonconfig.Node, cfg cmds.Agent) error
  • func (*Embedded) CloudControllerManager(ctx context.Context, ccmRBACReady <-chan struct{}, args []string) error
  • func (e *Embedded) Containerd(ctx context.Context, cfg *daemonconfig.Node) error
  • func (*Embedded) ControllerManager(ctx context.Context, apiReady <-chan struct{}, args []string) error
  • func (e *Embedded) CurrentETCDOptions() (InitialOptions, error)
  • func (e *Embedded) Docker(ctx context.Context, cfg *daemonconfig.Node) error
  • func (e *Embedded) ETCD(ctx context.Context, args ETCDConfig, extraArgs []string) error
  • func (e *Embedded) Kubelet(ctx context.Context, args []string) error
  • func (e *Embedded) Scheduler(ctx context.Context, apiReady <-chan struct{}, args []string) error
• type Executor
• type InitialOptions
  • func CurrentETCDOptions() (InitialOptions, error)
• type PeerTrust
• type ServerTrust

Functions

func APIServer

func APIServer(ctx context.Context, etcdReady <-chan struct{}, args []string) error

func APIServerHandlers

func APIServerHandlers(ctx context.Context) (authenticator.Request, http.Handler, error)

func Bootstrap

func Bootstrap(ctx context.Context, nodeConfig *daemonconfig.Node, cfg cmds.Agent) error

func CloudControllerManager

func CloudControllerManager(ctx context.Context, ccmRBACReady <-chan struct{}, args []string) error

func Containerd

func Containerd(ctx context.Context, config *daemonconfig.Node) error

func ControllerManager

func ControllerManager(ctx context.Context, apiReady <-chan struct{}, args []string) error

func Docker

func Docker(ctx context.Context, config *daemonconfig.Node) error

func ETCD

func ETCD(ctx context.Context, args ETCDConfig, extraArgs []string) error

func Kubelet

func Kubelet(ctx context.Context, args []string) error

func Scheduler

func Scheduler(ctx context.Context, apiReady <-chan struct{}, args []string) error

func Set

func Set(driver Executor)

Types

type ETCDConfig

type ETCDConfig struct {
	InitialOptions       `json:",inline"`
	Name                 string      `json:"name,omitempty"`
	ListenClientURLs     string      `json:"listen-client-urls,omitempty"`
	ListenClientHTTPURLs string      `json:"listen-client-http-urls,omitempty"`
	ListenMetricsURLs    string      `json:"listen-metrics-urls,omitempty"`
	ListenPeerURLs       string      `json:"listen-peer-urls,omitempty"`
	AdvertiseClientURLs  string      `json:"advertise-client-urls,omitempty"`
	DataDir              string      `json:"data-dir,omitempty"`
	SnapshotCount        int         `json:"snapshot-count,omitempty"`
	ServerTrust          ServerTrust `json:"client-transport-security"`
	PeerTrust            PeerTrust   `json:"peer-transport-security"`
	ForceNewCluster      bool        `json:"force-new-cluster,omitempty"`
	HeartbeatInterval    int         `json:"heartbeat-interval"`
	ElectionTimeout      int         `json:"election-timeout"`
	Logger               string      `json:"logger"`
	LogOutputs           []string    `json:"log-outputs"`

	ExperimentalInitialCorruptCheck         bool          `json:"experimental-initial-corrupt-check"`
	ExperimentalWatchProgressNotifyInterval time.Duration `json:"experimental-watch-progress-notify-interval"`
}

func (ETCDConfig) ToConfigFile

func (e ETCDConfig) ToConfigFile(extraArgs []string) (string, error)

type Embedded

type Embedded struct {
	// contains filtered or unexported fields
}

func (*Embedded) APIServer

func (*Embedded) APIServer(ctx context.Context, etcdReady <-chan struct{}, args []string) error

func (*Embedded) APIServerHandlers

func (*Embedded) APIServerHandlers(ctx context.Context) (authenticator.Request, http.Handler, error)

func (*Embedded) Bootstrap

func (e *Embedded) Bootstrap(ctx context.Context, nodeConfig *daemonconfig.Node, cfg cmds.Agent) error

func (*Embedded) CloudControllerManager

func (*Embedded) CloudControllerManager(ctx context.Context, ccmRBACReady <-chan struct{}, args []string) error

func (*Embedded) Containerd

func (e *Embedded) Containerd(ctx context.Context, cfg *daemonconfig.Node) error

func (*Embedded) ControllerManager

func (*Embedded) ControllerManager(ctx context.Context, apiReady <-chan struct{}, args []string) error

func (*Embedded) CurrentETCDOptions

func (e *Embedded) CurrentETCDOptions() (InitialOptions, error)

func (*Embedded) Docker

func (e *Embedded) Docker(ctx context.Context, cfg *daemonconfig.Node) error

func (*Embedded) ETCD

func (e *Embedded) ETCD(ctx context.Context, args ETCDConfig, extraArgs []string) error

func (*Embedded) Kubelet

func (e *Embedded) Kubelet(ctx context.Context, args []string) error

func (*Embedded) Scheduler

func (e *Embedded) Scheduler(ctx context.Context, apiReady <-chan struct{}, args []string) error

type Executor

type Executor interface {
	Bootstrap(ctx context.Context, nodeConfig *daemonconfig.Node, cfg cmds.Agent) error
	Kubelet(ctx context.Context, args []string) error
	APIServerHandlers(ctx context.Context) (authenticator.Request, http.Handler, error)
	APIServer(ctx context.Context, etcdReady <-chan struct{}, args []string) error
	Scheduler(ctx context.Context, apiReady <-chan struct{}, args []string) error
	ControllerManager(ctx context.Context, apiReady <-chan struct{}, args []string) error
	CurrentETCDOptions() (InitialOptions, error)
	ETCD(ctx context.Context, args ETCDConfig, extraArgs []string) error
	CloudControllerManager(ctx context.Context, ccmRBACReady <-chan struct{}, args []string) error
	Containerd(ctx context.Context, node *daemonconfig.Node) error
	Docker(ctx context.Context, node *daemonconfig.Node) error
}

type InitialOptions

type InitialOptions struct {
	AdvertisePeerURL string `json:"initial-advertise-peer-urls,omitempty"`
	Cluster          string `json:"initial-cluster,omitempty"`
	State            string `json:"initial-cluster-state,omitempty"`
}

func CurrentETCDOptions

func CurrentETCDOptions() (InitialOptions, error)

type PeerTrust

type PeerTrust struct {
	CertFile       string `json:"cert-file"`
	KeyFile        string `json:"key-file"`
	ClientCertAuth bool   `json:"client-cert-auth"`
	TrustedCAFile  string `json:"trusted-ca-file"`
}

type ServerTrust

type ServerTrust struct {
	CertFile       string `json:"cert-file"`
	KeyFile        string `json:"key-file"`
	ClientCertAuth bool   `json:"client-cert-auth"`
	TrustedCAFile  string `json:"trusted-ca-file"`
}