rpcdbproto

package
v1.0.0-c Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2020 License: BSD-3-Clause Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDatabaseServer 

func RegisterDatabaseServer(s *grpc.Server, srv DatabaseServer)

Types

type CloseRequest 

type CloseRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseRequest) Descriptor 

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

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset 

func (m *CloseRequest) Reset()

func (*CloseRequest) String 

func (m *CloseRequest) String() string

func (*CloseRequest) XXX_DiscardUnknown 

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal 

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

func (*CloseRequest) XXX_Merge 

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

func (*CloseRequest) XXX_Size 

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal 

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

type CloseResponse 

type CloseResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseResponse) Descriptor 

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

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset 

func (m *CloseResponse) Reset()

func (*CloseResponse) String 

func (m *CloseResponse) String() string

func (*CloseResponse) XXX_DiscardUnknown 

func (m *CloseResponse) XXX_DiscardUnknown()

func (*CloseResponse) XXX_Marshal 

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

func (*CloseResponse) XXX_Merge 

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

func (*CloseResponse) XXX_Size 

func (m *CloseResponse) XXX_Size() int

func (*CloseResponse) XXX_Unmarshal 

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

type CompactRequest 

type CompactRequest struct {
	Start                []byte   `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Limit                []byte   `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompactRequest) Descriptor 

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

func (*CompactRequest) GetLimit 

func (m *CompactRequest) GetLimit() []byte

func (*CompactRequest) GetStart 

func (m *CompactRequest) GetStart() []byte

func (*CompactRequest) ProtoMessage 

func (*CompactRequest) ProtoMessage()

func (*CompactRequest) Reset 

func (m *CompactRequest) Reset()

func (*CompactRequest) String 

func (m *CompactRequest) String() string

func (*CompactRequest) XXX_DiscardUnknown 

func (m *CompactRequest) XXX_DiscardUnknown()

func (*CompactRequest) XXX_Marshal 

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

func (*CompactRequest) XXX_Merge 

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

func (*CompactRequest) XXX_Size 

func (m *CompactRequest) XXX_Size() int

func (*CompactRequest) XXX_Unmarshal 

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

type CompactResponse 

type CompactResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompactResponse) Descriptor 

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

func (*CompactResponse) ProtoMessage 

func (*CompactResponse) ProtoMessage()

func (*CompactResponse) Reset 

func (m *CompactResponse) Reset()

func (*CompactResponse) String 

func (m *CompactResponse) String() string

func (*CompactResponse) XXX_DiscardUnknown 

func (m *CompactResponse) XXX_DiscardUnknown()

func (*CompactResponse) XXX_Marshal 

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

func (*CompactResponse) XXX_Merge 

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

func (*CompactResponse) XXX_Size 

func (m *CompactResponse) XXX_Size() int

func (*CompactResponse) XXX_Unmarshal 

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

type DatabaseClient 

type DatabaseClient interface {
	Has(ctx context.Context, in *HasRequest, opts ...grpc.CallOption) (*HasResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error)
	Compact(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	WriteBatch(ctx context.Context, in *WriteBatchRequest, opts ...grpc.CallOption) (*WriteBatchResponse, error)
	NewIteratorWithStartAndPrefix(ctx context.Context, in *NewIteratorWithStartAndPrefixRequest, opts ...grpc.CallOption) (*NewIteratorWithStartAndPrefixResponse, error)
	IteratorNext(ctx context.Context, in *IteratorNextRequest, opts ...grpc.CallOption) (*IteratorNextResponse, error)
	IteratorError(ctx context.Context, in *IteratorErrorRequest, opts ...grpc.CallOption) (*IteratorErrorResponse, error)
	IteratorRelease(ctx context.Context, in *IteratorReleaseRequest, opts ...grpc.CallOption) (*IteratorReleaseResponse, error)
}

DatabaseClient is the client API for Database service.

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

func NewDatabaseClient 

func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient

type DatabaseServer 

type DatabaseServer interface {
	Has(context.Context, *HasRequest) (*HasResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Stat(context.Context, *StatRequest) (*StatResponse, error)
	Compact(context.Context, *CompactRequest) (*CompactResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	WriteBatch(context.Context, *WriteBatchRequest) (*WriteBatchResponse, error)
	NewIteratorWithStartAndPrefix(context.Context, *NewIteratorWithStartAndPrefixRequest) (*NewIteratorWithStartAndPrefixResponse, error)
	IteratorNext(context.Context, *IteratorNextRequest) (*IteratorNextResponse, error)
	IteratorError(context.Context, *IteratorErrorRequest) (*IteratorErrorResponse, error)
	IteratorRelease(context.Context, *IteratorReleaseRequest) (*IteratorReleaseResponse, error)
}

DatabaseServer is the server API for Database service.

type DeleteRequest 

type DeleteRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetKey 

func (m *DeleteRequest) GetKey() []byte

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeleteResponse 

type DeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

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

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetKey 

func (m *GetRequest) GetKey() []byte

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetValue 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type HasRequest 

type HasRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HasRequest) Descriptor 

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

func (*HasRequest) GetKey 

func (m *HasRequest) GetKey() []byte

func (*HasRequest) ProtoMessage 

func (*HasRequest) ProtoMessage()

func (*HasRequest) Reset 

func (m *HasRequest) Reset()

func (*HasRequest) String 

func (m *HasRequest) String() string

func (*HasRequest) XXX_DiscardUnknown 

func (m *HasRequest) XXX_DiscardUnknown()

func (*HasRequest) XXX_Marshal 

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

func (*HasRequest) XXX_Merge 

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

func (*HasRequest) XXX_Size 

func (m *HasRequest) XXX_Size() int

func (*HasRequest) XXX_Unmarshal 

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

type HasResponse 

type HasResponse struct {
	Has                  bool     `protobuf:"varint,1,opt,name=has,proto3" json:"has,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HasResponse) Descriptor 

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

func (*HasResponse) GetHas 

func (m *HasResponse) GetHas() bool

func (*HasResponse) ProtoMessage 

func (*HasResponse) ProtoMessage()

func (*HasResponse) Reset 

func (m *HasResponse) Reset()

func (*HasResponse) String 

func (m *HasResponse) String() string

func (*HasResponse) XXX_DiscardUnknown 

func (m *HasResponse) XXX_DiscardUnknown()

func (*HasResponse) XXX_Marshal 

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

func (*HasResponse) XXX_Merge 

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

func (*HasResponse) XXX_Size 

func (m *HasResponse) XXX_Size() int

func (*HasResponse) XXX_Unmarshal 

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

type IteratorErrorRequest 

type IteratorErrorRequest struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IteratorErrorRequest) Descriptor 

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

func (*IteratorErrorRequest) GetId 

func (m *IteratorErrorRequest) GetId() uint64

func (*IteratorErrorRequest) ProtoMessage 

func (*IteratorErrorRequest) ProtoMessage()

func (*IteratorErrorRequest) Reset 

func (m *IteratorErrorRequest) Reset()

func (*IteratorErrorRequest) String 

func (m *IteratorErrorRequest) String() string

func (*IteratorErrorRequest) XXX_DiscardUnknown 

func (m *IteratorErrorRequest) XXX_DiscardUnknown()

func (*IteratorErrorRequest) XXX_Marshal 

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

func (*IteratorErrorRequest) XXX_Merge 

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

func (*IteratorErrorRequest) XXX_Size 

func (m *IteratorErrorRequest) XXX_Size() int

func (*IteratorErrorRequest) XXX_Unmarshal 

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

type IteratorErrorResponse 

type IteratorErrorResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IteratorErrorResponse) Descriptor 

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

func (*IteratorErrorResponse) ProtoMessage 

func (*IteratorErrorResponse) ProtoMessage()

func (*IteratorErrorResponse) Reset 

func (m *IteratorErrorResponse) Reset()

func (*IteratorErrorResponse) String 

func (m *IteratorErrorResponse) String() string

func (*IteratorErrorResponse) XXX_DiscardUnknown 

func (m *IteratorErrorResponse) XXX_DiscardUnknown()

func (*IteratorErrorResponse) XXX_Marshal 

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

func (*IteratorErrorResponse) XXX_Merge 

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

func (*IteratorErrorResponse) XXX_Size 

func (m *IteratorErrorResponse) XXX_Size() int

func (*IteratorErrorResponse) XXX_Unmarshal 

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

type IteratorNextRequest 

type IteratorNextRequest struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IteratorNextRequest) Descriptor 

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

func (*IteratorNextRequest) GetId 

func (m *IteratorNextRequest) GetId() uint64

func (*IteratorNextRequest) ProtoMessage 

func (*IteratorNextRequest) ProtoMessage()

func (*IteratorNextRequest) Reset 

func (m *IteratorNextRequest) Reset()

func (*IteratorNextRequest) String 

func (m *IteratorNextRequest) String() string

func (*IteratorNextRequest) XXX_DiscardUnknown 

func (m *IteratorNextRequest) XXX_DiscardUnknown()

func (*IteratorNextRequest) XXX_Marshal 

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

func (*IteratorNextRequest) XXX_Merge 

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

func (*IteratorNextRequest) XXX_Size 

func (m *IteratorNextRequest) XXX_Size() int

func (*IteratorNextRequest) XXX_Unmarshal 

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

type IteratorNextResponse 

type IteratorNextResponse struct {
	FoundNext            bool     `protobuf:"varint,1,opt,name=foundNext,proto3" json:"foundNext,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IteratorNextResponse) Descriptor 

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

func (*IteratorNextResponse) GetFoundNext 

func (m *IteratorNextResponse) GetFoundNext() bool

func (*IteratorNextResponse) GetKey 

func (m *IteratorNextResponse) GetKey() []byte

func (*IteratorNextResponse) GetValue 

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

func (*IteratorNextResponse) ProtoMessage 

func (*IteratorNextResponse) ProtoMessage()

func (*IteratorNextResponse) Reset 

func (m *IteratorNextResponse) Reset()

func (*IteratorNextResponse) String 

func (m *IteratorNextResponse) String() string

func (*IteratorNextResponse) XXX_DiscardUnknown 

func (m *IteratorNextResponse) XXX_DiscardUnknown()

func (*IteratorNextResponse) XXX_Marshal 

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

func (*IteratorNextResponse) XXX_Merge 

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

func (*IteratorNextResponse) XXX_Size 

func (m *IteratorNextResponse) XXX_Size() int

func (*IteratorNextResponse) XXX_Unmarshal 

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

type IteratorReleaseRequest 

type IteratorReleaseRequest struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IteratorReleaseRequest) Descriptor 

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

func (*IteratorReleaseRequest) GetId 

func (m *IteratorReleaseRequest) GetId() uint64

func (*IteratorReleaseRequest) ProtoMessage 

func (*IteratorReleaseRequest) ProtoMessage()

func (*IteratorReleaseRequest) Reset 

func (m *IteratorReleaseRequest) Reset()

func (*IteratorReleaseRequest) String 

func (m *IteratorReleaseRequest) String() string

func (*IteratorReleaseRequest) XXX_DiscardUnknown 

func (m *IteratorReleaseRequest) XXX_DiscardUnknown()

func (*IteratorReleaseRequest) XXX_Marshal 

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

func (*IteratorReleaseRequest) XXX_Merge 

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

func (*IteratorReleaseRequest) XXX_Size 

func (m *IteratorReleaseRequest) XXX_Size() int

func (*IteratorReleaseRequest) XXX_Unmarshal 

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

type IteratorReleaseResponse 

type IteratorReleaseResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IteratorReleaseResponse) Descriptor 

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

func (*IteratorReleaseResponse) ProtoMessage 

func (*IteratorReleaseResponse) ProtoMessage()

func (*IteratorReleaseResponse) Reset 

func (m *IteratorReleaseResponse) Reset()

func (*IteratorReleaseResponse) String 

func (m *IteratorReleaseResponse) String() string

func (*IteratorReleaseResponse) XXX_DiscardUnknown 

func (m *IteratorReleaseResponse) XXX_DiscardUnknown()

func (*IteratorReleaseResponse) XXX_Marshal 

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

func (*IteratorReleaseResponse) XXX_Merge 

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

func (*IteratorReleaseResponse) XXX_Size 

func (m *IteratorReleaseResponse) XXX_Size() int

func (*IteratorReleaseResponse) XXX_Unmarshal 

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

type NewIteratorRequest 

type NewIteratorRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewIteratorRequest) Descriptor 

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

func (*NewIteratorRequest) ProtoMessage 

func (*NewIteratorRequest) ProtoMessage()

func (*NewIteratorRequest) Reset 

func (m *NewIteratorRequest) Reset()

func (*NewIteratorRequest) String 

func (m *NewIteratorRequest) String() string

func (*NewIteratorRequest) XXX_DiscardUnknown 

func (m *NewIteratorRequest) XXX_DiscardUnknown()

func (*NewIteratorRequest) XXX_Marshal 

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

func (*NewIteratorRequest) XXX_Merge 

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

func (*NewIteratorRequest) XXX_Size 

func (m *NewIteratorRequest) XXX_Size() int

func (*NewIteratorRequest) XXX_Unmarshal 

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

type NewIteratorWithStartAndPrefixRequest 

type NewIteratorWithStartAndPrefixRequest struct {
	Start                []byte   `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Prefix               []byte   `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewIteratorWithStartAndPrefixRequest) Descriptor 

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

func (*NewIteratorWithStartAndPrefixRequest) GetPrefix 

func (m *NewIteratorWithStartAndPrefixRequest) GetPrefix() []byte

func (*NewIteratorWithStartAndPrefixRequest) GetStart 

func (m *NewIteratorWithStartAndPrefixRequest) GetStart() []byte

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage 

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage()

func (*NewIteratorWithStartAndPrefixRequest) Reset 

func (m *NewIteratorWithStartAndPrefixRequest) Reset()

func (*NewIteratorWithStartAndPrefixRequest) String 

func (m *NewIteratorWithStartAndPrefixRequest) String() string

func (*NewIteratorWithStartAndPrefixRequest) XXX_DiscardUnknown 

func (m *NewIteratorWithStartAndPrefixRequest) XXX_DiscardUnknown()

func (*NewIteratorWithStartAndPrefixRequest) XXX_Marshal 

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

func (*NewIteratorWithStartAndPrefixRequest) XXX_Merge 

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

func (*NewIteratorWithStartAndPrefixRequest) XXX_Size 

func (m *NewIteratorWithStartAndPrefixRequest) XXX_Size() int

func (*NewIteratorWithStartAndPrefixRequest) XXX_Unmarshal 

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

type NewIteratorWithStartAndPrefixResponse 

type NewIteratorWithStartAndPrefixResponse struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewIteratorWithStartAndPrefixResponse) Descriptor 

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

func (*NewIteratorWithStartAndPrefixResponse) GetId 

func (m *NewIteratorWithStartAndPrefixResponse) GetId() uint64

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage 

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage()

func (*NewIteratorWithStartAndPrefixResponse) Reset 

func (m *NewIteratorWithStartAndPrefixResponse) Reset()

func (*NewIteratorWithStartAndPrefixResponse) String 

func (m *NewIteratorWithStartAndPrefixResponse) String() string

func (*NewIteratorWithStartAndPrefixResponse) XXX_DiscardUnknown 

func (m *NewIteratorWithStartAndPrefixResponse) XXX_DiscardUnknown()

func (*NewIteratorWithStartAndPrefixResponse) XXX_Marshal 

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

func (*NewIteratorWithStartAndPrefixResponse) XXX_Merge 

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

func (*NewIteratorWithStartAndPrefixResponse) XXX_Size 

func (m *NewIteratorWithStartAndPrefixResponse) XXX_Size() int

func (*NewIteratorWithStartAndPrefixResponse) XXX_Unmarshal 

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

type PutRequest 

type PutRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetKey 

func (m *PutRequest) GetKey() []byte

func (*PutRequest) GetValue 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) XXX_DiscardUnknown 

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal 

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

func (*PutRequest) XXX_Merge 

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

func (*PutRequest) XXX_Size 

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal 

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

type PutResponse 

type PutResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutResponse) Descriptor 

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

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) String 

func (m *PutResponse) String() string

func (*PutResponse) XXX_DiscardUnknown 

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal 

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

func (*PutResponse) XXX_Merge 

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

func (*PutResponse) XXX_Size 

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal 

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

type StatRequest 

type StatRequest struct {
	Property             string   `protobuf:"bytes,1,opt,name=property,proto3" json:"property,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatRequest) Descriptor 

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

func (*StatRequest) GetProperty 

func (m *StatRequest) GetProperty() string

func (*StatRequest) ProtoMessage 

func (*StatRequest) ProtoMessage()

func (*StatRequest) Reset 

func (m *StatRequest) Reset()

func (*StatRequest) String 

func (m *StatRequest) String() string

func (*StatRequest) XXX_DiscardUnknown 

func (m *StatRequest) XXX_DiscardUnknown()

func (*StatRequest) XXX_Marshal 

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

func (*StatRequest) XXX_Merge 

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

func (*StatRequest) XXX_Size 

func (m *StatRequest) XXX_Size() int

func (*StatRequest) XXX_Unmarshal 

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

type StatResponse 

type StatResponse struct {
	Stat                 string   `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatResponse) Descriptor 

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

func (*StatResponse) GetStat 

func (m *StatResponse) GetStat() string

func (*StatResponse) ProtoMessage 

func (*StatResponse) ProtoMessage()

func (*StatResponse) Reset 

func (m *StatResponse) Reset()

func (*StatResponse) String 

func (m *StatResponse) String() string

func (*StatResponse) XXX_DiscardUnknown 

func (m *StatResponse) XXX_DiscardUnknown()

func (*StatResponse) XXX_Marshal 

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

func (*StatResponse) XXX_Merge 

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

func (*StatResponse) XXX_Size 

func (m *StatResponse) XXX_Size() int

func (*StatResponse) XXX_Unmarshal 

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

type UnimplementedDatabaseServer 

type UnimplementedDatabaseServer struct {
}

UnimplementedDatabaseServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatabaseServer) Close 

func (*UnimplementedDatabaseServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)

func (*UnimplementedDatabaseServer) Compact 

func (*UnimplementedDatabaseServer) Compact(ctx context.Context, req *CompactRequest) (*CompactResponse, error)

func (*UnimplementedDatabaseServer) Delete 

func (*UnimplementedDatabaseServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*UnimplementedDatabaseServer) Get 

func (*UnimplementedDatabaseServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedDatabaseServer) Has 

func (*UnimplementedDatabaseServer) Has(ctx context.Context, req *HasRequest) (*HasResponse, error)

func (*UnimplementedDatabaseServer) IteratorError 

func (*UnimplementedDatabaseServer) IteratorError(ctx context.Context, req *IteratorErrorRequest) (*IteratorErrorResponse, error)

func (*UnimplementedDatabaseServer) IteratorNext 

func (*UnimplementedDatabaseServer) IteratorNext(ctx context.Context, req *IteratorNextRequest) (*IteratorNextResponse, error)

func (*UnimplementedDatabaseServer) IteratorRelease 

func (*UnimplementedDatabaseServer) IteratorRelease(ctx context.Context, req *IteratorReleaseRequest) (*IteratorReleaseResponse, error)

func (*UnimplementedDatabaseServer) NewIteratorWithStartAndPrefix 

func (*UnimplementedDatabaseServer) NewIteratorWithStartAndPrefix(ctx context.Context, req *NewIteratorWithStartAndPrefixRequest) (*NewIteratorWithStartAndPrefixResponse, error)

func (*UnimplementedDatabaseServer) Put 

func (*UnimplementedDatabaseServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error)

func (*UnimplementedDatabaseServer) Stat 

func (*UnimplementedDatabaseServer) Stat(ctx context.Context, req *StatRequest) (*StatResponse, error)

func (*UnimplementedDatabaseServer) WriteBatch 

func (*UnimplementedDatabaseServer) WriteBatch(ctx context.Context, req *WriteBatchRequest) (*WriteBatchResponse, error)

type WriteBatchRequest 

type WriteBatchRequest struct {
	Puts                 []*PutRequest    `protobuf:"bytes,1,rep,name=puts,proto3" json:"puts,omitempty"`
	Deletes              []*DeleteRequest `protobuf:"bytes,2,rep,name=deletes,proto3" json:"deletes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*WriteBatchRequest) Descriptor 

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

func (*WriteBatchRequest) GetDeletes 

func (m *WriteBatchRequest) GetDeletes() []*DeleteRequest

func (*WriteBatchRequest) GetPuts 

func (m *WriteBatchRequest) GetPuts() []*PutRequest

func (*WriteBatchRequest) ProtoMessage 

func (*WriteBatchRequest) ProtoMessage()

func (*WriteBatchRequest) Reset 

func (m *WriteBatchRequest) Reset()

func (*WriteBatchRequest) String 

func (m *WriteBatchRequest) String() string

func (*WriteBatchRequest) XXX_DiscardUnknown 

func (m *WriteBatchRequest) XXX_DiscardUnknown()

func (*WriteBatchRequest) XXX_Marshal 

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

func (*WriteBatchRequest) XXX_Merge 

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

func (*WriteBatchRequest) XXX_Size 

func (m *WriteBatchRequest) XXX_Size() int

func (*WriteBatchRequest) XXX_Unmarshal 

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

type WriteBatchResponse 

type WriteBatchResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteBatchResponse) Descriptor 

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

func (*WriteBatchResponse) ProtoMessage 

func (*WriteBatchResponse) ProtoMessage()

func (*WriteBatchResponse) Reset 

func (m *WriteBatchResponse) Reset()

func (*WriteBatchResponse) String 

func (m *WriteBatchResponse) String() string

func (*WriteBatchResponse) XXX_DiscardUnknown 

func (m *WriteBatchResponse) XXX_DiscardUnknown()

func (*WriteBatchResponse) XXX_Marshal 

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

func (*WriteBatchResponse) XXX_Merge 

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

func (*WriteBatchResponse) XXX_Size 

func (m *WriteBatchResponse) XXX_Size() int

func (*WriteBatchResponse) XXX_Unmarshal 

func (m *WriteBatchResponse) 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.