worker

package

v0.0.0-...-e3835e8 Latest Latest Go to latest Published: Apr 14, 2016 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

func Connect(workerList []string)

func GetOrAssignUidsOverNetwork(xidToUid *map[string]uint64) (rerr error)

func Init(ps, uStore *store.Store, idx, numInst uint64)

func MutateOverNetwork(
	edges []x.DirectedEdge) (left []x.DirectedEdge, rerr error)

func NewQuery(attr string, uids []uint64) []byte

func ProcessTaskOverNetwork(qu []byte) (result []byte, rerr error)

type Mutations struct {
	Set []x.DirectedEdge
	Del []x.DirectedEdge
}

func (m *Mutations) Decode(data []byte) error

func (m *Mutations) Encode() (data []byte, rerr error)

type Worker struct {
}

func (w *Worker) GetOrAssign(query *conn.Query,
	reply *conn.Reply) (rerr error)

func (w *Worker) Hello(query *conn.Query, reply *conn.Reply) error

func (w *Worker) Mutate(query *conn.Query, reply *conn.Reply) (rerr error)

func (w *Worker) ServeTask(query *conn.Query, reply *conn.Reply) (rerr error)