ippool

Documentation

Index

• Constants
• type Controller
  • func NewController(queue workqueue.RateLimitingInterface, indexer cache.Indexer, ...) *Controller
  • func (c *Controller) Run(workers int, stopCh chan struct{})
• type Event
• type EventHandler
  • func NewEventHandler(ctx context.Context, ipam *ipam.IPAllocator, dhcp *dhcp.DHCPAllocator, ...) *EventHandler
  • func (e *EventHandler) EventListener() (err error)
  • func (e *EventHandler) Init() (err error)

Constants

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

const (
	APP_INIT    = 0
	APP_RUNNING = 1
	APP_RESTART = 2

	IPPOOL_NOCHANGE = 0
	IPPOOL_RELOAD   = 1
	IPPOOL_RESTART  = 2
)

Types

type Controller

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

func NewController

func NewController(
	queue workqueue.RateLimitingInterface,
	indexer cache.Indexer,
	informer cache.Controller,
	ctx context.Context,
	cache *kihcache.CacheAllocator,
	ipam *ipam.IPAllocator,
	dhcp *dhcp.DHCPAllocator,
	metrics *metrics.MetricsAllocator,
	kihClientset *kihclientset.Clientset,
	appStatus *int,
) *Controller

func (*Controller) Run

func (c *Controller) Run(workers int, stopCh chan struct{})

type Event

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

type EventHandler

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

func NewEventHandler

func NewEventHandler(
	ctx context.Context,
	ipam *ipam.IPAllocator,
	dhcp *dhcp.DHCPAllocator,
	metrics *metrics.MetricsAllocator,
	cache *kihcache.CacheAllocator,
	kubeConfig string,
	kubeContext string,
	kubeRestConfig *rest.Config,
	kihClientset *kihclientset.Clientset,
	appStatus *int,
) *EventHandler

func (*EventHandler) EventListener

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

func (*EventHandler) Init

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