pb

package
v0.0.0-...-a38de57 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ManifestModify_Operation_name = map[int32]string{
	0: "CREATE",
	1: "DELETE",
}
View Source 
var ManifestModify_Operation_value = map[string]int32{
	"CREATE": 0,
	"DELETE": 1,
}

Functions

This section is empty.

Types

type BlockOffset 

type BlockOffset struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Offset               uint32   `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Len                  uint32   `protobuf:"varint,3,opt,name=len,proto3" json:"len,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlockOffset) Descriptor 

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

func (*BlockOffset) GetKey 

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

func (*BlockOffset) GetLen 

func (m *BlockOffset) GetLen() uint32

func (*BlockOffset) GetOffset 

func (m *BlockOffset) GetOffset() uint32

func (*BlockOffset) Marshal 

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

func (*BlockOffset) MarshalTo 

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

func (*BlockOffset) MarshalToSizedBuffer 

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

func (*BlockOffset) ProtoMessage 

func (*BlockOffset) ProtoMessage()

func (*BlockOffset) Reset 

func (m *BlockOffset) Reset()

func (*BlockOffset) Size 

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

func (*BlockOffset) String 

func (m *BlockOffset) String() string

func (*BlockOffset) Unmarshal 

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

func (*BlockOffset) XXX_DiscardUnknown 

func (m *BlockOffset) XXX_DiscardUnknown()

func (*BlockOffset) XXX_Marshal 

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

func (*BlockOffset) XXX_Merge 

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

func (*BlockOffset) XXX_Size 

func (m *BlockOffset) XXX_Size() int

func (*BlockOffset) XXX_Unmarshal 

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

type ManifestModifies 

type ManifestModifies struct {
	Modifies             []*ManifestModify `protobuf:"bytes,1,rep,name=modifies,proto3" json:"modifies,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ManifestModifies) Descriptor 

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

func (*ManifestModifies) GetModifies 

func (m *ManifestModifies) GetModifies() []*ManifestModify

func (*ManifestModifies) Marshal 

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

func (*ManifestModifies) MarshalTo 

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

func (*ManifestModifies) MarshalToSizedBuffer 

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

func (*ManifestModifies) ProtoMessage 

func (*ManifestModifies) ProtoMessage()

func (*ManifestModifies) Reset 

func (m *ManifestModifies) Reset()

func (*ManifestModifies) Size 

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

func (*ManifestModifies) String 

func (m *ManifestModifies) String() string

func (*ManifestModifies) Unmarshal 

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

func (*ManifestModifies) XXX_DiscardUnknown 

func (m *ManifestModifies) XXX_DiscardUnknown()

func (*ManifestModifies) XXX_Marshal 

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

func (*ManifestModifies) XXX_Merge 

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

func (*ManifestModifies) XXX_Size 

func (m *ManifestModifies) XXX_Size() int

func (*ManifestModifies) XXX_Unmarshal 

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

type ManifestModify 

type ManifestModify struct {
	Id                   uint64                   `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Op                   ManifestModify_Operation `protobuf:"varint,2,opt,name=Op,proto3,enum=pb.ManifestModify_Operation" json:"Op,omitempty"`
	Level                uint32                   `protobuf:"varint,3,opt,name=Level,proto3" json:"Level,omitempty"`
	Checksum             []byte                   `protobuf:"bytes,4,opt,name=Checksum,proto3" json:"Checksum,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ManifestModify) Descriptor 

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

func (*ManifestModify) GetChecksum 

func (m *ManifestModify) GetChecksum() []byte

func (*ManifestModify) GetId 

func (m *ManifestModify) GetId() uint64

func (*ManifestModify) GetLevel 

func (m *ManifestModify) GetLevel() uint32

func (*ManifestModify) GetOp 

func (m *ManifestModify) GetOp() ManifestModify_Operation

func (*ManifestModify) Marshal 

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

func (*ManifestModify) MarshalTo 

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

func (*ManifestModify) MarshalToSizedBuffer 

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

func (*ManifestModify) ProtoMessage 

func (*ManifestModify) ProtoMessage()

func (*ManifestModify) Reset 

func (m *ManifestModify) Reset()

func (*ManifestModify) Size 

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

func (*ManifestModify) String 

func (m *ManifestModify) String() string

func (*ManifestModify) Unmarshal 

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

func (*ManifestModify) XXX_DiscardUnknown 

func (m *ManifestModify) XXX_DiscardUnknown()

func (*ManifestModify) XXX_Marshal 

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

func (*ManifestModify) XXX_Merge 

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

func (*ManifestModify) XXX_Size 

func (m *ManifestModify) XXX_Size() int

func (*ManifestModify) XXX_Unmarshal 

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

type ManifestModify_Operation 

type ManifestModify_Operation int32
const (
	ManifestModify_CREATE ManifestModify_Operation = 0
	ManifestModify_DELETE ManifestModify_Operation = 1
)

func (ManifestModify_Operation) EnumDescriptor 

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

func (ManifestModify_Operation) String 

func (x ManifestModify_Operation) String() string

type TableIndex 

type TableIndex struct {
	Offsets              []*BlockOffset `protobuf:"bytes,1,rep,name=offsets,proto3" json:"offsets,omitempty"`
	BloomFilter          []byte         `protobuf:"bytes,2,opt,name=bloomFilter,proto3" json:"bloomFilter,omitempty"`
	MaxVersion           uint64         `protobuf:"varint,3,opt,name=maxVersion,proto3" json:"maxVersion,omitempty"`
	KeyCount             uint32         `protobuf:"varint,4,opt,name=keyCount,proto3" json:"keyCount,omitempty"`
	StaleDataSize        uint32         `protobuf:"varint,5,opt,name=staleDataSize,proto3" json:"staleDataSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TableIndex) Descriptor 

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

func (*TableIndex) GetBloomFilter 

func (m *TableIndex) GetBloomFilter() []byte

func (*TableIndex) GetKeyCount 

func (m *TableIndex) GetKeyCount() uint32

func (*TableIndex) GetMaxVersion 

func (m *TableIndex) GetMaxVersion() uint64

func (*TableIndex) GetOffsets 

func (m *TableIndex) GetOffsets() []*BlockOffset

func (*TableIndex) GetStaleDataSize 

func (m *TableIndex) GetStaleDataSize() uint32

func (*TableIndex) Marshal 

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

func (*TableIndex) MarshalTo 

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

func (*TableIndex) MarshalToSizedBuffer 

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

func (*TableIndex) ProtoMessage 

func (*TableIndex) ProtoMessage()

func (*TableIndex) Reset 

func (m *TableIndex) Reset()

func (*TableIndex) Size 

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

func (*TableIndex) String 

func (m *TableIndex) String() string

func (*TableIndex) Unmarshal 

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

func (*TableIndex) XXX_DiscardUnknown 

func (m *TableIndex) XXX_DiscardUnknown()

func (*TableIndex) XXX_Marshal 

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

func (*TableIndex) XXX_Merge 

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

func (*TableIndex) XXX_Size 

func (m *TableIndex) XXX_Size() int

func (*TableIndex) XXX_Unmarshal 

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