pkg

Documentation

Index

• func NewDriver() types.Driver
• type OKEDriver
  • func (d *OKEDriver) Create(ctx context.Context, opts *types.DriverOptions, _ *types.ClusterInfo) (*types.ClusterInfo, error)
  • func (d *OKEDriver) ETCDRemoveSnapshot(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions, ...) error
  • func (d *OKEDriver) ETCDRestore(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions, ...) (*types.ClusterInfo, error)
  • func (d *OKEDriver) ETCDSave(ctx context.Context, clusterInfo *types.ClusterInfo, opts *types.DriverOptions, ...) error
  • func (d *OKEDriver) GetCapabilities(_ context.Context) (*types.Capabilities, error)
  • func (d *OKEDriver) GetClusterSize(_ context.Context, info *types.ClusterInfo) (*types.NodeCount, error)
  • func (d *OKEDriver) GetDriverCreateOptions(ctx context.Context) (*types.DriverFlags, error)
  • func (d *OKEDriver) GetDriverUpdateOptions(ctx context.Context) (*types.DriverFlags, error)
  • func (d *OKEDriver) GetK8SCapabilities(ctx context.Context, options *types.DriverOptions) (*types.K8SCapabilities, error)
  • func (d *OKEDriver) GetVersion(_ context.Context, info *types.ClusterInfo) (*types.KubernetesVersion, error)
  • func (d *OKEDriver) NewCAPIClient(logger *provisioning.Logger) *capi.CAPIClient
  • func (d *OKEDriver) PostCheck(ctx context.Context, info *types.ClusterInfo) (*types.ClusterInfo, error)
  • func (d *OKEDriver) Remove(ctx context.Context, info *types.ClusterInfo) error
  • func (d *OKEDriver) RemoveLegacyServiceAccount(ctx context.Context, info *types.ClusterInfo) error
  • func (d *OKEDriver) SetClusterSize(ctx context.Context, info *types.ClusterInfo, count *types.NodeCount) error
  • func (d *OKEDriver) SetVersion(ctx context.Context, info *types.ClusterInfo, version *types.KubernetesVersion) error
  • func (d *OKEDriver) Update(ctx context.Context, info *types.ClusterInfo, opts *types.DriverOptions) (*types.ClusterInfo, error)

Functions

func NewDriver

func NewDriver() types.Driver

Types

type OKEDriver

type OKEDriver struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func (*OKEDriver) Create

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

Create implements driver interface

func (*OKEDriver) ETCDRemoveSnapshot

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

func (*OKEDriver) ETCDRestore

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

func (*OKEDriver) ETCDSave

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

func (*OKEDriver) GetCapabilities

func (d *OKEDriver) GetCapabilities(_ context.Context) (*types.Capabilities, error)

func (*OKEDriver) GetClusterSize

func (d *OKEDriver) GetClusterSize(_ context.Context, info *types.ClusterInfo) (*types.NodeCount, error)

func (*OKEDriver) GetDriverCreateOptions

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

GetDriverCreateOptions implements driver interface

func (*OKEDriver) GetDriverUpdateOptions

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

GetDriverUpdateOptions implements driver interface

func (*OKEDriver) GetK8SCapabilities

func (d *OKEDriver) GetK8SCapabilities(ctx context.Context, options *types.DriverOptions) (*types.K8SCapabilities, error)

func (*OKEDriver) GetVersion

func (d *OKEDriver) GetVersion(_ context.Context, info *types.ClusterInfo) (*types.KubernetesVersion, error)

func (*OKEDriver) NewCAPIClient

func (d *OKEDriver) NewCAPIClient(logger *provisioning.Logger) *capi.CAPIClient

func (*OKEDriver) PostCheck

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

func (*OKEDriver) Remove

func (d *OKEDriver) Remove(ctx context.Context, info *types.ClusterInfo) error

func (*OKEDriver) RemoveLegacyServiceAccount

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

func (*OKEDriver) SetClusterSize

func (d *OKEDriver) SetClusterSize(ctx context.Context, info *types.ClusterInfo, count *types.NodeCount) error

func (*OKEDriver) SetVersion

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

SetVersion sets the Kubernetes Version of cluster

func (*OKEDriver) Update

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

Update implements driver interface