intern

package

Go to main page

Versions in this module

v1

v1.0.9-rc5

Sep 25, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.9-rc4

Sep 20, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.9-rc3

Sep 18, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.9-rc2

Sep 15, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.9-rc1

Sep 13, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.8-rc2

Aug 29, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.8-rc1

Aug 24, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.7-rc4

Jul 27, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.7-rc3

Jul 19, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.7-rc2

Jul 19, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.6-rc1

Jul 1, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.4

Mar 9, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

Changes in this version

type SchemaUpdate

+ Upsert bool

+ func (m *SchemaUpdate) GetUpsert() bool

v1.0.3

Feb 7, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.2

Jan 17, 2018 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

Changes in this version

type RaftContext

+ SnapshotTs uint64

+ func (m *RaftContext) GetSnapshotTs() uint64

type Result

+ List bool

+ func (m *Result) GetList() bool

+ type SnapshotMeta struct

+ ClientTs uint64

+ GroupId uint32

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

+ func (*SnapshotMeta) ProtoMessage()

+ func (m *SnapshotMeta) GetClientTs() uint64

+ func (m *SnapshotMeta) GetGroupId() uint32

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

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

+ func (m *SnapshotMeta) Reset()

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

+ func (m *SnapshotMeta) String() string

+ func (m *SnapshotMeta) Unmarshal(dAtA []byte) error

v1.0.1

Dec 20, 2017 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v1.0.0

Dec 18, 2017 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

Changes in this version

type Tablet

+ Remove bool

+ func (m *Tablet) GetRemove() bool

v0

v0.9.4

Dec 4, 2017 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

v0.9.3

Dec 1, 2017 GO-2026-5274 +6 more

GO-2026-5274: Dgraph: Unauthenticated admin token disclosure via /debug/pprof/cmdline in github.com/dgraph-io/dgraph

GO-2026-5516: Pre-Auth DQL injection in upsert condition field in github.com/dgraph-io/dgraph

GO-2026-5529: Unauthenticated restoreTenant mutation allows database overwrite and SSRF in github.com/dgraph-io/dgraph

GO-2026-5675: Unauthenticated admin token disclosure via /debug/vars in github.com/dgraph-io/dgraph

GO-2026-5749: DQL injection via unsanitized NQuad Lang field in github.com/dgraph-io/dgraph

GO-2026-5837: DQL injection via checkUserPassword GraphQL query in github.com/dgraph-io/dgraph

GO-2026-6261: Dgraph Alpha group stores can be replaced via unauthenticated external snapshot import in github.com/dgraph-io/dgraph

Changes in this version

+ var DirectedEdge_Op_name = map[int32]string

+ var DirectedEdge_Op_value = map[string]int32

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

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

+ var ExportPayload_Status_name = map[int32]string

+ var ExportPayload_Status_value = map[string]int32

+ var Posting_PostingType_name = map[int32]string

+ var Posting_PostingType_value = map[string]int32

+ var Posting_ValType_name = map[int32]string

+ var Posting_ValType_value = map[string]int32

+ var SchemaUpdate_Directive_name = map[int32]string

+ var SchemaUpdate_Directive_value = map[string]int32

+ func RegisterRaftServer(s *grpc.Server, srv RaftServer)

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

+ func RegisterZeroServer(s *grpc.Server, srv ZeroServer)

+ type ConnectionState struct

+ Member *Member

+ State *MembershipState

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

+ func (*ConnectionState) ProtoMessage()

+ func (m *ConnectionState) GetMember() *Member

+ func (m *ConnectionState) GetState() *MembershipState

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

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

+ func (m *ConnectionState) Reset()

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

+ func (m *ConnectionState) String() string

+ func (m *ConnectionState) Unmarshal(dAtA []byte) error

+ type DirectedEdge struct

+ Attr string

+ Entity uint64

+ Facets []*api.Facet

+ Label string

+ Lang string

+ Op DirectedEdge_Op

+ Value []byte

+ ValueId uint64

+ ValueType Posting_ValType

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

+ func (*DirectedEdge) ProtoMessage()

+ func (m *DirectedEdge) GetAttr() string

+ func (m *DirectedEdge) GetEntity() uint64

+ func (m *DirectedEdge) GetFacets() []*api.Facet

+ func (m *DirectedEdge) GetLabel() string

+ func (m *DirectedEdge) GetLang() string

+ func (m *DirectedEdge) GetOp() DirectedEdge_Op

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

+ func (m *DirectedEdge) GetValueId() uint64

+ func (m *DirectedEdge) GetValueType() Posting_ValType

+ 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 DirectedEdge_Op int32

+ const DirectedEdge_DEL

+ const DirectedEdge_SET

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

+ func (x DirectedEdge_Op) String() string

+ type ExportPayload struct

+ GroupId uint32

+ ReadTs uint64

+ ReqId uint64

+ Status ExportPayload_Status

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

+ func (*ExportPayload) ProtoMessage()

+ func (m *ExportPayload) GetGroupId() uint32

+ func (m *ExportPayload) GetReadTs() uint64

+ func (m *ExportPayload) GetReqId() uint64

+ func (m *ExportPayload) GetStatus() ExportPayload_Status

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

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

+ func (m *ExportPayload) Reset()

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

+ func (m *ExportPayload) String() string

+ func (m *ExportPayload) Unmarshal(dAtA []byte) error

+ type ExportPayload_Status int32

+ const ExportPayload_DUPLICATE

+ const ExportPayload_FAILED

+ const ExportPayload_NONE

+ const ExportPayload_SUCCESS

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

+ func (x ExportPayload_Status) String() string

+ type FacetParam struct

+ Alias string

+ Key string

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

+ func (*FacetParam) ProtoMessage()

+ func (m *FacetParam) GetAlias() string

+ func (m *FacetParam) GetKey() string

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

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

+ func (m *FacetParam) Reset()

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

+ func (m *FacetParam) String() string

+ func (m *FacetParam) Unmarshal(dAtA []byte) error

+ type FacetParams struct

+ AllKeys bool

+ Param []*FacetParam

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

+ func (*FacetParams) ProtoMessage()

+ func (m *FacetParams) GetAllKeys() bool

+ func (m *FacetParams) GetParam() []*FacetParam

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

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

+ func (m *FacetParams) Reset()

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

+ func (m *FacetParams) String() string

+ func (m *FacetParams) Unmarshal(dAtA []byte) error

+ type Facets struct

+ Facets []*api.Facet

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

+ func (*Facets) ProtoMessage()

+ func (m *Facets) GetFacets() []*api.Facet

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

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

+ func (m *Facets) Reset()

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

+ func (m *Facets) String() string

+ func (m *Facets) Unmarshal(dAtA []byte) error

+ type FacetsList struct

+ FacetsList []*Facets

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

+ func (*FacetsList) ProtoMessage()

+ func (m *FacetsList) GetFacetsList() []*Facets

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

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

+ func (m *FacetsList) Reset()

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

+ func (m *FacetsList) String() string

+ func (m *FacetsList) Unmarshal(dAtA []byte) error

+ type FilterTree struct

+ Children []*FilterTree

+ Func *Function

+ Op string

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

+ func (*FilterTree) ProtoMessage()

+ func (m *FilterTree) GetChildren() []*FilterTree

+ func (m *FilterTree) GetFunc() *Function

+ func (m *FilterTree) GetOp() string

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

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

+ func (m *FilterTree) Reset()

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

+ func (m *FilterTree) String() string

+ func (m *FilterTree) Unmarshal(dAtA []byte) error

+ type Function struct

+ Args []string

+ Key string

+ Name string

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

+ func (*Function) ProtoMessage()

+ func (m *Function) GetArgs() []string

+ func (m *Function) GetKey() string

+ func (m *Function) GetName() string

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

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

+ func (m *Function) Reset()

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

+ func (m *Function) String() string

+ func (m *Function) Unmarshal(dAtA []byte) error

+ type Group struct

+ Members map[uint64]*Member

+ Tablets map[string]*Tablet

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

+ func (*Group) ProtoMessage()

+ func (m *Group) GetMembers() map[uint64]*Member

+ func (m *Group) GetTablets() map[string]*Tablet

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

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

+ func (m *Group) Reset()

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

+ func (m *Group) String() string

+ func (m *Group) Unmarshal(dAtA []byte) error

+ type GroupKeys struct

+ GroupId uint32

+ Keys []*KC

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

+ func (*GroupKeys) ProtoMessage()

+ func (m *GroupKeys) GetGroupId() uint32

+ 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

+ Key []byte

+ Timestamp uint64

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

+ func (*KC) ProtoMessage()

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

+ func (m *KC) GetTimestamp() uint64

+ 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 struct

+ Key []byte

+ UserMeta []byte

+ Val []byte

+ Version uint64

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

+ func (*KV) ProtoMessage()

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

+ func (m *KV) GetUserMeta() []byte

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

+ func (m *KV) GetVersion() uint64

+ 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 KeyValues struct

+ Kv []*KV

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

+ func (*KeyValues) ProtoMessage()

+ func (m *KeyValues) GetKv() []*KV

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

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

+ func (m *KeyValues) Reset()

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

+ func (m *KeyValues) String() string

+ func (m *KeyValues) Unmarshal(dAtA []byte) error

+ type LangList struct

+ Lang []string

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

+ func (*LangList) ProtoMessage()

+ func (m *LangList) GetLang() []string

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

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

+ func (m *LangList) Reset()

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

+ func (m *LangList) String() string

+ func (m *LangList) Unmarshal(dAtA []byte) error

+ type List struct

+ Uids []uint64

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

+ func (*List) ProtoMessage()

+ func (m *List) GetUids() []uint64

+ 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 MapEntry struct

+ Key []byte

+ Posting *Posting

+ Uid uint64

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

+ func (*MapEntry) ProtoMessage()

+ func (m *MapEntry) GetKey() []byte

+ func (m *MapEntry) GetPosting() *Posting

+ func (m *MapEntry) GetUid() uint64

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

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

+ func (m *MapEntry) Reset()

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

+ func (m *MapEntry) String() string

+ func (m *MapEntry) Unmarshal(dAtA []byte) error

+ type Member struct

+ Addr string

+ AmDead bool

+ ClusterInfoOnly bool

+ GroupId uint32

+ Id uint64

+ LastUpdate uint64

+ Leader bool

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

+ func (*Member) ProtoMessage()

+ func (m *Member) GetAddr() string

+ func (m *Member) GetAmDead() bool

+ func (m *Member) GetClusterInfoOnly() bool

+ func (m *Member) GetGroupId() uint32

+ func (m *Member) GetId() uint64

+ func (m *Member) GetLastUpdate() uint64

+ func (m *Member) GetLeader() bool

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

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

+ func (m *Member) Reset()

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

+ func (m *Member) String() string

+ func (m *Member) Unmarshal(dAtA []byte) error

+ type MembershipState struct

+ Counter uint64

+ Groups map[uint32]*Group

+ MaxLeaseId uint64

+ MaxRaftId uint64

+ MaxTxnTs uint64

+ Removed []*Member

+ Zeros map[uint64]*Member

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

+ func (*MembershipState) ProtoMessage()

+ func (m *MembershipState) GetCounter() uint64

+ func (m *MembershipState) GetGroups() map[uint32]*Group

+ func (m *MembershipState) GetMaxLeaseId() uint64

+ func (m *MembershipState) GetMaxRaftId() uint64

+ func (m *MembershipState) GetMaxTxnTs() uint64

+ func (m *MembershipState) GetRemoved() []*Member

+ func (m *MembershipState) GetZeros() map[uint64]*Member

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

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

+ func (m *MembershipState) Reset()

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

+ func (m *MembershipState) String() string

+ func (m *MembershipState) Unmarshal(dAtA []byte) error

+ type MovePredicatePayload struct

+ DestGroupId uint32

+ Predicate string

+ SourceGroupId uint32

+ State *MembershipState

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

+ func (*MovePredicatePayload) ProtoMessage()

+ func (m *MovePredicatePayload) GetDestGroupId() uint32

+ func (m *MovePredicatePayload) GetPredicate() string

+ func (m *MovePredicatePayload) GetSourceGroupId() uint32

+ func (m *MovePredicatePayload) GetState() *MembershipState

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

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

+ func (m *MovePredicatePayload) Reset()

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

+ func (m *MovePredicatePayload) String() string

+ func (m *MovePredicatePayload) Unmarshal(dAtA []byte) error

+ type Mutations struct

+ DropAll bool

+ Edges []*DirectedEdge

+ GroupId uint32

+ IgnoreIndexConflict bool

+ Schema []*SchemaUpdate

+ StartTs uint64

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

+ func (*Mutations) ProtoMessage()

+ func (m *Mutations) GetDropAll() bool

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

+ func (m *Mutations) GetGroupId() uint32

+ func (m *Mutations) GetIgnoreIndexConflict() bool

+ func (m *Mutations) GetSchema() []*SchemaUpdate

+ func (m *Mutations) GetStartTs() uint64

+ 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

+ Val uint64

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

+ func (*Num) ProtoMessage()

+ func (m *Num) GetVal() uint64

+ 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 OracleDelta struct

+ Aborts []uint64

+ Commits map[uint64]uint64

+ MaxPending uint64

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

+ func (*OracleDelta) ProtoMessage()

+ func (m *OracleDelta) GetAborts() []uint64

+ func (m *OracleDelta) GetCommits() map[uint64]uint64

+ func (m *OracleDelta) GetMaxPending() uint64

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

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

+ func (m *OracleDelta) Reset()

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

+ func (m *OracleDelta) String() string

+ func (m *OracleDelta) Unmarshal(dAtA []byte) error

+ type Order struct

+ Attr string

+ Desc bool

+ Langs []string

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

+ func (*Order) ProtoMessage()

+ func (m *Order) GetAttr() string

+ func (m *Order) GetDesc() bool

+ func (m *Order) GetLangs() []string

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

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

+ func (m *Order) Reset()

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

+ func (m *Order) String() string

+ func (m *Order) Unmarshal(dAtA []byte) error

+ type Posting struct

+ CommitTs uint64

+ Facets []*api.Facet

+ Label string

+ LangTag []byte

+ Op uint32

+ PostingType Posting_PostingType

+ StartTs uint64

+ Uid uint64

+ ValType Posting_ValType

+ Value []byte

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

+ func (*Posting) ProtoMessage()

+ func (m *Posting) GetCommitTs() uint64

+ func (m *Posting) GetFacets() []*api.Facet

+ func (m *Posting) GetLabel() string

+ func (m *Posting) GetLangTag() []byte

+ func (m *Posting) GetOp() uint32

+ func (m *Posting) GetPostingType() Posting_PostingType

+ func (m *Posting) GetStartTs() uint64

+ func (m *Posting) GetUid() uint64

+ func (m *Posting) GetValType() Posting_ValType

+ func (m *Posting) GetValue() []byte

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

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

+ func (m *Posting) Reset()

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

+ func (m *Posting) String() string

+ func (m *Posting) Unmarshal(dAtA []byte) error

+ type PostingList struct

+ Checksum []byte

+ Commit uint64

+ Postings []*Posting

+ Uids []byte

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

+ func (*PostingList) ProtoMessage()

+ func (m *PostingList) GetChecksum() []byte

+ func (m *PostingList) GetCommit() uint64

+ func (m *PostingList) GetPostings() []*Posting

+ func (m *PostingList) GetUids() []byte

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

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

+ func (m *PostingList) Reset()

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

+ func (m *PostingList) String() string

+ func (m *PostingList) Unmarshal(dAtA []byte) error

+ type Posting_PostingType int32

+ const Posting_REF

+ const Posting_VALUE

+ const Posting_VALUE_LANG

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

+ func (x Posting_PostingType) String() string

+ type Posting_ValType int32

+ const Posting_BINARY

+ const Posting_BOOL

+ const Posting_DATETIME

+ const Posting_DEFAULT

+ const Posting_FLOAT

+ const Posting_GEO

+ const Posting_INT

+ const Posting_PASSWORD

+ const Posting_STRING

+ const Posting_UID

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

+ func (x Posting_ValType) String() string

+ type Proposal struct

+ CleanPredicate string

+ Id uint32

+ Kv []*KV

+ Mutations *Mutations

+ State *MembershipState

+ TxnContext *api.TxnContext

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

+ func (*Proposal) ProtoMessage()

+ func (m *Proposal) GetCleanPredicate() string

+ func (m *Proposal) GetId() uint32

+ func (m *Proposal) GetKv() []*KV

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

+ func (m *Proposal) GetState() *MembershipState

+ func (m *Proposal) GetTxnContext() *api.TxnContext

+ 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 struct

+ AfterUid uint64

+ Attr string

+ DoCount bool

+ ExpandAll bool

+ FacetParam *FacetParams

+ FacetsFilter *FilterTree

+ Langs []string

+ LinRead *api.LinRead

+ ReadTs uint64

+ Reverse bool

+ SrcFunc *SrcFunction

+ UidList *List

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

+ func (*Query) ProtoMessage()

+ func (m *Query) GetAfterUid() uint64

+ func (m *Query) GetAttr() string

+ func (m *Query) GetDoCount() bool

+ func (m *Query) GetExpandAll() bool

+ func (m *Query) GetFacetParam() *FacetParams

+ func (m *Query) GetFacetsFilter() *FilterTree

+ func (m *Query) GetLangs() []string

+ func (m *Query) GetLinRead() *api.LinRead

+ func (m *Query) GetReadTs() uint64

+ func (m *Query) GetReverse() bool

+ func (m *Query) GetSrcFunc() *SrcFunction

+ func (m *Query) GetUidList() *List

+ 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 RaftClient interface

+ Echo func(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (*api.Payload, error)

+ JoinCluster func(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*api.Payload, error)

+ RaftMessage func(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (*api.Payload, error)

+ func NewRaftClient(cc *grpc.ClientConn) RaftClient

+ type RaftContext struct

+ Addr string

+ Group uint32

+ Id uint64

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

+ func (*RaftContext) ProtoMessage()

+ func (m *RaftContext) GetAddr() string

+ func (m *RaftContext) GetGroup() uint32

+ func (m *RaftContext) GetId() uint64

+ 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 RaftServer interface

+ Echo func(context.Context, *api.Payload) (*api.Payload, error)

+ JoinCluster func(context.Context, *RaftContext) (*api.Payload, error)

+ RaftMessage func(context.Context, *api.Payload) (*api.Payload, error)

+ type Result struct

+ Counts []uint32

+ FacetMatrix []*FacetsList

+ IntersectDest bool

+ LangMatrix []*LangList

+ LinRead *api.LinRead

+ UidMatrix []*List

+ ValueMatrix []*ValueList

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

+ func (*Result) ProtoMessage()

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

+ func (m *Result) GetFacetMatrix() []*FacetsList

+ func (m *Result) GetIntersectDest() bool

+ func (m *Result) GetLangMatrix() []*LangList

+ func (m *Result) GetLinRead() *api.LinRead

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

+ func (m *Result) GetValueMatrix() []*ValueList

+ 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 SchemaRequest struct

+ Fields []string

+ GroupId uint32

+ Predicates []string

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

+ func (*SchemaRequest) ProtoMessage()

+ func (m *SchemaRequest) GetFields() []string

+ func (m *SchemaRequest) GetGroupId() uint32

+ func (m *SchemaRequest) GetPredicates() []string

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

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

+ func (m *SchemaRequest) Reset()

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

+ func (m *SchemaRequest) String() string

+ func (m *SchemaRequest) Unmarshal(dAtA []byte) error

+ type SchemaResult struct

+ Schema []*api.SchemaNode

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

+ func (*SchemaResult) ProtoMessage()

+ func (m *SchemaResult) GetSchema() []*api.SchemaNode

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

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

+ func (m *SchemaResult) Reset()

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

+ func (m *SchemaResult) String() string

+ func (m *SchemaResult) Unmarshal(dAtA []byte) error

+ type SchemaUpdate struct

+ Count bool

+ Directive SchemaUpdate_Directive

+ Explicit bool

+ List bool

+ Predicate string

+ Tokenizer []string

+ ValueType Posting_ValType

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

+ func (*SchemaUpdate) ProtoMessage()

+ func (m *SchemaUpdate) GetCount() bool

+ func (m *SchemaUpdate) GetDirective() SchemaUpdate_Directive

+ func (m *SchemaUpdate) GetExplicit() bool

+ func (m *SchemaUpdate) GetList() bool

+ func (m *SchemaUpdate) GetPredicate() string

+ func (m *SchemaUpdate) GetTokenizer() []string

+ func (m *SchemaUpdate) GetValueType() Posting_ValType

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

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

+ func (m *SchemaUpdate) Reset()

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

+ func (m *SchemaUpdate) String() string

+ func (m *SchemaUpdate) Unmarshal(dAtA []byte) error

+ type SchemaUpdate_Directive int32

+ const SchemaUpdate_DELETE

+ const SchemaUpdate_INDEX

+ const SchemaUpdate_NONE

+ const SchemaUpdate_REVERSE

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

+ func (x SchemaUpdate_Directive) String() string

+ type SortMessage struct

+ Count int32

+ LinRead *api.LinRead

+ Offset int32

+ Order []*Order

+ ReadTs uint64

+ UidMatrix []*List

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

+ func (*SortMessage) ProtoMessage()

+ func (m *SortMessage) GetCount() int32

+ func (m *SortMessage) GetLinRead() *api.LinRead

+ func (m *SortMessage) GetOffset() int32

+ func (m *SortMessage) GetOrder() []*Order

+ func (m *SortMessage) GetReadTs() uint64

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

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

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

+ func (m *SortMessage) Reset()

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

+ func (m *SortMessage) String() string

+ func (m *SortMessage) Unmarshal(dAtA []byte) error

+ type SortResult struct

+ LinRead *api.LinRead

+ UidMatrix []*List

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

+ func (*SortResult) ProtoMessage()

+ func (m *SortResult) GetLinRead() *api.LinRead

+ 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 SrcFunction struct

+ Args []string

+ IsCount bool

+ Name string

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

+ func (*SrcFunction) ProtoMessage()

+ func (m *SrcFunction) GetArgs() []string

+ func (m *SrcFunction) GetIsCount() bool

+ func (m *SrcFunction) GetName() string

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

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

+ func (m *SrcFunction) Reset()

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

+ func (m *SrcFunction) String() string

+ func (m *SrcFunction) Unmarshal(dAtA []byte) error

+ type Tablet struct

+ Force bool

+ GroupId uint32

+ Predicate string

+ ReadOnly bool

+ Space int64

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

+ func (*Tablet) ProtoMessage()

+ func (m *Tablet) GetForce() bool

+ func (m *Tablet) GetGroupId() uint32

+ func (m *Tablet) GetPredicate() string

+ func (m *Tablet) GetReadOnly() bool

+ func (m *Tablet) GetSpace() int64

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

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

+ func (m *Tablet) Reset()

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

+ func (m *Tablet) String() string

+ func (m *Tablet) Unmarshal(dAtA []byte) error

+ type TaskValue struct

+ Val []byte

+ ValType Posting_ValType

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

+ func (*TaskValue) ProtoMessage()

+ func (m *TaskValue) GetVal() []byte

+ func (m *TaskValue) GetValType() Posting_ValType

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

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

+ func (m *TaskValue) Reset()

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

+ func (m *TaskValue) String() string

+ func (m *TaskValue) Unmarshal(dAtA []byte) error

+ type TxnTimestamps struct

+ Ts []uint64

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

+ func (*TxnTimestamps) ProtoMessage()

+ func (m *TxnTimestamps) GetTs() []uint64

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

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

+ func (m *TxnTimestamps) Reset()

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

+ func (m *TxnTimestamps) String() string

+ func (m *TxnTimestamps) Unmarshal(dAtA []byte) error

+ type ValueList struct

+ Values []*TaskValue

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

+ func (*ValueList) ProtoMessage()

+ func (m *ValueList) GetValues() []*TaskValue

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

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

+ func (m *ValueList) Reset()

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

+ func (m *ValueList) String() string

+ func (m *ValueList) Unmarshal(dAtA []byte) error

+ type WorkerClient interface

+ CommitOrAbort func(ctx context.Context, in *api.TxnContext, opts ...grpc.CallOption) (*api.Payload, error)

+ Export func(ctx context.Context, in *ExportPayload, opts ...grpc.CallOption) (*ExportPayload, error)

+ MinTxnTs func(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (*Num, error)

+ MovePredicate func(ctx context.Context, in *MovePredicatePayload, opts ...grpc.CallOption) (*api.Payload, error)

+ Mutate func(ctx context.Context, in *Mutations, opts ...grpc.CallOption) (*api.TxnContext, error)

+ PredicateAndSchemaData func(ctx context.Context, opts ...grpc.CallOption) (Worker_PredicateAndSchemaDataClient, error)

+ ReceivePredicate func(ctx context.Context, opts ...grpc.CallOption) (Worker_ReceivePredicateClient, error)

+ Schema func(ctx context.Context, in *SchemaRequest, opts ...grpc.CallOption) (*SchemaResult, error)

+ ServeTask func(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Result, error)

+ Sort func(ctx context.Context, in *SortMessage, opts ...grpc.CallOption) (*SortResult, error)

+ func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

+ type WorkerServer interface

+ CommitOrAbort func(context.Context, *api.TxnContext) (*api.Payload, error)

+ Export func(context.Context, *ExportPayload) (*ExportPayload, error)

+ MinTxnTs func(context.Context, *api.Payload) (*Num, error)

+ MovePredicate func(context.Context, *MovePredicatePayload) (*api.Payload, error)

+ Mutate func(context.Context, *Mutations) (*api.TxnContext, error)

+ PredicateAndSchemaData func(Worker_PredicateAndSchemaDataServer) error

+ ReceivePredicate func(Worker_ReceivePredicateServer) error

+ Schema func(context.Context, *SchemaRequest) (*SchemaResult, error)

+ ServeTask func(context.Context, *Query) (*Result, error)

+ Sort func(context.Context, *SortMessage) (*SortResult, error)

+ type Worker_PredicateAndSchemaDataClient interface

+ Recv func() (*KV, error)

+ Send func(*GroupKeys) error

+ type Worker_PredicateAndSchemaDataServer interface

+ Recv func() (*GroupKeys, error)

+ Send func(*KV) error

+ type Worker_ReceivePredicateClient interface

+ CloseAndRecv func() (*api.Payload, error)

+ Send func(*KV) error

+ type Worker_ReceivePredicateServer interface

+ Recv func() (*KV, error)

+ SendAndClose func(*api.Payload) error

+ type ZeroClient interface

+ AssignUids func(ctx context.Context, in *Num, opts ...grpc.CallOption) (*api.AssignedIds, error)

+ CommitOrAbort func(ctx context.Context, in *api.TxnContext, opts ...grpc.CallOption) (*api.TxnContext, error)

+ Connect func(ctx context.Context, in *Member, opts ...grpc.CallOption) (*ConnectionState, error)

+ Oracle func(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (Zero_OracleClient, error)

+ ShouldServe func(ctx context.Context, in *Tablet, opts ...grpc.CallOption) (*Tablet, error)

+ Timestamps func(ctx context.Context, in *Num, opts ...grpc.CallOption) (*api.AssignedIds, error)

+ TryAbort func(ctx context.Context, in *TxnTimestamps, opts ...grpc.CallOption) (*TxnTimestamps, error)

+ Update func(ctx context.Context, opts ...grpc.CallOption) (Zero_UpdateClient, error)

+ func NewZeroClient(cc *grpc.ClientConn) ZeroClient

+ type ZeroProposal struct

+ Id uint32

+ MaxLeaseId uint64

+ MaxRaftId uint64

+ MaxTxnTs uint64

+ Member *Member

+ Tablet *Tablet

+ Txn *api.TxnContext

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

+ func (*ZeroProposal) ProtoMessage()

+ func (m *ZeroProposal) GetId() uint32

+ func (m *ZeroProposal) GetMaxLeaseId() uint64

+ func (m *ZeroProposal) GetMaxRaftId() uint64

+ func (m *ZeroProposal) GetMaxTxnTs() uint64

+ func (m *ZeroProposal) GetMember() *Member

+ func (m *ZeroProposal) GetTablet() *Tablet

+ func (m *ZeroProposal) GetTxn() *api.TxnContext

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

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

+ func (m *ZeroProposal) Reset()

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

+ func (m *ZeroProposal) String() string

+ func (m *ZeroProposal) Unmarshal(dAtA []byte) error

+ type ZeroServer interface

+ AssignUids func(context.Context, *Num) (*api.AssignedIds, error)

+ CommitOrAbort func(context.Context, *api.TxnContext) (*api.TxnContext, error)

+ Connect func(context.Context, *Member) (*ConnectionState, error)

+ Oracle func(*api.Payload, Zero_OracleServer) error

+ ShouldServe func(context.Context, *Tablet) (*Tablet, error)

+ Timestamps func(context.Context, *Num) (*api.AssignedIds, error)

+ TryAbort func(context.Context, *TxnTimestamps) (*TxnTimestamps, error)

+ Update func(Zero_UpdateServer) error

+ type Zero_OracleClient interface

+ Recv func() (*OracleDelta, error)

+ type Zero_OracleServer interface

+ Send func(*OracleDelta) error

+ type Zero_UpdateClient interface

+ Recv func() (*MembershipState, error)

+ Send func(*Group) error

+ type Zero_UpdateServer interface

+ Recv func() (*Group, error)

+ Send func(*MembershipState) error

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