node

Documentation

Index

• Variables
• type Node
  • func MakeNode(host, path string, port int) (*Node, error)
  • func Me(servernameIfExist bool) *Node
  • func MustNew(names []string) []*Node
  • func New(nodestr string) (*Node, error)
  • func (n *Node) Bye() bool
  • func (n *Node) Equals(nn *Node) bool
  • func (n *Node) GetherNodes() []*Node
  • func (n *Node) IsAllowed() bool
  • func (n *Node) Join() (*Node, error)
  • func (n *Node) Ping() (string, error)
  • func (n *Node) Talk(message string, fn func(string) error) ([]string, error)
  • func (n *Node) Toxstring() string
• type Slice
  • func NewSlice(names []string) Slice
  • func (ns Slice) Extend(a Slice) Slice
  • func (ns Slice) GetNodestrSlice() []string
  • func (ns Slice) Has(n *Node) bool
  • func (ns Slice) Len() int
  • func (ns Slice) ToMap() map[string]struct{}
  • func (ns Slice) Uniq() Slice

Variables

var InitNode = util.NewConfList(cfg.InitnodeList, defaultInitNode)

InitNode stores initial nodes.

Types

type Node

type Node struct {
	Nodestr string
}

Node represents node info.

func MakeNode

func MakeNode(host, path string, port int) (*Node, error)

MakeNode makes node from host info.

func Me

func Me(servernameIfExist bool) *Node

Me converts myself to *Node.

func MustNew

func MustNew(names []string) []*Node

MustNew makes node slice from names.

func New

func New(nodestr string) (*Node, error)

New checks nodestr format and returns node obj.

func (*Node) Bye

func (n *Node) Bye() bool

Bye says goodBye to n and returns true if success.

func (*Node) Equals

func (n *Node) Equals(nn *Node) bool

Equals return true is Nodestr is equal.

func (*Node) GetherNodes

func (n *Node) GetherNodes() []*Node

GetherNodes gethers nodes from n.

func (*Node) IsAllowed

func (n *Node) IsAllowed() bool

IsAllowed returns fase if n is not allowed and denied.

func (*Node) Join

func (n *Node) Join() (*Node, error)

Join requests n to Join me and return true and other node name if success.

func (*Node) Ping

func (n *Node) Ping() (string, error)

Ping pings to n and return response.

func (*Node) Talk

func (n *Node) Talk(message string, fn func(string) error) ([]string, error)

Talk talks with n with the message and returns data.

func (*Node) Toxstring

func (n *Node) Toxstring() string

Toxstring covnerts Nodestr to saku node format.

type Slice

type Slice []*Node

Slice is slice of node.

func NewSlice

func NewSlice(names []string) Slice

NewSlice makes node slice from names.

func (Slice) Extend

func (ns Slice) Extend(a Slice) Slice

Extend make a New nodeslice including specified slices.

func (Slice) GetNodestrSlice

func (ns Slice) GetNodestrSlice() []string

GetNodestrSlice returns slice of Nodestr of nodes.

func (Slice) Has

func (ns Slice) Has(n *Node) bool

Has returns true if ns has n.

func (Slice) Len

func (ns Slice) Len() int

Len returns size of nodes.

func (Slice) ToMap

func (ns Slice) ToMap() map[string]struct{}

ToMap returns map[nodestr]struct{}{} for searching a node.

func (Slice) Uniq

func (ns Slice) Uniq() Slice

Uniq solidate the slice.