controller

Documentation

Index

• Variables
• func CreateKubeService(client kubernetes.Interface, namespace string, services ...*corev1.Service) error
• func Replicas(n int) []byte
• func WaitReady(store store.Storer, a *v1.AppService, timeout time.Duration, ...) error
• func WaitStop(store store.Storer, a *v1.AppService, timeout time.Duration, ...) error
• func WaitUpgradeReady(store store.Storer, a *v1.AppService, timeout time.Duration, ...) error
• type Controller
• type Manager
  • func NewManager(store store.Storer, client kubernetes.Interface, ...) *Manager
  • func (m *Manager) GetControllerSize() int
  • func (m *Manager) StartController(controllerType TypeController, apps ...v1.AppService) error
  • func (m *Manager) Stop() error
• type TypeController

Variables

var ErrWaitCancel = fmt.Errorf("Wait cancel")

ErrWaitCancel wait cancel

var ErrWaitTimeOut = fmt.Errorf("Wait time out")

ErrWaitTimeOut wait time out

Functions

func CreateKubeService

func CreateKubeService(client kubernetes.Interface, namespace string, services ...*corev1.Service) error

CreateKubeService create kube service

func Replicas

func Replicas(n int) []byte

Replicas petch replicas to n

func WaitReady

func WaitReady(store store.Storer, a *v1.AppService, timeout time.Duration, logger event.Logger, cancel chan struct{}) error

WaitReady wait ready

func WaitStop

func WaitStop(store store.Storer, a *v1.AppService, timeout time.Duration, logger event.Logger, cancel chan struct{}) error

WaitStop wait service stop complete

func WaitUpgradeReady

func WaitUpgradeReady(store store.Storer, a *v1.AppService, timeout time.Duration, logger event.Logger, cancel chan struct{}) error

WaitUpgradeReady wait upgrade success

Types

type Controller

type Controller interface {
	Begin()
	Stop() error
}

Controller service operating controller interface

type Manager

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

Manager controller manager

func NewManager

func NewManager(store store.Storer, client kubernetes.Interface, rbdNamespace, rbdDNSName string) *Manager

NewManager new manager

func (*Manager) GetControllerSize

func (m *Manager) GetControllerSize() int

GetControllerSize get running controller number

func (*Manager) StartController

func (m *Manager) StartController(controllerType TypeController, apps ...v1.AppService) error

StartController create and start service controller

func (*Manager) Stop

func (m *Manager) Stop() error

Stop stop all controller

type TypeController

type TypeController string

TypeController controller type

var TypeApplyConfigController TypeController = "apply_config"

TypeApplyConfigController -

var TypeApplyRuleController TypeController = "apply_rule"

TypeApplyRuleController -

var TypeControllerRefreshHPA TypeController = "refreshhpa"

TypeControllerRefreshHPA -

var TypeRestartController TypeController = "restart"

TypeRestartController restart service type

var TypeScalingController TypeController = "scaling"

TypeScalingController start service type

var TypeStartController TypeController = "start"

TypeStartController start service type

var TypeStopController TypeController = "stop"

TypeStopController start service type

var TypeUpgradeController TypeController = "upgrade"

TypeUpgradeController start service type