orchestration

Documentation

Index

• Constants
• type K8sIPAMClient
  • func NewIPAMK8SClient(namespaces []string) *K8sIPAMClient
  • func (k8sc *K8sIPAMClient) SetupCommunicationChannels(reqChan chan<- ipamspec.IPAMRequest, respChan <-chan ipamspec.IPAMResponse)
  • func (k8sc *K8sIPAMClient) Start(stopCh <-chan struct{})
  • func (k8sc *K8sIPAMClient) Stop()
• type Orchestrator
  • func NewOrchestrator(namespaces []string) Orchestrator
• type ResourceMeta

Constants

const (
	CREATE = "Create"
	UPDATE = "Update"
	DELETE = "Delete"

	DefaultNamespace = "kube-system"
)

Types

type K8sIPAMClient

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

func NewIPAMK8SClient

func NewIPAMK8SClient(namespaces []string) *K8sIPAMClient

func (*K8sIPAMClient) SetupCommunicationChannels

func (k8sc *K8sIPAMClient) SetupCommunicationChannels(
	reqChan chan<- ipamspec.IPAMRequest,
	respChan <-chan ipamspec.IPAMResponse,
)

SetupCommunicationChannels sets Request and Response channels

func (*K8sIPAMClient) Start

func (k8sc *K8sIPAMClient) Start(stopCh <-chan struct{})

Start method runs the Orchestrator, watching for resources

func (*K8sIPAMClient) Stop

func (k8sc *K8sIPAMClient) Stop()

type Orchestrator

type Orchestrator interface {
	// SetupCommunicationChannels sets Request and Response channels
	SetupCommunicationChannels(reqChan chan<- ipamspec.IPAMRequest, respChan <-chan ipamspec.IPAMResponse)

	// Start starts the Orchestrator, watching for resources
	Start(stopCh <-chan struct{})

	Stop()
}

func NewOrchestrator

func NewOrchestrator(namespaces []string) Orchestrator

type ResourceMeta

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