register

package

v1.19.1 Latest Latest Go to latest Published: Oct 25, 2022 License: MIT Imports: 6 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

This section is empty.

This section is empty.

This section is empty.

type DummyNode struct {
	Id string
}

DummyNode is dummy, it has an ID field which will be using as primary key

func (n *DummyNode) OwnsPayload(payload []byte) bool

func (n *DummyNode) Payload() []byte

func (n *DummyNode) PrimaryKey() string

type Node interface {
	PrimaryKey() string
	Payload() []byte

	// It knows if given payload was genereate from node
	OwnsPayload([]byte) bool
}

type NodeRegister struct {
	ZkServerAddresses string
	StateChan         chan ServiceState
	// contains filtered or unexported fields
}

NodeRegister is the low-level register for any type of nodes

func NewNodeRegister(zkServerAddresses string, baseKey string, node Node) *NodeRegister

func (r *NodeRegister) DoRegister() error

DoRegister register current node info to ZK Servers

func (r *NodeRegister) EnsureConn() error

EnsureConn connects to zookeeper server if needed

func (r *NodeRegister) GetRegisterKey() string

GetRegisterkey accepts a node and returns the key of zookeeper

func (r *NodeRegister) SendEmptyEvent()

func (r *NodeRegister) StartDiscover(timeoutSeconds int) error

StartDiscover watch for new events on current cluster node, will retry on connection errors

func (r *NodeRegister) Stop() error

type ServiceState struct {
	Nodes        int
	NodePayloads []string
	MyPostion    int
}

ServiceState is event for StartDiscover