source

package
v5.0.0-release+incompa... Latest Latest
Warning

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

Go to latest
Published: Dec 29, 2018 License: LGPL-3.0 Imports: 24 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 {
	RegionAPI         string
	LBAPIPort         string
	Token             string
	Ctx               context.Context
	Cancel            context.CancelFunc
	CoreManager       core.Manager
	ClientSet         *kubernetes.Clientset
	ErrChan           chan error
	ServiceUpdateChan chan config.ServiceUpdate
	PodUpdateChan     chan config.PodUpdate
	// contains filtered or unexported fields
}

func NewSourceManager

func NewSourceManager(c option.Config, coreManager core.Manager, errChan chan error) *Manager

NewSourceManager new

func (*Manager) NodeIsReady

func (m *Manager) NodeIsReady(n *object.NodeObject) bool

NodeIsReady check node is ready TODO:

func (*Manager) PodsLW

func (m *Manager) PodsLW()

PodsLW watch TODO: 监听服务需要更健壮 如果退出了需要进程退出

func (*Manager) PoolIsReady

func (m *Manager) PoolIsReady(p *object.PoolObject) bool

PoolIsReady check pool whether ready if pool is exist ,it can be ready TODO:

func (*Manager) RcDomain

func (m *Manager) RcDomain(s *config.SourceBranch)

RcDomain RcDomain FROM API GET USER DOAMINS

func (*Manager) RcNode

func (m *Manager) RcNode(s *config.SourceBranch)

func (*Manager) RcPool

func (m *Manager) RcPool(s *config.SourceBranch)

RcPool RcPool

func (*Manager) RcRule

func (m *Manager) RcRule(s *config.SourceBranch)

RcRule TODO: FROM API GET USER DOAMINS CREATE RULE

func (*Manager) RcVS

func (m *Manager) RcVS(s *config.SourceBranch)

RcVS RcVS

func (*Manager) ServicesLW

func (m *Manager) ServicesLW()

ServicesLW service watch TODO: 监听服务需要更健壮 如果退出了需要进程退出

func (*Manager) Start

func (m *Manager) Start() error

Start 启动

func (*Manager) Stop

func (m *Manager) Stop() error

Stop 停止

func (*Manager) VSIsReady

func (m *Manager) VSIsReady(v *object.VirtualServiceObject) bool

VSIsReady check vs is ready TODO:

type ResponseBody

type ResponseBody struct {
	Bean     interface{}    `json:"bean,omitempty"`
	List     []model.Domain `json:"list,omitempty"`
	PageNum  int            `json:"pageNumber,omitempty"`
	PageSize int            `json:"pageSize,omitempty"`
	Total    int            `json:"total,omitempty"`
}

ResponseBody 返回主要内容体

type ResponseType

type ResponseType struct {
	Code      int          `json:"code"`
	Message   string       `json:"msg"`
	MessageCN string       `json:"msgcn"`
	Body      ResponseBody `json:"body,omitempty"`
}

ResponseType 返回内容

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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