Documentation ¶
Index ¶
- Constants
- type Peer
- func (self *Peer) AddPeer(peer *ring.Peer) (err error)
- func (self *Peer) AsPeer() (result *ring.Peer)
- func (self *Peer) AssertResponsibility(key []byte) (err error)
- func (self *Peer) Continue(r *ring.Ring) (err error)
- func (self *Peer) Dump() (result string, err error)
- func (self *Peer) LeaderForward(method string, input interface{}, output interface{}) (forwarded bool, err error)
- func (self *Peer) Name() string
- func (self *Peer) Pos() (result []byte)
- func (self *Peer) Raft() raft.Server
- func (self *Peer) RaftDo(cmd raft.Command) (result interface{}, err error)
- func (self *Peer) Recovery(b []byte) (err error)
- func (self *Peer) RemovePeer(name string) (err error)
- func (self *Peer) Ring() *ring.Ring
- func (self *Peer) Save() (b []byte, err error)
- func (self *Peer) Start(join string) (err error)
- func (self *Peer) Stop() (err error)
- func (self *Peer) Storage() *storage.DB
- func (self *Peer) String() string
- func (self *Peer) WhileRunning(f func() error) error
Constants ¶
View Source
const (
NBackups = 2
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Peer ¶
type Peer struct {
// contains filtered or unexported fields
}
func (*Peer) AssertResponsibility ¶
func (*Peer) LeaderForward ¶
func (*Peer) RemovePeer ¶
func (*Peer) WhileRunning ¶
Click to show internal directories.
Click to hide internal directories.