controllers

package
v0.6.0 Latest Latest
Warning

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

Go to latest
Published: Jun 13, 2023 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Manager

type Manager struct {
	Config *config.ControllerConfig
}

Manager defines the controller manager

func New

New creates the controller manager

func (*Manager) Start

func (m *Manager) Start() error

Start starts the controllers it has managed

type Registry

type Registry map[string]FeatureFactory

func NewRegistry

func NewRegistry() Registry

type UpstreamController

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

UpstreamController subscribes the updates from edge and syncs to k8s api server

func NewUpstreamController

func NewUpstreamController(cc *runtime.ControllerContext) (*UpstreamController, error)

NewUpstreamController creates a new Upstream controller from config

func (*UpstreamController) Add

func (uc *UpstreamController) Add(kind string, handler runtime.UpstreamHandler) error

func (*UpstreamController) Run

func (uc *UpstreamController) Run(stopCh <-chan struct{})

Run starts the upstream controller

Jump to

Keyboard shortcuts

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