node

package
v0.0.0-...-ae8d93c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 31, 2015 License: GPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const PROTOCOLL_SIGNATURE uint8 = 0xA5

Variables

This section is empty.

Functions

func IsValidSignal

func IsValidSignal(d eventual2go.Data) bool

func NewSignalPayload

func NewSignalPayload(port uint16) (payload []byte)

func SignalToAdress

func SignalToAdress(d eventual2go.Data) eventual2go.Data

Types

type LeaveEvent

type LeaveEvent struct {
	Name string
}

type Node

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

func New

func New(uuid string, cfg *config.Config, tags map[string]string) (node *Node)

func (*Node) Join

func (n *Node) Join() *eventual2go.Stream

func (*Node) Leave

func (n *Node) Leave() *eventual2go.Stream

func (*Node) Queries

func (n *Node) Queries() *eventual2go.Stream

func (*Node) Query

func (n *Node) Query(name string, data []byte, results *eventual2go.StreamController)

func (*Node) Run

func (n *Node) Run()

func (*Node) Shutdown

func (n *Node) Shutdown()

type PeerAddress

type PeerAddress struct {
	IP   net.IP
	Port uint16
}

type QueryEvent

type QueryEvent struct {
	Address string
	Query   *serf.Query
}

type QueryResponseEvent

type QueryResponseEvent struct {
	Interface string
	Response  serf.NodeResponse
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL