client

Documentation

Index

• type Client
  • func New(ctx context.Context) (*Client, error)
  • func NewWithRegion(ctx context.Context, region string) (*Client, error)
  • func (c *Client) AutoscalingCloudProvider() string
  • func (c *Client) CreateNode(ctx context.Context, scalingGroupID string) (nodeName, providerID string, err error)
  • func (c *Client) DeleteNode(ctx context.Context, providerID string) error
  • func (c *Client) GetAutoscalingGroupName(scalingGroupID string) (string, error)
  • func (c *Client) GetNodeImage(ctx context.Context, providerID string) (string, error)
  • func (c *Client) GetNodeState(ctx context.Context, providerID string) (updatev1alpha1.CSPNodeState, error)
  • func (c *Client) GetScalingGroupID(ctx context.Context, providerID string) (string, error)
  • func (c *Client) GetScalingGroupImage(ctx context.Context, scalingGroupID string) (string, error)
  • func (c *Client) GetScalingGroupName(scalingGroupID string) (string, error)
  • func (c *Client) ListScalingGroups(ctx context.Context, uid string) ([]cspapi.ScalingGroup, error)
  • func (c *Client) SetScalingGroupImage(ctx context.Context, scalingGroupID, imageURI string) error

Types

type Client

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

Client is a client for the AWS Cloud.

func New

func New(ctx context.Context) (*Client, error)

New creates a client with initialized clients.

func NewWithRegion

func NewWithRegion(ctx context.Context, region string) (*Client, error)

NewWithRegion creates a client with initialized clients and a given region.

func (*Client) AutoscalingCloudProvider

func (c *Client) AutoscalingCloudProvider() string

AutoscalingCloudProvider returns the cloud-provider name as used by k8s cluster-autoscaler.

func (*Client) CreateNode

func (c *Client) CreateNode(ctx context.Context, scalingGroupID string) (nodeName, providerID string, err error)

CreateNode creates a node in the specified scaling group.

func (*Client) DeleteNode

func (c *Client) DeleteNode(ctx context.Context, providerID string) error

DeleteNode deletes a node from the specified scaling group.

func (*Client) GetAutoscalingGroupName

func (c *Client) GetAutoscalingGroupName(scalingGroupID string) (string, error)

GetAutoscalingGroupName retrieves the name of a scaling group as needed by the cluster-autoscaler.

func (*Client) GetNodeImage

func (c *Client) GetNodeImage(ctx context.Context, providerID string) (string, error)

GetNodeImage returns the image name of the node.

func (*Client) GetNodeState

func (c *Client) GetNodeState(ctx context.Context, providerID string) (updatev1alpha1.CSPNodeState, error)

GetNodeState returns the state of the node.

func (*Client) GetScalingGroupID

func (c *Client) GetScalingGroupID(ctx context.Context, providerID string) (string, error)

GetScalingGroupID returns the scaling group ID of the node.

func (*Client) GetScalingGroupImage

func (c *Client) GetScalingGroupImage(ctx context.Context, scalingGroupID string) (string, error)

GetScalingGroupImage returns the image URI of the scaling group.

func (*Client) GetScalingGroupName

func (c *Client) GetScalingGroupName(scalingGroupID string) (string, error)

GetScalingGroupName retrieves the name of a scaling group. This keeps the casing of the original name, but Kubernetes requires the name to be lowercase, so use strings.ToLower() on the result if using the name in a Kubernetes context.

func (*Client) ListScalingGroups

func (c *Client) ListScalingGroups(ctx context.Context, uid string) ([]cspapi.ScalingGroup, error)

ListScalingGroups retrieves a list of scaling groups for the cluster.

func (*Client) SetScalingGroupImage

func (c *Client) SetScalingGroupImage(ctx context.Context, scalingGroupID, imageURI string) error

SetScalingGroupImage sets the image URI of the scaling group.