grpc

package
v0.0.0-...-e951c9a Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2022 License: AGPL-3.0 Imports: 23 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() index.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 config.SchemaConfig) (*StorageClient, error)

NewStorageClient returns a new StorageClient.

func (*StorageClient) BatchWrite 

func (s *StorageClient) BatchWrite(c context.Context, batch index.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) IsChunkNotFoundErr 

func (s *StorageClient) IsChunkNotFoundErr(_ error) bool

func (*StorageClient) NewWriteBatch 

func (s *StorageClient) NewWriteBatch() index.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 []index.Query, callback index.QueryPagesCallback) 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 config.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 config.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 config.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.