bee

Documentation

Index

• type Client
  • func NewClient(k8s *k8s.Client) (c *Client)
  • func (c *Client) Create(ctx context.Context, o k8s.CreateOptions) (err error)
  • func (c *Client) Delete(ctx context.Context, name, namespace string) (err error)
  • func (c *Client) Ready(ctx context.Context, name, namespace string) (ready bool, err error)
  • func (c *Client) RunningNodes(ctx context.Context, namespace string) (running []string, err error)
  • func (c *Client) Start(ctx context.Context, name, namespace string) (err error)
  • func (c *Client) Stop(ctx context.Context, name, namespace string) (err error)
  • func (c *Client) StoppedNodes(ctx context.Context, namespace string) (stopped []string, err error)
• type ClientOptions

Types

type Client

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

Client manages communication with the Kubernetes

func NewClient

func NewClient(k8s *k8s.Client) (c *Client)

NewClient returns Kubernetes clientset

func (*Client) Create

func (c *Client) Create(ctx context.Context, o k8s.CreateOptions) (err error)

Create creates Bee node in the cluster

func (*Client) Delete

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

Delete deletes Bee node from the cluster

func (*Client) Ready

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

Ready gets Bee node's readiness

func (*Client) RunningNodes

func (c *Client) RunningNodes(ctx context.Context, namespace string) (running []string, err error)

RunningNodes returns list of running nodes TODO: filter by labels

func (*Client) Start

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

Start starts Bee node in the cluster

func (*Client) Stop

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

Stop stops Bee node in the cluster

func (*Client) StoppedNodes

func (c *Client) StoppedNodes(ctx context.Context, namespace string) (stopped []string, err error)

StoppedNodes returns list of stopped nodes TODO: filter by labels

type ClientOptions

type ClientOptions struct {
	KubeconfigPath string
}

ClientOptions holds optional parameters for the Client.