orchestration

package
v0.0.0-...-add1e29 Latest Latest
Warning

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

Go to latest
Published: Jan 13, 2021 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() *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{})

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)
	// Starts the Orchestrator, watching for resources
	Start(stopCh <-chan struct{})

	Stop()
}

func NewOrchestrator

func NewOrchestrator() Orchestrator

type ResourceMeta

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

Jump to

Keyboard shortcuts

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