cluster

package

v0.0.0-...-aaf6028 Latest Latest Go to latest Published: Apr 11, 2018 License: MIT Imports: 12 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

View Source

const (
	Proto_HTTP = iota
	Proto_OO
	Proto_KCP
)

View Source

var ClientPlugins = map[uint]ClientLoader{
	Proto_HTTP: ccHttp,
	Proto_OO:   ccOO,
	Proto_KCP:  ccKcp,
}

View Source

var ENodeError error = NodeError(0)

View Source

var ServerPlugins = map[uint]ListenerAndServer{
	Proto_HTTP: lasHttp,
	Proto_OO:   lasOO,
	Proto_KCP:  lasKCP,
}

This section is empty.

type ClientLoader func(*MetaData, net.IP) remote.HttpClient

type KCPOptions struct {
	DataShards   int
	ParityShards int
	Salsa20Key   []byte
	TurboMode    bool
	// contains filtered or unexported fields
}

type ListenerAndServer func(*MetaData, fasthttp.RequestHandler)

type MemberMap map[string]*OtherMember

type Membered struct {
	Router *remote.BucketRouter
	Meta   MetaData

	Ml     sync.Mutex
	Member MemberMap
}

func NewMembered() *Membered

func (m *Membered) AddLocal(bu *bucketstore.Bucket)

func (m *Membered) GetBroadcasts(overhead, limit int) [][]byte

func (m *Membered) ListenAndServe()

func (m *Membered) LocalState(join bool) []byte

func (m *Membered) MergeRemoteState(buf []byte, join bool)

func (m *Membered) NodeMeta(limit int) []byte

func (m *Membered) NotifyAlive(peer *memberlist.Node) error

func (m *Membered) NotifyJoin(n *memberlist.Node)

func (m *Membered) NotifyLeave(n *memberlist.Node)

func (m *Membered) NotifyMerge(peers []*memberlist.Node) error

func (m *Membered) NotifyMsg([]byte)

func (m *Membered) NotifyUpdate(n *memberlist.Node)

type MetaData struct {
	Buckets []string
	Proto   uint
	Port    uint
	KCP     KCPOptions
}

type NodeError int

func (a NodeError) Error() string

type OtherMember struct {
	Client remote.HttpClient
	Meta   MetaData
}