pb

package
v3.2104.2 Latest Latest
Warning

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

 Go to latest Published: Mar 23, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

Variables ¶

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

Functions ¶

This section is empty.

Types ¶

type Checksum ¶ 

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 ¶ 

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

func (*Checksum) GetAlgo ¶ 

func (m *Checksum) GetAlgo() Checksum_Algorithm

func (*Checksum) GetSum ¶ 

func (m *Checksum) GetSum() uint64

func (*Checksum) Marshal ¶ 

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

func (*Checksum) MarshalTo ¶ 

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

func (*Checksum) MarshalToSizedBuffer ¶ 

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

func (*Checksum) ProtoMessage ¶ 

func (*Checksum) ProtoMessage()

func (*Checksum) Reset ¶ 

func (m *Checksum) Reset()

func (*Checksum) Size ¶ 

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

func (*Checksum) String ¶ 

func (m *Checksum) String() string

func (*Checksum) Unmarshal ¶ 

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

func (*Checksum) XXX_DiscardUnknown ¶ 

func (m *Checksum) XXX_DiscardUnknown()

func (*Checksum) XXX_Marshal ¶ 

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

func (*Checksum) XXX_Merge ¶ 

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

func (*Checksum) XXX_Size ¶ 

func (m *Checksum) XXX_Size() int

func (*Checksum) XXX_Unmarshal ¶ 

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

type Checksum_Algorithm ¶ 

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

func (Checksum_Algorithm) EnumDescriptor ¶ 

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

func (Checksum_Algorithm) String ¶ 

func (x Checksum_Algorithm) String() string

type DataKey ¶ 

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 ¶ 

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

func (*DataKey) GetCreatedAt ¶ 

func (m *DataKey) GetCreatedAt() int64

func (*DataKey) GetData ¶ 

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

func (*DataKey) GetIv ¶ 

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

func (*DataKey) GetKeyId ¶ 

func (m *DataKey) GetKeyId() uint64

func (*DataKey) Marshal ¶ 

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

func (*DataKey) MarshalTo ¶ 

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

func (*DataKey) MarshalToSizedBuffer ¶ 

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

func (*DataKey) ProtoMessage ¶ 

func (*DataKey) ProtoMessage()

func (*DataKey) Reset ¶ 

func (m *DataKey) Reset()

func (*DataKey) Size ¶ 

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

func (*DataKey) String ¶ 

func (m *DataKey) String() string

func (*DataKey) Unmarshal ¶ 

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

func (*DataKey) XXX_DiscardUnknown ¶ 

func (m *DataKey) XXX_DiscardUnknown()

func (*DataKey) XXX_Marshal ¶ 

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

func (*DataKey) XXX_Merge ¶ 

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

func (*DataKey) XXX_Size ¶ 

func (m *DataKey) XXX_Size() int

func (*DataKey) XXX_Unmarshal ¶ 

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

type EncryptionAlgo ¶ 

type EncryptionAlgo int32
const (
	EncryptionAlgo_aes EncryptionAlgo = 0
)

func (EncryptionAlgo) EnumDescriptor ¶ 

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

func (EncryptionAlgo) String ¶ 

func (x EncryptionAlgo) String() string

type KV ¶ 

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"`
	Kind       KV_Kind `protobuf:"varint,12,opt,name=kind,proto3,enum=badgerpb3.KV_Kind" json:"kind,omitempty"`
}

func (*KV) Descriptor ¶ 

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

func (*KV) GetExpiresAt ¶ 

func (m *KV) GetExpiresAt() uint64

func (*KV) GetKey ¶ 

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

func (*KV) GetKind ¶ 

func (m *KV) GetKind() KV_Kind

func (*KV) GetMeta ¶ 

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

func (*KV) GetStreamDone ¶ 

func (m *KV) GetStreamDone() bool

func (*KV) GetStreamId ¶ 

func (m *KV) GetStreamId() uint32

func (*KV) GetUserMeta ¶ 

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

func (*KV) GetValue ¶ 

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

func (*KV) GetVersion ¶ 

func (m *KV) GetVersion() uint64

func (*KV) Marshal ¶ 

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

func (*KV) MarshalTo ¶ 

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

func (*KV) MarshalToSizedBuffer ¶ 

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

func (*KV) ProtoMessage ¶ 

func (*KV) ProtoMessage()

func (*KV) Reset ¶ 

func (m *KV) Reset()

func (*KV) Size ¶ 

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

func (*KV) String ¶ 

func (m *KV) String() string

func (*KV) Unmarshal ¶ 

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

func (*KV) XXX_DiscardUnknown ¶ 

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal ¶ 

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

func (*KV) XXX_Merge ¶ 

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

func (*KV) XXX_Size ¶ 

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal ¶ 

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

type KVList ¶ 

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 ¶ 

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

func (*KVList) GetAllocRef ¶ 

func (m *KVList) GetAllocRef() uint64

func (*KVList) GetKv ¶ 

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

func (*KVList) Marshal ¶ 

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

func (*KVList) MarshalTo ¶ 

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

func (*KVList) MarshalToSizedBuffer ¶ 

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

func (*KVList) ProtoMessage ¶ 

func (*KVList) ProtoMessage()

func (*KVList) Reset ¶ 

func (m *KVList) Reset()

func (*KVList) Size ¶ 

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

func (*KVList) String ¶ 

func (m *KVList) String() string

func (*KVList) Unmarshal ¶ 

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

func (*KVList) XXX_DiscardUnknown ¶ 

func (m *KVList) XXX_DiscardUnknown()

func (*KVList) XXX_Marshal ¶ 

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

func (*KVList) XXX_Merge ¶ 

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

func (*KVList) XXX_Size ¶ 

func (m *KVList) XXX_Size() int

func (*KVList) XXX_Unmarshal ¶ 

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

type KV_Kind ¶ 

type KV_Kind int32
const (
	KV_KEY      KV_Kind = 0
	KV_DATA_KEY KV_Kind = 1
	KV_FILE     KV_Kind = 2
)

func (KV_Kind) EnumDescriptor ¶ 

func (KV_Kind) EnumDescriptor() ([]byte, []int)

func (KV_Kind) String ¶ 

func (x KV_Kind) String() string

type ManifestChange ¶ 

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           `` /* 134-byte string literal not displayed */
	Compression    uint32                   `protobuf:"varint,6,opt,name=compression,proto3" json:"compression,omitempty"`
}

func (*ManifestChange) Descriptor ¶ 

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

func (*ManifestChange) GetCompression ¶ 

func (m *ManifestChange) GetCompression() uint32

func (*ManifestChange) GetEncryptionAlgo ¶ 

func (m *ManifestChange) GetEncryptionAlgo() EncryptionAlgo

func (*ManifestChange) GetId ¶ 

func (m *ManifestChange) GetId() uint64

func (*ManifestChange) GetKeyId ¶ 

func (m *ManifestChange) GetKeyId() uint64

func (*ManifestChange) GetLevel ¶ 

func (m *ManifestChange) GetLevel() uint32

func (*ManifestChange) GetOp ¶ 

func (m *ManifestChange) GetOp() ManifestChange_Operation

func (*ManifestChange) Marshal ¶ 

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

func (*ManifestChange) MarshalTo ¶ 

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

func (*ManifestChange) MarshalToSizedBuffer ¶ 

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

func (*ManifestChange) ProtoMessage ¶ 

func (*ManifestChange) ProtoMessage()

func (*ManifestChange) Reset ¶ 

func (m *ManifestChange) Reset()

func (*ManifestChange) Size ¶ 

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

func (*ManifestChange) String ¶ 

func (m *ManifestChange) String() string

func (*ManifestChange) Unmarshal ¶ 

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

func (*ManifestChange) XXX_DiscardUnknown ¶ 

func (m *ManifestChange) XXX_DiscardUnknown()

func (*ManifestChange) XXX_Marshal ¶ 

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

func (*ManifestChange) XXX_Merge ¶ 

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

func (*ManifestChange) XXX_Size ¶ 

func (m *ManifestChange) XXX_Size() int

func (*ManifestChange) XXX_Unmarshal ¶ 

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

type ManifestChangeSet ¶ 

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 ¶ 

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

func (*ManifestChangeSet) GetChanges ¶ 

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

func (*ManifestChangeSet) Marshal ¶ 

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

func (*ManifestChangeSet) MarshalTo ¶ 

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

func (*ManifestChangeSet) MarshalToSizedBuffer ¶ 

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

func (*ManifestChangeSet) ProtoMessage ¶ 

func (*ManifestChangeSet) ProtoMessage()

func (*ManifestChangeSet) Reset ¶ 

func (m *ManifestChangeSet) Reset()

func (*ManifestChangeSet) Size ¶ 

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

func (*ManifestChangeSet) String ¶ 

func (m *ManifestChangeSet) String() string

func (*ManifestChangeSet) Unmarshal ¶ 

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

func (*ManifestChangeSet) XXX_DiscardUnknown ¶ 

func (m *ManifestChangeSet) XXX_DiscardUnknown()

func (*ManifestChangeSet) XXX_Marshal ¶ 

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

func (*ManifestChangeSet) XXX_Merge ¶ 

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

func (*ManifestChangeSet) XXX_Size ¶ 

func (m *ManifestChangeSet) XXX_Size() int

func (*ManifestChangeSet) XXX_Unmarshal ¶ 

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

type ManifestChange_Operation ¶ 

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

func (ManifestChange_Operation) EnumDescriptor ¶ 

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

func (ManifestChange_Operation) String ¶ 

func (x ManifestChange_Operation) String() string

type Match ¶ 

type Match struct {
	Prefix      []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	IgnoreBytes string `protobuf:"bytes,2,opt,name=ignore_bytes,json=ignoreBytes,proto3" json:"ignore_bytes,omitempty"`
}

func (*Match) Descriptor ¶ 

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

func (*Match) GetIgnoreBytes ¶ 

func (m *Match) GetIgnoreBytes() string

func (*Match) GetPrefix ¶ 

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

func (*Match) Marshal ¶ 

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

func (*Match) MarshalTo ¶ 

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

func (*Match) MarshalToSizedBuffer ¶ 

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

func (*Match) ProtoMessage ¶ 

func (*Match) ProtoMessage()

func (*Match) Reset ¶ 

func (m *Match) Reset()

func (*Match) Size ¶ 

func (m *Match) Size() (n int)

func (*Match) String ¶ 

func (m *Match) String() string

func (*Match) Unmarshal ¶ 

func (m *Match) Unmarshal(dAtA []byte) error

func (*Match) XXX_DiscardUnknown ¶ 

func (m *Match) XXX_DiscardUnknown()

func (*Match) XXX_Marshal ¶ 

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

func (*Match) XXX_Merge ¶ 

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

func (*Match) XXX_Size ¶ 

func (m *Match) XXX_Size() int

func (*Match) XXX_Unmarshal ¶ 

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