task

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: Dec 26, 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.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")
)
View Source 
var DirectedEdge_Op_name = map[int32]string{
	0: "SET",
	1: "DEL",
}
View Source 
var DirectedEdge_Op_value = map[string]int32{
	"SET": 0,
	"DEL": 1,
}

Functions

This section is empty.

Types

type DirectedEdge added in v0.7.0 

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"`
	Op        DirectedEdge_Op `protobuf:"varint,7,opt,name=op,proto3,enum=task.DirectedEdge_Op" json:"op,omitempty"`
}

func (*DirectedEdge) Descriptor added in v0.7.0 

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

func (*DirectedEdge) Marshal added in v0.7.0 

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

func (*DirectedEdge) MarshalTo added in v0.7.0 

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

func (*DirectedEdge) ProtoMessage added in v0.7.0 

func (*DirectedEdge) ProtoMessage()

func (*DirectedEdge) Reset added in v0.7.0 

func (m *DirectedEdge) Reset()

func (*DirectedEdge) Size added in v0.7.0 

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

func (*DirectedEdge) String added in v0.7.0 

func (m *DirectedEdge) String() string

func (*DirectedEdge) Unmarshal added in v0.7.0 

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

type DirectedEdge_Op added in v0.7.1 

type DirectedEdge_Op int32
const (
	DirectedEdge_SET DirectedEdge_Op = 0
	DirectedEdge_DEL DirectedEdge_Op = 1
)

func (DirectedEdge_Op) EnumDescriptor added in v0.7.1 

func (DirectedEdge_Op) EnumDescriptor() ([]byte, []int)

func (DirectedEdge_Op) String added in v0.7.1 

func (x DirectedEdge_Op) String() string

type GroupKeys added in v0.7.0 

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 added in v0.7.0 

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

func (*GroupKeys) GetKeys added in v0.7.0 

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

func (*GroupKeys) Marshal added in v0.7.0 

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

func (*GroupKeys) MarshalTo added in v0.7.0 

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

func (*GroupKeys) ProtoMessage added in v0.7.0 

func (*GroupKeys) ProtoMessage()

func (*GroupKeys) Reset added in v0.7.0 

func (m *GroupKeys) Reset()

func (*GroupKeys) Size added in v0.7.0 

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

func (*GroupKeys) String added in v0.7.0 

func (m *GroupKeys) String() string

func (*GroupKeys) Unmarshal added in v0.7.0 

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

type KC added in v0.7.0 

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 added in v0.7.0 

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

func (*KC) Marshal added in v0.7.0 

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

func (*KC) MarshalTo added in v0.7.0 

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

func (*KC) ProtoMessage added in v0.7.0 

func (*KC) ProtoMessage()

func (*KC) Reset added in v0.7.0 

func (m *KC) Reset()

func (*KC) Size added in v0.7.0 

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

func (*KC) String added in v0.7.0 

func (m *KC) String() string

func (*KC) Unmarshal added in v0.7.0 

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

type KV added in v0.4.4 

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 added in v0.7.0 

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

func (*KV) Marshal added in v0.7.0 

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

func (*KV) MarshalTo added in v0.7.0 

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

func (*KV) ProtoMessage added in v0.7.0 

func (*KV) ProtoMessage()

func (*KV) Reset added in v0.7.0 

func (m *KV) Reset()

func (*KV) Size added in v0.7.0 

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

func (*KV) String added in v0.7.0 

func (m *KV) String() string

func (*KV) Unmarshal added in v0.7.0 

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

type List added in v0.7.0 

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

func (*List) Descriptor added in v0.7.0 

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

func (*List) Marshal added in v0.7.0 

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

func (*List) MarshalTo added in v0.7.0 

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

func (*List) ProtoMessage added in v0.7.0 

func (*List) ProtoMessage()

func (*List) Reset added in v0.7.0 

func (m *List) Reset()

func (*List) Size added in v0.7.0 

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

func (*List) String added in v0.7.0 

func (m *List) String() string

func (*List) Unmarshal added in v0.7.0 

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

type Membership added in v0.7.0 

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 added in v0.7.0 

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

func (*Membership) Marshal added in v0.7.0 

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

func (*Membership) MarshalTo added in v0.7.0 

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

func (*Membership) ProtoMessage added in v0.7.0 

func (*Membership) ProtoMessage()

func (*Membership) Reset added in v0.7.0 

func (m *Membership) Reset()

func (*Membership) Size added in v0.7.0 

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

func (*Membership) String added in v0.7.0 

func (m *Membership) String() string

func (*Membership) Unmarshal added in v0.7.0 

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

type MembershipUpdate added in v0.7.0 

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 added in v0.7.0 

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

func (*MembershipUpdate) GetMembers added in v0.7.0 

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

func (*MembershipUpdate) Marshal added in v0.7.0 

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

func (*MembershipUpdate) MarshalTo added in v0.7.0 

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

func (*MembershipUpdate) ProtoMessage added in v0.7.0 

func (*MembershipUpdate) ProtoMessage()

func (*MembershipUpdate) Reset added in v0.7.0 

func (m *MembershipUpdate) Reset()

func (*MembershipUpdate) Size added in v0.7.0 

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

func (*MembershipUpdate) String added in v0.7.0 

func (m *MembershipUpdate) String() string

func (*MembershipUpdate) Unmarshal added in v0.7.0 

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

type Mutations added in v0.7.0 

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

func (*Mutations) Descriptor added in v0.7.0 

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

func (*Mutations) GetEdges added in v0.7.1 

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

func (*Mutations) Marshal added in v0.7.0 

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

func (*Mutations) MarshalTo added in v0.7.0 

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

func (*Mutations) ProtoMessage added in v0.7.0 

func (*Mutations) ProtoMessage()

func (*Mutations) Reset added in v0.7.0 

func (m *Mutations) Reset()

func (*Mutations) Size added in v0.7.0 

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

func (*Mutations) String added in v0.7.0 

func (m *Mutations) String() string

func (*Mutations) Unmarshal added in v0.7.0 

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

type Num added in v0.7.0 

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 added in v0.7.0 

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

func (*Num) Marshal added in v0.7.0 

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

func (*Num) MarshalTo added in v0.7.0 

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

func (*Num) ProtoMessage added in v0.7.0 

func (*Num) ProtoMessage()

func (*Num) Reset added in v0.7.0 

func (m *Num) Reset()

func (*Num) Size added in v0.7.0 

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

func (*Num) String added in v0.7.0 

func (m *Num) String() string

func (*Num) Unmarshal added in v0.7.0 

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

type Proposal added in v0.7.0 

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 added in v0.7.0 

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

func (*Proposal) GetMembership added in v0.7.0 

func (m *Proposal) GetMembership() *Membership

func (*Proposal) GetMutations added in v0.7.0 

func (m *Proposal) GetMutations() *Mutations

func (*Proposal) Marshal added in v0.7.0 

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

func (*Proposal) MarshalTo added in v0.7.0 

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

func (*Proposal) ProtoMessage added in v0.7.0 

func (*Proposal) ProtoMessage()

func (*Proposal) Reset added in v0.7.0 

func (m *Proposal) Reset()

func (*Proposal) Size added in v0.7.0 

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

func (*Proposal) String added in v0.7.0 

func (m *Proposal) String() string

func (*Proposal) Unmarshal added in v0.7.0 

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"`
	Reverse bool     `protobuf:"varint,8,opt,name=reverse,proto3" json:"reverse,omitempty"`
}

func (*Query) Descriptor added in v0.7.0 

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

func (*Query) Marshal added in v0.7.0 

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

func (*Query) MarshalTo added in v0.7.0 

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

func (*Query) ProtoMessage added in v0.7.0 

func (*Query) ProtoMessage()

func (*Query) Reset added in v0.7.0 

func (m *Query) Reset()

func (*Query) Size added in v0.7.0 

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

func (*Query) String added in v0.7.0 

func (m *Query) String() string

func (*Query) Unmarshal added in v0.7.0 

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

type RaftContext added in v0.7.0 

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 added in v0.7.0 

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

func (*RaftContext) Marshal added in v0.7.0 

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

func (*RaftContext) MarshalTo added in v0.7.0 

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

func (*RaftContext) ProtoMessage added in v0.7.0 

func (*RaftContext) ProtoMessage()

func (*RaftContext) Reset added in v0.7.0 

func (m *RaftContext) Reset()

func (*RaftContext) Size added in v0.7.0 

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

func (*RaftContext) String added in v0.7.0 

func (m *RaftContext) String() string

func (*RaftContext) Unmarshal added in v0.7.0 

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 added in v0.7.0 

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

func (*Result) GetUidMatrix added in v0.7.0 

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

func (*Result) GetValues added in v0.7.0 

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

func (*Result) Marshal added in v0.7.0 

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

func (*Result) MarshalTo added in v0.7.0 

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

func (*Result) ProtoMessage added in v0.7.0 

func (*Result) ProtoMessage()

func (*Result) Reset added in v0.7.0 

func (m *Result) Reset()

func (*Result) Size added in v0.7.0 

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

func (*Result) String added in v0.7.0 

func (m *Result) String() string

func (*Result) Unmarshal added in v0.7.0 

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

type Sort added in v0.7.0 

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"`
	Desc      bool    `protobuf:"varint,5,opt,name=desc,proto3" json:"desc,omitempty"`
}

func (*Sort) Descriptor added in v0.7.0 

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

func (*Sort) GetUidMatrix added in v0.7.0 

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

func (*Sort) Marshal added in v0.7.0 

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

func (*Sort) MarshalTo added in v0.7.0 

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

func (*Sort) ProtoMessage added in v0.7.0 

func (*Sort) ProtoMessage()

func (*Sort) Reset added in v0.7.0 

func (m *Sort) Reset()

func (*Sort) Size added in v0.7.0 

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

func (*Sort) String added in v0.7.0 

func (m *Sort) String() string

func (*Sort) Unmarshal added in v0.7.0 

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

type SortResult added in v0.7.0 

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

func (*SortResult) Descriptor added in v0.7.0 

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

func (*SortResult) GetUidMatrix added in v0.7.0 

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

func (*SortResult) Marshal added in v0.7.0 

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

func (*SortResult) MarshalTo added in v0.7.0 

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

func (*SortResult) ProtoMessage added in v0.7.0 

func (*SortResult) ProtoMessage()

func (*SortResult) Reset added in v0.7.0 

func (m *SortResult) Reset()

func (*SortResult) Size added in v0.7.0 

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

func (*SortResult) String added in v0.7.0 

func (m *SortResult) String() string

func (*SortResult) Unmarshal added in v0.7.0 

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 int32  `protobuf:"varint,2,opt,name=val_type,json=valType,proto3" json:"val_type,omitempty"`
}

func (*Value) Descriptor added in v0.7.0 

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

func (*Value) Marshal added in v0.7.0 

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

func (*Value) MarshalTo added in v0.7.0 

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

func (*Value) ProtoMessage added in v0.7.0 

func (*Value) ProtoMessage()

func (*Value) Reset added in v0.7.0 

func (m *Value) Reset()

func (*Value) Size added in v0.7.0 

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

func (*Value) String added in v0.7.0 

func (m *Value) String() string

func (*Value) Unmarshal added in v0.7.0 

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.