peer

Documentation

Index

• func NewRouter(self plan.PeerID) *router
• type Peer
  • func New() (*Peer, error)
  • func NewFromConfig(cfg *env.Config) (*Peer, error)
  • func (p *Peer) Close() error
  • func (p *Peer) CurrentSession() *session.Session
  • func (p *Peer) Detached() bool
  • func (p *Peer) ProposeNewSize(newSize int) error
  • func (p *Peer) Request(target plan.PeerID, version, name string, buf *base.Vector) (bool, error)
  • func (p *Peer) RequestRank(rank int, version, name string, buf *base.Vector) (bool, error)
  • func (p *Peer) ResizeCluster(newSize int) (bool, bool, error)
  • func (p *Peer) ResizeClusterFromURL() (bool, bool, error)
  • func (p *Peer) Save(name string, buf *base.Vector) error
  • func (p *Peer) SaveVersion(version, name string, buf *base.Vector) error
  • func (p *Peer) Start() error
  • func (p *Peer) UID() uint64
  • func (p *Peer) Update() bool

Functions

func NewRouter

func NewRouter(self plan.PeerID) *router

Types

type Peer

type Peer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New() (*Peer, error)

func NewFromConfig

func NewFromConfig(cfg *env.Config) (*Peer, error)

func (*Peer) Close

func (p *Peer) Close() error

func (*Peer) CurrentSession

func (p *Peer) CurrentSession() *session.Session

func (*Peer) Detached

func (p *Peer) Detached() bool

func (*Peer) ProposeNewSize

func (p *Peer) ProposeNewSize(newSize int) error

func (*Peer) Request

func (p *Peer) Request(target plan.PeerID, version, name string, buf *base.Vector) (bool, error)

func (*Peer) RequestRank

func (p *Peer) RequestRank(rank int, version, name string, buf *base.Vector) (bool, error)

func (*Peer) ResizeCluster

func (p *Peer) ResizeCluster(newSize int) (bool, bool, error)

func (*Peer) ResizeClusterFromURL

func (p *Peer) ResizeClusterFromURL() (bool, bool, error)

func (*Peer) Save

func (p *Peer) Save(name string, buf *base.Vector) error

func (*Peer) SaveVersion

func (p *Peer) SaveVersion(version, name string, buf *base.Vector) error

func (*Peer) Start

func (p *Peer) Start() error

func (*Peer) UID

func (p *Peer) UID() uint64

UID returns an immutable unique ID of this peer

func (*Peer) Update

func (p *Peer) Update() bool