grpc

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

Variables ¶

View Source 
var (
	ErrInvalidLengthGrpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGrpc   = fmt.Errorf("proto: integer overflow")
)

Functions ¶

func RegisterGrpcStoreServer ¶ 

func RegisterGrpcStoreServer(s *grpc.Server, srv GrpcStoreServer)

Types ¶

type Chunk ¶ 

type Chunk struct {
	Encoded   []byte `protobuf:"bytes,1,opt,name=encoded,proto3" json:"encoded,omitempty"`
	Key       string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	TableName string `protobuf:"bytes,3,opt,name=tableName,proto3" json:"tableName,omitempty"`
}

func (*Chunk) Descriptor ¶ 

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

func (*Chunk) Equal ¶ 

func (this *Chunk) Equal(that interface{}) bool

func (*Chunk) GetEncoded ¶ 

func (m *Chunk) GetEncoded() []byte

func (*Chunk) GetKey ¶ 

func (m *Chunk) GetKey() string

func (*Chunk) GetTableName ¶ 

func (m *Chunk) GetTableName() string

func (*Chunk) GoString ¶ 

func (this *Chunk) GoString() string

func (*Chunk) Marshal ¶ 

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

func (*Chunk) MarshalTo ¶ 

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

func (*Chunk) MarshalToSizedBuffer ¶ 

func (m *Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Chunk) ProtoMessage ¶ 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset ¶ 

func (m *Chunk) Reset()

func (*Chunk) Size ¶ 

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

func (*Chunk) String ¶ 

func (this *Chunk) String() string

func (*Chunk) Unmarshal ¶ 

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

func (*Chunk) XXX_DiscardUnknown ¶ 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal ¶ 

func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Chunk) XXX_Merge ¶ 

func (m *Chunk) XXX_Merge(src proto.Message)

func (*Chunk) XXX_Size ¶ 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal ¶ 

func (m *Chunk) XXX_Unmarshal(b []byte) error

type ChunkID ¶ 

type ChunkID struct {
	ChunkID string `protobuf:"bytes,1,opt,name=chunkID,proto3" json:"chunkID,omitempty"`
}

func (*ChunkID) Descriptor ¶ 

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

func (*ChunkID) Equal ¶ 

func (this *ChunkID) Equal(that interface{}) bool

func (*ChunkID) GetChunkID ¶ 

func (m *ChunkID) GetChunkID() string

func (*ChunkID) GoString ¶ 

func (this *ChunkID) GoString() string

func (*ChunkID) Marshal ¶ 

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

func (*ChunkID) MarshalTo ¶ 

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

func (*ChunkID) MarshalToSizedBuffer ¶ 

func (m *ChunkID) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChunkID) ProtoMessage ¶ 

func (*ChunkID) ProtoMessage()

func (*ChunkID) Reset ¶ 

func (m *ChunkID) Reset()

func (*ChunkID) Size ¶ 

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

func (*ChunkID) String ¶ 

func (this *ChunkID) String() string

func (*ChunkID) Unmarshal ¶ 

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

func (*ChunkID) XXX_DiscardUnknown ¶ 

func (m *ChunkID) XXX_DiscardUnknown()

func (*ChunkID) XXX_Marshal ¶ 

func (m *ChunkID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChunkID) XXX_Merge ¶ 

func (m *ChunkID) XXX_Merge(src proto.Message)

func (*ChunkID) XXX_Size ¶ 

func (m *ChunkID) XXX_Size() int

func (*ChunkID) XXX_Unmarshal ¶ 

func (m *ChunkID) XXX_Unmarshal(b []byte) error

type Config ¶ 

type Config struct {
	Address string `yaml:"server_address,omitempty"`
}

Config for a StorageClient

func (*Config) RegisterFlags ¶ 

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags adds the flags required to config this to the given FlagSet

type CreateTableRequest ¶ 

type CreateTableRequest struct {
	Desc *TableDesc `protobuf:"bytes,1,opt,name=desc,proto3" json:"desc,omitempty"`
}

func (*CreateTableRequest) Descriptor ¶ 

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

func (*CreateTableRequest) Equal ¶ 

func (this *CreateTableRequest) Equal(that interface{}) bool

func (*CreateTableRequest) GetDesc ¶ 

func (m *CreateTableRequest) GetDesc() *TableDesc

func (*CreateTableRequest) GoString ¶ 

func (this *CreateTableRequest) GoString() string

func (*CreateTableRequest) Marshal ¶ 

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

func (*CreateTableRequest) MarshalTo ¶ 

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

func (*CreateTableRequest) MarshalToSizedBuffer ¶ 

func (m *CreateTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateTableRequest) ProtoMessage ¶ 

func (*CreateTableRequest) ProtoMessage()

func (*CreateTableRequest) Reset ¶ 

func (m *CreateTableRequest) Reset()

func (*CreateTableRequest) Size ¶ 

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

func (*CreateTableRequest) String ¶ 

func (this *CreateTableRequest) String() string

func (*CreateTableRequest) Unmarshal ¶ 

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

func (*CreateTableRequest) XXX_DiscardUnknown ¶ 

func (m *CreateTableRequest) XXX_DiscardUnknown()

func (*CreateTableRequest) XXX_Marshal ¶ 

func (m *CreateTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTableRequest) XXX_Merge ¶ 

func (m *CreateTableRequest) XXX_Merge(src proto.Message)

func (*CreateTableRequest) XXX_Size ¶ 

func (m *CreateTableRequest) XXX_Size() int

func (*CreateTableRequest) XXX_Unmarshal ¶ 

func (m *CreateTableRequest) XXX_Unmarshal(b []byte) error

type DeleteIndexRequest ¶ 

type DeleteIndexRequest struct {
	Deletes []*IndexEntry `protobuf:"bytes,1,rep,name=deletes,proto3" json:"deletes,omitempty"`
}

func (*DeleteIndexRequest) Descriptor ¶ 

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

func (*DeleteIndexRequest) Equal ¶ 

func (this *DeleteIndexRequest) Equal(that interface{}) bool

func (*DeleteIndexRequest) GetDeletes ¶ 

func (m *DeleteIndexRequest) GetDeletes() []*IndexEntry

func (*DeleteIndexRequest) GoString ¶ 

func (this *DeleteIndexRequest) GoString() string

func (*DeleteIndexRequest) Marshal ¶ 

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

func (*DeleteIndexRequest) MarshalTo ¶ 

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

func (*DeleteIndexRequest) MarshalToSizedBuffer ¶ 

func (m *DeleteIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteIndexRequest) ProtoMessage ¶ 

func (*DeleteIndexRequest) ProtoMessage()

func (*DeleteIndexRequest) Reset ¶ 

func (m *DeleteIndexRequest) Reset()

func (*DeleteIndexRequest) Size ¶ 

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

func (*DeleteIndexRequest) String ¶ 

func (this *DeleteIndexRequest) String() string

func (*DeleteIndexRequest) Unmarshal ¶ 

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

func (*DeleteIndexRequest) XXX_DiscardUnknown ¶ 

func (m *DeleteIndexRequest) XXX_DiscardUnknown()

func (*DeleteIndexRequest) XXX_Marshal ¶ 

func (m *DeleteIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteIndexRequest) XXX_Merge ¶ 

func (m *DeleteIndexRequest) XXX_Merge(src proto.Message)

func (*DeleteIndexRequest) XXX_Size ¶ 

func (m *DeleteIndexRequest) XXX_Size() int

func (*DeleteIndexRequest) XXX_Unmarshal ¶ 

func (m *DeleteIndexRequest) XXX_Unmarshal(b []byte) error

type DeleteTableRequest ¶ 

type DeleteTableRequest struct {
	TableName string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
}

func (*DeleteTableRequest) Descriptor ¶ 

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

func (*DeleteTableRequest) Equal ¶ 

func (this *DeleteTableRequest) Equal(that interface{}) bool

func (*DeleteTableRequest) GetTableName ¶ 

func (m *DeleteTableRequest) GetTableName() string

func (*DeleteTableRequest) GoString ¶ 

func (this *DeleteTableRequest) GoString() string

func (*DeleteTableRequest) Marshal ¶ 

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

func (*DeleteTableRequest) MarshalTo ¶ 

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

func (*DeleteTableRequest) MarshalToSizedBuffer ¶ 

func (m *DeleteTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteTableRequest) ProtoMessage ¶ 

func (*DeleteTableRequest) ProtoMessage()

func (*DeleteTableRequest) Reset ¶ 

func (m *DeleteTableRequest) Reset()

func (*DeleteTableRequest) Size ¶ 

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

func (*DeleteTableRequest) String ¶ 

func (this *DeleteTableRequest) String() string

func (*DeleteTableRequest) Unmarshal ¶ 

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

func (*DeleteTableRequest) XXX_DiscardUnknown ¶ 

func (m *DeleteTableRequest) XXX_DiscardUnknown()

func (*DeleteTableRequest) XXX_Marshal ¶ 

func (m *DeleteTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTableRequest) XXX_Merge ¶ 

func (m *DeleteTableRequest) XXX_Merge(src proto.Message)

func (*DeleteTableRequest) XXX_Size ¶ 

func (m *DeleteTableRequest) XXX_Size() int

func (*DeleteTableRequest) XXX_Unmarshal ¶ 

func (m *DeleteTableRequest) XXX_Unmarshal(b []byte) error

type DescribeTableRequest ¶ 

type DescribeTableRequest struct {
	TableName string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
}

func (*DescribeTableRequest) Descriptor ¶ 

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

func (*DescribeTableRequest) Equal ¶ 

func (this *DescribeTableRequest) Equal(that interface{}) bool

func (*DescribeTableRequest) GetTableName ¶ 

func (m *DescribeTableRequest) GetTableName() string

func (*DescribeTableRequest) GoString ¶ 

func (this *DescribeTableRequest) GoString() string

func (*DescribeTableRequest) Marshal ¶ 

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

func (*DescribeTableRequest) MarshalTo ¶ 

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

func (*DescribeTableRequest) MarshalToSizedBuffer ¶ 

func (m *DescribeTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DescribeTableRequest) ProtoMessage ¶ 

func (*DescribeTableRequest) ProtoMessage()

func (*DescribeTableRequest) Reset ¶ 

func (m *DescribeTableRequest) Reset()

func (*DescribeTableRequest) Size ¶ 

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

func (*DescribeTableRequest) String ¶ 

func (this *DescribeTableRequest) String() string

func (*DescribeTableRequest) Unmarshal ¶ 

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

func (*DescribeTableRequest) XXX_DiscardUnknown ¶ 

func (m *DescribeTableRequest) XXX_DiscardUnknown()

func (*DescribeTableRequest) XXX_Marshal ¶ 

func (m *DescribeTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTableRequest) XXX_Merge ¶ 

func (m *DescribeTableRequest) XXX_Merge(src proto.Message)

func (*DescribeTableRequest) XXX_Size ¶ 

func (m *DescribeTableRequest) XXX_Size() int

func (*DescribeTableRequest) XXX_Unmarshal ¶ 

func (m *DescribeTableRequest) XXX_Unmarshal(b []byte) error

type DescribeTableResponse ¶ 

type DescribeTableResponse struct {
	Desc     *TableDesc `protobuf:"bytes,1,opt,name=desc,proto3" json:"desc,omitempty"`
	IsActive bool       `protobuf:"varint,2,opt,name=isActive,proto3" json:"isActive,omitempty"`
}

func (*DescribeTableResponse) Descriptor ¶ 

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

func (*DescribeTableResponse) Equal ¶ 

func (this *DescribeTableResponse) Equal(that interface{}) bool

func (*DescribeTableResponse) GetDesc ¶ 

func (m *DescribeTableResponse) GetDesc() *TableDesc

func (*DescribeTableResponse) GetIsActive ¶ 

func (m *DescribeTableResponse) GetIsActive() bool

func (*DescribeTableResponse) GoString ¶ 

func (this *DescribeTableResponse) GoString() string

func (*DescribeTableResponse) Marshal ¶ 

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

func (*DescribeTableResponse) MarshalTo ¶ 

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

func (*DescribeTableResponse) MarshalToSizedBuffer ¶ 

func (m *DescribeTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DescribeTableResponse) ProtoMessage ¶ 

func (*DescribeTableResponse) ProtoMessage()

func (*DescribeTableResponse) Reset ¶ 

func (m *DescribeTableResponse) Reset()

func (*DescribeTableResponse) Size ¶ 

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

func (*DescribeTableResponse) String ¶ 

func (this *DescribeTableResponse) String() string

func (*DescribeTableResponse) Unmarshal ¶ 

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

func (*DescribeTableResponse) XXX_DiscardUnknown ¶ 

func (m *DescribeTableResponse) XXX_DiscardUnknown()

func (*DescribeTableResponse) XXX_Marshal ¶ 

func (m *DescribeTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTableResponse) XXX_Merge ¶ 

func (m *DescribeTableResponse) XXX_Merge(src proto.Message)

func (*DescribeTableResponse) XXX_Size ¶ 

func (m *DescribeTableResponse) XXX_Size() int

func (*DescribeTableResponse) XXX_Unmarshal ¶ 

func (m *DescribeTableResponse) XXX_Unmarshal(b []byte) error

type GetChunksRequest ¶ 

type GetChunksRequest struct {
	Chunks []*Chunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"`
}

func (*GetChunksRequest) Descriptor ¶ 

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

func (*GetChunksRequest) Equal ¶ 

func (this *GetChunksRequest) Equal(that interface{}) bool

func (*GetChunksRequest) GetChunks ¶ 

func (m *GetChunksRequest) GetChunks() []*Chunk

func (*GetChunksRequest) GoString ¶ 

func (this *GetChunksRequest) GoString() string

func (*GetChunksRequest) Marshal ¶ 

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

func (*GetChunksRequest) MarshalTo ¶ 

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

func (*GetChunksRequest) MarshalToSizedBuffer ¶ 

func (m *GetChunksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetChunksRequest) ProtoMessage ¶ 

func (*GetChunksRequest) ProtoMessage()

func (*GetChunksRequest) Reset ¶ 

func (m *GetChunksRequest) Reset()

func (*GetChunksRequest) Size ¶ 

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

func (*GetChunksRequest) String ¶ 

func (this *GetChunksRequest) String() string

func (*GetChunksRequest) Unmarshal ¶ 

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

func (*GetChunksRequest) XXX_DiscardUnknown ¶ 

func (m *GetChunksRequest) XXX_DiscardUnknown()

func (*GetChunksRequest) XXX_Marshal ¶ 

func (m *GetChunksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChunksRequest) XXX_Merge ¶ 

func (m *GetChunksRequest) XXX_Merge(src proto.Message)

func (*GetChunksRequest) XXX_Size ¶ 

func (m *GetChunksRequest) XXX_Size() int

func (*GetChunksRequest) XXX_Unmarshal ¶ 

func (m *GetChunksRequest) XXX_Unmarshal(b []byte) error

type GetChunksResponse ¶ 

type GetChunksResponse struct {
	Chunks []*Chunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"`
}

func (*GetChunksResponse) Descriptor ¶ 

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

func (*GetChunksResponse) Equal ¶ 

func (this *GetChunksResponse) Equal(that interface{}) bool

func (*GetChunksResponse) GetChunks ¶ 

func (m *GetChunksResponse) GetChunks() []*Chunk

func (*GetChunksResponse) GoString ¶ 

func (this *GetChunksResponse) GoString() string

func (*GetChunksResponse) Marshal ¶ 

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

func (*GetChunksResponse) MarshalTo ¶ 

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

func (*GetChunksResponse) MarshalToSizedBuffer ¶ 

func (m *GetChunksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetChunksResponse) ProtoMessage ¶ 

func (*GetChunksResponse) ProtoMessage()

func (*GetChunksResponse) Reset ¶ 

func (m *GetChunksResponse) Reset()

func (*GetChunksResponse) Size ¶ 

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

func (*GetChunksResponse) String ¶ 

func (this *GetChunksResponse) String() string

func (*GetChunksResponse) Unmarshal ¶ 

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

func (*GetChunksResponse) XXX_DiscardUnknown ¶ 

func (m *GetChunksResponse) XXX_DiscardUnknown()

func (*GetChunksResponse) XXX_Marshal ¶ 

func (m *GetChunksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChunksResponse) XXX_Merge ¶ 

func (m *GetChunksResponse) XXX_Merge(src proto.Message)

func (*GetChunksResponse) XXX_Size ¶ 

func (m *GetChunksResponse) XXX_Size() int

func (*GetChunksResponse) XXX_Unmarshal ¶ 

func (m *GetChunksResponse) XXX_Unmarshal(b []byte) error

type GrpcStoreClient ¶ 

type GrpcStoreClient interface {
	/// WriteIndex writes batch of indexes to the index tables.
	WriteIndex(ctx context.Context, in *WriteIndexRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	/// QueryIndex reads the indexes required for given query & sends back the batch of rows
	/// in rpc streams
	QueryIndex(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (GrpcStore_QueryIndexClient, error)
	/// DeleteIndex deletes the batch of index entries from the index tables
	DeleteIndex(ctx context.Context, in *DeleteIndexRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	/// PutChunks saves the batch of chunks into the chunk tables.
	PutChunks(ctx context.Context, in *PutChunksRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	/// GetChunks requests for batch of chunks and the batch of chunks are sent back in rpc streams
	/// batching needs to be performed at server level as per requirement instead of sending single chunk per stream.
	/// In GetChunks rpc request send buf as nil
	GetChunks(ctx context.Context, in *GetChunksRequest, opts ...grpc.CallOption) (GrpcStore_GetChunksClient, error)
	/// DeleteChunks deletes the chunks based on chunkID.
	DeleteChunks(ctx context.Context, in *ChunkID, opts ...grpc.CallOption) (*empty.Empty, error)
	/// Lists all the tables that exists in the database.
	ListTables(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTablesResponse, error)
	/// Creates a table with provided name & attributes.
	CreateTable(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Deletes a table using table name provided.
	DeleteTable(ctx context.Context, in *DeleteTableRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Describes a table information for the provided table.
	DescribeTable(ctx context.Context, in *DescribeTableRequest, opts ...grpc.CallOption) (*DescribeTableResponse, error)
	// Update a table with newly provided table information.
	UpdateTable(ctx context.Context, in *UpdateTableRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

GrpcStoreClient is the client API for GrpcStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGrpcStoreClient ¶ 

func NewGrpcStoreClient(cc *grpc.ClientConn) GrpcStoreClient

type GrpcStoreServer ¶ 

type GrpcStoreServer interface {
	/// WriteIndex writes batch of indexes to the index tables.
	WriteIndex(context.Context, *WriteIndexRequest) (*empty.Empty, error)
	/// QueryIndex reads the indexes required for given query & sends back the batch of rows
	/// in rpc streams
	QueryIndex(*QueryIndexRequest, GrpcStore_QueryIndexServer) error
	/// DeleteIndex deletes the batch of index entries from the index tables
	DeleteIndex(context.Context, *DeleteIndexRequest) (*empty.Empty, error)
	/// PutChunks saves the batch of chunks into the chunk tables.
	PutChunks(context.Context, *PutChunksRequest) (*empty.Empty, error)
	/// GetChunks requests for batch of chunks and the batch of chunks are sent back in rpc streams
	/// batching needs to be performed at server level as per requirement instead of sending single chunk per stream.
	/// In GetChunks rpc request send buf as nil
	GetChunks(*GetChunksRequest, GrpcStore_GetChunksServer) error
	/// DeleteChunks deletes the chunks based on chunkID.
	DeleteChunks(context.Context, *ChunkID) (*empty.Empty, error)
	/// Lists all the tables that exists in the database.
	ListTables(context.Context, *empty.Empty) (*ListTablesResponse, error)
	/// Creates a table with provided name & attributes.
	CreateTable(context.Context, *CreateTableRequest) (*empty.Empty, error)
	// Deletes a table using table name provided.
	DeleteTable(context.Context, *DeleteTableRequest) (*empty.Empty, error)
	// Describes a table information for the provided table.
	DescribeTable(context.Context, *DescribeTableRequest) (*DescribeTableResponse, error)
	// Update a table with newly provided table information.
	UpdateTable(context.Context, *UpdateTableRequest) (*empty.Empty, error)
}

GrpcStoreServer is the server API for GrpcStore service.

type GrpcStore_GetChunksClient ¶ 

type GrpcStore_GetChunksClient interface {
	Recv() (*GetChunksResponse, error)
	grpc.ClientStream
}

type GrpcStore_GetChunksServer ¶ 

type GrpcStore_GetChunksServer interface {
	Send(*GetChunksResponse) error
	grpc.ServerStream
}

type GrpcStore_QueryIndexClient ¶ 

type GrpcStore_QueryIndexClient interface {
	Recv() (*QueryIndexResponse, error)
	grpc.ClientStream
}

type GrpcStore_QueryIndexServer ¶ 

type GrpcStore_QueryIndexServer interface {
	Send(*QueryIndexResponse) error
	grpc.ServerStream
}

type IndexEntry ¶ 

type IndexEntry struct {
	TableName  string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	HashValue  string `protobuf:"bytes,2,opt,name=hashValue,proto3" json:"hashValue,omitempty"`
	RangeValue []byte `protobuf:"bytes,3,opt,name=rangeValue,proto3" json:"rangeValue,omitempty"`
	Value      []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
}

func (*IndexEntry) Descriptor ¶ 

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

func (*IndexEntry) Equal ¶ 

func (this *IndexEntry) Equal(that interface{}) bool

func (*IndexEntry) GetHashValue ¶ 

func (m *IndexEntry) GetHashValue() string

func (*IndexEntry) GetRangeValue ¶ 

func (m *IndexEntry) GetRangeValue() []byte

func (*IndexEntry) GetTableName ¶ 

func (m *IndexEntry) GetTableName() string

func (*IndexEntry) GetValue ¶ 

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

func (*IndexEntry) GoString ¶ 

func (this *IndexEntry) GoString() string

func (*IndexEntry) Marshal ¶ 

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

func (*IndexEntry) MarshalTo ¶ 

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

func (*IndexEntry) MarshalToSizedBuffer ¶ 

func (m *IndexEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IndexEntry) ProtoMessage ¶ 

func (*IndexEntry) ProtoMessage()

func (*IndexEntry) Reset ¶ 

func (m *IndexEntry) Reset()

func (*IndexEntry) Size ¶ 

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

func (*IndexEntry) String ¶ 

func (this *IndexEntry) String() string

func (*IndexEntry) Unmarshal ¶ 

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

func (*IndexEntry) XXX_DiscardUnknown ¶ 

func (m *IndexEntry) XXX_DiscardUnknown()

func (*IndexEntry) XXX_Marshal ¶ 

func (m *IndexEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexEntry) XXX_Merge ¶ 

func (m *IndexEntry) XXX_Merge(src proto.Message)

func (*IndexEntry) XXX_Size ¶ 

func (m *IndexEntry) XXX_Size() int

func (*IndexEntry) XXX_Unmarshal ¶ 

func (m *IndexEntry) XXX_Unmarshal(b []byte) error

type Labels ¶ 

type Labels struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Labels) Descriptor ¶ 

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

func (*Labels) Equal ¶ 

func (this *Labels) Equal(that interface{}) bool

func (*Labels) GetName ¶ 

func (m *Labels) GetName() string

func (*Labels) GetValue ¶ 

func (m *Labels) GetValue() string

func (*Labels) GoString ¶ 

func (this *Labels) GoString() string

func (*Labels) Marshal ¶ 

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

func (*Labels) MarshalTo ¶ 

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

func (*Labels) MarshalToSizedBuffer ¶ 

func (m *Labels) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Labels) ProtoMessage ¶ 

func (*Labels) ProtoMessage()

func (*Labels) Reset ¶ 

func (m *Labels) Reset()

func (*Labels) Size ¶ 

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

func (*Labels) String ¶ 

func (this *Labels) String() string

func (*Labels) Unmarshal ¶ 

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

func (*Labels) XXX_DiscardUnknown ¶ 

func (m *Labels) XXX_DiscardUnknown()

func (*Labels) XXX_Marshal ¶ 

func (m *Labels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Labels) XXX_Merge ¶ 

func (m *Labels) XXX_Merge(src proto.Message)

func (*Labels) XXX_Size ¶ 

func (m *Labels) XXX_Size() int

func (*Labels) XXX_Unmarshal ¶ 

func (m *Labels) XXX_Unmarshal(b []byte) error

type ListTablesResponse ¶ 

type ListTablesResponse struct {
	TableNames []string `protobuf:"bytes,1,rep,name=tableNames,proto3" json:"tableNames,omitempty"`
}

func (*ListTablesResponse) Descriptor ¶ 

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

func (*ListTablesResponse) Equal ¶ 

func (this *ListTablesResponse) Equal(that interface{}) bool

func (*ListTablesResponse) GetTableNames ¶ 

func (m *ListTablesResponse) GetTableNames() []string

func (*ListTablesResponse) GoString ¶ 

func (this *ListTablesResponse) GoString() string

func (*ListTablesResponse) Marshal ¶ 

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

func (*ListTablesResponse) MarshalTo ¶ 

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

func (*ListTablesResponse) MarshalToSizedBuffer ¶ 

func (m *ListTablesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListTablesResponse) ProtoMessage ¶ 

func (*ListTablesResponse) ProtoMessage()

func (*ListTablesResponse) Reset ¶ 

func (m *ListTablesResponse) Reset()

func (*ListTablesResponse) Size ¶ 

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

func (*ListTablesResponse) String ¶ 

func (this *ListTablesResponse) String() string

func (*ListTablesResponse) Unmarshal ¶ 

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

func (*ListTablesResponse) XXX_DiscardUnknown ¶ 

func (m *ListTablesResponse) XXX_DiscardUnknown()

func (*ListTablesResponse) XXX_Marshal ¶ 

func (m *ListTablesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTablesResponse) XXX_Merge ¶ 

func (m *ListTablesResponse) XXX_Merge(src proto.Message)

func (*ListTablesResponse) XXX_Size ¶ 

func (m *ListTablesResponse) XXX_Size() int

func (*ListTablesResponse) XXX_Unmarshal ¶ 

func (m *ListTablesResponse) XXX_Unmarshal(b []byte) error

type PutChunksRequest ¶ 

type PutChunksRequest struct {
	Chunks []*Chunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"`
}

func (*PutChunksRequest) Descriptor ¶ 

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

func (*PutChunksRequest) Equal ¶ 

func (this *PutChunksRequest) Equal(that interface{}) bool

func (*PutChunksRequest) GetChunks ¶ 

func (m *PutChunksRequest) GetChunks() []*Chunk

func (*PutChunksRequest) GoString ¶ 

func (this *PutChunksRequest) GoString() string

func (*PutChunksRequest) Marshal ¶ 

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

func (*PutChunksRequest) MarshalTo ¶ 

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

func (*PutChunksRequest) MarshalToSizedBuffer ¶ 

func (m *PutChunksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PutChunksRequest) ProtoMessage ¶ 

func (*PutChunksRequest) ProtoMessage()

func (*PutChunksRequest) Reset ¶ 

func (m *PutChunksRequest) Reset()

func (*PutChunksRequest) Size ¶ 

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

func (*PutChunksRequest) String ¶ 

func (this *PutChunksRequest) String() string

func (*PutChunksRequest) Unmarshal ¶ 

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

func (*PutChunksRequest) XXX_DiscardUnknown ¶ 

func (m *PutChunksRequest) XXX_DiscardUnknown()

func (*PutChunksRequest) XXX_Marshal ¶ 

func (m *PutChunksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutChunksRequest) XXX_Merge ¶ 

func (m *PutChunksRequest) XXX_Merge(src proto.Message)

func (*PutChunksRequest) XXX_Size ¶ 

func (m *PutChunksRequest) XXX_Size() int

func (*PutChunksRequest) XXX_Unmarshal ¶ 

func (m *PutChunksRequest) XXX_Unmarshal(b []byte) error

type QueryIndexRequest ¶ 

type QueryIndexRequest struct {
	TableName        string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	HashValue        string `protobuf:"bytes,2,opt,name=hashValue,proto3" json:"hashValue,omitempty"`
	RangeValuePrefix []byte `protobuf:"bytes,3,opt,name=rangeValuePrefix,proto3" json:"rangeValuePrefix,omitempty"`
	RangeValueStart  []byte `protobuf:"bytes,4,opt,name=rangeValueStart,proto3" json:"rangeValueStart,omitempty"`
	ValueEqual       []byte `protobuf:"bytes,5,opt,name=valueEqual,proto3" json:"valueEqual,omitempty"`
	Immutable        bool   `protobuf:"varint,6,opt,name=immutable,proto3" json:"immutable,omitempty"`
}

func (*QueryIndexRequest) Descriptor ¶ 

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

func (*QueryIndexRequest) Equal ¶ 

func (this *QueryIndexRequest) Equal(that interface{}) bool

func (*QueryIndexRequest) GetHashValue ¶ 

func (m *QueryIndexRequest) GetHashValue() string

func (*QueryIndexRequest) GetImmutable ¶ 

func (m *QueryIndexRequest) GetImmutable() bool

func (*QueryIndexRequest) GetRangeValuePrefix ¶ 

func (m *QueryIndexRequest) GetRangeValuePrefix() []byte

func (*QueryIndexRequest) GetRangeValueStart ¶ 

func (m *QueryIndexRequest) GetRangeValueStart() []byte

func (*QueryIndexRequest) GetTableName ¶ 

func (m *QueryIndexRequest) GetTableName() string

func (*QueryIndexRequest) GetValueEqual ¶ 

func (m *QueryIndexRequest) GetValueEqual() []byte

func (*QueryIndexRequest) GoString ¶ 

func (this *QueryIndexRequest) GoString() string

func (*QueryIndexRequest) Marshal ¶ 

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

func (*QueryIndexRequest) MarshalTo ¶ 

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

func (*QueryIndexRequest) MarshalToSizedBuffer ¶ 

func (m *QueryIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryIndexRequest) ProtoMessage ¶ 

func (*QueryIndexRequest) ProtoMessage()

func (*QueryIndexRequest) Reset ¶ 

func (m *QueryIndexRequest) Reset()

func (*QueryIndexRequest) Size ¶ 

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

func (*QueryIndexRequest) String ¶ 

func (this *QueryIndexRequest) String() string

func (*QueryIndexRequest) Unmarshal ¶ 

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

func (*QueryIndexRequest) XXX_DiscardUnknown ¶ 

func (m *QueryIndexRequest) XXX_DiscardUnknown()

func (*QueryIndexRequest) XXX_Marshal ¶ 

func (m *QueryIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryIndexRequest) XXX_Merge ¶ 

func (m *QueryIndexRequest) XXX_Merge(src proto.Message)

func (*QueryIndexRequest) XXX_Size ¶ 

func (m *QueryIndexRequest) XXX_Size() int

func (*QueryIndexRequest) XXX_Unmarshal ¶ 

func (m *QueryIndexRequest) XXX_Unmarshal(b []byte) error

type QueryIndexResponse ¶ 

type QueryIndexResponse struct {
	Rows []*Row `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
}

func (*QueryIndexResponse) Descriptor ¶ 

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

func (*QueryIndexResponse) Equal ¶ 

func (this *QueryIndexResponse) Equal(that interface{}) bool

func (*QueryIndexResponse) GetRows ¶ 

func (m *QueryIndexResponse) GetRows() []*Row

func (*QueryIndexResponse) GoString ¶ 

func (this *QueryIndexResponse) GoString() string

func (*QueryIndexResponse) Iterator ¶ 

func (r *QueryIndexResponse) Iterator() chunk.ReadBatchIterator

func (*QueryIndexResponse) Marshal ¶ 

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

func (*QueryIndexResponse) MarshalTo ¶ 

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

func (*QueryIndexResponse) MarshalToSizedBuffer ¶ 

func (m *QueryIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryIndexResponse) ProtoMessage ¶ 

func (*QueryIndexResponse) ProtoMessage()

func (*QueryIndexResponse) Reset ¶ 

func (m *QueryIndexResponse) Reset()

func (*QueryIndexResponse) Size ¶ 

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

func (*QueryIndexResponse) String ¶ 

func (this *QueryIndexResponse) String() string

func (*QueryIndexResponse) Unmarshal ¶ 

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

func (*QueryIndexResponse) XXX_DiscardUnknown ¶ 

func (m *QueryIndexResponse) XXX_DiscardUnknown()

func (*QueryIndexResponse) XXX_Marshal ¶ 

func (m *QueryIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryIndexResponse) XXX_Merge ¶ 

func (m *QueryIndexResponse) XXX_Merge(src proto.Message)

func (*QueryIndexResponse) XXX_Size ¶ 

func (m *QueryIndexResponse) XXX_Size() int

func (*QueryIndexResponse) XXX_Unmarshal ¶ 

func (m *QueryIndexResponse) XXX_Unmarshal(b []byte) error

type Row ¶ 

type Row struct {
	RangeValue []byte `protobuf:"bytes,1,opt,name=rangeValue,proto3" json:"rangeValue,omitempty"`
	Value      []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Row) Descriptor ¶ 

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

func (*Row) Equal ¶ 

func (this *Row) Equal(that interface{}) bool

func (*Row) GetRangeValue ¶ 

func (m *Row) GetRangeValue() []byte

func (*Row) GetValue ¶ 

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

func (*Row) GoString ¶ 

func (this *Row) GoString() string

func (*Row) Marshal ¶ 

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

func (*Row) MarshalTo ¶ 

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

func (*Row) MarshalToSizedBuffer ¶ 

func (m *Row) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Row) ProtoMessage ¶ 

func (*Row) ProtoMessage()

func (*Row) Reset ¶ 

func (m *Row) Reset()

func (*Row) Size ¶ 

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

func (*Row) String ¶ 

func (this *Row) String() string

func (*Row) Unmarshal ¶ 

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

func (*Row) XXX_DiscardUnknown ¶ 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal ¶ 

func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Row) XXX_Merge ¶ 

func (m *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size ¶ 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal ¶ 

func (m *Row) XXX_Unmarshal(b []byte) error

type StorageClient ¶ 

type StorageClient struct {
	// contains filtered or unexported fields
}

func NewStorageClient ¶ 

func NewStorageClient(cfg Config, schemaCfg chunk.SchemaConfig) (*StorageClient, error)

NewStorageClient returns a new StorageClient.

func (*StorageClient) BatchWrite ¶ 

func (s *StorageClient) BatchWrite(c context.Context, batch chunk.WriteBatch) error

func (*StorageClient) DeleteChunk ¶ 

func (s *StorageClient) DeleteChunk(ctx context.Context, userID, chunkID string) error

func (*StorageClient) GetChunks ¶ 

func (s *StorageClient) GetChunks(ctx context.Context, input []chunk.Chunk) ([]chunk.Chunk, error)

func (*StorageClient) NewWriteBatch ¶ 

func (s *StorageClient) NewWriteBatch() chunk.WriteBatch

func (*StorageClient) PutChunks ¶ 

func (s *StorageClient) PutChunks(ctx context.Context, chunks []chunk.Chunk) error

PutChunks implements chunk.ObjectClient.

func (*StorageClient) QueryPages ¶ 

func (s *StorageClient) QueryPages(ctx context.Context, queries []chunk.IndexQuery, callback func(chunk.IndexQuery, chunk.ReadBatch) (shouldContinue bool)) error

func (*StorageClient) Stop ¶ 

func (s *StorageClient) Stop()

type TableClient ¶ 

type TableClient struct {
	// contains filtered or unexported fields
}

func NewTableClient ¶ 

func NewTableClient(cfg Config) (*TableClient, error)

NewTableClient returns a new TableClient.

func (*TableClient) CreateTable ¶ 

func (c *TableClient) CreateTable(ctx context.Context, desc chunk.TableDesc) error

func (*TableClient) DeleteTable ¶ 

func (c *TableClient) DeleteTable(ctx context.Context, name string) error

func (*TableClient) DescribeTable ¶ 

func (c *TableClient) DescribeTable(ctx context.Context, name string) (desc chunk.TableDesc, isActive bool, err error)

func (*TableClient) ListTables ¶ 

func (c *TableClient) ListTables(ctx context.Context) ([]string, error)

func (*TableClient) Stop ¶ 

func (c *TableClient) Stop()

func (*TableClient) UpdateTable ¶ 

func (c *TableClient) UpdateTable(ctx context.Context, current, expected chunk.TableDesc) error

type TableDesc ¶ 

type TableDesc struct {
	Name              string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UseOnDemandIOMode bool              `protobuf:"varint,2,opt,name=useOnDemandIOMode,proto3" json:"useOnDemandIOMode,omitempty"`
	ProvisionedRead   int64             `protobuf:"varint,3,opt,name=provisionedRead,proto3" json:"provisionedRead,omitempty"`
	ProvisionedWrite  int64             `protobuf:"varint,4,opt,name=provisionedWrite,proto3" json:"provisionedWrite,omitempty"`
	Tags              map[string]string `` /* 149-byte string literal not displayed */
}

func (*TableDesc) Descriptor ¶ 

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

func (*TableDesc) Equal ¶ 

func (this *TableDesc) Equal(that interface{}) bool

func (*TableDesc) GetName ¶ 

func (m *TableDesc) GetName() string

func (*TableDesc) GetProvisionedRead ¶ 

func (m *TableDesc) GetProvisionedRead() int64

func (*TableDesc) GetProvisionedWrite ¶ 

func (m *TableDesc) GetProvisionedWrite() int64

func (*TableDesc) GetTags ¶ 

func (m *TableDesc) GetTags() map[string]string

func (*TableDesc) GetUseOnDemandIOMode ¶ 

func (m *TableDesc) GetUseOnDemandIOMode() bool

func (*TableDesc) GoString ¶ 

func (this *TableDesc) GoString() string

func (*TableDesc) Marshal ¶ 

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

func (*TableDesc) MarshalTo ¶ 

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

func (*TableDesc) MarshalToSizedBuffer ¶ 

func (m *TableDesc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TableDesc) ProtoMessage ¶ 

func (*TableDesc) ProtoMessage()

func (*TableDesc) Reset ¶ 

func (m *TableDesc) Reset()

func (*TableDesc) Size ¶ 

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

func (*TableDesc) String ¶ 

func (this *TableDesc) String() string

func (*TableDesc) Unmarshal ¶ 

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

func (*TableDesc) XXX_DiscardUnknown ¶ 

func (m *TableDesc) XXX_DiscardUnknown()

func (*TableDesc) XXX_Marshal ¶ 

func (m *TableDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableDesc) XXX_Merge ¶ 

func (m *TableDesc) XXX_Merge(src proto.Message)

func (*TableDesc) XXX_Size ¶ 

func (m *TableDesc) XXX_Size() int

func (*TableDesc) XXX_Unmarshal ¶ 

func (m *TableDesc) XXX_Unmarshal(b []byte) error

type UnimplementedGrpcStoreServer ¶ 

type UnimplementedGrpcStoreServer struct {
}

UnimplementedGrpcStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedGrpcStoreServer) CreateTable ¶ 

func (*UnimplementedGrpcStoreServer) CreateTable(ctx context.Context, req *CreateTableRequest) (*empty.Empty, error)

func (*UnimplementedGrpcStoreServer) DeleteChunks ¶ 

func (*UnimplementedGrpcStoreServer) DeleteChunks(ctx context.Context, req *ChunkID) (*empty.Empty, error)

func (*UnimplementedGrpcStoreServer) DeleteIndex ¶ 

func (*UnimplementedGrpcStoreServer) DeleteIndex(ctx context.Context, req *DeleteIndexRequest) (*empty.Empty, error)

func (*UnimplementedGrpcStoreServer) DeleteTable ¶ 

func (*UnimplementedGrpcStoreServer) DeleteTable(ctx context.Context, req *DeleteTableRequest) (*empty.Empty, error)

func (*UnimplementedGrpcStoreServer) DescribeTable ¶ 

func (*UnimplementedGrpcStoreServer) DescribeTable(ctx context.Context, req *DescribeTableRequest) (*DescribeTableResponse, error)

func (*UnimplementedGrpcStoreServer) GetChunks ¶ 

func (*UnimplementedGrpcStoreServer) GetChunks(req *GetChunksRequest, srv GrpcStore_GetChunksServer) error

func (*UnimplementedGrpcStoreServer) ListTables ¶ 

func (*UnimplementedGrpcStoreServer) ListTables(ctx context.Context, req *empty.Empty) (*ListTablesResponse, error)

func (*UnimplementedGrpcStoreServer) PutChunks ¶ 

func (*UnimplementedGrpcStoreServer) PutChunks(ctx context.Context, req *PutChunksRequest) (*empty.Empty, error)

func (*UnimplementedGrpcStoreServer) QueryIndex ¶ 

func (*UnimplementedGrpcStoreServer) QueryIndex(req *QueryIndexRequest, srv GrpcStore_QueryIndexServer) error

func (*UnimplementedGrpcStoreServer) UpdateTable ¶ 

func (*UnimplementedGrpcStoreServer) UpdateTable(ctx context.Context, req *UpdateTableRequest) (*empty.Empty, error)

func (*UnimplementedGrpcStoreServer) WriteIndex ¶ 

func (*UnimplementedGrpcStoreServer) WriteIndex(ctx context.Context, req *WriteIndexRequest) (*empty.Empty, error)

type UpdateTableRequest ¶ 

type UpdateTableRequest struct {
	Current  *TableDesc `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	Expected *TableDesc `protobuf:"bytes,2,opt,name=expected,proto3" json:"expected,omitempty"`
}

func (*UpdateTableRequest) Descriptor ¶ 

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

func (*UpdateTableRequest) Equal ¶ 

func (this *UpdateTableRequest) Equal(that interface{}) bool

func (*UpdateTableRequest) GetCurrent ¶ 

func (m *UpdateTableRequest) GetCurrent() *TableDesc

func (*UpdateTableRequest) GetExpected ¶ 

func (m *UpdateTableRequest) GetExpected() *TableDesc

func (*UpdateTableRequest) GoString ¶ 

func (this *UpdateTableRequest) GoString() string

func (*UpdateTableRequest) Marshal ¶ 

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

func (*UpdateTableRequest) MarshalTo ¶ 

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

func (*UpdateTableRequest) MarshalToSizedBuffer ¶ 

func (m *UpdateTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateTableRequest) ProtoMessage ¶ 

func (*UpdateTableRequest) ProtoMessage()

func (*UpdateTableRequest) Reset ¶ 

func (m *UpdateTableRequest) Reset()

func (*UpdateTableRequest) Size ¶ 

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

func (*UpdateTableRequest) String ¶ 

func (this *UpdateTableRequest) String() string

func (*UpdateTableRequest) Unmarshal ¶ 

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

func (*UpdateTableRequest) XXX_DiscardUnknown ¶ 

func (m *UpdateTableRequest) XXX_DiscardUnknown()

func (*UpdateTableRequest) XXX_Marshal ¶ 

func (m *UpdateTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateTableRequest) XXX_Merge ¶ 

func (m *UpdateTableRequest) XXX_Merge(src proto.Message)

func (*UpdateTableRequest) XXX_Size ¶ 

func (m *UpdateTableRequest) XXX_Size() int

func (*UpdateTableRequest) XXX_Unmarshal ¶ 

func (m *UpdateTableRequest) XXX_Unmarshal(b []byte) error

type WriteBatch ¶ 

type WriteBatch struct {
	Writes  []*IndexEntry `protobuf:"bytes,1,rep,name=writes,proto3" json:"writes,omitempty"`
	Deletes []*IndexEntry `protobuf:"bytes,2,rep,name=deletes,proto3" json:"deletes,omitempty"`
}

func (*WriteBatch) Add ¶ 

func (w *WriteBatch) Add(tableName, hashValue string, rangeValue []byte, value []byte)

func (*WriteBatch) Delete ¶ 

func (w *WriteBatch) Delete(tableName, hashValue string, rangeValue []byte)

func (*WriteBatch) Descriptor ¶ 

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

func (*WriteBatch) Equal ¶ 

func (this *WriteBatch) Equal(that interface{}) bool

func (*WriteBatch) GetDeletes ¶ 

func (m *WriteBatch) GetDeletes() []*IndexEntry

func (*WriteBatch) GetWrites ¶ 

func (m *WriteBatch) GetWrites() []*IndexEntry

func (*WriteBatch) GoString ¶ 

func (this *WriteBatch) GoString() string

func (*WriteBatch) Marshal ¶ 

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

func (*WriteBatch) MarshalTo ¶ 

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

func (*WriteBatch) MarshalToSizedBuffer ¶ 

func (m *WriteBatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WriteBatch) ProtoMessage ¶ 

func (*WriteBatch) ProtoMessage()

func (*WriteBatch) Reset ¶ 

func (m *WriteBatch) Reset()

func (*WriteBatch) Size ¶ 

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

func (*WriteBatch) String ¶ 

func (this *WriteBatch) String() string

func (*WriteBatch) Unmarshal ¶ 

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

func (*WriteBatch) XXX_DiscardUnknown ¶ 

func (m *WriteBatch) XXX_DiscardUnknown()

func (*WriteBatch) XXX_Marshal ¶ 

func (m *WriteBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteBatch) XXX_Merge ¶ 

func (m *WriteBatch) XXX_Merge(src proto.Message)

func (*WriteBatch) XXX_Size ¶ 

func (m *WriteBatch) XXX_Size() int

func (*WriteBatch) XXX_Unmarshal ¶ 

func (m *WriteBatch) XXX_Unmarshal(b []byte) error

type WriteIndexRequest ¶ 

type WriteIndexRequest struct {
	Writes []*IndexEntry `protobuf:"bytes,1,rep,name=writes,proto3" json:"writes,omitempty"`
}

func (*WriteIndexRequest) Descriptor ¶ 

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

func (*WriteIndexRequest) Equal ¶ 

func (this *WriteIndexRequest) Equal(that interface{}) bool

func (*WriteIndexRequest) GetWrites ¶ 

func (m *WriteIndexRequest) GetWrites() []*IndexEntry

func (*WriteIndexRequest) GoString ¶ 

func (this *WriteIndexRequest) GoString() string

func (*WriteIndexRequest) Marshal ¶ 

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

func (*WriteIndexRequest) MarshalTo ¶ 

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

func (*WriteIndexRequest) MarshalToSizedBuffer ¶ 

func (m *WriteIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WriteIndexRequest) ProtoMessage ¶ 

func (*WriteIndexRequest) ProtoMessage()

func (*WriteIndexRequest) Reset ¶ 

func (m *WriteIndexRequest) Reset()

func (*WriteIndexRequest) Size ¶ 

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

func (*WriteIndexRequest) String ¶ 

func (this *WriteIndexRequest) String() string

func (*WriteIndexRequest) Unmarshal ¶ 

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

func (*WriteIndexRequest) XXX_DiscardUnknown ¶ 

func (m *WriteIndexRequest) XXX_DiscardUnknown()

func (*WriteIndexRequest) XXX_Marshal ¶ 

func (m *WriteIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteIndexRequest) XXX_Merge ¶ 

func (m *WriteIndexRequest) XXX_Merge(src proto.Message)

func (*WriteIndexRequest) XXX_Size ¶ 

func (m *WriteIndexRequest) XXX_Size() int

func (*WriteIndexRequest) XXX_Unmarshal ¶ 

func (m *WriteIndexRequest) XXX_Unmarshal(b []byte) error

Source Files ¶

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳