task

package

Go to main page

Versions in this module

v0

v0.7.1

Dec 26, 2016

Changes in this version

+ var DirectedEdge_Op_name = map[int32]string

+ var DirectedEdge_Op_value = map[string]int32

type DirectedEdge

+ Op DirectedEdge_Op

+ type DirectedEdge_Op int32

+ const DirectedEdge_DEL

+ const DirectedEdge_SET

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

+ func (x DirectedEdge_Op) String() string

type Mutations

+ Edges []*DirectedEdge

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

type Query

+ Reverse bool

type Sort

+ Desc bool

v0.7.0

Dec 8, 2016

Changes in this version

+ var ErrIntOverflowTask = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling")

+ type DirectedEdge struct

+ Attr string

+ Entity uint64

+ Label string

+ Value []byte

+ ValueId uint64

+ ValueType uint32

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

+ func (*DirectedEdge) ProtoMessage()

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

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

+ func (m *DirectedEdge) Reset()

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

+ func (m *DirectedEdge) String() string

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

+ type GroupKeys struct

+ GroupId uint32

+ Keys []*KC

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

+ func (*GroupKeys) ProtoMessage()

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

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

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

+ func (m *GroupKeys) Reset()

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

+ func (m *GroupKeys) String() string

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

+ type KC struct

+ Checksum []byte

+ Key []byte

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

+ func (*KC) ProtoMessage()

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

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

+ func (m *KC) Reset()

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

+ func (m *KC) String() string

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

type KV

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

+ func (*KV) ProtoMessage()

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

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

+ func (m *KV) Reset()

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

+ func (m *KV) String() string

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

+ type List struct

+ Uids []uint64

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

+ func (*List) ProtoMessage()

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

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

+ func (m *List) Reset()

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

+ func (m *List) String() string

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

+ type Membership struct

+ Addr string

+ AmDead bool

+ GroupId uint32

+ Id uint64

+ LastUpdate uint64

+ Leader bool

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

+ func (*Membership) ProtoMessage()

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

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

+ func (m *Membership) Reset()

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

+ func (m *Membership) String() string

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

+ type MembershipUpdate struct

+ LastUpdate uint64

+ Members []*Membership

+ Redirect bool

+ RedirectAddr string

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

+ func (*MembershipUpdate) ProtoMessage()

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

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

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

+ func (m *MembershipUpdate) Reset()

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

+ func (m *MembershipUpdate) String() string

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

+ type Mutations struct

+ Del []*DirectedEdge

+ GroupId uint32

+ Set []*DirectedEdge

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

+ func (*Mutations) ProtoMessage()

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

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

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

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

+ func (m *Mutations) Reset()

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

+ func (m *Mutations) String() string

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

+ type Num struct

+ Group uint32

+ Uids []uint64

+ Val int64

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

+ func (*Num) ProtoMessage()

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

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

+ func (m *Num) Reset()

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

+ func (m *Num) String() string

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

+ type Proposal struct

+ Id uint32

+ Membership *Membership

+ Mutations *Mutations

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

+ func (*Proposal) ProtoMessage()

+ func (m *Proposal) GetMembership() *Membership

+ func (m *Proposal) GetMutations() *Mutations

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

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

+ func (m *Proposal) Reset()

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

+ func (m *Proposal) String() string

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

type Query

+ DoCount bool

+ SrcFunc []string

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

+ func (*Query) ProtoMessage()

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

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

+ func (m *Query) Reset()

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

+ func (m *Query) String() string

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

+ type RaftContext struct

+ Addr string

+ Group uint32

+ Id uint64

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

+ func (*RaftContext) ProtoMessage()

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

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

+ func (m *RaftContext) Reset()

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

+ func (m *RaftContext) String() string

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

type Result

+ Counts []uint32

+ IntersectDest bool

+ UidMatrix []*List

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

+ func (*Result) ProtoMessage()

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

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

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

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

+ func (m *Result) Reset()

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

+ func (m *Result) String() string

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

+ type Sort struct

+ Attr string

+ Count int32

+ Offset int32

+ UidMatrix []*List

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

+ func (*Sort) ProtoMessage()

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

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

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

+ func (m *Sort) Reset()

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

+ func (m *Sort) String() string

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

+ type SortResult struct

+ UidMatrix []*List

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

+ func (*SortResult) ProtoMessage()

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

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

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

+ func (m *SortResult) Reset()

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

+ func (m *SortResult) String() string

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

type Value

+ ValType uint32

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

+ func (*Value) ProtoMessage()

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

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

+ func (m *Value) Reset()

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

+ func (m *Value) String() string

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

v0.4.4

Sep 1, 2016

Changes in this version

+ func KVAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)

+ func KVAddVal(builder *flatbuffers.Builder, val flatbuffers.UOffsetT)

+ func KVEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ func KVStart(builder *flatbuffers.Builder)

+ func KVStartKeyVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

+ func KVStartValVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

+ type KV struct

+ func (rcv *KV) Init(buf []byte, i flatbuffers.UOffsetT)

+ func (rcv *KV) Key(j int) byte

+ func (rcv *KV) KeyBytes() []byte

+ func (rcv *KV) KeyLength() int

+ func (rcv *KV) Val(j int) byte

+ func (rcv *KV) ValBytes() []byte

+ func (rcv *KV) ValLength() int

v0.4.3

Aug 11, 2016

Changes in this version

+ func QueryAddAfterUid(builder *flatbuffers.Builder, afterUid uint64)

+ func QueryAddGetCount(builder *flatbuffers.Builder, getCount uint16)

+ func ResultAddCount(builder *flatbuffers.Builder, count flatbuffers.UOffsetT)

+ func ResultStartCountVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

type Query

+ func (rcv *Query) AfterUid() uint64

+ func (rcv *Query) GetCount() uint16

+ func (rcv *Query) MutateAfterUid(n uint64) bool

+ func (rcv *Query) MutateCount(n int32) bool

+ func (rcv *Query) MutateGetCount(n uint16) bool

+ func (rcv *Query) MutateOffset(n int32) bool

type Result

+ func (rcv *Result) Count(j int) uint64

+ func (rcv *Result) CountLength() int

v0.4.2

Jul 13, 2016

v0.4.1

Jul 13, 2016

v0.4.0

Jul 11, 2016

Changes in this version

+ func QueryAddAttr(builder *flatbuffers.Builder, attr flatbuffers.UOffsetT)

+ func QueryAddCount(builder *flatbuffers.Builder, count int32)

+ func QueryAddOffset(builder *flatbuffers.Builder, offset int32)

+ func QueryAddUids(builder *flatbuffers.Builder, uids flatbuffers.UOffsetT)

+ func QueryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ func QueryStart(builder *flatbuffers.Builder)

+ func QueryStartUidsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

+ func ResultAddUidmatrix(builder *flatbuffers.Builder, uidmatrix flatbuffers.UOffsetT)

+ func ResultAddValues(builder *flatbuffers.Builder, values flatbuffers.UOffsetT)

+ func ResultEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ func ResultStart(builder *flatbuffers.Builder)

+ func ResultStartUidmatrixVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

+ func ResultStartValuesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

+ func UidListAddUids(builder *flatbuffers.Builder, uids flatbuffers.UOffsetT)

+ func UidListEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ func UidListStart(builder *flatbuffers.Builder)

+ func UidListStartUidsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

+ func ValueAddVal(builder *flatbuffers.Builder, val flatbuffers.UOffsetT)

+ func ValueEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ func ValueStart(builder *flatbuffers.Builder)

+ func ValueStartValVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

+ func XidListAddXids(builder *flatbuffers.Builder, xids flatbuffers.UOffsetT)

+ func XidListEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ func XidListStart(builder *flatbuffers.Builder)

+ func XidListStartXidsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

+ type Query struct

+ func (rcv *Query) Attr() []byte

+ func (rcv *Query) Count() int32

+ func (rcv *Query) Init(buf []byte, i flatbuffers.UOffsetT)

+ func (rcv *Query) Offset() int32

+ func (rcv *Query) Uids(j int) uint64

+ func (rcv *Query) UidsLength() int

+ type Result struct

+ func (rcv *Result) Init(buf []byte, i flatbuffers.UOffsetT)

+ func (rcv *Result) Uidmatrix(obj *UidList, j int) bool

+ func (rcv *Result) UidmatrixLength() int

+ func (rcv *Result) Values(obj *Value, j int) bool

+ func (rcv *Result) ValuesLength() int

+ type UidList struct

+ func (rcv *UidList) Init(buf []byte, i flatbuffers.UOffsetT)

+ func (rcv *UidList) Uids(j int) uint64

+ func (rcv *UidList) UidsLength() int

+ type Value struct

+ func (rcv *Value) Init(buf []byte, i flatbuffers.UOffsetT)

+ func (rcv *Value) Val(j int) byte

+ func (rcv *Value) ValBytes() []byte

+ func (rcv *Value) ValLength() int

+ type XidList struct

+ func (rcv *XidList) Init(buf []byte, i flatbuffers.UOffsetT)

+ func (rcv *XidList) Xids(j int) []byte

+ func (rcv *XidList) XidsLength() int

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