task

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 8, 2016 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package task is a generated protocol buffer package.

It is generated from these files: 

task/task.proto

It has these top-level messages: 

List
Value
Query
Result
Sort
SortResult
Num
RaftContext
Membership
MembershipUpdate
DirectedEdge
Mutations
Proposal
KV
KC
GroupKeys

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTask   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type DirectedEdge 

type DirectedEdge struct {
	Entity    uint64 `protobuf:"fixed64,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Attr      string `protobuf:"bytes,2,opt,name=attr,proto3" json:"attr,omitempty"`
	Value     []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	ValueType uint32 `protobuf:"varint,4,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"`
	ValueId   uint64 `protobuf:"fixed64,5,opt,name=value_id,json=valueId,proto3" json:"value_id,omitempty"`
	Label     string `protobuf:"bytes,6,opt,name=label,proto3" json:"label,omitempty"`
}

func (*DirectedEdge) Descriptor 

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

func (*DirectedEdge) Marshal 

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

func (*DirectedEdge) MarshalTo 

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

func (*DirectedEdge) ProtoMessage 

func (*DirectedEdge) ProtoMessage()

func (*DirectedEdge) Reset 

func (m *DirectedEdge) Reset()

func (*DirectedEdge) Size 

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

func (*DirectedEdge) String 

func (m *DirectedEdge) String() string

func (*DirectedEdge) Unmarshal 

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

type GroupKeys 

type GroupKeys struct {
	GroupId uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Keys    []*KC  `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
}

func (*GroupKeys) Descriptor 

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

func (*GroupKeys) GetKeys 

func (m *GroupKeys) GetKeys() []*KC

func (*GroupKeys) Marshal 

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

func (*GroupKeys) MarshalTo 

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

func (*GroupKeys) ProtoMessage 

func (*GroupKeys) ProtoMessage()

func (*GroupKeys) Reset 

func (m *GroupKeys) Reset()

func (*GroupKeys) Size 

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

func (*GroupKeys) String 

func (m *GroupKeys) String() string

func (*GroupKeys) Unmarshal 

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

type KC 

type KC struct {
	Key      []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Checksum []byte `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
}

func (*KC) Descriptor 

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

func (*KC) Marshal 

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

func (*KC) MarshalTo 

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

func (*KC) ProtoMessage 

func (*KC) ProtoMessage()

func (*KC) Reset 

func (m *KC) Reset()

func (*KC) Size 

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

func (*KC) String 

func (m *KC) String() string

func (*KC) Unmarshal 

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

type KV 

type KV struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Val []byte `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
}

func (*KV) Descriptor 

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

func (*KV) Marshal 

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

func (*KV) MarshalTo 

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

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) Reset 

func (m *KV) Reset()

func (*KV) Size 

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

func (*KV) String 

func (m *KV) String() string

func (*KV) Unmarshal 

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

type List 

type List struct {
	Uids []uint64 `protobuf:"fixed64,1,rep,name=uids" json:"uids,omitempty"`
}

func (*List) Descriptor 

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

func (*List) Marshal 

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

func (*List) MarshalTo 

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

func (*List) ProtoMessage 

func (*List) ProtoMessage()

func (*List) Reset 

func (m *List) Reset()

func (*List) Size 

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

func (*List) String 

func (m *List) String() string

func (*List) Unmarshal 

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

type Membership 

type Membership struct {
	Id         uint64 `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"`
	GroupId    uint32 `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Addr       string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	Leader     bool   `protobuf:"varint,4,opt,name=leader,proto3" json:"leader,omitempty"`
	AmDead     bool   `protobuf:"varint,5,opt,name=am_dead,json=amDead,proto3" json:"am_dead,omitempty"`
	LastUpdate uint64 `protobuf:"varint,6,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"`
}

Membership stores information about RAFT group membership for a single RAFT node. Note that each server can be serving multiple RAFT groups. Each group would have one RAFT node per server serving that group.

func (*Membership) Descriptor 

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

func (*Membership) Marshal 

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

func (*Membership) MarshalTo 

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

func (*Membership) ProtoMessage 

func (*Membership) ProtoMessage()

func (*Membership) Reset 

func (m *Membership) Reset()

func (*Membership) Size 

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

func (*Membership) String 

func (m *Membership) String() string

func (*Membership) Unmarshal 

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

type MembershipUpdate 

type MembershipUpdate struct {
	Members      []*Membership `protobuf:"bytes,1,rep,name=members" json:"members,omitempty"`
	LastUpdate   uint64        `protobuf:"varint,2,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"`
	Redirect     bool          `protobuf:"varint,3,opt,name=redirect,proto3" json:"redirect,omitempty"`
	RedirectAddr string        `protobuf:"bytes,4,opt,name=redirect_addr,json=redirectAddr,proto3" json:"redirect_addr,omitempty"`
}

MembershipUpdate is used to pack together the current membership state of all the nodes in the caller server; and the membership updates recorded by the callee server since the provided lastUpdate.

func (*MembershipUpdate) Descriptor 

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

func (*MembershipUpdate) GetMembers 

func (m *MembershipUpdate) GetMembers() []*Membership

func (*MembershipUpdate) Marshal 

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

func (*MembershipUpdate) MarshalTo 

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

func (*MembershipUpdate) ProtoMessage 

func (*MembershipUpdate) ProtoMessage()

func (*MembershipUpdate) Reset 

func (m *MembershipUpdate) Reset()

func (*MembershipUpdate) Size 

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

func (*MembershipUpdate) String 

func (m *MembershipUpdate) String() string

func (*MembershipUpdate) Unmarshal 

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

type Mutations 

type Mutations struct {
	GroupId uint32          `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Set     []*DirectedEdge `protobuf:"bytes,2,rep,name=set" json:"set,omitempty"`
	Del     []*DirectedEdge `protobuf:"bytes,3,rep,name=del" json:"del,omitempty"`
}

func (*Mutations) Descriptor 

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

func (*Mutations) GetDel 

func (m *Mutations) GetDel() []*DirectedEdge

func (*Mutations) GetSet 

func (m *Mutations) GetSet() []*DirectedEdge

func (*Mutations) Marshal 

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

func (*Mutations) MarshalTo 

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

func (*Mutations) ProtoMessage 

func (*Mutations) ProtoMessage()

func (*Mutations) Reset 

func (m *Mutations) Reset()

func (*Mutations) Size 

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

func (*Mutations) String 

func (m *Mutations) String() string

func (*Mutations) Unmarshal 

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

type Num 

type Num struct {
	Group uint32   `protobuf:"varint,1,opt,name=group,proto3" json:"group,omitempty"`
	Val   int64    `protobuf:"varint,2,opt,name=val,proto3" json:"val,omitempty"`
	Uids  []uint64 `protobuf:"varint,3,rep,name=uids" json:"uids,omitempty"`
}

func (*Num) Descriptor 

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

func (*Num) Marshal 

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

func (*Num) MarshalTo 

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

func (*Num) ProtoMessage 

func (*Num) ProtoMessage()

func (*Num) Reset 

func (m *Num) Reset()

func (*Num) Size 

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

func (*Num) String 

func (m *Num) String() string

func (*Num) Unmarshal 

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

type Proposal 

type Proposal struct {
	Id         uint32      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Mutations  *Mutations  `protobuf:"bytes,2,opt,name=mutations" json:"mutations,omitempty"`
	Membership *Membership `protobuf:"bytes,3,opt,name=membership" json:"membership,omitempty"`
}

func (*Proposal) Descriptor 

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

func (*Proposal) GetMembership 

func (m *Proposal) GetMembership() *Membership

func (*Proposal) GetMutations 

func (m *Proposal) GetMutations() *Mutations

func (*Proposal) Marshal 

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

func (*Proposal) MarshalTo 

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

func (*Proposal) ProtoMessage 

func (*Proposal) ProtoMessage()

func (*Proposal) Reset 

func (m *Proposal) Reset()

func (*Proposal) Size 

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

func (*Proposal) String 

func (m *Proposal) String() string

func (*Proposal) Unmarshal 

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

type Query 

type Query struct {
	Attr     string `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"`
	Count    int32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Offset   int32  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	AfterUid uint64 `protobuf:"fixed64,4,opt,name=after_uid,json=afterUid,proto3" json:"after_uid,omitempty"`
	DoCount  bool   `protobuf:"varint,5,opt,name=do_count,json=doCount,proto3" json:"do_count,omitempty"`
	// Exactly one of uids and terms is populated.
	Uids []uint64 `protobuf:"fixed64,6,rep,name=uids" json:"uids,omitempty"`
	// Function to generate or filter UIDs.
	SrcFunc []string `protobuf:"bytes,7,rep,name=src_func,json=srcFunc" json:"src_func,omitempty"`
}

func (*Query) Descriptor 

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

func (*Query) Marshal 

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

func (*Query) MarshalTo 

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

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) Size 

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

func (*Query) String 

func (m *Query) String() string

func (*Query) Unmarshal 

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

type RaftContext 

type RaftContext struct {
	Id    uint64 `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"`
	Group uint32 `protobuf:"varint,2,opt,name=group,proto3" json:"group,omitempty"`
	Addr  string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*RaftContext) Descriptor 

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

func (*RaftContext) Marshal 

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

func (*RaftContext) MarshalTo 

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

func (*RaftContext) ProtoMessage 

func (*RaftContext) ProtoMessage()

func (*RaftContext) Reset 

func (m *RaftContext) Reset()

func (*RaftContext) Size 

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

func (*RaftContext) String 

func (m *RaftContext) String() string

func (*RaftContext) Unmarshal 

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

type Result 

type Result struct {
	UidMatrix     []*List  `protobuf:"bytes,1,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"`
	Values        []*Value `protobuf:"bytes,2,rep,name=values" json:"values,omitempty"`
	Counts        []uint32 `protobuf:"varint,3,rep,name=counts" json:"counts,omitempty"`
	IntersectDest bool     `protobuf:"varint,4,opt,name=intersect_dest,json=intersectDest,proto3" json:"intersect_dest,omitempty"`
}

func (*Result) Descriptor 

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

func (*Result) GetUidMatrix 

func (m *Result) GetUidMatrix() []*List

func (*Result) GetValues 

func (m *Result) GetValues() []*Value

func (*Result) Marshal 

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

func (*Result) MarshalTo 

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

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) Size 

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

func (*Result) String 

func (m *Result) String() string

func (*Result) Unmarshal 

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

type Sort 

type Sort struct {
	Attr      string  `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"`
	UidMatrix []*List `protobuf:"bytes,2,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"`
	Count     int32   `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	Offset    int32   `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
}

func (*Sort) Descriptor 

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

func (*Sort) GetUidMatrix 

func (m *Sort) GetUidMatrix() []*List

func (*Sort) Marshal 

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

func (*Sort) MarshalTo 

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

func (*Sort) ProtoMessage 

func (*Sort) ProtoMessage()

func (*Sort) Reset 

func (m *Sort) Reset()

func (*Sort) Size 

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

func (*Sort) String 

func (m *Sort) String() string

func (*Sort) Unmarshal 

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

type SortResult 

type SortResult struct {
	UidMatrix []*List `protobuf:"bytes,1,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"`
}

func (*SortResult) Descriptor 

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

func (*SortResult) GetUidMatrix 

func (m *SortResult) GetUidMatrix() []*List

func (*SortResult) Marshal 

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

func (*SortResult) MarshalTo 

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

func (*SortResult) ProtoMessage 

func (*SortResult) ProtoMessage()

func (*SortResult) Reset 

func (m *SortResult) Reset()

func (*SortResult) Size 

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

func (*SortResult) String 

func (m *SortResult) String() string

func (*SortResult) Unmarshal 

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

type Value 

type Value struct {
	Val     []byte `protobuf:"bytes,1,opt,name=val,proto3" json:"val,omitempty"`
	ValType uint32 `protobuf:"varint,2,opt,name=val_type,json=valType,proto3" json:"val_type,omitempty"`
}

func (*Value) Descriptor 

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

func (*Value) Marshal 

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

func (*Value) MarshalTo 

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

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) Size 

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

func (*Value) String 

func (m *Value) String() string

func (*Value) Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.