node

Documentation

Index

• Variables
• type Client
  • func New(cfg *ClientConfig) *Client
  • func (sc *Client) GetNodes(ctx context.Context) (nodes NodeList, err error)
• type ClientConfig
• type DeploymentType
• type Node
  • func NewNode(client *api.Client, name string) *Node
  • func (n *Node) Client() *api.Client
  • func (n *Node) Name() string
• type NodeList
  • func (ns NodeList) Get(name string) *Node
• type NodeProvider
• type NotSet
  • func (n *NotSet) GetNodes(ctx context.Context) (NodeList, error)

Variables

var ErrNotSet = errors.New("node client not initialized")

ErrNotSet represents error when NodeClient is not set

Types

type Client

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

func New

func New(cfg *ClientConfig) *Client

func (*Client) GetNodes

func (sc *Client) GetNodes(ctx context.Context) (nodes NodeList, err error)

type ClientConfig

type ClientConfig struct {
	Log            logging.Logger
	HTTPClient     *http.Client
	K8sClient      *k8s.Client
	BeeClients     map[string]*bee.Client
	Namespace      string
	LabelSelector  string
	DeploymentType DeploymentType
	InCluster      bool
	UseNamespace   bool // Overrides the usage of the bee clients
}

type DeploymentType

type DeploymentType string

const (
	DeploymentTypeBeekeeper DeploymentType = "beekeeper"
	DeploymentTypeHelm      DeploymentType = "helm"
)

type Node

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

func NewNode

func NewNode(client *api.Client, name string) *Node

func (*Node) Client

func (n *Node) Client() *api.Client

func (*Node) Name

func (n *Node) Name() string

type NodeList

type NodeList []Node

func (NodeList) Get

func (ns NodeList) Get(name string) *Node

type NodeProvider

type NodeProvider interface {
	GetNodes(ctx context.Context) (NodeList, error)
}

type NotSet

type NotSet struct{}

func (*NotSet) GetNodes

func (n *NotSet) GetNodes(ctx context.Context) (NodeList, error)

GetNodes implements NodeProvider.