provider

Documentation

Index

• func IsInvalidConfig(err error) bool
• type Interface
• type KVM
  • func NewKVM(config KVMConfig) (*KVM, error)
  • func (k *KVM) AddWorker() error
  • func (k *KVM) NumMasters() (int, error)
  • func (k *KVM) NumWorkers() (int, error)
  • func (k *KVM) RemoveWorker() error
  • func (k *KVM) WaitForNodes(ctx context.Context, num int) error
• type KVMConfig
• type Patch
• type Waiter

Functions

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

Types

type Interface

type Interface interface {
	AddWorker() error
	NumMasters() (int, error)
	NumWorkers() (int, error)
	RemoveWorker() error
	WaitForNodes(ctx context.Context, num int) error
}

type KVM

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

func NewKVM

func NewKVM(config KVMConfig) (*KVM, error)

func (*KVM) AddWorker

func (k *KVM) AddWorker() error

func (*KVM) NumMasters

func (k *KVM) NumMasters() (int, error)

func (*KVM) NumWorkers

func (k *KVM) NumWorkers() (int, error)

func (*KVM) RemoveWorker

func (k *KVM) RemoveWorker() error

func (*KVM) WaitForNodes

func (k *KVM) WaitForNodes(ctx context.Context, num int) error

type KVMConfig

type KVMConfig struct {
	K8sClient k8sclient.Interface
	Logger    micrologger.Logger
	Waiter    Waiter

	ClusterID string
}

type Patch

type Patch struct {
	Op    string      `json:"op"`
	Path  string      `json:"path"`
	Value interface{} `json:"value"`
}

type Waiter

type Waiter interface {
	// WaitForNodesReady waits for the given number of expected tenant cluster
	// nodes to be ready.
	WaitForNodesReady(ctx context.Context, expectedNodes int) error
}