kube

Documentation

Index

• type Client
  • func NewClient(kubeconfig string) (*Client, error)
  • func (c *Client) Apply(manifests []byte) error
  • func (c *Client) DeleteCluster(ctx context.Context, name, namespace string) error
  • func (c *Client) DeleteEtcdCluster(ctx context.Context, name, namespace string) error
  • func (c *Client) GetCluster(ctx context.Context, name, namespace string) (*greptimev1alpha1.GreptimeDBCluster, error)
  • func (c *Client) IsStatefulSetReady(ctx context.Context, name, namespace string) (bool, error)
  • func (c *Client) ListClusters(ctx context.Context) (*greptimev1alpha1.GreptimeDBClusterList, error)
  • func (c *Client) UpdateCluster(ctx context.Context, namespace string, ...) error
  • func (c *Client) WaitForClusterReady(name, namespace string, timeout time.Duration) error
  • func (c *Client) WaitForDeploymentReady(name, namespace string, timeout time.Duration) error
  • func (c *Client) WaitForEtcdReady(name, namespace string, timeout time.Duration) error

Types

type Client

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

func NewClient

func NewClient(kubeconfig string) (*Client, error)

func (*Client) Apply

func (c *Client) Apply(manifests []byte) error

func (*Client) DeleteCluster

func (c *Client) DeleteCluster(ctx context.Context, name, namespace string) error

func (*Client) DeleteEtcdCluster

func (c *Client) DeleteEtcdCluster(ctx context.Context, name, namespace string) error

func (*Client) GetCluster

func (c *Client) GetCluster(ctx context.Context, name, namespace string) (*greptimev1alpha1.GreptimeDBCluster, error)

func (*Client) IsStatefulSetReady

func (c *Client) IsStatefulSetReady(ctx context.Context, name, namespace string) (bool, error)

func (*Client) ListClusters

func (c *Client) ListClusters(ctx context.Context) (*greptimev1alpha1.GreptimeDBClusterList, error)

func (*Client) UpdateCluster

func (c *Client) UpdateCluster(ctx context.Context, namespace string, cluster *greptimev1alpha1.GreptimeDBCluster) error

func (*Client) WaitForClusterReady

func (c *Client) WaitForClusterReady(name, namespace string, timeout time.Duration) error

func (*Client) WaitForDeploymentReady

func (c *Client) WaitForDeploymentReady(name, namespace string, timeout time.Duration) error

func (*Client) WaitForEtcdReady

func (c *Client) WaitForEtcdReady(name, namespace string, timeout time.Duration) error