controllers

Documentation

Index

• type FeatureFactory
• type Manager
  • func New(cc *config.ControllerConfig) *Manager
  • func (m *Manager) Start() error
• type Registry
  • func NewRegistry() Registry
• type UpstreamController
  • func NewUpstreamController(cc *runtime.ControllerContext) (*UpstreamController, error)
  • func (uc *UpstreamController) Add(kind string, handler runtime.UpstreamHandler) error
  • func (uc *UpstreamController) Run(stopCh <-chan struct{})

Types

type FeatureFactory

type FeatureFactory = func(*runtime.ControllerContext) (runtime.FeatureControllerI, error)

type Manager

type Manager struct {
	Config *config.ControllerConfig
}

Manager defines the controller manager

func New

func New(cc *config.ControllerConfig) *Manager

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