grpc

package
v1.6.2-0...-b66c343 Latest Latest
Warning

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

Go to latest
Published: Apr 2, 2024 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 (*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(_ context.Context, batch index.WriteBatch) error

func (*StorageClient) DeleteChunk

func (s *StorageClient) DeleteChunk(ctx context.Context, _, 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) IsRetryableErr

func (s *StorageClient) IsRetryableErr(_ 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) DeleteChunks

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

func (*UnimplementedGrpcStoreServer) DeleteIndex

func (*UnimplementedGrpcStoreServer) DeleteTable

func (*UnimplementedGrpcStoreServer) DescribeTable

func (*UnimplementedGrpcStoreServer) GetChunks

func (*UnimplementedGrpcStoreServer) ListTables

func (*UnimplementedGrpcStoreServer) PutChunks

func (*UnimplementedGrpcStoreServer) QueryIndex

func (*UnimplementedGrpcStoreServer) UpdateTable

func (*UnimplementedGrpcStoreServer) WriteIndex

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

Jump to

Keyboard shortcuts

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