rke

Documentation

Index

• func NewDriver() types.Driver
• type Driver
  • func (d *Driver) Create(ctx context.Context, opts *types.DriverOptions, info *types.ClusterInfo) (*types.ClusterInfo, error)
  • func (d *Driver) ETCDRemoveSnapshot(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions, ...) error
  • func (d *Driver) ETCDRestore(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions, ...) (*types.ClusterInfo, error)
  • func (d *Driver) ETCDSave(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions, ...) error
  • func (d *Driver) GetCapabilities(ctx context.Context) (*types.Capabilities, error)
  • func (d *Driver) GetClusterSize(ctx context.Context, info *types.ClusterInfo) (*types.NodeCount, error)
  • func (d *Driver) GetDriverCreateOptions(ctx context.Context) (*types.DriverFlags, error)
  • func (d *Driver) GetDriverUpdateOptions(ctx context.Context) (*types.DriverFlags, error)
  • func (d *Driver) GetK8SCapabilities(ctx context.Context, _ *types.DriverOptions) (*types.K8SCapabilities, error)
  • func (d *Driver) GetVersion(ctx context.Context, info *types.ClusterInfo) (*types.KubernetesVersion, error)
  • func (d *Driver) PostCheck(ctx context.Context, info *types.ClusterInfo) (*types.ClusterInfo, error)
  • func (d *Driver) Remove(ctx context.Context, clusterInfo *types.ClusterInfo) error
  • func (d *Driver) RemoveLegacyServiceAccount(ctx context.Context, info *types.ClusterInfo) error
  • func (d *Driver) SetVersion(ctx context.Context, info *types.ClusterInfo, version *types.KubernetesVersion) error
  • func (d *Driver) Update(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions) (*types.ClusterInfo, error)
• type Store
• type WrapTransportFactory

Functions

func NewDriver

func NewDriver() types.Driver

Types

type Driver

type Driver struct {
	DockerDialer         hosts.DialerFactory
	LocalDialer          hosts.DialerFactory
	DataStore            Store
	WrapTransportFactory WrapTransportFactory

	types.UnimplementedVersionAccess
	types.UnimplementedClusterSizeAccess
	// contains filtered or unexported fields
}

func (*Driver) Create

func (d *Driver) Create(ctx context.Context, opts *types.DriverOptions, info *types.ClusterInfo) (*types.ClusterInfo, error)

Create creates the rke cluster

func (*Driver) ETCDRemoveSnapshot

func (d *Driver) ETCDRemoveSnapshot(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions, snapshotName string) error

func (*Driver) ETCDRestore

func (d *Driver) ETCDRestore(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions, snapshotName string) (*types.ClusterInfo, error)

func (*Driver) ETCDSave

func (d *Driver) ETCDSave(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions, snapshotName string) error

func (*Driver) GetCapabilities

func (d *Driver) GetCapabilities(ctx context.Context) (*types.Capabilities, error)

func (*Driver) GetClusterSize

func (d *Driver) GetClusterSize(ctx context.Context, info *types.ClusterInfo) (*types.NodeCount, error)

func (*Driver) GetDriverCreateOptions

func (d *Driver) GetDriverCreateOptions(ctx context.Context) (*types.DriverFlags, error)

GetDriverCreateOptions returns create flags for rke driver

func (*Driver) GetDriverUpdateOptions

func (d *Driver) GetDriverUpdateOptions(ctx context.Context) (*types.DriverFlags, error)

GetDriverUpdateOptions returns update flags for rke driver

func (*Driver) GetK8SCapabilities

func (d *Driver) GetK8SCapabilities(ctx context.Context, _ *types.DriverOptions) (*types.K8SCapabilities, error)

func (*Driver) GetVersion

func (d *Driver) GetVersion(ctx context.Context, info *types.ClusterInfo) (*types.KubernetesVersion, error)

func (*Driver) PostCheck

func (d *Driver) PostCheck(ctx context.Context, info *types.ClusterInfo) (*types.ClusterInfo, error)

PostCheck does post action

func (*Driver) Remove

func (d *Driver) Remove(ctx context.Context, clusterInfo *types.ClusterInfo) error

Remove removes the cluster

func (*Driver) RemoveLegacyServiceAccount

func (d *Driver) RemoveLegacyServiceAccount(ctx context.Context, info *types.ClusterInfo) error

func (*Driver) SetVersion

func (d *Driver) SetVersion(ctx context.Context, info *types.ClusterInfo, version *types.KubernetesVersion) error

func (*Driver) Update

func (d *Driver) Update(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions) (*types.ClusterInfo, error)

Update updates the rke cluster

type Store

type Store interface {
	// Add methods here to get rke driver specific data
	GetAddonTemplates(k8sVersion string) (map[string]interface{}, error)
	// GetServiceOptions returns the combined result of service options:
	// - `k8s-service-options` corresponds to linux options
	// - `k8s-windows-service-options` corresponds to windows options
	GetServiceOptions(k8sVersion string) (map[string]*v3.KubernetesServicesOptions, error)
}

type WrapTransportFactory

type WrapTransportFactory func(config *v3.RancherKubernetesEngineConfig) transport.WrapperFunc