Help us shape the future of Go! Take the 2026 Go Developer Survey

grpc

package
v1.13.2 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2022 License: Apache-2.0 Imports: 21 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.