cluster

Documentation

Index

• Variables
• type Client
  • func NewClient(client client.Client, namespace string, options *Options, ...) *Client
  • func (c *Client) Create(ctx context.Context, organizationID, projectID string, ...) (*openapi.KubernetesClusterRead, error)
  • func (c *Client) Delete(ctx context.Context, organizationID, projectID, clusterID string) error
  • func (c *Client) GetKubeconfig(ctx context.Context, organizationID, projectID, clusterID string) ([]byte, error)
  • func (c *Client) List(ctx context.Context, organizationID string) (openapi.KubernetesClusters, error)
  • func (c *Client) Update(ctx context.Context, organizationID, projectID, clusterID string, ...) error
• type Options
  • func (o *Options) AddFlags(f *pflag.FlagSet)

Variables

var (
	// ErrResourceLookup is raised when we are looking for a referenced resource
	// but cannot find it.
	ErrResourceLookup = goerrors.New("could not find the requested resource")

	// ErrUnhandledCase is raised when an unhandled switch case is encountered.
	ErrUnhandledCase = goerrors.New("handled case")
)

Types

type Client

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

Client wraps up cluster related management handling.

func NewClient

func NewClient(client client.Client, namespace string, options *Options, region regionapi.ClientWithResponsesInterface) *Client

NewClient returns a new client with required parameters.

func (*Client) Create

func (c *Client) Create(ctx context.Context, organizationID, projectID string, request *openapi.KubernetesClusterWrite) (*openapi.KubernetesClusterRead, error)

Create creates the implicit cluster indentified by the JTW claims.

func (*Client) Delete

func (c *Client) Delete(ctx context.Context, organizationID, projectID, clusterID string) error

Delete deletes the implicit cluster indentified by the JTW claims.

func (*Client) GetKubeconfig

func (c *Client) GetKubeconfig(ctx context.Context, organizationID, projectID, clusterID string) ([]byte, error)

GetKubeconfig returns the kubernetes configuation associated with a cluster.

func (*Client) List

func (c *Client) List(ctx context.Context, organizationID string) (openapi.KubernetesClusters, error)

List returns all clusters owned by the implicit control plane.

func (*Client) Update

func (c *Client) Update(ctx context.Context, organizationID, projectID, clusterID string, request *openapi.KubernetesClusterWrite) error

Update implements read/modify/write for the cluster.

type Options

type Options struct {
	NodeNetwork    net.IPNet
	ServiceNetwork net.IPNet
	PodNetwork     net.IPNet
	DNSNameservers []net.IP
}

func (*Options) AddFlags

func (o *Options) AddFlags(f *pflag.FlagSet)