source

package
v3.4.2+incompatible Latest Latest
Warning

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

 Go to latest Published: Feb 1, 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 返回内容

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.