source

Documentation

Index

• type Manager
  • func NewSourceManager(c option.Config, coreManager core.Manager, errChan chan error) *Manager
  • func (m *Manager) NodeIsReady(n *object.NodeObject) bool
  • func (m *Manager) PodsLW()
  • func (m *Manager) PoolIsReady(p *object.PoolObject) bool
  • func (m *Manager) RcDomain(s *config.SourceBranch)
  • func (m *Manager) RcNode(s *config.SourceBranch)
  • func (m *Manager) RcPool(s *config.SourceBranch)
  • func (m *Manager) RcRule(s *config.SourceBranch)
  • func (m *Manager) RcVS(s *config.SourceBranch)
  • func (m *Manager) ServicesLW()
  • func (m *Manager) Start() error
  • func (m *Manager) Stop() error
  • func (m *Manager) VSIsReady(v *object.VirtualServiceObject) bool
• type ResponseBody
• type ResponseType

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 返回内容