kwok

Documentation

Index

• Variables
• func ConstructInstanceTypes() ([]*cloudprovider.InstanceType, error)
• type CloudProvider
  • func NewCloudProvider(ctx context.Context, kubeClient client.Client, ...) *CloudProvider
  • func (c CloudProvider) Create(ctx context.Context, nodeClaim *v1beta1.NodeClaim) (*v1beta1.NodeClaim, error)
  • func (c CloudProvider) Delete(ctx context.Context, nodeClaim *v1beta1.NodeClaim) error
  • func (c CloudProvider) Get(ctx context.Context, providerID string) (*v1beta1.NodeClaim, error)
  • func (c CloudProvider) GetInstanceTypes(ctx context.Context, nodePool *v1beta1.NodePool) ([]*cloudprovider.InstanceType, error)
  • func (c CloudProvider) GetSupportedNodeClasses() []schema.GroupVersionKind
  • func (c CloudProvider) IsDrifted(ctx context.Context, nodeClaim *v1beta1.NodeClaim) (cloudprovider.DriftReason, error)
  • func (c CloudProvider) List(ctx context.Context) ([]*v1beta1.NodeClaim, error)
  • func (c CloudProvider) Name() string
• type InstanceTypeOptions

Variables

var (
	KwokPartitions = []string{"partition-a", "partition-b", "partition-c", "partition-d", "partition-e",
		"partition-f", "partition-g", "partition-h", "partition-i", "partition-j"}
)

Hard coded Kwok values

Functions

func ConstructInstanceTypes

func ConstructInstanceTypes() ([]*cloudprovider.InstanceType, error)

ConstructInstanceTypes create many instance types based on the embedded instance type data

Types

type CloudProvider

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

func NewCloudProvider

func NewCloudProvider(ctx context.Context, kubeClient client.Client, instanceTypes []*cloudprovider.InstanceType) *CloudProvider

func (CloudProvider) Create

func (c CloudProvider) Create(ctx context.Context, nodeClaim *v1beta1.NodeClaim) (*v1beta1.NodeClaim, error)

func (CloudProvider) Delete

func (c CloudProvider) Delete(ctx context.Context, nodeClaim *v1beta1.NodeClaim) error

func (CloudProvider) Get

func (c CloudProvider) Get(ctx context.Context, providerID string) (*v1beta1.NodeClaim, error)

func (CloudProvider) GetInstanceTypes

func (c CloudProvider) GetInstanceTypes(ctx context.Context, nodePool *v1beta1.NodePool) ([]*cloudprovider.InstanceType, error)

Return the hard-coded instance types.

func (CloudProvider) GetSupportedNodeClasses

func (c CloudProvider) GetSupportedNodeClasses() []schema.GroupVersionKind

func (CloudProvider) IsDrifted

func (c CloudProvider) IsDrifted(ctx context.Context, nodeClaim *v1beta1.NodeClaim) (cloudprovider.DriftReason, error)

Return nothing since there's no cloud provider drift.

func (CloudProvider) List

func (c CloudProvider) List(ctx context.Context) ([]*v1beta1.NodeClaim, error)

func (CloudProvider) Name

func (c CloudProvider) Name() string

type InstanceTypeOptions

type InstanceTypeOptions struct {
	Name             string                  `json:"name"`
	Offerings        cloudprovider.Offerings `json:"offerings"`
	Architecture     string                  `json:"architecture"`
	OperatingSystems []v1.OSName             `json:"operatingSystems"`
	Resources        v1.ResourceList         `json:"resources"`
	// contains filtered or unexported fields
}