discovery

Documentation

Index

• func SetNode(node *Node)
• type IMap
• type IServers
  • func NewServersPolicyRoundRobin() IServers
• type Node
  • func GetNode() *Node
  • func NewNode() *Node
  • func (this *Node) GetBase() interface{}
  • func (this *Node) Init(nodeType int, watchNodeTypes []int, d time.Duration, inst k8s.INode) error
  • func (this *Node) OnNodeJoin(endpoint *k8s.Endpoint)
  • func (this *Node) OnNodeLeave(endpoint *k8s.Endpoint)
• type Servers
  • func NewServers(creator func() IMap) *Servers
  • func (this *Servers) Count(nodeType int) int
  • func (this *Servers) Delete(nodeType int, id uint32)
  • func (this *Servers) GetAll(nodeType int) ([]*k8s.Endpoint, bool)
  • func (this *Servers) GetByID(id uint32) (m *k8s.Endpoint, ok bool)
  • func (this *Servers) GetOne(nodeType int) (uint32, *k8s.Endpoint, bool)
  • func (this *Servers) Set(nodeType int, id uint32, val *k8s.Endpoint)
• type ServersPolicyRoundRobin
  • func (this *ServersPolicyRoundRobin) GetOne() (key, val interface{}, ok bool)

Functions

func SetNode

func SetNode(node *Node)

Types

type IMap

type IMap interface {
	GetOne() (key, val interface{}, ok bool)

	Set(key interface{}, val interface{}) bool
	Delete(key interface{})
	Iterator() *gomap.Iterator
	Count() int
}

type IServers

type IServers interface {
	GetOne(nodeType int) (uint32, *k8s.Endpoint, bool)
	GetAll(nodeType int) ([]*k8s.Endpoint, bool)
	Set(nodeType int, id uint32, val *k8s.Endpoint)
	Delete(nodeType int, id uint32)
	GetByID(id uint32) (*k8s.Endpoint, bool)
	Count(nodeType int) int
}

func NewServersPolicyRoundRobin

func NewServersPolicyRoundRobin() IServers

type Node

type Node struct {
	k8s.Node
	Servers IServers
	// contains filtered or unexported fields
}

func GetNode

func GetNode() *Node

func NewNode

func NewNode() *Node

func (*Node) GetBase

func (this *Node) GetBase() interface{}

func (*Node) Init

func (this *Node) Init(nodeType int, watchNodeTypes []int, d time.Duration, inst k8s.INode) error

func (*Node) OnNodeJoin

func (this *Node) OnNodeJoin(endpoint *k8s.Endpoint)

func (*Node) OnNodeLeave

func (this *Node) OnNodeLeave(endpoint *k8s.Endpoint)

type Servers

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

func NewServers

func NewServers(creator func() IMap) *Servers

func (*Servers) Count

func (this *Servers) Count(nodeType int) int

func (*Servers) Delete

func (this *Servers) Delete(nodeType int, id uint32)

func (*Servers) GetAll

func (this *Servers) GetAll(nodeType int) ([]*k8s.Endpoint, bool)

func (*Servers) GetByID

func (this *Servers) GetByID(id uint32) (m *k8s.Endpoint, ok bool)

func (*Servers) GetOne

func (this *Servers) GetOne(nodeType int) (uint32, *k8s.Endpoint, bool)

func (*Servers) Set

func (this *Servers) Set(nodeType int, id uint32, val *k8s.Endpoint)

type ServersPolicyRoundRobin

type ServersPolicyRoundRobin struct {
	gomap.RoundRobinMap
}

func (*ServersPolicyRoundRobin) GetOne

func (this *ServersPolicyRoundRobin) GetOne() (key, val interface{}, ok bool)