store

package
v3.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 25, 2023 License: Apache-2.0 Imports: 6 Imported by: 52

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQueryResult        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueryResult          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueryResult = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStore        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStore          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStore = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ArchiveProcess_name = map[int32]string{
	0: "Normal",
	1: "Archiving",
	2: "Restoring",
}
View Source 
var ArchiveProcess_value = map[string]int32{
	"Normal":    0,
	"Archiving": 1,
	"Restoring": 2,
}
View Source 
var DataStoreType_name = map[int32]string{
	0: "FILE_STORE",
	1: "SQL_STORE",
	2: "COS",
}
View Source 
var DataStoreType_value = map[string]int32{
	"FILE_STORE": 0,
	"SQL_STORE":  1,
	"COS":        2,
}
View Source 
var DbType_name = map[int32]string{
	0: "INVALID_DB",
	1: "BLOCK_DB",
	2: "BLOCK_INDEX_DB",
	3: "TX_DB",
	4: "TX_INDEX_DB",
	5: "SOFT_DB",
	6: "STATE_DB",
	7: "READ_WRITE_DB",
}
View Source 
var DbType_value = map[string]int32{
	"INVALID_DB":     0,
	"BLOCK_DB":       1,
	"BLOCK_INDEX_DB": 2,
	"TX_DB":          3,
	"TX_INDEX_DB":    4,
	"SOFT_DB":        5,
	"STATE_DB":       6,
	"READ_WRITE_DB":  7,
}
View Source 
var StoreType_name = map[int32]string{
	0: "RawDB",
	1: "BFDB",
}
View Source 
var StoreType_value = map[string]int32{
	"RawDB": 0,
	"BFDB":  1,
}

Functions

This section is empty.

Types

type ArchiveJob 

type ArchiveJob struct {
	// job state time
	StartTime int64 `protobuf:"varint,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// job end time
	EndTime int64 `protobuf:"varint,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// job status
	Status int32 `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	// archive block's height that between start_height and end_height
	StartHeight uint64 `protobuf:"varint,4,opt,name=start_height,json=startHeight,proto3" json:"start_height,omitempty"`
	EndHeight   uint64 `protobuf:"varint,5,opt,name=end_height,json=endHeight,proto3" json:"end_height,omitempty"`
	// archive scan file name
	ScanFiles []string `protobuf:"bytes,6,rep,name=scan_files,json=scanFiles,proto3" json:"scan_files,omitempty"`
	// archive affect file name
	AffectFiles []string `protobuf:"bytes,7,rep,name=affect_files,json=affectFiles,proto3" json:"affect_files,omitempty"`
}

ArchiveJob include jobs for archiving blocks

func (*ArchiveJob) Descriptor 

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

func (*ArchiveJob) GetAffectFiles added in v3.0.1 

func (m *ArchiveJob) GetAffectFiles() []string

func (*ArchiveJob) GetEndHeight 

func (m *ArchiveJob) GetEndHeight() uint64

func (*ArchiveJob) GetEndTime 

func (m *ArchiveJob) GetEndTime() int64

func (*ArchiveJob) GetScanFiles added in v3.0.1 

func (m *ArchiveJob) GetScanFiles() []string

func (*ArchiveJob) GetStartHeight 

func (m *ArchiveJob) GetStartHeight() uint64

func (*ArchiveJob) GetStartTime 

func (m *ArchiveJob) GetStartTime() int64

func (*ArchiveJob) GetStatus 

func (m *ArchiveJob) GetStatus() int32

func (*ArchiveJob) Marshal 

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

func (*ArchiveJob) MarshalTo 

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

func (*ArchiveJob) MarshalToSizedBuffer 

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

func (*ArchiveJob) ProtoMessage 

func (*ArchiveJob) ProtoMessage()

func (*ArchiveJob) Reset 

func (m *ArchiveJob) Reset()

func (*ArchiveJob) Size 

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

func (*ArchiveJob) String 

func (m *ArchiveJob) String() string

func (*ArchiveJob) Unmarshal 

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

func (*ArchiveJob) XXX_DiscardUnknown 

func (m *ArchiveJob) XXX_DiscardUnknown()

func (*ArchiveJob) XXX_Marshal 

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

func (*ArchiveJob) XXX_Merge 

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

func (*ArchiveJob) XXX_Size 

func (m *ArchiveJob) XXX_Size() int

func (*ArchiveJob) XXX_Unmarshal 

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

type ArchiveProcess added in v3.0.1 

type ArchiveProcess int32

archive in process status 

const (
	// chain is normal status
	ArchiveProcess_Normal ArchiveProcess = 0
	// chain is doing archive
	ArchiveProcess_Archiving ArchiveProcess = 1
	// chain is doing restore
	ArchiveProcess_Restoring ArchiveProcess = 2
)

func (ArchiveProcess) EnumDescriptor added in v3.0.1 

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

func (ArchiveProcess) String added in v3.0.1 

func (x ArchiveProcess) String() string

type ArchiveStatus added in v3.0.1 

type ArchiveStatus struct {
	// store type
	Type StoreType `protobuf:"varint,1,opt,name=type,proto3,enum=store.StoreType" json:"type,omitempty"`
	// file range data
	FileRanges []*FileRange `protobuf:"bytes,2,rep,name=file_ranges,json=fileRanges,proto3" json:"file_ranges,omitempty"`
	// current archive pivot height
	ArchivePivot uint64 `protobuf:"varint,3,opt,name=archive_pivot,json=archivePivot,proto3" json:"archive_pivot,omitempty"`
	// max allow archive height
	MaxAllowArchiveHeight uint64 `` /* 129-byte string literal not displayed */
	// node archive process status
	Process ArchiveProcess `protobuf:"varint,5,opt,name=process,proto3,enum=store.ArchiveProcess" json:"process,omitempty"`
}

archive status data

func (*ArchiveStatus) Descriptor added in v3.0.1 

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

func (*ArchiveStatus) GetArchivePivot added in v3.0.1 

func (m *ArchiveStatus) GetArchivePivot() uint64

func (*ArchiveStatus) GetFileRanges added in v3.0.1 

func (m *ArchiveStatus) GetFileRanges() []*FileRange

func (*ArchiveStatus) GetMaxAllowArchiveHeight added in v3.0.1 

func (m *ArchiveStatus) GetMaxAllowArchiveHeight() uint64

func (*ArchiveStatus) GetProcess added in v3.0.1 

func (m *ArchiveStatus) GetProcess() ArchiveProcess

func (*ArchiveStatus) GetType added in v3.0.1 

func (m *ArchiveStatus) GetType() StoreType

func (*ArchiveStatus) Marshal added in v3.0.1 

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

func (*ArchiveStatus) MarshalTo added in v3.0.1 

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

func (*ArchiveStatus) MarshalToSizedBuffer added in v3.0.1 

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

func (*ArchiveStatus) ProtoMessage added in v3.0.1 

func (*ArchiveStatus) ProtoMessage()

func (*ArchiveStatus) Reset added in v3.0.1 

func (m *ArchiveStatus) Reset()

func (*ArchiveStatus) Size added in v3.0.1 

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

func (*ArchiveStatus) String added in v3.0.1 

func (m *ArchiveStatus) String() string

func (*ArchiveStatus) Unmarshal added in v3.0.1 

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

func (*ArchiveStatus) XXX_DiscardUnknown added in v3.0.1 

func (m *ArchiveStatus) XXX_DiscardUnknown()

func (*ArchiveStatus) XXX_Marshal added in v3.0.1 

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

func (*ArchiveStatus) XXX_Merge added in v3.0.1 

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

func (*ArchiveStatus) XXX_Size added in v3.0.1 

func (m *ArchiveStatus) XXX_Size() int

func (*ArchiveStatus) XXX_Unmarshal added in v3.0.1 

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

type BlockWithRWSet 

type BlockWithRWSet struct {
	// block data
	Block *common.Block `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	// transaction read/write set of blocks
	TxRWSets []*common.TxRWSet `protobuf:"bytes,2,rep,name=txRWSets,proto3" json:"txRWSets,omitempty"`
	// contract event info
	ContractEvents []*common.ContractEvent `protobuf:"bytes,3,rep,name=contract_events,json=contractEvents,proto3" json:"contract_events,omitempty"`
}

Block and its read/write set information

func (*BlockWithRWSet) Descriptor 

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

func (*BlockWithRWSet) GetBlock 

func (m *BlockWithRWSet) GetBlock() *common.Block

func (*BlockWithRWSet) GetContractEvents 

func (m *BlockWithRWSet) GetContractEvents() []*common.ContractEvent

func (*BlockWithRWSet) GetTxRWSets 

func (m *BlockWithRWSet) GetTxRWSets() []*common.TxRWSet

func (*BlockWithRWSet) Marshal 

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

func (*BlockWithRWSet) MarshalTo 

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

func (*BlockWithRWSet) MarshalToSizedBuffer 

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

func (*BlockWithRWSet) ProtoMessage 

func (*BlockWithRWSet) ProtoMessage()

func (*BlockWithRWSet) Reset 

func (m *BlockWithRWSet) Reset()

func (*BlockWithRWSet) Size 

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

func (*BlockWithRWSet) String 

func (m *BlockWithRWSet) String() string

func (*BlockWithRWSet) Unmarshal 

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

func (*BlockWithRWSet) XXX_DiscardUnknown 

func (m *BlockWithRWSet) XXX_DiscardUnknown()

func (*BlockWithRWSet) XXX_Marshal 

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

func (*BlockWithRWSet) XXX_Merge 

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

func (*BlockWithRWSet) XXX_Size 

func (m *BlockWithRWSet) XXX_Size() int

func (*BlockWithRWSet) XXX_Unmarshal 

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

type DataStoreType 

type DataStoreType int32
const (
	// 文件系统存储
	DataStoreType_FILE_STORE DataStoreType = 0
	//SQL数据库存储
	DataStoreType_SQL_STORE DataStoreType = 1
	//云对象存储
	DataStoreType_COS DataStoreType = 2
)

func (DataStoreType) EnumDescriptor 

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

func (DataStoreType) String 

func (x DataStoreType) String() string

type DbType 

type DbType int32
const (
	DbType_INVALID_DB     DbType = 0
	DbType_BLOCK_DB       DbType = 1
	DbType_BLOCK_INDEX_DB DbType = 2
	DbType_TX_DB          DbType = 3
	DbType_TX_INDEX_DB    DbType = 4
	DbType_SOFT_DB        DbType = 5
	DbType_STATE_DB       DbType = 6
	DbType_READ_WRITE_DB  DbType = 7
)

func (DbType) EnumDescriptor 

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

func (DbType) String 

func (x DbType) String() string

type FileCrcInfo 

type FileCrcInfo struct {
	// file crc
	CrcData int64 `protobuf:"varint,1,opt,name=crc_data,json=crcData,proto3" json:"crc_data,omitempty"`
}

FileCrcInfoI includes file crc

func (*FileCrcInfo) Descriptor 

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

func (*FileCrcInfo) GetCrcData 

func (m *FileCrcInfo) GetCrcData() int64

func (*FileCrcInfo) Marshal 

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

func (*FileCrcInfo) MarshalTo 

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

func (*FileCrcInfo) MarshalToSizedBuffer 

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

func (*FileCrcInfo) ProtoMessage 

func (*FileCrcInfo) ProtoMessage()

func (*FileCrcInfo) Reset 

func (m *FileCrcInfo) Reset()

func (*FileCrcInfo) Size 

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

func (*FileCrcInfo) String 

func (m *FileCrcInfo) String() string

func (*FileCrcInfo) Unmarshal 

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

func (*FileCrcInfo) XXX_DiscardUnknown 

func (m *FileCrcInfo) XXX_DiscardUnknown()

func (*FileCrcInfo) XXX_Marshal 

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

func (*FileCrcInfo) XXX_Merge 

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

func (*FileCrcInfo) XXX_Size 

func (m *FileCrcInfo) XXX_Size() int

func (*FileCrcInfo) XXX_Unmarshal 

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

type FileRange added in v3.0.1 

type FileRange struct {
	// file name: 00000000000000000019.xxx
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// file contains block start height
	Start uint64 `protobuf:"varint,2,opt,name=Start,proto3" json:"Start,omitempty"`
	// file contains block end height
	End uint64 `protobuf:"varint,3,opt,name=End,proto3" json:"End,omitempty"`
}

xxx.fdb information

func (*FileRange) Descriptor added in v3.0.1 

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

func (*FileRange) GetEnd added in v3.0.1 

func (m *FileRange) GetEnd() uint64

func (*FileRange) GetFileName added in v3.0.1 

func (m *FileRange) GetFileName() string

func (*FileRange) GetStart added in v3.0.1 

func (m *FileRange) GetStart() uint64

func (*FileRange) Marshal added in v3.0.1 

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

func (*FileRange) MarshalTo added in v3.0.1 

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

func (*FileRange) MarshalToSizedBuffer added in v3.0.1 

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

func (*FileRange) ProtoMessage added in v3.0.1 

func (*FileRange) ProtoMessage()

func (*FileRange) Reset added in v3.0.1 

func (m *FileRange) Reset()

func (*FileRange) Size added in v3.0.1 

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

func (*FileRange) String added in v3.0.1 

func (m *FileRange) String() string

func (*FileRange) Unmarshal added in v3.0.1 

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

func (*FileRange) XXX_DiscardUnknown added in v3.0.1 

func (m *FileRange) XXX_DiscardUnknown()

func (*FileRange) XXX_Marshal added in v3.0.1 

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

func (*FileRange) XXX_Merge added in v3.0.1 

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

func (*FileRange) XXX_Size added in v3.0.1 

func (m *FileRange) XXX_Size() int

func (*FileRange) XXX_Unmarshal added in v3.0.1 

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

type HotColdSeparateMaxHeight added in v3.0.1 

type HotColdSeparateMaxHeight struct {
	// max height
	MaxHeight uint64 `protobuf:"varint,1,opt,name=max_height,json=maxHeight,proto3" json:"max_height,omitempty"`
}

HotColdSeparateMaxHeight include max height for hot-cold-separate

func (*HotColdSeparateMaxHeight) Descriptor added in v3.0.1 

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

func (*HotColdSeparateMaxHeight) GetMaxHeight added in v3.0.1 

func (m *HotColdSeparateMaxHeight) GetMaxHeight() uint64

func (*HotColdSeparateMaxHeight) Marshal added in v3.0.1 

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

func (*HotColdSeparateMaxHeight) MarshalTo added in v3.0.1 

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

func (*HotColdSeparateMaxHeight) MarshalToSizedBuffer added in v3.0.1 

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

func (*HotColdSeparateMaxHeight) ProtoMessage added in v3.0.1 

func (*HotColdSeparateMaxHeight) ProtoMessage()

func (*HotColdSeparateMaxHeight) Reset added in v3.0.1 

func (m *HotColdSeparateMaxHeight) Reset()

func (*HotColdSeparateMaxHeight) Size added in v3.0.1 

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

func (*HotColdSeparateMaxHeight) String added in v3.0.1 

func (m *HotColdSeparateMaxHeight) String() string

func (*HotColdSeparateMaxHeight) Unmarshal added in v3.0.1 

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

func (*HotColdSeparateMaxHeight) XXX_DiscardUnknown added in v3.0.1 

func (m *HotColdSeparateMaxHeight) XXX_DiscardUnknown()

func (*HotColdSeparateMaxHeight) XXX_Marshal added in v3.0.1 

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

func (*HotColdSeparateMaxHeight) XXX_Merge added in v3.0.1 

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

func (*HotColdSeparateMaxHeight) XXX_Size added in v3.0.1 

func (m *HotColdSeparateMaxHeight) XXX_Size() int

func (*HotColdSeparateMaxHeight) XXX_Unmarshal added in v3.0.1 

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

type KV 

type KV struct {
	ContractName string `protobuf:"bytes,1,opt,name=contract_name,json=contractName,proto3" json:"contract_name,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"`
}

func (*KV) Descriptor 

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

func (*KV) GetContractName 

func (m *KV) GetContractName() string

func (*KV) GetKey 

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

func (*KV) GetValue 

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

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 KeyModification 

type KeyModification struct {
	TxId        string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	Value       []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp   int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	IsDelete    bool   `protobuf:"varint,4,opt,name=is_delete,json=isDelete,proto3" json:"is_delete,omitempty"`
	BlockHeight uint64 `protobuf:"varint,5,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

KeyModification -- QueryResult for history db query. Holds a transaction ID, value, timestamp, and delete marker which resulted from a history query.

func (*KeyModification) Descriptor 

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

func (*KeyModification) GetBlockHeight 

func (m *KeyModification) GetBlockHeight() uint64

func (*KeyModification) GetIsDelete 

func (m *KeyModification) GetIsDelete() bool

func (*KeyModification) GetTimestamp 

func (m *KeyModification) GetTimestamp() int64

func (*KeyModification) GetTxId 

func (m *KeyModification) GetTxId() string

func (*KeyModification) GetValue 

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

func (*KeyModification) Marshal 

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

func (*KeyModification) MarshalTo 

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

func (*KeyModification) MarshalToSizedBuffer 

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

func (*KeyModification) ProtoMessage 

func (*KeyModification) ProtoMessage()

func (*KeyModification) Reset 

func (m *KeyModification) Reset()

func (*KeyModification) Size 

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

func (*KeyModification) String 

func (m *KeyModification) String() string

func (*KeyModification) Unmarshal 

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

func (*KeyModification) XXX_DiscardUnknown 

func (m *KeyModification) XXX_DiscardUnknown()

func (*KeyModification) XXX_Marshal 

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

func (*KeyModification) XXX_Merge 

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

func (*KeyModification) XXX_Size 

func (m *KeyModification) XXX_Size() int

func (*KeyModification) XXX_Unmarshal 

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

type MetaFileInfo 

type MetaFileInfo struct {
	// online file system
	OnlineFileSystem string `protobuf:"bytes,1,opt,name=online_file_system,json=onlineFileSystem,proto3" json:"online_file_system,omitempty"`
	// file is archived or not
	Status int32 `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	// archive file system
	ArchiveFileSystem string `protobuf:"bytes,3,opt,name=archive_file_system,json=archiveFileSystem,proto3" json:"archive_file_system,omitempty"`
	// start height
	StartHeight uint64 `protobuf:"varint,4,opt,name=start_height,json=startHeight,proto3" json:"start_height,omitempty"`
	// end height
	EndHeight uint64 `protobuf:"varint,5,opt,name=end_height,json=endHeight,proto3" json:"end_height,omitempty"`
}

MetaFileInfo include wal file info

func (*MetaFileInfo) Descriptor 

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

func (*MetaFileInfo) GetArchiveFileSystem 

func (m *MetaFileInfo) GetArchiveFileSystem() string

func (*MetaFileInfo) GetEndHeight 

func (m *MetaFileInfo) GetEndHeight() uint64

func (*MetaFileInfo) GetOnlineFileSystem 

func (m *MetaFileInfo) GetOnlineFileSystem() string

func (*MetaFileInfo) GetStartHeight 

func (m *MetaFileInfo) GetStartHeight() uint64

func (*MetaFileInfo) GetStatus 

func (m *MetaFileInfo) GetStatus() int32

func (*MetaFileInfo) Marshal 

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

func (*MetaFileInfo) MarshalTo 

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

func (*MetaFileInfo) MarshalToSizedBuffer 

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

func (*MetaFileInfo) ProtoMessage 

func (*MetaFileInfo) ProtoMessage()

func (*MetaFileInfo) Reset 

func (m *MetaFileInfo) Reset()

func (*MetaFileInfo) Size 

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

func (*MetaFileInfo) String 

func (m *MetaFileInfo) String() string

func (*MetaFileInfo) Unmarshal 

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

func (*MetaFileInfo) XXX_DiscardUnknown 

func (m *MetaFileInfo) XXX_DiscardUnknown()

func (*MetaFileInfo) XXX_Marshal 

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

func (*MetaFileInfo) XXX_Merge 

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

func (*MetaFileInfo) XXX_Size 

func (m *MetaFileInfo) XXX_Size() int

func (*MetaFileInfo) XXX_Unmarshal 

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

type MetaFileSystem 

type MetaFileSystem struct {
	// online file system
	OnlineFileSystem []string `protobuf:"bytes,1,rep,name=online_file_system,json=onlineFileSystem,proto3" json:"online_file_system,omitempty"`
	// archive file system
	ArchiveFileSystem []string `protobuf:"bytes,2,rep,name=archive_file_system,json=archiveFileSystem,proto3" json:"archive_file_system,omitempty"`
}

MetaFileSystem info include online file system and archive file system

func (*MetaFileSystem) Descriptor 

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

func (*MetaFileSystem) GetArchiveFileSystem 

func (m *MetaFileSystem) GetArchiveFileSystem() []string

func (*MetaFileSystem) GetOnlineFileSystem 

func (m *MetaFileSystem) GetOnlineFileSystem() []string

func (*MetaFileSystem) Marshal 

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

func (*MetaFileSystem) MarshalTo 

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

func (*MetaFileSystem) MarshalToSizedBuffer 

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

func (*MetaFileSystem) ProtoMessage 

func (*MetaFileSystem) ProtoMessage()

func (*MetaFileSystem) Reset 

func (m *MetaFileSystem) Reset()

func (*MetaFileSystem) Size 

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

func (*MetaFileSystem) String 

func (m *MetaFileSystem) String() string

func (*MetaFileSystem) Unmarshal 

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

func (*MetaFileSystem) XXX_DiscardUnknown 

func (m *MetaFileSystem) XXX_DiscardUnknown()

func (*MetaFileSystem) XXX_Marshal 

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

func (*MetaFileSystem) XXX_Merge 

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

func (*MetaFileSystem) XXX_Size 

func (m *MetaFileSystem) XXX_Size() int

func (*MetaFileSystem) XXX_Unmarshal 

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

type MetaMultVersions 

type MetaMultVersions struct {
	// multi version
	Version []*MetaVersion `protobuf:"bytes,1,rep,name=version,proto3" json:"version,omitempty"`
}

MetaMultVersions include every version

func (*MetaMultVersions) Descriptor 

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

func (*MetaMultVersions) GetVersion 

func (m *MetaMultVersions) GetVersion() []*MetaVersion

func (*MetaMultVersions) Marshal 

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

func (*MetaMultVersions) MarshalTo 

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

func (*MetaMultVersions) MarshalToSizedBuffer 

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

func (*MetaMultVersions) ProtoMessage 

func (*MetaMultVersions) ProtoMessage()

func (*MetaMultVersions) Reset 

func (m *MetaMultVersions) Reset()

func (*MetaMultVersions) Size 

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

func (*MetaMultVersions) String 

func (m *MetaMultVersions) String() string

func (*MetaMultVersions) Unmarshal 

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

func (*MetaMultVersions) XXX_DiscardUnknown 

func (m *MetaMultVersions) XXX_DiscardUnknown()

func (*MetaMultVersions) XXX_Marshal 

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

func (*MetaMultVersions) XXX_Merge 

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

func (*MetaMultVersions) XXX_Size 

func (m *MetaMultVersions) XXX_Size() int

func (*MetaMultVersions) XXX_Unmarshal 

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

type MetaVersion 

type MetaVersion struct {
	// major version
	MajorVersion int32 `protobuf:"varint,1,opt,name=major_version,json=majorVersion,proto3" json:"major_version,omitempty"`
	// minor version
	MinorVersion int32 `protobuf:"varint,2,opt,name=minor_version,json=minorVersion,proto3" json:"minor_version,omitempty"`
	// update time
	UpdateTime int64 `protobuf:"varint,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
}

MetaVersions include every version

func (*MetaVersion) Descriptor 

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

func (*MetaVersion) GetMajorVersion 

func (m *MetaVersion) GetMajorVersion() int32

func (*MetaVersion) GetMinorVersion 

func (m *MetaVersion) GetMinorVersion() int32

func (*MetaVersion) GetUpdateTime 

func (m *MetaVersion) GetUpdateTime() int64

func (*MetaVersion) Marshal 

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

func (*MetaVersion) MarshalTo 

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

func (*MetaVersion) MarshalToSizedBuffer 

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

func (*MetaVersion) ProtoMessage 

func (*MetaVersion) ProtoMessage()

func (*MetaVersion) Reset 

func (m *MetaVersion) Reset()

func (*MetaVersion) Size 

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

func (*MetaVersion) String 

func (m *MetaVersion) String() string

func (*MetaVersion) Unmarshal 

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

func (*MetaVersion) XXX_DiscardUnknown 

func (m *MetaVersion) XXX_DiscardUnknown()

func (*MetaVersion) XXX_Marshal 

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

func (*MetaVersion) XXX_Merge 

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

func (*MetaVersion) XXX_Size 

func (m *MetaVersion) XXX_Size() int

func (*MetaVersion) XXX_Unmarshal 

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

type SerializedBlock 

type SerializedBlock struct {
	// header of block
	Header *common.BlockHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// transaction execution sequence of the block, described by DAG
	Dag *common.DAG `protobuf:"bytes,2,opt,name=dag,proto3" json:"dag,omitempty"`
	// transaction id list within the block
	TxIds []string `protobuf:"bytes,3,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
	// block additional data, not included in block hash calculation
	AdditionalData *common.AdditionalData `protobuf:"bytes,4,opt,name=additional_data,json=additionalData,proto3" json:"additional_data,omitempty"`
}

block structure used in serialization

func (*SerializedBlock) Descriptor 

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

func (*SerializedBlock) GetAdditionalData 

func (m *SerializedBlock) GetAdditionalData() *common.AdditionalData

func (*SerializedBlock) GetDag 

func (m *SerializedBlock) GetDag() *common.DAG

func (*SerializedBlock) GetHeader 

func (m *SerializedBlock) GetHeader() *common.BlockHeader

func (*SerializedBlock) GetTxIds 

func (m *SerializedBlock) GetTxIds() []string

func (*SerializedBlock) Marshal 

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

func (*SerializedBlock) MarshalTo 

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

func (*SerializedBlock) MarshalToSizedBuffer 

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

func (*SerializedBlock) ProtoMessage 

func (*SerializedBlock) ProtoMessage()

func (*SerializedBlock) Reset 

func (m *SerializedBlock) Reset()

func (*SerializedBlock) Size 

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

func (*SerializedBlock) String 

func (m *SerializedBlock) String() string

func (*SerializedBlock) Unmarshal 

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

func (*SerializedBlock) XXX_DiscardUnknown 

func (m *SerializedBlock) XXX_DiscardUnknown()

func (*SerializedBlock) XXX_Marshal 

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

func (*SerializedBlock) XXX_Merge 

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

func (*SerializedBlock) XXX_Size 

func (m *SerializedBlock) XXX_Size() int

func (*SerializedBlock) XXX_Unmarshal 

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

type StoreInfo 

type StoreInfo struct {
	//store type
	StoreType DataStoreType `protobuf:"varint,1,opt,name=store_type,json=storeType,proto3,enum=store.DataStoreType" json:"store_type,omitempty"`
	// file name
	FileName string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// offset in file
	Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// data length
	ByteLen uint64 `protobuf:"varint,4,opt,name=byte_len,json=byteLen,proto3" json:"byte_len,omitempty"`
}

store data information

func (*StoreInfo) Descriptor 

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

func (*StoreInfo) GetByteLen 

func (m *StoreInfo) GetByteLen() uint64

func (*StoreInfo) GetFileName 

func (m *StoreInfo) GetFileName() string

func (*StoreInfo) GetOffset 

func (m *StoreInfo) GetOffset() uint64

func (*StoreInfo) GetStoreType 

func (m *StoreInfo) GetStoreType() DataStoreType

func (*StoreInfo) Marshal 

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

func (*StoreInfo) MarshalTo 

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

func (*StoreInfo) MarshalToSizedBuffer 

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

func (*StoreInfo) ProtoMessage 

func (*StoreInfo) ProtoMessage()

func (*StoreInfo) Reset 

func (m *StoreInfo) Reset()

func (*StoreInfo) Size 

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

func (*StoreInfo) String 

func (m *StoreInfo) String() string

func (*StoreInfo) Unmarshal 

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

func (*StoreInfo) XXX_DiscardUnknown 

func (m *StoreInfo) XXX_DiscardUnknown()

func (*StoreInfo) XXX_Marshal 

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

func (*StoreInfo) XXX_Merge 

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

func (*StoreInfo) XXX_Size 

func (m *StoreInfo) XXX_Size() int

func (*StoreInfo) XXX_Unmarshal 

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

type StoreType added in v3.0.1 

type StoreType int32

store type 

const (
	StoreType_RawDB StoreType = 0
	StoreType_BFDB  StoreType = 1
)

func (StoreType) EnumDescriptor added in v3.0.1 

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

func (StoreType) String added in v3.0.1 

func (x StoreType) String() string

type TransactionStoreInfo 

type TransactionStoreInfo struct {
	// transaction raw data
	Transaction *common.Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	// block height
	BlockHeight uint64 `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// Deprecated, block hash
	BlockHash []byte `protobuf:"bytes,3,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	// transaction index in block
	TxIndex uint32 `protobuf:"varint,4,opt,name=tx_index,json=txIndex,proto3" json:"tx_index,omitempty"`
	// block header timestamp
	BlockTimestamp int64 `protobuf:"varint,5,opt,name=block_timestamp,json=blockTimestamp,proto3" json:"block_timestamp,omitempty"`
	// transaction offset index in file
	TransactionStoreInfo *StoreInfo `protobuf:"bytes,6,opt,name=transaction_store_info,json=transactionStoreInfo,proto3" json:"transaction_store_info,omitempty"`
}

transaction info include transaction and its block height hash and tx index

func (*TransactionStoreInfo) Descriptor 

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

func (*TransactionStoreInfo) GetBlockHash 

func (m *TransactionStoreInfo) GetBlockHash() []byte

func (*TransactionStoreInfo) GetBlockHeight 

func (m *TransactionStoreInfo) GetBlockHeight() uint64

func (*TransactionStoreInfo) GetBlockTimestamp 

func (m *TransactionStoreInfo) GetBlockTimestamp() int64

func (*TransactionStoreInfo) GetTransaction 

func (m *TransactionStoreInfo) GetTransaction() *common.Transaction

func (*TransactionStoreInfo) GetTransactionStoreInfo 

func (m *TransactionStoreInfo) GetTransactionStoreInfo() *StoreInfo

func (*TransactionStoreInfo) GetTxIndex 

func (m *TransactionStoreInfo) GetTxIndex() uint32

func (*TransactionStoreInfo) Marshal 

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

func (*TransactionStoreInfo) MarshalTo 

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

func (*TransactionStoreInfo) MarshalToSizedBuffer 

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

func (*TransactionStoreInfo) ProtoMessage 

func (*TransactionStoreInfo) ProtoMessage()

func (*TransactionStoreInfo) Reset 

func (m *TransactionStoreInfo) Reset()

func (*TransactionStoreInfo) Size 

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

func (*TransactionStoreInfo) String 

func (m *TransactionStoreInfo) String() string

func (*TransactionStoreInfo) Unmarshal 

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

func (*TransactionStoreInfo) XXX_DiscardUnknown 

func (m *TransactionStoreInfo) XXX_DiscardUnknown()

func (*TransactionStoreInfo) XXX_Marshal 

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

func (*TransactionStoreInfo) XXX_Merge 

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

func (*TransactionStoreInfo) XXX_Size 

func (m *TransactionStoreInfo) XXX_Size() int

func (*TransactionStoreInfo) XXX_Unmarshal 

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

type TxHistory 

type TxHistory struct {
	TxId        string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	BlockHeight uint64 `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	BlockHash   []byte `protobuf:"bytes,3,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	Timestamp   int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*TxHistory) Descriptor 

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

func (*TxHistory) GetBlockHash 

func (m *TxHistory) GetBlockHash() []byte

func (*TxHistory) GetBlockHeight 

func (m *TxHistory) GetBlockHeight() uint64

func (*TxHistory) GetTimestamp 

func (m *TxHistory) GetTimestamp() int64

func (*TxHistory) GetTxId 

func (m *TxHistory) GetTxId() string

func (*TxHistory) Marshal 

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

func (*TxHistory) MarshalTo 

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

func (*TxHistory) MarshalToSizedBuffer 

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

func (*TxHistory) ProtoMessage 

func (*TxHistory) ProtoMessage()

func (*TxHistory) Reset 

func (m *TxHistory) Reset()

func (*TxHistory) Size 

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

func (*TxHistory) String 

func (m *TxHistory) String() string

func (*TxHistory) Unmarshal 

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

func (*TxHistory) XXX_DiscardUnknown 

func (m *TxHistory) XXX_DiscardUnknown()

func (*TxHistory) XXX_Marshal 

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

func (*TxHistory) XXX_Merge 

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

func (*TxHistory) XXX_Size 

func (m *TxHistory) XXX_Size() int

func (*TxHistory) XXX_Unmarshal 

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