handles

Documentation

Index

• type LocalVertexHandle
  • func NewLocalVertexHandle(taskCh chan request.Request, ackCh chan request.Request) *LocalVertexHandle
  • func (h *LocalVertexHandle) Ack(req *request.Request)
  • func (h *LocalVertexHandle) AckRecv() chan request.Request
  • func (h *LocalVertexHandle) MsgRecv() chan request.Request
  • func (h *LocalVertexHandle) Send(req *request.Request)
• type SimpleWorkerHandle
  • func NewSimpleWorkerHandle() *SimpleWorkerHandle
  • func (t *SimpleWorkerHandle) Recv() chan request.Request
  • func (t *SimpleWorkerHandle) Send(req *request.Request) error
• type VertexHandle
• type WorkerHandle

Types

type LocalVertexHandle

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

func NewLocalVertexHandle

func NewLocalVertexHandle(
	taskCh chan request.Request,
	ackCh chan request.Request,
) *LocalVertexHandle

func (*LocalVertexHandle) Ack

func (h *LocalVertexHandle) Ack(req *request.Request)

func (*LocalVertexHandle) AckRecv

func (h *LocalVertexHandle) AckRecv() chan request.Request

func (*LocalVertexHandle) MsgRecv

func (h *LocalVertexHandle) MsgRecv() chan request.Request

func (*LocalVertexHandle) Send

func (h *LocalVertexHandle) Send(req *request.Request)

type SimpleWorkerHandle

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

func NewSimpleWorkerHandle

func NewSimpleWorkerHandle() *SimpleWorkerHandle

func (*SimpleWorkerHandle) Recv

func (t *SimpleWorkerHandle) Recv() chan request.Request

func (*SimpleWorkerHandle) Send

func (t *SimpleWorkerHandle) Send(req *request.Request) error

type VertexHandle

type VertexHandle interface {
	Send(req *request.Request)
	Ack(req *request.Request)
	MsgRecv() chan request.Request
	AckRecv() chan request.Request
}

VertexHandle is the handle that is held by worker to communicate with Vertex. If the vertex is within the scope of a worker, then the handler contains a chan. Otherwise it contains network sockets to communicate with workers in other processes.

type WorkerHandle

type WorkerHandle interface {
	Send(*request.Request) error
	Recv() chan request.Request
}