task

package
v0.7.3 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2017 License: Apache-2.0 Imports: 6 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: 

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

Index

Constants

This section is empty.

Variables

View Source 
var (
	TrueVal  = FromBool(true)
	FalseVal = FromBool(false)
)
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

func ToBool added in v0.7.3 

func ToBool(val *Value) bool

func ToInt added in v0.7.3 

func ToInt(val *Value) int32

Types

type Block added in v0.7.3 

type Block struct {
	MaxInt uint64   `protobuf:"fixed64,2,opt,name=max_int,json=maxInt,proto3" json:"max_int,omitempty"`
	List   []uint64 `protobuf:"fixed64,1,rep,packed,name=list" json:"list,omitempty"`
}

func (*Block) Descriptor added in v0.7.3 

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

func (*Block) GetList added in v0.7.3 

func (m *Block) GetList() []uint64

func (*Block) GetMaxInt added in v0.7.3 

func (m *Block) GetMaxInt() uint64

func (*Block) Marshal added in v0.7.3 

func (m *Block) Marshal() (dAtA []byte, err error)

func (*Block) MarshalTo added in v0.7.3 

func (m *Block) MarshalTo(dAtA []byte) (int, error)

func (*Block) ProtoMessage added in v0.7.3 

func (*Block) ProtoMessage()

func (*Block) Reset added in v0.7.3 

func (m *Block) Reset()

func (*Block) Size added in v0.7.3 

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

func (*Block) String added in v0.7.3 

func (m *Block) String() string

func (*Block) Unmarshal added in v0.7.3 

func (m *Block) Unmarshal(dAtA []byte) error

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"`
	Lang      string          `protobuf:"bytes,7,opt,name=lang,proto3" json:"lang,omitempty"`
	Op        DirectedEdge_Op `protobuf:"varint,8,opt,name=op,proto3,enum=task.DirectedEdge_Op" json:"op,omitempty"`
	Facets    []*facets.Facet `protobuf:"bytes,9,rep,name=facets" json:"facets,omitempty"`
}

func (*DirectedEdge) Descriptor added in v0.7.0 

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

func (*DirectedEdge) GetAttr added in v0.7.2 

func (m *DirectedEdge) GetAttr() string

func (*DirectedEdge) GetEntity added in v0.7.2 

func (m *DirectedEdge) GetEntity() uint64

func (*DirectedEdge) GetFacets added in v0.7.3 

func (m *DirectedEdge) GetFacets() []*facets.Facet

func (*DirectedEdge) GetLabel added in v0.7.2 

func (m *DirectedEdge) GetLabel() string

func (*DirectedEdge) GetLang added in v0.7.3 

func (m *DirectedEdge) GetLang() string

func (*DirectedEdge) GetOp added in v0.7.2 

func (m *DirectedEdge) GetOp() DirectedEdge_Op

func (*DirectedEdge) GetValue added in v0.7.2 

func (m *DirectedEdge) GetValue() []byte

func (*DirectedEdge) GetValueId added in v0.7.2 

func (m *DirectedEdge) GetValueId() uint64

func (*DirectedEdge) GetValueType added in v0.7.2 

func (m *DirectedEdge) GetValueType() uint32

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) GetGroupId added in v0.7.2 

func (m *GroupKeys) GetGroupId() uint32

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) GetChecksum added in v0.7.2 

func (m *KC) GetChecksum() []byte

func (*KC) GetKey added in v0.7.2 

func (m *KC) GetKey() []byte

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) GetKey added in v0.7.2 

func (m *KV) GetKey() []byte

func (*KV) GetVal added in v0.7.2 

func (m *KV) GetVal() []byte

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 {
	Blocks []*Block `protobuf:"bytes,1,rep,name=blocks" json:"blocks,omitempty"`
}

func (*List) Descriptor added in v0.7.0 

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

func (*List) GetBlocks added in v0.7.3 

func (m *List) GetBlocks() []*Block

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) GetAddr added in v0.7.2 

func (m *Membership) GetAddr() string

func (*Membership) GetAmDead added in v0.7.2 

func (m *Membership) GetAmDead() bool

func (*Membership) GetGroupId added in v0.7.2 

func (m *Membership) GetGroupId() uint32

func (*Membership) GetId added in v0.7.2 

func (m *Membership) GetId() uint64

func (*Membership) GetLastUpdate added in v0.7.2 

func (m *Membership) GetLastUpdate() uint64

func (*Membership) GetLeader added in v0.7.2 

func (m *Membership) GetLeader() bool

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) GetLastUpdate added in v0.7.2 

func (m *MembershipUpdate) GetLastUpdate() uint64

func (*MembershipUpdate) GetMembers added in v0.7.0 

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

func (*MembershipUpdate) GetRedirect added in v0.7.2 

func (m *MembershipUpdate) GetRedirect() bool

func (*MembershipUpdate) GetRedirectAddr added in v0.7.2 

func (m *MembershipUpdate) GetRedirectAddr() string

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) GetGroupId added in v0.7.2 

func (m *Mutations) GetGroupId() uint32

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,packed,name=uids" json:"uids,omitempty"`
}

func (*Num) Descriptor added in v0.7.0 

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

func (*Num) GetGroup added in v0.7.2 

func (m *Num) GetGroup() uint32

func (*Num) GetUids added in v0.7.2 

func (m *Num) GetUids() []uint64

func (*Num) GetVal added in v0.7.2 

func (m *Num) GetVal() int64

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"`
	RebuildIndex *RebuildIndex `protobuf:"bytes,4,opt,name=rebuild_index,json=rebuildIndex" json:"rebuild_index,omitempty"`
}

func (*Proposal) Descriptor added in v0.7.0 

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

func (*Proposal) GetId added in v0.7.2 

func (m *Proposal) GetId() uint32

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) GetRebuildIndex added in v0.7.2 

func (m *Proposal) GetRebuildIndex() *RebuildIndex

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 *List `protobuf:"bytes,6,opt,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"`
	FacetParam *facets.Param `protobuf:"bytes,9,opt,name=facet_param,json=facetParam" json:"facet_param,omitempty"`
}

func (*Query) Descriptor added in v0.7.0 

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

func (*Query) GetAfterUid added in v0.7.2 

func (m *Query) GetAfterUid() uint64

func (*Query) GetAttr added in v0.7.2 

func (m *Query) GetAttr() string

func (*Query) GetCount added in v0.4.3 

func (m *Query) GetCount() int32

func (*Query) GetDoCount added in v0.7.2 

func (m *Query) GetDoCount() bool

func (*Query) GetFacetParam added in v0.7.3 

func (m *Query) GetFacetParam() *facets.Param

func (*Query) GetOffset added in v0.7.2 

func (m *Query) GetOffset() int32

func (*Query) GetReverse added in v0.7.2 

func (m *Query) GetReverse() bool

func (*Query) GetSrcFunc added in v0.7.2 

func (m *Query) GetSrcFunc() []string

func (*Query) GetUids added in v0.7.2 

func (m *Query) GetUids() *List

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) GetAddr added in v0.7.2 

func (m *RaftContext) GetAddr() string

func (*RaftContext) GetGroup added in v0.7.2 

func (m *RaftContext) GetGroup() uint32

func (*RaftContext) GetId added in v0.7.2 

func (m *RaftContext) GetId() uint64

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

type RebuildIndex struct {
	GroupId uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Attr    string `protobuf:"bytes,2,opt,name=attr,proto3" json:"attr,omitempty"`
}

func (*RebuildIndex) Descriptor added in v0.7.2 

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

func (*RebuildIndex) GetAttr added in v0.7.2 

func (m *RebuildIndex) GetAttr() string

func (*RebuildIndex) GetGroupId added in v0.7.2 

func (m *RebuildIndex) GetGroupId() uint32

func (*RebuildIndex) Marshal added in v0.7.2 

func (m *RebuildIndex) Marshal() (dAtA []byte, err error)

func (*RebuildIndex) MarshalTo added in v0.7.2 

func (m *RebuildIndex) MarshalTo(dAtA []byte) (int, error)

func (*RebuildIndex) ProtoMessage added in v0.7.2 

func (*RebuildIndex) ProtoMessage()

func (*RebuildIndex) Reset added in v0.7.2 

func (m *RebuildIndex) Reset()

func (*RebuildIndex) Size added in v0.7.2 

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

func (*RebuildIndex) String added in v0.7.2 

func (m *RebuildIndex) String() string

func (*RebuildIndex) Unmarshal added in v0.7.2 

func (m *RebuildIndex) 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,packed,name=counts" json:"counts,omitempty"`
	IntersectDest bool           `protobuf:"varint,4,opt,name=intersect_dest,json=intersectDest,proto3" json:"intersect_dest,omitempty"`
	FacetMatrix   []*facets.List `protobuf:"bytes,5,rep,name=facet_matrix,json=facetMatrix" json:"facet_matrix,omitempty"`
}

func (*Result) Descriptor added in v0.7.0 

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

func (*Result) GetCounts added in v0.7.2 

func (m *Result) GetCounts() []uint32

func (*Result) GetFacetMatrix added in v0.7.3 

func (m *Result) GetFacetMatrix() []*facets.List

func (*Result) GetIntersectDest added in v0.7.2 

func (m *Result) GetIntersectDest() bool

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) GetAttr added in v0.7.2 

func (m *Sort) GetAttr() string

func (*Sort) GetCount added in v0.7.2 

func (m *Sort) GetCount() int32

func (*Sort) GetDesc added in v0.7.2 

func (m *Sort) GetDesc() bool

func (*Sort) GetOffset added in v0.7.2 

func (m *Sort) GetOffset() int32

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

func FromBool(val bool) *Value

func FromInt added in v0.7.3 

func FromInt(val int) *Value

func (*Value) Descriptor added in v0.7.0 

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

func (*Value) GetVal added in v0.7.2 

func (m *Value) GetVal() []byte

func (*Value) GetValType added in v0.7.2 

func (m *Value) GetValType() int32

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.