session

Documentation

Index

• Constants
• type Session
  • func New(strategy kb.Strategy, self plan.PeerID, pl plan.PeerList, ...) (*Session, bool)
  • func (sess *Session) AllReduce(w Workspace) error
  • func (sess *Session) Barrier() error
  • func (sess *Session) Broadcast(w Workspace) error
  • func (sess *Session) BytesConsensus(bs []byte, name string) (bool, error)
  • func (sess *Session) ClusterSize() int
  • func (sess *Session) Consensus(w Workspace) error
  • func (sess *Session) Gather(w Workspace) error
  • func (sess *Session) GetPeerLatencies() []time.Duration
  • func (sess *Session) LocalRank() int
  • func (sess *Session) Rank() int
  • func (sess *Session) Reduce(w Workspace) error
  • func (sess *Session) Request(rank int, version, name string, buf *kb.Vector) (bool, error)
• type Workspace

Constants

const (
	Mi = 1 << 20
)

Types

type Session

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

Session contains the immutable topology and strategies for a given period of logical duration

func New

func New(strategy kb.Strategy, self plan.PeerID, pl plan.PeerList, client *client.Client, collectiveHandler *handler.CollectiveEndpoint, p2pHandler *handler.PeerToPeerEndpoint) (*Session, bool)

func (*Session) AllReduce

func (sess *Session) AllReduce(w Workspace) error

func (*Session) Barrier

func (sess *Session) Barrier() error

func (*Session) Broadcast

func (sess *Session) Broadcast(w Workspace) error

func (*Session) BytesConsensus

func (sess *Session) BytesConsensus(bs []byte, name string) (bool, error)

func (*Session) ClusterSize

func (sess *Session) ClusterSize() int

func (*Session) Consensus

func (sess *Session) Consensus(w Workspace) error

func (*Session) Gather

func (sess *Session) Gather(w Workspace) error

func (*Session) GetPeerLatencies

func (sess *Session) GetPeerLatencies() []time.Duration

func (*Session) LocalRank

func (sess *Session) LocalRank() int

func (*Session) Rank

func (sess *Session) Rank() int

func (*Session) Reduce

func (sess *Session) Reduce(w Workspace) error

func (*Session) Request

func (sess *Session) Request(rank int, version, name string, buf *kb.Vector) (bool, error)

type Workspace

type Workspace struct {
	SendBuf *kb.Vector
	RecvBuf *kb.Vector // TODO: if nil, will use SendBuf as in-place result
	OP      kb.OP
	Name    string
}

Workspace contains the data that a Kungfu operation will be performed on.