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 ControllerManager(ctx context.Context, apiReady <-chan struct{}, args []string) error
- func ETCD(ctx context.Context, args ETCDConfig, extraArgs []string) error
- func KubeProxy(ctx context.Context, args []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
- 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 (*Embedded) ControllerManager(ctx context.Context, apiReady <-chan struct{}, args []string) error
- func (e *Embedded) CurrentETCDOptions() (InitialOptions, error)
- func (e *Embedded) ETCD(ctx context.Context, args ETCDConfig, extraArgs []string) error
- func (*Embedded) KubeProxy(ctx context.Context, args []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
- type PeerTrust
- type ServerTrust
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func APIServerHandlers ¶
func CloudControllerManager ¶
func ControllerManager ¶
Types ¶
type ETCDConfig ¶
type ETCDConfig struct {
InitialOptions `json:",inline"`
Name string `json:"name,omitempty"`
ListenClientURLs string `json:"listen-client-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"`
}
func (ETCDConfig) ToConfigFile ¶
func (e ETCDConfig) ToConfigFile(extraArgs []string) (string, error)
type Embedded ¶
type Embedded struct {
// contains filtered or unexported fields
}
func (*Embedded) APIServerHandlers ¶
func (*Embedded) CloudControllerManager ¶
func (*Embedded) ControllerManager ¶
func (*Embedded) CurrentETCDOptions ¶
func (e *Embedded) CurrentETCDOptions() (InitialOptions, error)
type Executor ¶
type Executor interface {
Bootstrap(ctx context.Context, nodeConfig *daemonconfig.Node, cfg cmds.Agent) error
Kubelet(ctx context.Context, args []string) error
KubeProxy(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
}
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)
Click to show internal directories.
Click to hide internal directories.