controllers

Documentation

Index

• Constants
• type NodeController
  • func NewNodeController(clientset *kubernetes.Clientset) (*NodeController, error)
  • func (c *NodeController) Run(stopCh chan struct{})
• type SvcController
  • func NewSvcController(clientset *kubernetes.Clientset) (*SvcController, error)
  • func (c *SvcController) Run(stopCh chan struct{})

Constants

const (
	ReverseIPDomainEnv      = "REVERSE_IP_DOMAIN"
	DatabaseIDsEnv          = "DATABASE_IDS"
	RedisIDsEnv             = "REDIS_IDS"
	ReservedIPsPoolEnv      = "RESERVED_IPS_POOL"
	SecurityGroupIDs        = "SECURITY_GROUP_IDS"
	NumberRetries           = "NUMBER_RETRIES"
	NodesIPSource           = "NODES_IP_SOURCE"
	NodesIPSourceKubernetes = "kubernetes"
	NodeLabelReservedIP     = "reserved-ip"
)

Types

type NodeController

type NodeController struct {
	Wg sync.WaitGroup
	// contains filtered or unexported fields
}

func NewNodeController

func NewNodeController(clientset *kubernetes.Clientset) (*NodeController, error)

func (*NodeController) Run

func (c *NodeController) Run(stopCh chan struct{})

type SvcController

type SvcController struct {
	Wg sync.WaitGroup
	// contains filtered or unexported fields
}

func NewSvcController

func NewSvcController(clientset *kubernetes.Clientset) (*SvcController, error)

func (*SvcController) Run

func (c *SvcController) Run(stopCh chan struct{})