ippool

Documentation

Index

• Constants
• type Controller
  • func NewController(queue workqueue.RateLimitingInterface, indexer cache.Indexer, ...) *Controller
  • func (c *Controller) Run(workers int)
  • func (c *Controller) Stop()
  • func (c *Controller) Update(ipPool *networkv1.IPPool) error
• type Event
• type EventHandler
  • func NewEventHandler(kubeConfig string, kubeContext string, kubeRestConfig *rest.Config, ...) *EventHandler
  • func (e *EventHandler) EventListener(ctx context.Context)
  • func (e *EventHandler) Init() (err error)

Constants

const (
	ADD    = "add"
	UPDATE = "update"
	DELETE = "delete"
)

Types

type Controller

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

func NewController

func NewController(
	queue workqueue.RateLimitingInterface,
	indexer cache.Indexer,
	informer cache.Controller,
	poolRef types.NamespacedName,
	dhcpAllocator *dhcp.DHCPAllocator,
	poolCache map[string]string,
) *Controller

func (*Controller) Run

func (c *Controller) Run(workers int)

func (*Controller) Stop

func (c *Controller) Stop()

func (*Controller) Update

func (c *Controller) Update(ipPool *networkv1.IPPool) error

type Event

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

type EventHandler

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

func NewEventHandler

func NewEventHandler(
	kubeConfig string,
	kubeContext string,
	kubeRestConfig *rest.Config,
	poolRef types.NamespacedName,
	dhcpAllocator *dhcp.DHCPAllocator,
	poolCache map[string]string,
) *EventHandler

func (*EventHandler) EventListener

func (e *EventHandler) EventListener(ctx context.Context)

func (*EventHandler) Init

func (e *EventHandler) Init() (err error)