pools

Documentation

Index

• func Create(c *gcorecloud.ServiceClient, clusterName string, opts CreateOptsBuilder) (r tasks.Result)
• func Delete(c *gcorecloud.ServiceClient, clusterName, poolName string) (r tasks.Result)
• func ExtractClusterPoolIDFromTask(task *tasks.Task) (string, error)
• func ExtractClusterPoolsInto(r pagination.Page, v interface{}) error
• func List(c *gcorecloud.ServiceClient, clusterName string) pagination.Pager
• func ListInstances(c *gcorecloud.ServiceClient, clusterName, poolName string) pagination.Pager
• func ListInstancesAll(c *gcorecloud.ServiceClient, clusterName, poolName string) ([]instances.Instance, error)
• func Resize(c *gcorecloud.ServiceClient, clusterName, poolName string, ...) (r tasks.Result)
• type ClusterPool
  • func ExtractClusterPools(r pagination.Page) ([]ClusterPool, error)
  • func ListAll(client *gcorecloud.ServiceClient, clusterName string) ([]ClusterPool, error)
• type ClusterPoolPage
  • func (r ClusterPoolPage) IsEmpty() (bool, error)
  • func (r ClusterPoolPage) NextPageURL() (string, error)
• type CreateOpts
  • func (opts CreateOpts) ToClusterPoolCreateMap() (map[string]interface{}, error)
  • func (opts CreateOpts) Validate() error
• type CreateOptsBuilder
• type GetResult
  • func Get(c *gcorecloud.ServiceClient, clusterName, poolName string) (r GetResult)
  • func (r GetResult) Extract() (*ClusterPool, error)
  • func (r GetResult) ExtractInto(v interface{}) error
• type PoolTaskResult
• type ResizeOpts
  • func (opts ResizeOpts) ToClusterPoolResizeMap() (map[string]interface{}, error)
  • func (opts ResizeOpts) Validate() error
• type ResizeOptsBuilder
• type UpdateOpts
  • func (opts UpdateOpts) ToClusterPoolUpdateMap() (map[string]interface{}, error)
  • func (opts UpdateOpts) Validate() error
• type UpdateOptsBuilder
• type UpdateResult
  • func Update(c *gcorecloud.ServiceClient, clusterName, poolName string, ...) (r UpdateResult)
  • func (r UpdateResult) Extract() (*ClusterPool, error)
  • func (r UpdateResult) ExtractInto(v interface{}) error

Functions

func Create

func Create(c *gcorecloud.ServiceClient, clusterName string, opts CreateOptsBuilder) (r tasks.Result)

Create accepts a CreateOpts struct and creates a new cluster pool using the values provided.

func Delete

func Delete(c *gcorecloud.ServiceClient, clusterName, poolName string) (r tasks.Result)

Delete accepts a pool name and deletes the cluster pool associated with it.

func ExtractClusterPoolIDFromTask

func ExtractClusterPoolIDFromTask(task *tasks.Task) (string, error)

func ExtractClusterPoolsInto

func ExtractClusterPoolsInto(r pagination.Page, v interface{}) error

func List

func List(c *gcorecloud.ServiceClient, clusterName string) pagination.Pager

List returns a Pager which allows you to iterate over a collection of cluster pools.

func ListInstances

func ListInstances(c *gcorecloud.ServiceClient, clusterName, poolName string) pagination.Pager

ListInstances returns a Pager which allows you to iterate over a collection of pool instances.

func ListInstancesAll

func ListInstancesAll(c *gcorecloud.ServiceClient, clusterName, poolName string) ([]instances.Instance, error)

List returns all pool instances.

func Resize

func Resize(c *gcorecloud.ServiceClient, clusterName, poolName string, opts ResizeOptsBuilder) (r tasks.Result)

Resize accepts a ResizeOpts struct and resizes an existing cluster using the values provided.

Types

type ClusterPool

type ClusterPool struct {
	ID                 string             `json:"id"`
	Name               string             `json:"name"`
	FlavorID           string             `json:"flavor_id"`
	NodeCount          int                `json:"node_count"`
	MinNodeCount       int                `json:"min_node_count"`
	MaxNodeCount       int                `json:"max_node_count"`
	Status             string             `json:"status"`
	BootVolumeType     volumes.VolumeType `json:"boot_volume_type"`
	BootVolumeSize     int                `json:"boot_volume_size"`
	AutoHealingEnabled bool               `json:"auto_healing_enabled"`
	CreatedAt          time.Time          `json:"created_at"`
	IsPublicIPv4       bool               `json:"is_public_ipv4"`
	ServerGroupID      string             `json:"servergroup_id"`
	ServerGroupName    string             `json:"servergroup_name"`
	ServerGroupPolicy  string             `json:"servergroup_policy"`
	Labels             map[string]string  `json:"labels,omitempty"`
	Taints             map[string]string  `json:"taints,omitempty"`
	CrioConfig         map[string]string  `json:"crio_config,omitempty"`
	KubeletConfig      map[string]string  `json:"kubelet_config,omitempty"`
}

ClusterPool represents a cluster pool.

func ExtractClusterPools

func ExtractClusterPools(r pagination.Page) ([]ClusterPool, error)

ExtractClusterPools accepts a Page struct, specifically a ClusterPoolPage struct, and extracts the elements into a slice of ClusterPool structs. In other words, a generic collection is mapped into a relevant slice.

func ListAll

func ListAll(client *gcorecloud.ServiceClient, clusterName string) ([]ClusterPool, error)

ListAll is a convenience function that returns all cluster pools.

type ClusterPoolPage

type ClusterPoolPage struct {
	pagination.LinkedPageBase
}

ClusterPoolPage is the page returned by a pager when traversing over a collection of networks.

func (ClusterPoolPage) IsEmpty

func (r ClusterPoolPage) IsEmpty() (bool, error)

IsEmpty checks whether a ClusterPool struct is empty.

func (ClusterPoolPage) NextPageURL

func (r ClusterPoolPage) NextPageURL() (string, error)

NextPageURL is invoked when a paginated collection of cluster Pools has reached the end of a page and the pager seeks to traverse over a new one. In order to do this, it needs to construct the next page's URL.

type CreateOpts

type CreateOpts struct {
	Name               string                         `json:"name" required:"true" validate:"required"`
	FlavorID           string                         `json:"flavor_id" required:"true" validate:"required"`
	MinNodeCount       int                            `json:"min_node_count" required:"true" validate:"required,gt=0,ltefield=MaxNodeCount"`
	MaxNodeCount       int                            `json:"max_node_count,omitempty" validate:"omitempty,gt=0,gtefield=MinNodeCount"`
	BootVolumeSize     int                            `json:"boot_volume_size,omitempty" validate:"omitempty,gt=0"`
	BootVolumeType     volumes.VolumeType             `json:"boot_volume_type,omitempty" validate:"omitempty,enum"`
	AutoHealingEnabled bool                           `json:"auto_healing_enabled,omitempty"`
	ServerGroupPolicy  servergroups.ServerGroupPolicy `json:"servergroup_policy,omitempty" validate:"omitempty,enum"`
	IsPublicIPv4       bool                           `json:"is_public_ipv4,omitempty"`
	Labels             map[string]string              `json:"labels,omitempty"`
	Taints             map[string]string              `json:"taints,omitempty"`
	CrioConfig         map[string]string              `json:"crio_config,omitempty" validate:"omitempty"`
	KubeletConfig      map[string]string              `json:"kubelet_config,omitempty" validate:"omitempty"`
}

CreateOpts represents options used to create a cluster Pool.

func (CreateOpts) ToClusterPoolCreateMap

func (opts CreateOpts) ToClusterPoolCreateMap() (map[string]interface{}, error)

ToClusterPoolCreateMap builds a request body from CreateOpts.

func (CreateOpts) Validate

func (opts CreateOpts) Validate() error

Validate CreateOpts

type CreateOptsBuilder

type CreateOptsBuilder interface {
	ToClusterPoolCreateMap() (map[string]interface{}, error)
}

CreateOptsBuilder allows extensions to add additional parameters to the Create request.

type GetResult

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

GetResult represents the result of a get operation. Call its Extract method to interpret it as a ClusterPool.

func Get

func Get(c *gcorecloud.ServiceClient, clusterName, poolName string) (r GetResult)

Get retrieves a specific cluster pool based on its name.

func (GetResult) Extract

func (r GetResult) Extract() (*ClusterPool, error)

Extract is a function that accepts a result and extracts a ClusterPool resource.

func (GetResult) ExtractInto

func (r GetResult) ExtractInto(v interface{}) error

type PoolTaskResult

type PoolTaskResult struct {
	K8sPools []string `json:"k8s_pools" mapstructure:"k8s_pools"`
}

type ResizeOpts

type ResizeOpts struct {
	NodeCount int `json:"node_count" required:"true" validate:"required,gt=0,lte=20"`
}

ResizeOpts represents options used to update a cluster.

func (ResizeOpts) ToClusterPoolResizeMap

func (opts ResizeOpts) ToClusterPoolResizeMap() (map[string]interface{}, error)

ToClusterPoolResizeMap builds a request body from ResizeOpts.

func (ResizeOpts) Validate

func (opts ResizeOpts) Validate() error

Validate ResizeOpts

type ResizeOptsBuilder

type ResizeOptsBuilder interface {
	ToClusterPoolResizeMap() (map[string]interface{}, error)
}

ResizeOptsBuilder allows extensions to add additional parameters to the Resize request.

type UpdateOpts

type UpdateOpts struct {
	AutoHealingEnabled *bool              `json:"auto_healing_enabled,omitempty"`
	MinNodeCount       int                `json:"min_node_count,omitempty" validate:"omitempty,gt=0,lte=100,ltefield=MaxNodeCount"`
	MaxNodeCount       int                `json:"max_node_count,omitempty" validate:"omitempty,gt=0,lte=100,gtefield=MinNodeCount"`
	Labels             *map[string]string `json:"labels,omitempty"`
	Taints             *map[string]string `json:"taints,omitempty"`
}

UpdateOpts represents options used to update a pool.

func (UpdateOpts) ToClusterPoolUpdateMap

func (opts UpdateOpts) ToClusterPoolUpdateMap() (map[string]interface{}, error)

ToClusterPoolUpdateMap builds a request body from UpdateOpts.

func (UpdateOpts) Validate

func (opts UpdateOpts) Validate() error

Validate UpdateOpts

type UpdateOptsBuilder

type UpdateOptsBuilder interface {
	ToClusterPoolUpdateMap() (map[string]interface{}, error)
}

UpdateOptsBuilder allows extensions to add additional parameters to the Update request.

type UpdateResult

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

UpdateResult represents the result of an update operation. Call its Extract method to interpret it as a ClusterPool.

func Update

func Update(c *gcorecloud.ServiceClient, clusterName, poolName string, opts UpdateOptsBuilder) (r UpdateResult)

Update accepts an UpdateOpts struct and updates an existing cluster pool using the values provided.

func (UpdateResult) Extract

func (r UpdateResult) Extract() (*ClusterPool, error)

Extract is a function that accepts a result and extracts a ClusterPool resource.

func (UpdateResult) ExtractInto

func (r UpdateResult) ExtractInto(v interface{}) error