group

Documentation

Overview

All group memebership chagnes must go through this group

Index

• type Group
  • func JoinGroup(regReply RegisterReply, logger mlog.MLog, cb func(uint64), dataDir string) Group
  • func NewGroup(shards, failures uint, localPort, localAddress string, logger mlog.MLog, ...) Group
  • func (g *Group) AttachRSToGroup_local(rs RemoteServer) RegisterReply
  • func (g *Group) Coordinators() map[uint64]RemoteServer
  • func (g *Group) Delete(rs RemoteServer)
  • func (g *Group) GetCoordinator(d uint64) RemoteServer
  • func (g *Group) GetDaemon(d uint64) RemoteServer
  • func (g *Group) GetID() uint64
  • func (g *Group) GetNFailures() uint
  • func (g *Group) GetNShards() uint
  • func (g *Group) LocalAbort(rs RemoteServer)
  • func (g *Group) LocalCommit(rs RemoteServer)
  • func (g *Group) PreCommit(rs RemoteServer) bool

Types

type Group

type Group struct {
	// contains filtered or unexported fields
}

func JoinGroup

func JoinGroup(regReply RegisterReply, logger mlog.MLog, cb func(uint64), dataDir string) Group

func NewGroup

func NewGroup(shards, failures uint, localPort, localAddress string, logger mlog.MLog, cb func(uint64), dataDir string) Group

func (*Group) AttachRSToGroup_local

func (g *Group) AttachRSToGroup_local(rs RemoteServer) RegisterReply

this method does the two phase commit for a new server

func (*Group) Coordinators

func (g *Group) Coordinators() map[uint64]RemoteServer

func (*Group) Delete

func (g *Group) Delete(rs RemoteServer)

func (*Group) GetCoordinator

func (g *Group) GetCoordinator(d uint64) RemoteServer

func (*Group) GetDaemon

func (g *Group) GetDaemon(d uint64) RemoteServer

func (*Group) GetID

func (g *Group) GetID() uint64

func (*Group) GetNFailures

func (g *Group) GetNFailures() uint

func (*Group) GetNShards

func (g *Group) GetNShards() uint

func (*Group) LocalAbort

func (g *Group) LocalAbort(rs RemoteServer)

func (*Group) LocalCommit

func (g *Group) LocalCommit(rs RemoteServer)

func (*Group) PreCommit

func (g *Group) PreCommit(rs RemoteServer) bool