k8s

package

v0.0.0-...-b77c001 Latest Latest Go to latest Published: Dec 25, 2018 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Rendered for

View Source

const ID_BASE = 100000

This section is empty.

func GetNamespace(t int) string

func GetServiceName(t int) string

func GetServiceType(ns, svc string) int

给 k8s_api_windows.go 使用，不需要考虑效率问题

func RegisterNodeType(t int, ns, svc string)

type Endpoint struct {
	NodeType int
	Index    int
	IP       string
	Ports    map[string]int
}

func GetEndpoints(namespace, service string) ([]*Endpoint, error)

func NewEndpoint() *Endpoint

func (this *Endpoint) Id() uint32

type INode interface {
	OnNodeJoin(endpoint *Endpoint)
	OnNodeLeave(endpoint *Endpoint)
	GetBase() interface{}
}

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

func (this *Node) Close()

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

func (this *Node) Id() uint32

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

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

子类可以根据需要重载下面的方法

注意 OnNodeJoin 、 OnNodeLeave 在内部协程被调用，请注意多协程安全！！！

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

func (this *Node) Ports(name string) int

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

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

func NewWatch(nt *NodeType, ctx context.Context, d time.Duration, derived INode) *Watch

func (this *Watch) OnLoseEndpoint(index int)

Path	Synopsis
serverlist