Versions in this module Expand all Collapse all v2 v2.5.2 Apr 27, 2022 Changes in this version + var ErrIntOverflowGrpc = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGrpc = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterGrpcStoreServer(s *grpc.Server, srv GrpcStoreServer) + type Chunk struct + Encoded []byte + Key string + TableName string + func (*Chunk) Descriptor() ([]byte, []int) + func (*Chunk) ProtoMessage() + func (m *Chunk) GetEncoded() []byte + func (m *Chunk) GetKey() string + func (m *Chunk) GetTableName() string + func (m *Chunk) Marshal() (dAtA []byte, err error) + func (m *Chunk) MarshalTo(dAtA []byte) (int, error) + func (m *Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Chunk) Reset() + func (m *Chunk) Size() (n int) + func (m *Chunk) Unmarshal(dAtA []byte) error + func (m *Chunk) XXX_DiscardUnknown() + func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Chunk) XXX_Merge(src proto.Message) + func (m *Chunk) XXX_Size() int + func (m *Chunk) XXX_Unmarshal(b []byte) error + func (this *Chunk) Equal(that interface{}) bool + func (this *Chunk) GoString() string + func (this *Chunk) String() string + type ChunkID struct + ChunkID string + func (*ChunkID) Descriptor() ([]byte, []int) + func (*ChunkID) ProtoMessage() + func (m *ChunkID) GetChunkID() string + func (m *ChunkID) Marshal() (dAtA []byte, err error) + func (m *ChunkID) MarshalTo(dAtA []byte) (int, error) + func (m *ChunkID) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChunkID) Reset() + func (m *ChunkID) Size() (n int) + func (m *ChunkID) Unmarshal(dAtA []byte) error + func (m *ChunkID) XXX_DiscardUnknown() + func (m *ChunkID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChunkID) XXX_Merge(src proto.Message) + func (m *ChunkID) XXX_Size() int + func (m *ChunkID) XXX_Unmarshal(b []byte) error + func (this *ChunkID) Equal(that interface{}) bool + func (this *ChunkID) GoString() string + func (this *ChunkID) String() string + type Config struct + Address string + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type CreateTableRequest struct + Desc *TableDesc + func (*CreateTableRequest) Descriptor() ([]byte, []int) + func (*CreateTableRequest) ProtoMessage() + func (m *CreateTableRequest) GetDesc() *TableDesc + func (m *CreateTableRequest) Marshal() (dAtA []byte, err error) + func (m *CreateTableRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CreateTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateTableRequest) Reset() + func (m *CreateTableRequest) Size() (n int) + func (m *CreateTableRequest) Unmarshal(dAtA []byte) error + func (m *CreateTableRequest) XXX_DiscardUnknown() + func (m *CreateTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateTableRequest) XXX_Merge(src proto.Message) + func (m *CreateTableRequest) XXX_Size() int + func (m *CreateTableRequest) XXX_Unmarshal(b []byte) error + func (this *CreateTableRequest) Equal(that interface{}) bool + func (this *CreateTableRequest) GoString() string + func (this *CreateTableRequest) String() string + type DeleteIndexRequest struct + Deletes []*IndexEntry + func (*DeleteIndexRequest) Descriptor() ([]byte, []int) + func (*DeleteIndexRequest) ProtoMessage() + func (m *DeleteIndexRequest) GetDeletes() []*IndexEntry + func (m *DeleteIndexRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteIndexRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteIndexRequest) Reset() + func (m *DeleteIndexRequest) Size() (n int) + func (m *DeleteIndexRequest) Unmarshal(dAtA []byte) error + func (m *DeleteIndexRequest) XXX_DiscardUnknown() + func (m *DeleteIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteIndexRequest) XXX_Merge(src proto.Message) + func (m *DeleteIndexRequest) XXX_Size() int + func (m *DeleteIndexRequest) XXX_Unmarshal(b []byte) error + func (this *DeleteIndexRequest) Equal(that interface{}) bool + func (this *DeleteIndexRequest) GoString() string + func (this *DeleteIndexRequest) String() string + type DeleteTableRequest struct + TableName string + func (*DeleteTableRequest) Descriptor() ([]byte, []int) + func (*DeleteTableRequest) ProtoMessage() + func (m *DeleteTableRequest) GetTableName() string + func (m *DeleteTableRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteTableRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteTableRequest) Reset() + func (m *DeleteTableRequest) Size() (n int) + func (m *DeleteTableRequest) Unmarshal(dAtA []byte) error + func (m *DeleteTableRequest) XXX_DiscardUnknown() + func (m *DeleteTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteTableRequest) XXX_Merge(src proto.Message) + func (m *DeleteTableRequest) XXX_Size() int + func (m *DeleteTableRequest) XXX_Unmarshal(b []byte) error + func (this *DeleteTableRequest) Equal(that interface{}) bool + func (this *DeleteTableRequest) GoString() string + func (this *DeleteTableRequest) String() string + type DescribeTableRequest struct + TableName string + func (*DescribeTableRequest) Descriptor() ([]byte, []int) + func (*DescribeTableRequest) ProtoMessage() + func (m *DescribeTableRequest) GetTableName() string + func (m *DescribeTableRequest) Marshal() (dAtA []byte, err error) + func (m *DescribeTableRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DescribeTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DescribeTableRequest) Reset() + func (m *DescribeTableRequest) Size() (n int) + func (m *DescribeTableRequest) Unmarshal(dAtA []byte) error + func (m *DescribeTableRequest) XXX_DiscardUnknown() + func (m *DescribeTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DescribeTableRequest) XXX_Merge(src proto.Message) + func (m *DescribeTableRequest) XXX_Size() int + func (m *DescribeTableRequest) XXX_Unmarshal(b []byte) error + func (this *DescribeTableRequest) Equal(that interface{}) bool + func (this *DescribeTableRequest) GoString() string + func (this *DescribeTableRequest) String() string + type DescribeTableResponse struct + Desc *TableDesc + IsActive bool + func (*DescribeTableResponse) Descriptor() ([]byte, []int) + func (*DescribeTableResponse) ProtoMessage() + func (m *DescribeTableResponse) GetDesc() *TableDesc + func (m *DescribeTableResponse) GetIsActive() bool + func (m *DescribeTableResponse) Marshal() (dAtA []byte, err error) + func (m *DescribeTableResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DescribeTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DescribeTableResponse) Reset() + func (m *DescribeTableResponse) Size() (n int) + func (m *DescribeTableResponse) Unmarshal(dAtA []byte) error + func (m *DescribeTableResponse) XXX_DiscardUnknown() + func (m *DescribeTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DescribeTableResponse) XXX_Merge(src proto.Message) + func (m *DescribeTableResponse) XXX_Size() int + func (m *DescribeTableResponse) XXX_Unmarshal(b []byte) error + func (this *DescribeTableResponse) Equal(that interface{}) bool + func (this *DescribeTableResponse) GoString() string + func (this *DescribeTableResponse) String() string + type GetChunksRequest struct + Chunks []*Chunk + func (*GetChunksRequest) Descriptor() ([]byte, []int) + func (*GetChunksRequest) ProtoMessage() + func (m *GetChunksRequest) GetChunks() []*Chunk + func (m *GetChunksRequest) Marshal() (dAtA []byte, err error) + func (m *GetChunksRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetChunksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetChunksRequest) Reset() + func (m *GetChunksRequest) Size() (n int) + func (m *GetChunksRequest) Unmarshal(dAtA []byte) error + func (m *GetChunksRequest) XXX_DiscardUnknown() + func (m *GetChunksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetChunksRequest) XXX_Merge(src proto.Message) + func (m *GetChunksRequest) XXX_Size() int + func (m *GetChunksRequest) XXX_Unmarshal(b []byte) error + func (this *GetChunksRequest) Equal(that interface{}) bool + func (this *GetChunksRequest) GoString() string + func (this *GetChunksRequest) String() string + type GetChunksResponse struct + Chunks []*Chunk + func (*GetChunksResponse) Descriptor() ([]byte, []int) + func (*GetChunksResponse) ProtoMessage() + func (m *GetChunksResponse) GetChunks() []*Chunk + func (m *GetChunksResponse) Marshal() (dAtA []byte, err error) + func (m *GetChunksResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetChunksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetChunksResponse) Reset() + func (m *GetChunksResponse) Size() (n int) + func (m *GetChunksResponse) Unmarshal(dAtA []byte) error + func (m *GetChunksResponse) XXX_DiscardUnknown() + func (m *GetChunksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetChunksResponse) XXX_Merge(src proto.Message) + func (m *GetChunksResponse) XXX_Size() int + func (m *GetChunksResponse) XXX_Unmarshal(b []byte) error + func (this *GetChunksResponse) Equal(that interface{}) bool + func (this *GetChunksResponse) GoString() string + func (this *GetChunksResponse) String() string + type GrpcStoreClient interface + CreateTable func(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*empty.Empty, error) + DeleteChunks func(ctx context.Context, in *ChunkID, opts ...grpc.CallOption) (*empty.Empty, error) + DeleteIndex func(ctx context.Context, in *DeleteIndexRequest, opts ...grpc.CallOption) (*empty.Empty, error) + DeleteTable func(ctx context.Context, in *DeleteTableRequest, opts ...grpc.CallOption) (*empty.Empty, error) + DescribeTable func(ctx context.Context, in *DescribeTableRequest, opts ...grpc.CallOption) (*DescribeTableResponse, error) + GetChunks func(ctx context.Context, in *GetChunksRequest, opts ...grpc.CallOption) (GrpcStore_GetChunksClient, error) + ListTables func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTablesResponse, error) + PutChunks func(ctx context.Context, in *PutChunksRequest, opts ...grpc.CallOption) (*empty.Empty, error) + QueryIndex func(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (GrpcStore_QueryIndexClient, error) + UpdateTable func(ctx context.Context, in *UpdateTableRequest, opts ...grpc.CallOption) (*empty.Empty, error) + WriteIndex func(ctx context.Context, in *WriteIndexRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func NewGrpcStoreClient(cc *grpc.ClientConn) GrpcStoreClient + type GrpcStoreServer interface + CreateTable func(context.Context, *CreateTableRequest) (*empty.Empty, error) + DeleteChunks func(context.Context, *ChunkID) (*empty.Empty, error) + DeleteIndex func(context.Context, *DeleteIndexRequest) (*empty.Empty, error) + DeleteTable func(context.Context, *DeleteTableRequest) (*empty.Empty, error) + DescribeTable func(context.Context, *DescribeTableRequest) (*DescribeTableResponse, error) + GetChunks func(*GetChunksRequest, GrpcStore_GetChunksServer) error + ListTables func(context.Context, *empty.Empty) (*ListTablesResponse, error) + PutChunks func(context.Context, *PutChunksRequest) (*empty.Empty, error) + QueryIndex func(*QueryIndexRequest, GrpcStore_QueryIndexServer) error + UpdateTable func(context.Context, *UpdateTableRequest) (*empty.Empty, error) + WriteIndex func(context.Context, *WriteIndexRequest) (*empty.Empty, error) + type GrpcStore_GetChunksClient interface + Recv func() (*GetChunksResponse, error) + type GrpcStore_GetChunksServer interface + Send func(*GetChunksResponse) error + type GrpcStore_QueryIndexClient interface + Recv func() (*QueryIndexResponse, error) + type GrpcStore_QueryIndexServer interface + Send func(*QueryIndexResponse) error + type IndexEntry struct + HashValue string + RangeValue []byte + TableName string + Value []byte + func (*IndexEntry) Descriptor() ([]byte, []int) + func (*IndexEntry) ProtoMessage() + func (m *IndexEntry) GetHashValue() string + func (m *IndexEntry) GetRangeValue() []byte + func (m *IndexEntry) GetTableName() string + func (m *IndexEntry) GetValue() []byte + func (m *IndexEntry) Marshal() (dAtA []byte, err error) + func (m *IndexEntry) MarshalTo(dAtA []byte) (int, error) + func (m *IndexEntry) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IndexEntry) Reset() + func (m *IndexEntry) Size() (n int) + func (m *IndexEntry) Unmarshal(dAtA []byte) error + func (m *IndexEntry) XXX_DiscardUnknown() + func (m *IndexEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexEntry) XXX_Merge(src proto.Message) + func (m *IndexEntry) XXX_Size() int + func (m *IndexEntry) XXX_Unmarshal(b []byte) error + func (this *IndexEntry) Equal(that interface{}) bool + func (this *IndexEntry) GoString() string + func (this *IndexEntry) String() string + type Labels struct + Name string + Value string + func (*Labels) Descriptor() ([]byte, []int) + func (*Labels) ProtoMessage() + func (m *Labels) GetName() string + func (m *Labels) GetValue() string + func (m *Labels) Marshal() (dAtA []byte, err error) + func (m *Labels) MarshalTo(dAtA []byte) (int, error) + func (m *Labels) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Labels) Reset() + func (m *Labels) Size() (n int) + func (m *Labels) Unmarshal(dAtA []byte) error + func (m *Labels) XXX_DiscardUnknown() + func (m *Labels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Labels) XXX_Merge(src proto.Message) + func (m *Labels) XXX_Size() int + func (m *Labels) XXX_Unmarshal(b []byte) error + func (this *Labels) Equal(that interface{}) bool + func (this *Labels) GoString() string + func (this *Labels) String() string + type ListTablesResponse struct + TableNames []string + func (*ListTablesResponse) Descriptor() ([]byte, []int) + func (*ListTablesResponse) ProtoMessage() + func (m *ListTablesResponse) GetTableNames() []string + func (m *ListTablesResponse) Marshal() (dAtA []byte, err error) + func (m *ListTablesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListTablesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListTablesResponse) Reset() + func (m *ListTablesResponse) Size() (n int) + func (m *ListTablesResponse) Unmarshal(dAtA []byte) error + func (m *ListTablesResponse) XXX_DiscardUnknown() + func (m *ListTablesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListTablesResponse) XXX_Merge(src proto.Message) + func (m *ListTablesResponse) XXX_Size() int + func (m *ListTablesResponse) XXX_Unmarshal(b []byte) error + func (this *ListTablesResponse) Equal(that interface{}) bool + func (this *ListTablesResponse) GoString() string + func (this *ListTablesResponse) String() string + type PutChunksRequest struct + Chunks []*Chunk + func (*PutChunksRequest) Descriptor() ([]byte, []int) + func (*PutChunksRequest) ProtoMessage() + func (m *PutChunksRequest) GetChunks() []*Chunk + func (m *PutChunksRequest) Marshal() (dAtA []byte, err error) + func (m *PutChunksRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutChunksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutChunksRequest) Reset() + func (m *PutChunksRequest) Size() (n int) + func (m *PutChunksRequest) Unmarshal(dAtA []byte) error + func (m *PutChunksRequest) XXX_DiscardUnknown() + func (m *PutChunksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutChunksRequest) XXX_Merge(src proto.Message) + func (m *PutChunksRequest) XXX_Size() int + func (m *PutChunksRequest) XXX_Unmarshal(b []byte) error + func (this *PutChunksRequest) Equal(that interface{}) bool + func (this *PutChunksRequest) GoString() string + func (this *PutChunksRequest) String() string + type QueryIndexRequest struct + HashValue string + Immutable bool + RangeValuePrefix []byte + RangeValueStart []byte + TableName string + ValueEqual []byte + func (*QueryIndexRequest) Descriptor() ([]byte, []int) + func (*QueryIndexRequest) ProtoMessage() + func (m *QueryIndexRequest) GetHashValue() string + func (m *QueryIndexRequest) GetImmutable() bool + func (m *QueryIndexRequest) GetRangeValuePrefix() []byte + func (m *QueryIndexRequest) GetRangeValueStart() []byte + func (m *QueryIndexRequest) GetTableName() string + func (m *QueryIndexRequest) GetValueEqual() []byte + func (m *QueryIndexRequest) Marshal() (dAtA []byte, err error) + func (m *QueryIndexRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryIndexRequest) Reset() + func (m *QueryIndexRequest) Size() (n int) + func (m *QueryIndexRequest) Unmarshal(dAtA []byte) error + func (m *QueryIndexRequest) XXX_DiscardUnknown() + func (m *QueryIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryIndexRequest) XXX_Merge(src proto.Message) + func (m *QueryIndexRequest) XXX_Size() int + func (m *QueryIndexRequest) XXX_Unmarshal(b []byte) error + func (this *QueryIndexRequest) Equal(that interface{}) bool + func (this *QueryIndexRequest) GoString() string + func (this *QueryIndexRequest) String() string + type QueryIndexResponse struct + Rows []*Row + func (*QueryIndexResponse) Descriptor() ([]byte, []int) + func (*QueryIndexResponse) ProtoMessage() + func (m *QueryIndexResponse) GetRows() []*Row + func (m *QueryIndexResponse) Marshal() (dAtA []byte, err error) + func (m *QueryIndexResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryIndexResponse) Reset() + func (m *QueryIndexResponse) Size() (n int) + func (m *QueryIndexResponse) Unmarshal(dAtA []byte) error + func (m *QueryIndexResponse) XXX_DiscardUnknown() + func (m *QueryIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryIndexResponse) XXX_Merge(src proto.Message) + func (m *QueryIndexResponse) XXX_Size() int + func (m *QueryIndexResponse) XXX_Unmarshal(b []byte) error + func (r *QueryIndexResponse) Iterator() index.ReadBatchIterator + func (this *QueryIndexResponse) Equal(that interface{}) bool + func (this *QueryIndexResponse) GoString() string + func (this *QueryIndexResponse) String() string + type Row struct + RangeValue []byte + Value []byte + func (*Row) Descriptor() ([]byte, []int) + func (*Row) ProtoMessage() + func (m *Row) GetRangeValue() []byte + func (m *Row) GetValue() []byte + func (m *Row) Marshal() (dAtA []byte, err error) + func (m *Row) MarshalTo(dAtA []byte) (int, error) + func (m *Row) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Row) Reset() + func (m *Row) Size() (n int) + func (m *Row) Unmarshal(dAtA []byte) error + func (m *Row) XXX_DiscardUnknown() + func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Row) XXX_Merge(src proto.Message) + func (m *Row) XXX_Size() int + func (m *Row) XXX_Unmarshal(b []byte) error + func (this *Row) Equal(that interface{}) bool + func (this *Row) GoString() string + func (this *Row) String() string + type StorageClient struct + func NewStorageClient(cfg Config, schemaCfg config.SchemaConfig) (*StorageClient, error) + func (s *StorageClient) BatchWrite(c context.Context, batch index.WriteBatch) error + func (s *StorageClient) DeleteChunk(ctx context.Context, userID, chunkID string) error + func (s *StorageClient) GetChunks(ctx context.Context, input []chunk.Chunk) ([]chunk.Chunk, error) + func (s *StorageClient) IsChunkNotFoundErr(_ error) bool + func (s *StorageClient) NewWriteBatch() index.WriteBatch + func (s *StorageClient) PutChunks(ctx context.Context, chunks []chunk.Chunk) error + func (s *StorageClient) QueryPages(ctx context.Context, queries []index.Query, callback index.QueryPagesCallback) error + func (s *StorageClient) Stop() + type TableClient struct + func NewTableClient(cfg Config) (*TableClient, error) + func (c *TableClient) CreateTable(ctx context.Context, desc config.TableDesc) error + func (c *TableClient) DeleteTable(ctx context.Context, name string) error + func (c *TableClient) DescribeTable(ctx context.Context, name string) (desc config.TableDesc, isActive bool, err error) + func (c *TableClient) ListTables(ctx context.Context) ([]string, error) + func (c *TableClient) Stop() + func (c *TableClient) UpdateTable(ctx context.Context, current, expected config.TableDesc) error + type TableDesc struct + Name string + ProvisionedRead int64 + ProvisionedWrite int64 + Tags map[string]string + UseOnDemandIOMode bool + func (*TableDesc) Descriptor() ([]byte, []int) + func (*TableDesc) ProtoMessage() + func (m *TableDesc) GetName() string + func (m *TableDesc) GetProvisionedRead() int64 + func (m *TableDesc) GetProvisionedWrite() int64 + func (m *TableDesc) GetTags() map[string]string + func (m *TableDesc) GetUseOnDemandIOMode() bool + func (m *TableDesc) Marshal() (dAtA []byte, err error) + func (m *TableDesc) MarshalTo(dAtA []byte) (int, error) + func (m *TableDesc) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TableDesc) Reset() + func (m *TableDesc) Size() (n int) + func (m *TableDesc) Unmarshal(dAtA []byte) error + func (m *TableDesc) XXX_DiscardUnknown() + func (m *TableDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TableDesc) XXX_Merge(src proto.Message) + func (m *TableDesc) XXX_Size() int + func (m *TableDesc) XXX_Unmarshal(b []byte) error + func (this *TableDesc) Equal(that interface{}) bool + func (this *TableDesc) GoString() string + func (this *TableDesc) String() string + type UnimplementedGrpcStoreServer struct + func (*UnimplementedGrpcStoreServer) CreateTable(ctx context.Context, req *CreateTableRequest) (*empty.Empty, error) + func (*UnimplementedGrpcStoreServer) DeleteChunks(ctx context.Context, req *ChunkID) (*empty.Empty, error) + func (*UnimplementedGrpcStoreServer) DeleteIndex(ctx context.Context, req *DeleteIndexRequest) (*empty.Empty, error) + func (*UnimplementedGrpcStoreServer) DeleteTable(ctx context.Context, req *DeleteTableRequest) (*empty.Empty, error) + func (*UnimplementedGrpcStoreServer) DescribeTable(ctx context.Context, req *DescribeTableRequest) (*DescribeTableResponse, error) + func (*UnimplementedGrpcStoreServer) GetChunks(req *GetChunksRequest, srv GrpcStore_GetChunksServer) error + func (*UnimplementedGrpcStoreServer) ListTables(ctx context.Context, req *empty.Empty) (*ListTablesResponse, error) + func (*UnimplementedGrpcStoreServer) PutChunks(ctx context.Context, req *PutChunksRequest) (*empty.Empty, error) + func (*UnimplementedGrpcStoreServer) QueryIndex(req *QueryIndexRequest, srv GrpcStore_QueryIndexServer) error + func (*UnimplementedGrpcStoreServer) UpdateTable(ctx context.Context, req *UpdateTableRequest) (*empty.Empty, error) + func (*UnimplementedGrpcStoreServer) WriteIndex(ctx context.Context, req *WriteIndexRequest) (*empty.Empty, error) + type UpdateTableRequest struct + Current *TableDesc + Expected *TableDesc + func (*UpdateTableRequest) Descriptor() ([]byte, []int) + func (*UpdateTableRequest) ProtoMessage() + func (m *UpdateTableRequest) GetCurrent() *TableDesc + func (m *UpdateTableRequest) GetExpected() *TableDesc + func (m *UpdateTableRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateTableRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateTableRequest) Reset() + func (m *UpdateTableRequest) Size() (n int) + func (m *UpdateTableRequest) Unmarshal(dAtA []byte) error + func (m *UpdateTableRequest) XXX_DiscardUnknown() + func (m *UpdateTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateTableRequest) XXX_Merge(src proto.Message) + func (m *UpdateTableRequest) XXX_Size() int + func (m *UpdateTableRequest) XXX_Unmarshal(b []byte) error + func (this *UpdateTableRequest) Equal(that interface{}) bool + func (this *UpdateTableRequest) GoString() string + func (this *UpdateTableRequest) String() string + type WriteBatch struct + Deletes []*IndexEntry + Writes []*IndexEntry + func (*WriteBatch) Descriptor() ([]byte, []int) + func (*WriteBatch) ProtoMessage() + func (m *WriteBatch) GetDeletes() []*IndexEntry + func (m *WriteBatch) GetWrites() []*IndexEntry + func (m *WriteBatch) Marshal() (dAtA []byte, err error) + func (m *WriteBatch) MarshalTo(dAtA []byte) (int, error) + func (m *WriteBatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteBatch) Reset() + func (m *WriteBatch) Size() (n int) + func (m *WriteBatch) Unmarshal(dAtA []byte) error + func (m *WriteBatch) XXX_DiscardUnknown() + func (m *WriteBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteBatch) XXX_Merge(src proto.Message) + func (m *WriteBatch) XXX_Size() int + func (m *WriteBatch) XXX_Unmarshal(b []byte) error + func (this *WriteBatch) Equal(that interface{}) bool + func (this *WriteBatch) GoString() string + func (this *WriteBatch) String() string + func (w *WriteBatch) Add(tableName, hashValue string, rangeValue []byte, value []byte) + func (w *WriteBatch) Delete(tableName, hashValue string, rangeValue []byte) + type WriteIndexRequest struct + Writes []*IndexEntry + func (*WriteIndexRequest) Descriptor() ([]byte, []int) + func (*WriteIndexRequest) ProtoMessage() + func (m *WriteIndexRequest) GetWrites() []*IndexEntry + func (m *WriteIndexRequest) Marshal() (dAtA []byte, err error) + func (m *WriteIndexRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WriteIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteIndexRequest) Reset() + func (m *WriteIndexRequest) Size() (n int) + func (m *WriteIndexRequest) Unmarshal(dAtA []byte) error + func (m *WriteIndexRequest) XXX_DiscardUnknown() + func (m *WriteIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteIndexRequest) XXX_Merge(src proto.Message) + func (m *WriteIndexRequest) XXX_Size() int + func (m *WriteIndexRequest) XXX_Unmarshal(b []byte) error + func (this *WriteIndexRequest) Equal(that interface{}) bool + func (this *WriteIndexRequest) GoString() string + func (this *WriteIndexRequest) String() string
Go to main page