storage_proto

May 12, 2016

Changes in this version

type CountReply

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

type CountRequest

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

type Entries

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

type Entry

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

type ReadRequest

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

type ScanRequest

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

type SearchReply

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

type SearchRequest

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

type SearchRequest_Fact

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

type ShardRequest

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

type VName

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

type VNameMask

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

type WriteReply

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

type WriteRequest

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

type WriteRequest_Update

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

Dec 16, 2015

Changes in this version

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

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

type CountReply

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

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

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

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

type CountRequest

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

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

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

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

type Entries

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

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

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

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

type Entry

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

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

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

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

type ReadRequest

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

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

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

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

type ScanRequest

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

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

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

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

type SearchReply

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

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

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

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

type SearchRequest

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

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

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

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

type SearchRequest_Fact

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

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

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

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

type ShardRequest

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

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

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

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

type VName

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

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

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

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

type VNameMask

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

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

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

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

type WriteReply

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

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

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

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

type WriteRequest

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

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

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

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

type WriteRequest_Update

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

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

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

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

Jun 5, 2015

Changes in this version

+ func RegisterGraphStoreServer(s *grpc.Server, srv GraphStoreServer)

+ func RegisterSearchServiceServer(s *grpc.Server, srv SearchServiceServer)

+ func RegisterShardedGraphStoreServer(s *grpc.Server, srv ShardedGraphStoreServer)

+ type CountReply struct

+ Entries int64

+ func (*CountReply) ProtoMessage()

+ func (m *CountReply) Reset()

+ func (m *CountReply) String() string

+ type CountRequest struct

+ Index int64

+ Shards int64

+ func (*CountRequest) ProtoMessage()

+ func (m *CountRequest) Reset()

+ func (m *CountRequest) String() string

+ type Entries struct

+ Entries []*Entry

+ func (*Entries) ProtoMessage()

+ func (m *Entries) GetEntries() []*Entry

+ func (m *Entries) Reset()

+ func (m *Entries) String() string

+ type Entry struct

+ EdgeKind string

+ FactName string

+ FactValue []byte

+ Source *VName

+ Target *VName

+ func (*Entry) ProtoMessage()

+ func (m *Entry) GetSource() *VName

+ func (m *Entry) GetTarget() *VName

+ func (m *Entry) Reset()

+ func (m *Entry) String() string

+ type GraphStoreClient interface

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (GraphStore_ReadClient, error)

+ Scan func(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (GraphStore_ScanClient, error)

+ Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteReply, error)

+ func NewGraphStoreClient(cc *grpc.ClientConn) GraphStoreClient

+ type GraphStoreServer interface

+ Read func(*ReadRequest, GraphStore_ReadServer) error

+ Scan func(*ScanRequest, GraphStore_ScanServer) error

+ Write func(context.Context, *WriteRequest) (*WriteReply, error)

+ type GraphStore_ReadClient interface

+ Recv func() (*Entry, error)

+ type GraphStore_ReadServer interface

+ Send func(*Entry) error

+ type GraphStore_ScanClient interface

+ Recv func() (*Entry, error)

+ type GraphStore_ScanServer interface

+ Send func(*Entry) error

+ type ReadRequest struct

+ EdgeKind string

+ Source *VName

+ func (*ReadRequest) ProtoMessage()

+ func (m *ReadRequest) GetSource() *VName

+ func (m *ReadRequest) Reset()

+ func (m *ReadRequest) String() string

+ type ScanRequest struct

+ EdgeKind string

+ FactPrefix string

+ Target *VName

+ func (*ScanRequest) ProtoMessage()

+ func (m *ScanRequest) GetTarget() *VName

+ func (m *ScanRequest) Reset()

+ func (m *ScanRequest) String() string

+ type SearchReply struct

+ Ticket []string

+ func (*SearchReply) ProtoMessage()

+ func (m *SearchReply) Reset()

+ func (m *SearchReply) String() string

+ type SearchRequest struct

+ Fact []*SearchRequest_Fact

+ Partial *VName

+ PartialPrefix *VNameMask

+ func (*SearchRequest) ProtoMessage()

+ func (m *SearchRequest) GetFact() []*SearchRequest_Fact

+ func (m *SearchRequest) GetPartial() *VName

+ func (m *SearchRequest) GetPartialPrefix() *VNameMask

+ func (m *SearchRequest) Reset()

+ func (m *SearchRequest) String() string

+ type SearchRequest_Fact struct

+ Name string

+ Prefix bool

+ Value []byte

+ func (*SearchRequest_Fact) ProtoMessage()

+ func (m *SearchRequest_Fact) Reset()

+ func (m *SearchRequest_Fact) String() string

+ type SearchServiceClient interface

+ Search func(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchReply, error)

+ func NewSearchServiceClient(cc *grpc.ClientConn) SearchServiceClient

+ type SearchServiceServer interface

+ Search func(context.Context, *SearchRequest) (*SearchReply, error)

+ type ShardRequest struct

+ Index int64

+ Shards int64

+ func (*ShardRequest) ProtoMessage()

+ func (m *ShardRequest) Reset()

+ func (m *ShardRequest) String() string

+ type ShardedGraphStoreClient interface

+ Count func(ctx context.Context, in *CountRequest, opts ...grpc.CallOption) (*CountReply, error)

+ Shard func(ctx context.Context, in *ShardRequest, opts ...grpc.CallOption) (ShardedGraphStore_ShardClient, error)

+ func NewShardedGraphStoreClient(cc *grpc.ClientConn) ShardedGraphStoreClient

+ type ShardedGraphStoreServer interface

+ Count func(context.Context, *CountRequest) (*CountReply, error)

+ Shard func(*ShardRequest, ShardedGraphStore_ShardServer) error

+ type ShardedGraphStore_ShardClient interface

+ Recv func() (*Entry, error)

+ type ShardedGraphStore_ShardServer interface

+ Send func(*Entry) error

+ type VName struct

+ Corpus string

+ Language string

+ Path string

+ Root string

+ Signature string

+ func (*VName) ProtoMessage()

+ func (m *VName) Reset()

+ func (m *VName) String() string

+ type VNameMask struct

+ Corpus bool

+ Language bool

+ Path bool

+ Root bool

+ Signature bool

+ func (*VNameMask) ProtoMessage()

+ func (m *VNameMask) Reset()

+ func (m *VNameMask) String() string

+ type WriteReply struct

+ func (*WriteReply) ProtoMessage()

+ func (m *WriteReply) Reset()

+ func (m *WriteReply) String() string

+ type WriteRequest struct

+ Source *VName

+ Update []*WriteRequest_Update

+ func (*WriteRequest) ProtoMessage()

+ func (m *WriteRequest) GetSource() *VName

+ func (m *WriteRequest) GetUpdate() []*WriteRequest_Update

+ func (m *WriteRequest) Reset()

+ func (m *WriteRequest) String() string

+ type WriteRequest_Update struct

+ EdgeKind string

+ FactName string

+ FactValue []byte

+ Target *VName

+ func (*WriteRequest_Update) ProtoMessage()

+ func (m *WriteRequest_Update) GetTarget() *VName

+ func (m *WriteRequest_Update) Reset()

+ func (m *WriteRequest_Update) String() string