worker

package

v0.4.3 Latest Latest Go to latest Published: Aug 11, 2016 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/anacrolix/dgraph

Links

Open Source Insights

README ¶

To update the protocol buffer definitions, run this from one directory above:

protoc -I worker worker/payload.proto --go_out=plugins=grpc:worker

Documentation ¶

Overview ¶

Package worker is a generated protocol buffer package.

It is generated from these files:

payload.proto

It has these top-level messages:

Payload

Index ¶

Variables
func Connect(workerList []string)
func GetOrAssignUidsOverNetwork(ctx context.Context, xidToUid *map[string]uint64) (rerr error)
func Init(ps, uStore *store.Store, idx, numInst uint64)
func NewQuery(attr string, uids []uint64) []byte
func ProcessTaskOverNetwork(ctx context.Context, qu []byte) (result []byte, rerr error)
func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)
type Mutations
- func MutateOverNetwork(ctx context.Context, m Mutations) (left Mutations, rerr error)
- func (m *Mutations) Decode(data []byte) error
- func (m *Mutations) Encode() (data []byte, rerr error)
type Payload
- func (*Payload) Descriptor() ([]byte, []int)
- func (m *Payload) Marshal() (data []byte, err error)
- func (m *Payload) MarshalTo(data []byte) (int, error)
- func (*Payload) ProtoMessage()
- func (m *Payload) Reset()
- func (m *Payload) Size() (n int)
- func (m *Payload) String() string
- func (m *Payload) Unmarshal(data []byte) error
type PayloadCodec
- func (cb *PayloadCodec) Marshal(v interface{}) ([]byte, error)
- func (cb *PayloadCodec) String() string
- func (cb *PayloadCodec) Unmarshal(data []byte, v interface{}) error
type Pool
- func NewPool(addr string, maxCap int) *Pool
- func (p *Pool) Get() (*grpc.ClientConn, error)
- func (p *Pool) Put(conn *grpc.ClientConn) error
type WorkerClient
- func NewWorkerClient(cc *grpc.ClientConn) WorkerClient
type WorkerServer

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrInvalidLengthPayload = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPayload   = fmt.Errorf("proto: integer overflow")
)

Functions ¶

func Connect ¶

func Connect(workerList []string)

func GetOrAssignUidsOverNetwork ¶

func GetOrAssignUidsOverNetwork(ctx context.Context, xidToUid *map[string]uint64) (rerr error)

func Init ¶

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

func NewQuery ¶

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

func ProcessTaskOverNetwork ¶

func ProcessTaskOverNetwork(ctx context.Context, qu []byte) (result []byte, rerr error)

func RegisterWorkerServer ¶

func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)

Types ¶

type Mutations ¶

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

Mutations stores the directed edges for both the set and delete operations.

func MutateOverNetwork ¶

func MutateOverNetwork(ctx context.Context, m Mutations) (left Mutations, rerr error)

MutateOverNetwork checks which instance should be running the mutations according to fingerprint of the predicate and sends it to that instance.

func (*Mutations) Decode ¶

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

Decode decodes the mutation from a byte slice after receiving the byte slie over the network.

func (*Mutations) Encode ¶

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

Encode gob encodes the mutation which is then sent over to the instance which is supposed to run it.

type Payload ¶

type Payload struct {
	Data []byte `protobuf:"bytes,1,opt,name=Data,json=data,proto3" json:"Data,omitempty"`
}

func (*Payload) Descriptor ¶

func (*Payload) Descriptor() ([]byte, []int)

func (*Payload) Marshal ¶ added in v0.4.3

func (m *Payload) Marshal() (data []byte, err error)

func (*Payload) MarshalTo ¶ added in v0.4.3

func (m *Payload) MarshalTo(data []byte) (int, error)

func (*Payload) ProtoMessage ¶

func (*Payload) ProtoMessage()

func (*Payload) Reset ¶

func (m *Payload) Reset()

func (*Payload) Size ¶ added in v0.4.3

func (m *Payload) Size() (n int)

func (*Payload) String ¶

func (m *Payload) String() string

func (*Payload) Unmarshal ¶ added in v0.4.3

func (m *Payload) Unmarshal(data []byte) error

type PayloadCodec ¶

type PayloadCodec struct{}

func (*PayloadCodec) Marshal ¶

func (cb *PayloadCodec) Marshal(v interface{}) ([]byte, error)

func (*PayloadCodec) String ¶

func (cb *PayloadCodec) String() string

func (*PayloadCodec) Unmarshal ¶

func (cb *PayloadCodec) Unmarshal(data []byte, v interface{}) error

type Pool ¶

type Pool struct {
	Addr string
	// contains filtered or unexported fields
}

func NewPool ¶

func NewPool(addr string, maxCap int) *Pool

func (*Pool) Get ¶

func (p *Pool) Get() (*grpc.ClientConn, error)

func (*Pool) Put ¶

func (p *Pool) Put(conn *grpc.ClientConn) error

type WorkerClient ¶

type WorkerClient interface {
	Hello(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
	GetOrAssign(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
	Mutate(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
	ServeTask(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
}

func NewWorkerClient ¶

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerServer ¶

type WorkerServer interface {
	Hello(context.Context, *Payload) (*Payload, error)
	GetOrAssign(context.Context, *Payload) (*Payload, error)
	Mutate(context.Context, *Payload) (*Payload, error)
	ServeTask(context.Context, *Payload) (*Payload, error)
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL