controller

Documentation

Index

• type ContainerType
  • func (ct ContainerType) String() string
• type Controller
  • func NewController(kubeClient *kubernetes.Clientset, ...) (*Controller, error)
  • func (c *Controller) Process(e *Event)
  • func (c *Controller) Run(ctx context.Context, nodeName string) error
• type Event
• type EventQueue
  • func (eq *EventQueue) Dequeue() *Event
  • func (eq *EventQueue) Enqueue(event *Event)
• type OpType
• type Runtime

Types

type ContainerType

type ContainerType int

ContainerType defines the type if continer used to support the pods

const (
	// Docker type container
	Docker ContainerType = iota

	// Crio type container
	Crio
)

func (ContainerType) String

func (ct ContainerType) String() string

type Controller

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

Controller the controller object

func NewController

func NewController(kubeClient *kubernetes.Clientset, endpoint, cniBinPath, cniConfPath, cniVendor string, containerType ContainerType) (*Controller, error)

NewController instantiate a docker controller object

func (*Controller) Process

func (c *Controller) Process(e *Event)

Process will take a element from the FIFO queue and attempt to process it (either add or remove network)

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, nodeName string) error

Run starts a Pod resource controller

type Event

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

Event struct

type EventQueue

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

EventQueue is a FIFO type queue

func (*EventQueue) Dequeue

func (eq *EventQueue) Dequeue() *Event

Dequeue will remove the first element from the queue and return it for processing. The caller MUST use the mutex provided by the EventQueue struct

func (*EventQueue) Enqueue

func (eq *EventQueue) Enqueue(event *Event)

Enqueue will push the new event in the FIFO queue If a similar event already exists with a opposite operation type, both event will be discarded.

type OpType

type OpType int

const (
	Add OpType = iota
	Delete
)

type Runtime

type Runtime interface {
	// GetNetNS returns the network namespace of the given containerID. The ID
	// supplied is typically the ID of a pod sandbox. This getter doesn't try
	// to map non-sandbox IDs to their respective sandboxes.
	GetNetNS(podSandboxID string) (string, error)

	// GetSandboxID returns kubernete's docker "pause" container ID
	GetSandboxID(containerID string) (string, error)
}

Runtime interface