orchestration

package
v0.1.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 3, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

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

	DefaultNamespace = "kube-system"
)

Variables

This section is empty.

Functions

This section is empty.

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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL