binary

Documentation

Overview

Package binary implements the runtime.Runtime interface using the binaries.

Index

• func BuildPrometheus(conf BuildPrometheusConfig) (string, error)
• func NewCluster(name, workdir string) (runtime.Runtime, error)
• type BuildPrometheusConfig
• type Cluster
  • func (c *Cluster) AddContext(ctx context.Context, kubeconfigPath string) error
  • func (c *Cluster) Available(ctx context.Context) error
  • func (c *Cluster) CollectLogs(ctx context.Context, dir string) error
  • func (c *Cluster) Down(ctx context.Context) error
  • func (c *Cluster) EtcdctlInCluster(ctx context.Context, args ...string) error
  • func (c *Cluster) Install(ctx context.Context) error
  • func (c *Cluster) ListBinaries(ctx context.Context) ([]string, error)
  • func (c *Cluster) ListImages(ctx context.Context) ([]string, error)
  • func (c *Cluster) Logs(ctx context.Context, name string, out io.Writer) error
  • func (c *Cluster) LogsFollow(ctx context.Context, name string, out io.Writer) error
  • func (c *Cluster) Ready(ctx context.Context) (bool, error)
  • func (c *Cluster) RemoveContext(ctx context.Context, kubeconfigPath string) error
  • func (c *Cluster) SnapshotRestore(ctx context.Context, path string) error
  • func (c *Cluster) SnapshotRestoreWithYAML(ctx context.Context, path string, filters []string) error
  • func (c *Cluster) SnapshotSave(ctx context.Context, path string) error
  • func (c *Cluster) SnapshotSaveWithYAML(ctx context.Context, path string, filters []string) error
  • func (c *Cluster) Start(ctx context.Context) error
  • func (c *Cluster) StartComponent(ctx context.Context, name string) error
  • func (c *Cluster) Stop(ctx context.Context) error
  • func (c *Cluster) StopComponent(ctx context.Context, name string) error
  • func (c *Cluster) Uninstall(ctx context.Context) error
  • func (c *Cluster) Up(ctx context.Context) error
  • func (c *Cluster) WaitReady(ctx context.Context, timeout time.Duration) error

Functions

func BuildPrometheus

func BuildPrometheus(conf BuildPrometheusConfig) (string, error)

BuildPrometheus builds the prometheus yaml content.

func NewCluster

func NewCluster(name, workdir string) (runtime.Runtime, error)

NewCluster creates a new Runtime for binary

Types

type BuildPrometheusConfig

type BuildPrometheusConfig struct {
	ProjectName               string
	SecurePort                bool
	AdminCrtPath              string
	AdminKeyPath              string
	PrometheusPort            uint32
	EtcdPort                  uint32
	KubeApiserverPort         uint32
	KubeControllerManagerPort uint32
	KubeSchedulerPort         uint32
	KwokControllerPort        uint32
}

BuildPrometheusConfig is the configuration for building the prometheus config

type Cluster

type Cluster struct {
	*runtime.Cluster
}

Cluster is an implementation of Runtime for binary

func (*Cluster) AddContext

func (c *Cluster) AddContext(ctx context.Context, kubeconfigPath string) error

AddContext add the context of cluster to kubeconfig

func (*Cluster) Available

func (c *Cluster) Available(ctx context.Context) error

Available checks whether the runtime is available.

func (*Cluster) CollectLogs

func (c *Cluster) CollectLogs(ctx context.Context, dir string) error

CollectLogs returns the logs of the specified component.

func (*Cluster) Down

func (c *Cluster) Down(ctx context.Context) error

Down stops the cluster

func (*Cluster) EtcdctlInCluster

func (c *Cluster) EtcdctlInCluster(ctx context.Context, args ...string) error

EtcdctlInCluster implements the ectdctl subcommand

func (*Cluster) Install

func (c *Cluster) Install(ctx context.Context) error

Install installs the cluster

func (*Cluster) ListBinaries

func (c *Cluster) ListBinaries(ctx context.Context) ([]string, error)

ListBinaries list binaries in the cluster

func (*Cluster) ListImages

func (c *Cluster) ListImages(ctx context.Context) ([]string, error)

ListImages list images in the cluster

func (*Cluster) Logs

func (c *Cluster) Logs(ctx context.Context, name string, out io.Writer) error

Logs returns the logs of the specified component.

func (*Cluster) LogsFollow

func (c *Cluster) LogsFollow(ctx context.Context, name string, out io.Writer) error

LogsFollow follows the logs of the component

func (*Cluster) Ready

func (c *Cluster) Ready(ctx context.Context) (bool, error)

Ready returns true if the cluster is ready

func (*Cluster) RemoveContext

func (c *Cluster) RemoveContext(ctx context.Context, kubeconfigPath string) error

RemoveContext remove the context of cluster from kubeconfig

func (*Cluster) SnapshotRestore

func (c *Cluster) SnapshotRestore(ctx context.Context, path string) error

SnapshotRestore restore the snapshot of cluster

func (*Cluster) SnapshotRestoreWithYAML

func (c *Cluster) SnapshotRestoreWithYAML(ctx context.Context, path string, filters []string) error

SnapshotRestoreWithYAML restore the snapshot of cluster

func (*Cluster) SnapshotSave

func (c *Cluster) SnapshotSave(ctx context.Context, path string) error

SnapshotSave save the snapshot of cluster

func (*Cluster) SnapshotSaveWithYAML

func (c *Cluster) SnapshotSaveWithYAML(ctx context.Context, path string, filters []string) error

SnapshotSaveWithYAML save the snapshot of cluster

func (*Cluster) Start

func (c *Cluster) Start(ctx context.Context) error

Start starts the cluster

func (*Cluster) StartComponent

func (c *Cluster) StartComponent(ctx context.Context, name string) error

StartComponent starts a component in the cluster

func (*Cluster) Stop

func (c *Cluster) Stop(ctx context.Context) error

Stop stops the cluster

func (*Cluster) StopComponent

func (c *Cluster) StopComponent(ctx context.Context, name string) error

StopComponent stops a component in the cluster

func (*Cluster) Uninstall

func (c *Cluster) Uninstall(ctx context.Context) error

Uninstall uninstalls the cluster.

func (*Cluster) Up

func (c *Cluster) Up(ctx context.Context) error

Up starts the cluster.

func (*Cluster) WaitReady

func (c *Cluster) WaitReady(ctx context.Context, timeout time.Duration) error

WaitReady waits for the cluster to be ready.