k8sclient

Documentation

Index

• type Client
  • func New(cfg Config, podChanSize int) (*Client, error)
  • func (c *Client) AssignBinding(bindings []*k8stype.Binding) error
  • func (c *Client) GetNodeChan() NodeChan
  • func (c *Client) GetPodBatch(timeout time.Duration) []*k8stype.Pod
  • func (c *Client) GetUnscheduledPodChan() PodChan
• type Config
• type NodeChan
• type PodChan

Types

type Client

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

func New

func New(cfg Config, podChanSize int) (*Client, error)

func (*Client) AssignBinding

func (c *Client) AssignBinding(bindings []*k8stype.Binding) error

Write out node bindings

func (*Client) GetNodeChan

func (c *Client) GetNodeChan() NodeChan

func (*Client) GetPodBatch

func (c *Client) GetPodBatch(timeout time.Duration) []*k8stype.Pod

Returns a batch of pods or blocks until there is at least on pod creation call back The timeout specifies how long to wait for another pod on the pod channel before returning the batch of pods that need to be scheduled

func (*Client) GetUnscheduledPodChan

func (c *Client) GetUnscheduledPodChan() PodChan

type Config

type Config struct {
	Addr string
}

type NodeChan

type NodeChan <-chan *k8stype.Node

type PodChan

type PodChan <-chan *k8stype.Pod