kungfu

Documentation

Index

• Constants
• type Kungfu
  • func New() (*Kungfu, error)
  • func (kf *Kungfu) Close() int
  • func (kf *Kungfu) CurrentSession() *session
  • func (kf *Kungfu) GetCheckpoint() string
  • func (kf *Kungfu) ResizeCluster(ckpt string, newSize int) (bool, error)
  • func (kf *Kungfu) Save(version, name string, buf *kb.Vector) error
  • func (kf *Kungfu) Start() int
  • func (kf *Kungfu) Update() bool
• type Workspace

Constants

const (
	Mi = 1 << 20
)

Types

type Kungfu

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

func New

func New() (*Kungfu, error)

func (*Kungfu) Close

func (kf *Kungfu) Close() int

func (*Kungfu) CurrentSession

func (kf *Kungfu) CurrentSession() *session

func (*Kungfu) GetCheckpoint

func (kf *Kungfu) GetCheckpoint() string

func (*Kungfu) ResizeCluster

func (kf *Kungfu) ResizeCluster(ckpt string, newSize int) (bool, error)

func (*Kungfu) Save

func (kf *Kungfu) Save(version, name string, buf *kb.Vector) error

func (*Kungfu) Start

func (kf *Kungfu) Start() int

func (*Kungfu) Update

func (kf *Kungfu) Update() bool

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.