kubernetes

Documentation

Index

• Constants
• func GenerateLabelFilter(key, value string) (interface{}, error)
• func GenerateLabelFilterWithOp(key, op, value string) (interface{}, error)
• type Client
  • func New() (Client, error)
  • func (cl *Client) InitClient() error
  • func (cl *Client) ListBlockDevice(filters ...interface{}) ([]blockdevice.BlockDevice, error)
  • func (cl *Client) RegisterAPI() error
  • func (cl *Client) SetClient(client2 client.Client)

Constants

const (

	// KubernetesHostNameLabel is the kubernetes hostname label
	KubernetesHostNameLabel = kubernetesLabelPrefix + blockdevice.HostName

	// BlockDeviceTagLabel is the label used to tag a blockdevice for
	// a particular use case.
	// BlockDevices having this label can only be claimed by BDCs which
	// have a matching label selector.
	BlockDeviceTagLabel = openebsLabelPrefix + blockDeviceTag
)

const (
	// NamespaceENV is the name of environment variable to get the namespace
	NamespaceENV = "NAMESPACE"
)

Functions

func GenerateLabelFilter

func GenerateLabelFilter(key, value string) (interface{}, error)

GenerateLabelFilter is used to generate a label filter that can be used while listing resources

func GenerateLabelFilterWithOp

func GenerateLabelFilterWithOp(key, op, value string) (interface{}, error)

GenerateLabelFilterWithOp creates a label filter with the given operator between key and value

Types

type Client

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

Client is the wrapper over the k8s client that will be used by NDM to interface with etcd

func New

func New() (Client, error)

New creates a new client object using the default config

func (*Client) InitClient

func (cl *Client) InitClient() error

InitClient sets the client using the config

func (*Client) ListBlockDevice

func (cl *Client) ListBlockDevice(filters ...interface{}) ([]blockdevice.BlockDevice, error)

ListBlockDevice lists the block device from etcd based on the filters used

func (*Client) RegisterAPI

func (cl *Client) RegisterAPI() error

RegisterAPI registers the API scheme in the client using the manager. This function needs to be called only once a client object

func (*Client) SetClient

func (cl *Client) SetClient(client2 client.Client)

SetClient sets the given client