Documentation
¶
Overview ¶
Package ddb is a generated protocol buffer package.
It is generated from these files:
proto/ddb.proto proto/internal.proto
It has these top-level messages:
GetRequest GetResponse SetRequest SetResponse LogRecord Mutation DescriptorProto SstMeta
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Mutation_Type_name = map[int32]string{
0: "UNSPECIFIED",
1: "PUT",
2: "DELETE",
}
View Source
var Mutation_Type_value = map[string]int32{
"UNSPECIFIED": 0,
"PUT": 1,
"DELETE": 2,
}
Functions ¶
func RegisterDdbServer ¶
Types ¶
type DdbClient ¶
type DdbClient interface {
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
}
func NewDdbClient ¶
func NewDdbClient(cc *grpc.ClientConn) DdbClient
type DdbServer ¶
type DdbServer interface {
Get(context.Context, *GetRequest) (*GetResponse, error)
Set(context.Context, *SetRequest) (*SetResponse, error)
}
type DescriptorProto ¶
type DescriptorProto struct {
SstMeta []*SstMeta `protobuf:"bytes,1,rep,name=sst_meta,json=sstMeta" json:"sst_meta,omitempty"`
}
func (*DescriptorProto) Descriptor ¶
func (*DescriptorProto) Descriptor() ([]byte, []int)
func (*DescriptorProto) GetSstMeta ¶
func (m *DescriptorProto) GetSstMeta() []*SstMeta
func (*DescriptorProto) ProtoMessage ¶
func (*DescriptorProto) ProtoMessage()
func (*DescriptorProto) Reset ¶
func (m *DescriptorProto) Reset()
func (*DescriptorProto) String ¶
func (m *DescriptorProto) String() string
type GetRequest ¶
type GetRequest struct {
Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
}
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetKey ¶
func (m *GetRequest) GetKey() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) String ¶
func (m *GetRequest) String() string
type GetResponse ¶
type GetResponse struct {
Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
Timestamp int64 `protobuf:"varint,2,opt,name=timestamp" json:"timestamp,omitempty"`
Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetKey ¶
func (m *GetResponse) GetKey() string
func (*GetResponse) GetTimestamp ¶
func (m *GetResponse) GetTimestamp() int64
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
type LogRecord ¶
type LogRecord struct {
Sequence int64 `protobuf:"varint,1,opt,name=sequence" json:"sequence,omitempty"`
Mutation *Mutation `protobuf:"bytes,2,opt,name=mutation" json:"mutation,omitempty"`
}
func (*LogRecord) Descriptor ¶
func (*LogRecord) GetMutation ¶
func (*LogRecord) GetSequence ¶
func (*LogRecord) ProtoMessage ¶
func (*LogRecord) ProtoMessage()
type Mutation ¶
type Mutation struct {
// The key associated with this mutation.
Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
// The type of this mutation.
Type Mutation_Type `protobuf:"varint,2,opt,name=type,enum=ddb.internal.Mutation_Type" json:"type,omitempty"`
// Timestamp of this mutation.
Timestamp int64 `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
// For mutations that update, this is the value.
Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
}
func (*Mutation) Descriptor ¶
func (*Mutation) GetTimestamp ¶
func (*Mutation) GetType ¶
func (m *Mutation) GetType() Mutation_Type
func (*Mutation) ProtoMessage ¶
func (*Mutation) ProtoMessage()
type Mutation_Type ¶
type Mutation_Type int32
const ( Mutation_UNSPECIFIED Mutation_Type = 0 Mutation_PUT Mutation_Type = 1 Mutation_DELETE Mutation_Type = 2 )
func (Mutation_Type) EnumDescriptor ¶
func (Mutation_Type) EnumDescriptor() ([]byte, []int)
func (Mutation_Type) String ¶
func (x Mutation_Type) String() string
type SetRequest ¶
type SetRequest struct {
Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}
func (*SetRequest) Descriptor ¶
func (*SetRequest) Descriptor() ([]byte, []int)
func (*SetRequest) GetKey ¶
func (m *SetRequest) GetKey() string
func (*SetRequest) GetValue ¶
func (m *SetRequest) GetValue() []byte
func (*SetRequest) ProtoMessage ¶
func (*SetRequest) ProtoMessage()
func (*SetRequest) Reset ¶
func (m *SetRequest) Reset()
func (*SetRequest) String ¶
func (m *SetRequest) String() string
type SetResponse ¶
type SetResponse struct {
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp" json:"timestamp,omitempty"`
}
func (*SetResponse) Descriptor ¶
func (*SetResponse) Descriptor() ([]byte, []int)
func (*SetResponse) GetTimestamp ¶
func (m *SetResponse) GetTimestamp() int64
func (*SetResponse) ProtoMessage ¶
func (*SetResponse) ProtoMessage()
func (*SetResponse) Reset ¶
func (m *SetResponse) Reset()
func (*SetResponse) String ¶
func (m *SetResponse) String() string
type SstMeta ¶
type SstMeta struct {
// Filename is the name of the SST file, relative to the configured SST directory.
Filename string `protobuf:"bytes,1,opt,name=filename" json:"filename,omitempty"`
// The sequence number (inclusive) of mutations that have been applied.
AppliedUntil int64 `protobuf:"varint,2,opt,name=applied_until,json=appliedUntil" json:"applied_until,omitempty"`
}
func (*SstMeta) Descriptor ¶
func (*SstMeta) GetAppliedUntil ¶
func (*SstMeta) GetFilename ¶
func (*SstMeta) ProtoMessage ¶
func (*SstMeta) ProtoMessage()
Source Files
Click to show internal directories.
Click to hide internal directories.