cluster

package

v1.17.0 Latest Latest Go to latest Published: Aug 18, 2026 License: Apache-2.0 Imports: 40 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/unikorn-cloud/kubernetes

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Client
- func NewClient(client client.Client, options *Options, ...) *Client
type Options
- func (o *Options) AddFlags(f *pflag.FlagSet)

Constants ¶

This section is empty.

Variables ¶

View Source

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")
)

View Source

var (
	ErrConsistency = goerrors.New("consistency error")
)

Functions ¶

This section is empty.

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, options *Options, identity identityapi.ClientWithResponsesInterface, region *region.Client) *Client

NewClient returns a new client with required parameters.

func (*Client) Create ¶

func (c *Client) Create(ctx context.Context, appclient appBundleListerPlus, organizationID identityids.OrganizationID, projectID identityids.ProjectID, request *openapi.KubernetesClusterWrite) (*openapi.KubernetesClusterRead, error)

Create creates the implicit cluster identified by the JTW claims.

func (*Client) Delete ¶

func (c *Client) Delete(ctx context.Context, organizationID identityids.OrganizationID, projectID identityids.ProjectID, clusterID kubernetesids.KubernetesClusterID) error

Delete deletes the implicit cluster identified by the JTW claims.

func (*Client) GetKubeconfig ¶

func (c *Client) GetKubeconfig(ctx context.Context, organizationID identityids.OrganizationID, projectID identityids.ProjectID, clusterID kubernetesids.KubernetesClusterID) ([]byte, error)

GetKubeconfig returns the kubernetes configuation associated with a cluster.

func (*Client) List ¶

func (c *Client) List(ctx context.Context, organizationID identityids.OrganizationID, params openapi.GetApiV1OrganizationsOrganizationIDClustersParams) (openapi.KubernetesClusters, error)

List returns all clusters owned by the implicit control plane.

func (*Client) Update ¶

func (c *Client) Update(ctx context.Context, appclient appBundleLister, organizationID identityids.OrganizationID, projectID identityids.ProjectID, clusterID kubernetesids.KubernetesClusterID, request *openapi.KubernetesClusterWrite) error

Update implements read/modify/write for the cluster.

type Options ¶

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

func (*Options) AddFlags ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL