badger: github.com/dgraph-io/badger/pb Index | Files

package pb

import "github.com/dgraph-io/badger/pb"

Index

Package Files

badgerpb3.pb.go

Variables

❖
var (
    ErrInvalidLengthBadgerpb3        = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowBadgerpb3          = fmt.Errorf("proto: integer overflow")
    ErrUnexpectedEndOfGroupBadgerpb3 = fmt.Errorf("proto: unexpected end of group")
)
❖
var Checksum_Algorithm_name = map[int32]string{
    0:  "CRC32C",
    1:  "XXHash64",
}
❖
var Checksum_Algorithm_value = map[string]int32{
    "CRC32C":   0,
    "XXHash64": 1,
}
❖
var EncryptionAlgo_name = map[int32]string{
    0: "aes",
}
❖
var EncryptionAlgo_value = map[string]int32{
    "aes": 0,
}
❖
var ManifestChange_Operation_name = map[int32]string{
    0:  "CREATE",
    1:  "DELETE",
}
❖
var ManifestChange_Operation_value = map[string]int32{
    "CREATE": 0,
    "DELETE": 1,
}

type Checksum Uses

❖
type Checksum struct {
    Algo Checksum_Algorithm `protobuf:"varint,1,opt,name=algo,proto3,enum=badgerpb3.Checksum_Algorithm" json:"algo,omitempty"`
    Sum  uint64             `protobuf:"varint,2,opt,name=sum,proto3" json:"sum,omitempty"`
}

func (*Checksum) Descriptor Uses

❖
func (*Checksum) Descriptor() ([]byte, []int)

func (*Checksum) GetAlgo Uses

❖
func (m *Checksum) GetAlgo() Checksum_Algorithm

func (*Checksum) GetSum Uses

❖
func (m *Checksum) GetSum() uint64

func (*Checksum) Marshal Uses

❖
func (m *Checksum) Marshal() (dAtA []byte, err error)

func (*Checksum) MarshalTo Uses

❖
func (m *Checksum) MarshalTo(dAtA []byte) (int, error)

func (*Checksum) MarshalToSizedBuffer Uses

❖
func (m *Checksum) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Checksum) ProtoMessage Uses

❖
func (*Checksum) ProtoMessage()

func (*Checksum) Reset Uses

❖
func (m *Checksum) Reset()

func (*Checksum) Size Uses

❖
func (m *Checksum) Size() (n int)

func (*Checksum) String Uses

❖
func (m *Checksum) String() string

func (*Checksum) Unmarshal Uses

❖
func (m *Checksum) Unmarshal(dAtA []byte) error

func (*Checksum) XXX_DiscardUnknown Uses

❖
func (m *Checksum) XXX_DiscardUnknown()

func (*Checksum) XXX_Marshal Uses

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

func (*Checksum) XXX_Merge Uses

❖
func (m *Checksum) XXX_Merge(src proto.Message)

func (*Checksum) XXX_Size Uses

❖
func (m *Checksum) XXX_Size() int

func (*Checksum) XXX_Unmarshal Uses

❖
func (m *Checksum) XXX_Unmarshal(b []byte) error

type Checksum_Algorithm Uses

❖
type Checksum_Algorithm int32
❖
const (
    Checksum_CRC32C   Checksum_Algorithm = 0
    Checksum_XXHash64 Checksum_Algorithm = 1
)

func (Checksum_Algorithm) EnumDescriptor Uses

❖
func (Checksum_Algorithm) EnumDescriptor() ([]byte, []int)

func (Checksum_Algorithm) String Uses

❖
func (x Checksum_Algorithm) String() string

type DataKey Uses

❖
type DataKey struct {
    KeyId     uint64 `protobuf:"varint,1,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`
    Data      []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
    Iv        []byte `protobuf:"bytes,3,opt,name=iv,proto3" json:"iv,omitempty"`
    CreatedAt int64  `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
}

func (*DataKey) Descriptor Uses

❖
func (*DataKey) Descriptor() ([]byte, []int)

func (*DataKey) GetCreatedAt Uses

❖
func (m *DataKey) GetCreatedAt() int64

func (*DataKey) GetData Uses

❖
func (m *DataKey) GetData() []byte

func (*DataKey) GetIv Uses

❖
func (m *DataKey) GetIv() []byte

func (*DataKey) GetKeyId Uses

❖
func (m *DataKey) GetKeyId() uint64

func (*DataKey) Marshal Uses

❖
func (m *DataKey) Marshal() (dAtA []byte, err error)

func (*DataKey) MarshalTo Uses

❖
func (m *DataKey) MarshalTo(dAtA []byte) (int, error)

func (*DataKey) MarshalToSizedBuffer Uses

❖
func (m *DataKey) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataKey) ProtoMessage Uses

❖
func (*DataKey) ProtoMessage()

func (*DataKey) Reset Uses

❖
func (m *DataKey) Reset()

func (*DataKey) Size Uses

❖
func (m *DataKey) Size() (n int)

func (*DataKey) String Uses

❖
func (m *DataKey) String() string

func (*DataKey) Unmarshal Uses

❖
func (m *DataKey) Unmarshal(dAtA []byte) error

func (*DataKey) XXX_DiscardUnknown Uses

❖
func (m *DataKey) XXX_DiscardUnknown()

func (*DataKey) XXX_Marshal Uses

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

func (*DataKey) XXX_Merge Uses

❖
func (m *DataKey) XXX_Merge(src proto.Message)

func (*DataKey) XXX_Size Uses

❖
func (m *DataKey) XXX_Size() int

func (*DataKey) XXX_Unmarshal Uses

❖
func (m *DataKey) XXX_Unmarshal(b []byte) error

type EncryptionAlgo Uses

❖
type EncryptionAlgo int32
❖
const (
    EncryptionAlgo_aes EncryptionAlgo = 0
)

func (EncryptionAlgo) EnumDescriptor Uses

❖
func (EncryptionAlgo) EnumDescriptor() ([]byte, []int)

func (EncryptionAlgo) String Uses

❖
func (x EncryptionAlgo) String() string

type KV Uses

❖
type KV 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"`
    UserMeta  []byte `protobuf:"bytes,3,opt,name=user_meta,json=userMeta,proto3" json:"user_meta,omitempty"`
    Version   uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
    ExpiresAt uint64 `protobuf:"varint,5,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
    Meta      []byte `protobuf:"bytes,6,opt,name=meta,proto3" json:"meta,omitempty"`
    // Stream id is used to identify which stream the KV came from.
    StreamId uint32 `protobuf:"varint,10,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
    // Stream done is used to indicate end of stream.
    StreamDone bool `protobuf:"varint,11,opt,name=stream_done,json=streamDone,proto3" json:"stream_done,omitempty"`
}

func (*KV) Descriptor Uses

❖
func (*KV) Descriptor() ([]byte, []int)

func (*KV) GetExpiresAt Uses

❖
func (m *KV) GetExpiresAt() uint64

func (*KV) GetKey Uses

❖
func (m *KV) GetKey() []byte

func (*KV) GetMeta Uses

❖
func (m *KV) GetMeta() []byte

func (*KV) GetStreamDone Uses

❖
func (m *KV) GetStreamDone() bool

func (*KV) GetStreamId Uses

❖
func (m *KV) GetStreamId() uint32

func (*KV) GetUserMeta Uses

❖
func (m *KV) GetUserMeta() []byte

func (*KV) GetValue Uses

❖
func (m *KV) GetValue() []byte

func (*KV) GetVersion Uses

❖
func (m *KV) GetVersion() uint64

func (*KV) Marshal Uses

❖
func (m *KV) Marshal() (dAtA []byte, err error)

func (*KV) MarshalTo Uses

❖
func (m *KV) MarshalTo(dAtA []byte) (int, error)

func (*KV) MarshalToSizedBuffer Uses

❖
func (m *KV) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KV) ProtoMessage Uses

❖
func (*KV) ProtoMessage()

func (*KV) Reset Uses

❖
func (m *KV) Reset()

func (*KV) Size Uses

❖
func (m *KV) Size() (n int)

func (*KV) String Uses

❖
func (m *KV) String() string

func (*KV) Unmarshal Uses

❖
func (m *KV) Unmarshal(dAtA []byte) error

func (*KV) XXX_DiscardUnknown Uses

❖
func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal Uses

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

func (*KV) XXX_Merge Uses

❖
func (m *KV) XXX_Merge(src proto.Message)

func (*KV) XXX_Size Uses

❖
func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal Uses

❖
func (m *KV) XXX_Unmarshal(b []byte) error

type KVList Uses

❖
type KVList struct {
    Kv  []*KV `protobuf:"bytes,1,rep,name=kv,proto3" json:"kv,omitempty"`
    // alloc_ref used internally for memory management.
    AllocRef uint64 `protobuf:"varint,10,opt,name=alloc_ref,json=allocRef,proto3" json:"alloc_ref,omitempty"`
}

func (*KVList) Descriptor Uses

❖
func (*KVList) Descriptor() ([]byte, []int)

func (*KVList) GetAllocRef Uses

❖
func (m *KVList) GetAllocRef() uint64

func (*KVList) GetKv Uses

❖
func (m *KVList) GetKv() []*KV

func (*KVList) Marshal Uses

❖
func (m *KVList) Marshal() (dAtA []byte, err error)

func (*KVList) MarshalTo Uses

❖
func (m *KVList) MarshalTo(dAtA []byte) (int, error)

func (*KVList) MarshalToSizedBuffer Uses

❖
func (m *KVList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVList) ProtoMessage Uses

❖
func (*KVList) ProtoMessage()

func (*KVList) Reset Uses

❖
func (m *KVList) Reset()

func (*KVList) Size Uses

❖
func (m *KVList) Size() (n int)

func (*KVList) String Uses

❖
func (m *KVList) String() string

func (*KVList) Unmarshal Uses

❖
func (m *KVList) Unmarshal(dAtA []byte) error

func (*KVList) XXX_DiscardUnknown Uses

❖
func (m *KVList) XXX_DiscardUnknown()

func (*KVList) XXX_Marshal Uses

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

func (*KVList) XXX_Merge Uses

❖
func (m *KVList) XXX_Merge(src proto.Message)

func (*KVList) XXX_Size Uses

❖
func (m *KVList) XXX_Size() int

func (*KVList) XXX_Unmarshal Uses

❖
func (m *KVList) XXX_Unmarshal(b []byte) error

type ManifestChange Uses

❖
type ManifestChange struct {
    Id             uint64                   `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
    Op             ManifestChange_Operation `protobuf:"varint,2,opt,name=Op,proto3,enum=badgerpb3.ManifestChange_Operation" json:"Op,omitempty"`
    Level          uint32                   `protobuf:"varint,3,opt,name=Level,proto3" json:"Level,omitempty"`
    KeyId          uint64                   `protobuf:"varint,4,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`
    EncryptionAlgo EncryptionAlgo           `protobuf:"varint,5,opt,name=encryption_algo,json=encryptionAlgo,proto3,enum=badgerpb3.EncryptionAlgo" json:"encryption_algo,omitempty"`
    Compression    uint32                   `protobuf:"varint,6,opt,name=compression,proto3" json:"compression,omitempty"`
}

func (*ManifestChange) Descriptor Uses

❖
func (*ManifestChange) Descriptor() ([]byte, []int)

func (*ManifestChange) GetCompression Uses

❖
func (m *ManifestChange) GetCompression() uint32

func (*ManifestChange) GetEncryptionAlgo Uses

❖
func (m *ManifestChange) GetEncryptionAlgo() EncryptionAlgo

func (*ManifestChange) GetId Uses

❖
func (m *ManifestChange) GetId() uint64

func (*ManifestChange) GetKeyId Uses

❖
func (m *ManifestChange) GetKeyId() uint64

func (*ManifestChange) GetLevel Uses

❖
func (m *ManifestChange) GetLevel() uint32

func (*ManifestChange) GetOp Uses

❖
func (m *ManifestChange) GetOp() ManifestChange_Operation

func (*ManifestChange) Marshal Uses

❖
func (m *ManifestChange) Marshal() (dAtA []byte, err error)

func (*ManifestChange) MarshalTo Uses

❖
func (m *ManifestChange) MarshalTo(dAtA []byte) (int, error)

func (*ManifestChange) MarshalToSizedBuffer Uses

❖
func (m *ManifestChange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ManifestChange) ProtoMessage Uses

❖
func (*ManifestChange) ProtoMessage()

func (*ManifestChange) Reset Uses

❖
func (m *ManifestChange) Reset()

func (*ManifestChange) Size Uses

❖
func (m *ManifestChange) Size() (n int)

func (*ManifestChange) String Uses

❖
func (m *ManifestChange) String() string

func (*ManifestChange) Unmarshal Uses

❖
func (m *ManifestChange) Unmarshal(dAtA []byte) error

func (*ManifestChange) XXX_DiscardUnknown Uses

❖
func (m *ManifestChange) XXX_DiscardUnknown()

func (*ManifestChange) XXX_Marshal Uses

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

func (*ManifestChange) XXX_Merge Uses

❖
func (m *ManifestChange) XXX_Merge(src proto.Message)

func (*ManifestChange) XXX_Size Uses

❖
func (m *ManifestChange) XXX_Size() int

func (*ManifestChange) XXX_Unmarshal Uses

❖
func (m *ManifestChange) XXX_Unmarshal(b []byte) error

type ManifestChangeSet Uses

❖
type ManifestChangeSet struct {
    // A set of changes that are applied atomically.
    Changes []*ManifestChange `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"`
}

func (*ManifestChangeSet) Descriptor Uses

❖
func (*ManifestChangeSet) Descriptor() ([]byte, []int)

func (*ManifestChangeSet) GetChanges Uses

❖
func (m *ManifestChangeSet) GetChanges() []*ManifestChange

func (*ManifestChangeSet) Marshal Uses

❖
func (m *ManifestChangeSet) Marshal() (dAtA []byte, err error)

func (*ManifestChangeSet) MarshalTo Uses

❖
func (m *ManifestChangeSet) MarshalTo(dAtA []byte) (int, error)

func (*ManifestChangeSet) MarshalToSizedBuffer Uses

❖
func (m *ManifestChangeSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ManifestChangeSet) ProtoMessage Uses

❖
func (*ManifestChangeSet) ProtoMessage()

func (*ManifestChangeSet) Reset Uses

❖
func (m *ManifestChangeSet) Reset()

func (*ManifestChangeSet) Size Uses

❖
func (m *ManifestChangeSet) Size() (n int)

func (*ManifestChangeSet) String Uses

❖
func (m *ManifestChangeSet) String() string

func (*ManifestChangeSet) Unmarshal Uses

❖
func (m *ManifestChangeSet) Unmarshal(dAtA []byte) error

func (*ManifestChangeSet) XXX_DiscardUnknown Uses

❖
func (m *ManifestChangeSet) XXX_DiscardUnknown()

func (*ManifestChangeSet) XXX_Marshal Uses

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

func (*ManifestChangeSet) XXX_Merge Uses

❖
func (m *ManifestChangeSet) XXX_Merge(src proto.Message)

func (*ManifestChangeSet) XXX_Size Uses

❖
func (m *ManifestChangeSet) XXX_Size() int

func (*ManifestChangeSet) XXX_Unmarshal Uses

❖
func (m *ManifestChangeSet) XXX_Unmarshal(b []byte) error

type ManifestChange_Operation Uses

❖
type ManifestChange_Operation int32
❖
const (
    ManifestChange_CREATE ManifestChange_Operation = 0
    ManifestChange_DELETE ManifestChange_Operation = 1
)

func (ManifestChange_Operation) EnumDescriptor Uses

❖
func (ManifestChange_Operation) EnumDescriptor() ([]byte, []int)

func (ManifestChange_Operation) String Uses

❖
func (x ManifestChange_Operation) String() string

Package pb imports 5 packages (graph) and is imported by 6 packages. Updated 2021-01-27. Refresh now. Tools for package owners.