txpool

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: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTransactionPool        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTransactionPool          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTransactionPool = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var SignalType_name = map[int32]string{
	0: "NO_EVENT",
	1: "TRANSACTION_INCOME",
	2: "BLOCK_PROPOSE",
}
View Source 
var SignalType_value = map[string]int32{
	"NO_EVENT":           0,
	"TRANSACTION_INCOME": 1,
	"BLOCK_PROPOSE":      2,
}
View Source 
var TxPoolMsgType_name = map[int32]string{
	0: "SINGLE_TX",
	1: "BATCH_TX",
	2: "RECOVER_REQ",
	3: "RECOVER_RESP",
}
View Source 
var TxPoolMsgType_value = map[string]int32{
	"SINGLE_TX":    0,
	"BATCH_TX":     1,
	"RECOVER_REQ":  2,
	"RECOVER_RESP": 3,
}
View Source 
var TxStage_name = map[int32]string{
	0: "UNKNOWN_STAGE",
	1: "IN_QUEUE",
	2: "IN_PENDING",
	3: "ALL_STAGE",
}
View Source 
var TxStage_value = map[string]int32{
	"UNKNOWN_STAGE": 0,
	"IN_QUEUE":      1,
	"IN_PENDING":    2,
	"ALL_STAGE":     3,
}
View Source 
var TxStatus_name = map[int32]string{
	0: "UNKNOWN_STATUS",
	1: "UNPACKAGED",
	2: "PACKAGED",
	3: "COMMITTED",
	4: "TIMEOUT_REMOVED",
	5: "DOUBLE_SPEND_REMOVED",
	6: "EVIL_REMOVED",
}
View Source 
var TxStatus_value = map[string]int32{
	"UNKNOWN_STATUS":       0,
	"UNPACKAGED":           1,
	"PACKAGED":             2,
	"COMMITTED":            3,
	"TIMEOUT_REMOVED":      4,
	"DOUBLE_SPEND_REMOVED": 5,
	"EVIL_REMOVED":         6,
}
View Source 
var TxType_name = map[int32]string{
	0: "UNKNOWN_TYPE",
	1: "CONFIG_TX",
	2: "COMMON_TX",
	3: "ALL_TYPE",
}
View Source 
var TxType_value = map[string]int32{
	"UNKNOWN_TYPE": 0,
	"CONFIG_TX":    1,
	"COMMON_TX":    2,
	"ALL_TYPE":     3,
}

Functions

This section is empty.

Types

type GetPoolStatusRequest 

type GetPoolStatusRequest struct {
	// blockchain identifier
	ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
}

rpc get pool status request

func (*GetPoolStatusRequest) Descriptor 

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

func (*GetPoolStatusRequest) GetChainId 

func (m *GetPoolStatusRequest) GetChainId() string

func (*GetPoolStatusRequest) Marshal 

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

func (*GetPoolStatusRequest) MarshalTo 

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

func (*GetPoolStatusRequest) MarshalToSizedBuffer 

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

func (*GetPoolStatusRequest) ProtoMessage 

func (*GetPoolStatusRequest) ProtoMessage()

func (*GetPoolStatusRequest) Reset 

func (m *GetPoolStatusRequest) Reset()

func (*GetPoolStatusRequest) Size 

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

func (*GetPoolStatusRequest) String 

func (m *GetPoolStatusRequest) String() string

func (*GetPoolStatusRequest) Unmarshal 

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

func (*GetPoolStatusRequest) XXX_DiscardUnknown 

func (m *GetPoolStatusRequest) XXX_DiscardUnknown()

func (*GetPoolStatusRequest) XXX_Marshal 

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

func (*GetPoolStatusRequest) XXX_Merge 

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

func (*GetPoolStatusRequest) XXX_Size 

func (m *GetPoolStatusRequest) XXX_Size() int

func (*GetPoolStatusRequest) XXX_Unmarshal 

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

type GetTxIdsByTypeAndStageRequest 

type GetTxIdsByTypeAndStageRequest struct {
	// blockchain identifier
	ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// tx type
	TxType TxType `protobuf:"varint,2,opt,name=tx_type,json=txType,proto3,enum=txpool.TxType" json:"tx_type,omitempty"`
	// tx stage
	TxStage TxStage `protobuf:"varint,3,opt,name=tx_stage,json=txStage,proto3,enum=txpool.TxStage" json:"tx_stage,omitempty"`
}

rpc get tx ids by type and stage request

func (*GetTxIdsByTypeAndStageRequest) Descriptor 

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

func (*GetTxIdsByTypeAndStageRequest) GetChainId 

func (m *GetTxIdsByTypeAndStageRequest) GetChainId() string

func (*GetTxIdsByTypeAndStageRequest) GetTxStage 

func (m *GetTxIdsByTypeAndStageRequest) GetTxStage() TxStage

func (*GetTxIdsByTypeAndStageRequest) GetTxType 

func (m *GetTxIdsByTypeAndStageRequest) GetTxType() TxType

func (*GetTxIdsByTypeAndStageRequest) Marshal 

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

func (*GetTxIdsByTypeAndStageRequest) MarshalTo 

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

func (*GetTxIdsByTypeAndStageRequest) MarshalToSizedBuffer 

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

func (*GetTxIdsByTypeAndStageRequest) ProtoMessage 

func (*GetTxIdsByTypeAndStageRequest) ProtoMessage()

func (*GetTxIdsByTypeAndStageRequest) Reset 

func (m *GetTxIdsByTypeAndStageRequest) Reset()

func (*GetTxIdsByTypeAndStageRequest) Size 

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

func (*GetTxIdsByTypeAndStageRequest) String 

func (m *GetTxIdsByTypeAndStageRequest) String() string

func (*GetTxIdsByTypeAndStageRequest) Unmarshal 

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

func (*GetTxIdsByTypeAndStageRequest) XXX_DiscardUnknown 

func (m *GetTxIdsByTypeAndStageRequest) XXX_DiscardUnknown()

func (*GetTxIdsByTypeAndStageRequest) XXX_Marshal 

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

func (*GetTxIdsByTypeAndStageRequest) XXX_Merge 

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

func (*GetTxIdsByTypeAndStageRequest) XXX_Size 

func (m *GetTxIdsByTypeAndStageRequest) XXX_Size() int

func (*GetTxIdsByTypeAndStageRequest) XXX_Unmarshal 

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

type GetTxIdsByTypeAndStageResponse 

type GetTxIdsByTypeAndStageResponse struct {
	// tx id list
	TxIds []string `protobuf:"bytes,1,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
}

rpc get tx ids by type and stage response

func (*GetTxIdsByTypeAndStageResponse) Descriptor 

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

func (*GetTxIdsByTypeAndStageResponse) GetTxIds 

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

func (*GetTxIdsByTypeAndStageResponse) Marshal 

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

func (*GetTxIdsByTypeAndStageResponse) MarshalTo 

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

func (*GetTxIdsByTypeAndStageResponse) MarshalToSizedBuffer 

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

func (*GetTxIdsByTypeAndStageResponse) ProtoMessage 

func (*GetTxIdsByTypeAndStageResponse) ProtoMessage()

func (*GetTxIdsByTypeAndStageResponse) Reset 

func (m *GetTxIdsByTypeAndStageResponse) Reset()

func (*GetTxIdsByTypeAndStageResponse) Size 

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

func (*GetTxIdsByTypeAndStageResponse) String 

func (m *GetTxIdsByTypeAndStageResponse) String() string

func (*GetTxIdsByTypeAndStageResponse) Unmarshal 

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

func (*GetTxIdsByTypeAndStageResponse) XXX_DiscardUnknown 

func (m *GetTxIdsByTypeAndStageResponse) XXX_DiscardUnknown()

func (*GetTxIdsByTypeAndStageResponse) XXX_Marshal 

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

func (*GetTxIdsByTypeAndStageResponse) XXX_Merge 

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

func (*GetTxIdsByTypeAndStageResponse) XXX_Size 

func (m *GetTxIdsByTypeAndStageResponse) XXX_Size() int

func (*GetTxIdsByTypeAndStageResponse) XXX_Unmarshal 

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

type GetTxStatusRequest 

type GetTxStatusRequest struct {
	// blockchain identifier
	ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// tx id
	TxId string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
}

rpc get tx status in pool by txId request

func (*GetTxStatusRequest) Descriptor 

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

func (*GetTxStatusRequest) GetChainId 

func (m *GetTxStatusRequest) GetChainId() string

func (*GetTxStatusRequest) GetTxId 

func (m *GetTxStatusRequest) GetTxId() string

func (*GetTxStatusRequest) Marshal 

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

func (*GetTxStatusRequest) MarshalTo 

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

func (*GetTxStatusRequest) MarshalToSizedBuffer 

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

func (*GetTxStatusRequest) ProtoMessage 

func (*GetTxStatusRequest) ProtoMessage()

func (*GetTxStatusRequest) Reset 

func (m *GetTxStatusRequest) Reset()

func (*GetTxStatusRequest) Size 

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

func (*GetTxStatusRequest) String 

func (m *GetTxStatusRequest) String() string

func (*GetTxStatusRequest) Unmarshal 

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

func (*GetTxStatusRequest) XXX_DiscardUnknown 

func (m *GetTxStatusRequest) XXX_DiscardUnknown()

func (*GetTxStatusRequest) XXX_Marshal 

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

func (*GetTxStatusRequest) XXX_Merge 

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

func (*GetTxStatusRequest) XXX_Size 

func (m *GetTxStatusRequest) XXX_Size() int

func (*GetTxStatusRequest) XXX_Unmarshal 

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

type GetTxStatusResponse 

type GetTxStatusResponse struct {
	// tx status
	TxStatus TxStatus `protobuf:"varint,1,opt,name=tx_status,json=txStatus,proto3,enum=txpool.TxStatus" json:"tx_status,omitempty"`
	// chainId
	TxId string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
}

rpc get tx status in pool by txId response

func (*GetTxStatusResponse) Descriptor 

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

func (*GetTxStatusResponse) GetTxId 

func (m *GetTxStatusResponse) GetTxId() string

func (*GetTxStatusResponse) GetTxStatus 

func (m *GetTxStatusResponse) GetTxStatus() TxStatus

func (*GetTxStatusResponse) Marshal 

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

func (*GetTxStatusResponse) MarshalTo 

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

func (*GetTxStatusResponse) MarshalToSizedBuffer 

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

func (*GetTxStatusResponse) ProtoMessage 

func (*GetTxStatusResponse) ProtoMessage()

func (*GetTxStatusResponse) Reset 

func (m *GetTxStatusResponse) Reset()

func (*GetTxStatusResponse) Size 

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

func (*GetTxStatusResponse) String 

func (m *GetTxStatusResponse) String() string

func (*GetTxStatusResponse) Unmarshal 

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

func (*GetTxStatusResponse) XXX_DiscardUnknown 

func (m *GetTxStatusResponse) XXX_DiscardUnknown()

func (*GetTxStatusResponse) XXX_Marshal 

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

func (*GetTxStatusResponse) XXX_Merge 

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

func (*GetTxStatusResponse) XXX_Size 

func (m *GetTxStatusResponse) XXX_Size() int

func (*GetTxStatusResponse) XXX_Unmarshal 

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

type GetTxsInPoolByTxIdsRequest 

type GetTxsInPoolByTxIdsRequest struct {
	// blockchain identifier
	ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// tx id list
	TxIds []string `protobuf:"bytes,2,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
}

rpc get txs in pool by tx ids request

func (*GetTxsInPoolByTxIdsRequest) Descriptor 

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

func (*GetTxsInPoolByTxIdsRequest) GetChainId 

func (m *GetTxsInPoolByTxIdsRequest) GetChainId() string

func (*GetTxsInPoolByTxIdsRequest) GetTxIds 

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

func (*GetTxsInPoolByTxIdsRequest) Marshal 

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

func (*GetTxsInPoolByTxIdsRequest) MarshalTo 

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

func (*GetTxsInPoolByTxIdsRequest) MarshalToSizedBuffer 

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

func (*GetTxsInPoolByTxIdsRequest) ProtoMessage 

func (*GetTxsInPoolByTxIdsRequest) ProtoMessage()

func (*GetTxsInPoolByTxIdsRequest) Reset 

func (m *GetTxsInPoolByTxIdsRequest) Reset()

func (*GetTxsInPoolByTxIdsRequest) Size 

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

func (*GetTxsInPoolByTxIdsRequest) String 

func (m *GetTxsInPoolByTxIdsRequest) String() string

func (*GetTxsInPoolByTxIdsRequest) Unmarshal 

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

func (*GetTxsInPoolByTxIdsRequest) XXX_DiscardUnknown 

func (m *GetTxsInPoolByTxIdsRequest) XXX_DiscardUnknown()

func (*GetTxsInPoolByTxIdsRequest) XXX_Marshal 

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

func (*GetTxsInPoolByTxIdsRequest) XXX_Merge 

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

func (*GetTxsInPoolByTxIdsRequest) XXX_Size 

func (m *GetTxsInPoolByTxIdsRequest) XXX_Size() int

func (*GetTxsInPoolByTxIdsRequest) XXX_Unmarshal 

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

type GetTxsInPoolByTxIdsResponse 

type GetTxsInPoolByTxIdsResponse struct {
	// txs in the tx pool
	Txs []*common.Transaction `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
	// tx ids of txs that are not in the tx pool
	TxIds []string `protobuf:"bytes,2,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
}

rpc get txs in pool by tx ids response

func (*GetTxsInPoolByTxIdsResponse) Descriptor 

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

func (*GetTxsInPoolByTxIdsResponse) GetTxIds 

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

func (*GetTxsInPoolByTxIdsResponse) GetTxs 

func (m *GetTxsInPoolByTxIdsResponse) GetTxs() []*common.Transaction

func (*GetTxsInPoolByTxIdsResponse) Marshal 

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

func (*GetTxsInPoolByTxIdsResponse) MarshalTo 

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

func (*GetTxsInPoolByTxIdsResponse) MarshalToSizedBuffer 

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

func (*GetTxsInPoolByTxIdsResponse) ProtoMessage 

func (*GetTxsInPoolByTxIdsResponse) ProtoMessage()

func (*GetTxsInPoolByTxIdsResponse) Reset 

func (m *GetTxsInPoolByTxIdsResponse) Reset()

func (*GetTxsInPoolByTxIdsResponse) Size 

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

func (*GetTxsInPoolByTxIdsResponse) String 

func (m *GetTxsInPoolByTxIdsResponse) String() string

func (*GetTxsInPoolByTxIdsResponse) Unmarshal 

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

func (*GetTxsInPoolByTxIdsResponse) XXX_DiscardUnknown 

func (m *GetTxsInPoolByTxIdsResponse) XXX_DiscardUnknown()

func (*GetTxsInPoolByTxIdsResponse) XXX_Marshal 

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

func (*GetTxsInPoolByTxIdsResponse) XXX_Merge 

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

func (*GetTxsInPoolByTxIdsResponse) XXX_Size 

func (m *GetTxsInPoolByTxIdsResponse) XXX_Size() int

func (*GetTxsInPoolByTxIdsResponse) XXX_Unmarshal 

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

type SignalType 

type SignalType int32

SignalType is a transaction event type 

const (
	// no transaction
	SignalType_NO_EVENT SignalType = 0
	// new transaction
	SignalType_TRANSACTION_INCOME SignalType = 1
	// packing block
	SignalType_BLOCK_PROPOSE SignalType = 2
)

func (SignalType) EnumDescriptor 

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

func (SignalType) String 

func (x SignalType) String() string

type TxBatch 

type TxBatch struct {
	// batch id = timestamp(8byte)+nodeId(8byte)+batchHash(8byte)
	BatchId string `protobuf:"bytes,1,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	// batch size
	Size_ int32 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// transaction list
	Txs []*common.Transaction `protobuf:"bytes,4,rep,name=txs,proto3" json:"txs,omitempty"`
	// Map: transaction ID mapping record( key: transaction ID, value: transaction index in txs)
	TxIdsMap map[string]int32 `` /* 176-byte string literal not displayed */
	// batch signature
	Endorsement *common.EndorsementEntry `protobuf:"bytes,6,opt,name=endorsement,proto3" json:"endorsement,omitempty"`
}

transaction batch, used to add transaction efficiently in normal and batch txPool

func (*TxBatch) Descriptor 

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

func (*TxBatch) GetBatchId 

func (m *TxBatch) GetBatchId() string

func (*TxBatch) GetEndorsement 

func (m *TxBatch) GetEndorsement() *common.EndorsementEntry

func (*TxBatch) GetSize_ 

func (m *TxBatch) GetSize_() int32

func (*TxBatch) GetTxIdsMap 

func (m *TxBatch) GetTxIdsMap() map[string]int32

func (*TxBatch) GetTxs 

func (m *TxBatch) GetTxs() []*common.Transaction

func (*TxBatch) Marshal 

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

func (*TxBatch) MarshalTo 

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

func (*TxBatch) MarshalToSizedBuffer 

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

func (*TxBatch) ProtoMessage 

func (*TxBatch) ProtoMessage()

func (*TxBatch) Reset 

func (m *TxBatch) Reset()

func (*TxBatch) Size 

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

func (*TxBatch) String 

func (m *TxBatch) String() string

func (*TxBatch) Unmarshal 

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

func (*TxBatch) XXX_DiscardUnknown 

func (m *TxBatch) XXX_DiscardUnknown()

func (*TxBatch) XXX_Marshal 

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

func (*TxBatch) XXX_Merge 

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

func (*TxBatch) XXX_Size 

func (m *TxBatch) XXX_Size() int

func (*TxBatch) XXX_Unmarshal 

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

type TxBatchRecoverRequest 

type TxBatchRecoverRequest struct {
	// proposer node id
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// height
	Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// batchId list
	BatchIds []string `protobuf:"bytes,3,rep,name=batch_ids,json=batchIds,proto3" json:"batch_ids,omitempty"`
}

batch recover request, used to request batch from proposer

func (*TxBatchRecoverRequest) Descriptor 

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

func (*TxBatchRecoverRequest) GetBatchIds 

func (m *TxBatchRecoverRequest) GetBatchIds() []string

func (*TxBatchRecoverRequest) GetHeight 

func (m *TxBatchRecoverRequest) GetHeight() uint64

func (*TxBatchRecoverRequest) GetNodeId 

func (m *TxBatchRecoverRequest) GetNodeId() string

func (*TxBatchRecoverRequest) Marshal 

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

func (*TxBatchRecoverRequest) MarshalTo 

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

func (*TxBatchRecoverRequest) MarshalToSizedBuffer 

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

func (*TxBatchRecoverRequest) ProtoMessage 

func (*TxBatchRecoverRequest) ProtoMessage()

func (*TxBatchRecoverRequest) Reset 

func (m *TxBatchRecoverRequest) Reset()

func (*TxBatchRecoverRequest) Size 

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

func (*TxBatchRecoverRequest) String 

func (m *TxBatchRecoverRequest) String() string

func (*TxBatchRecoverRequest) Unmarshal 

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

func (*TxBatchRecoverRequest) XXX_DiscardUnknown 

func (m *TxBatchRecoverRequest) XXX_DiscardUnknown()

func (*TxBatchRecoverRequest) XXX_Marshal 

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

func (*TxBatchRecoverRequest) XXX_Merge 

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

func (*TxBatchRecoverRequest) XXX_Size 

func (m *TxBatchRecoverRequest) XXX_Size() int

func (*TxBatchRecoverRequest) XXX_Unmarshal 

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

type TxBatchRecoverResponse 

type TxBatchRecoverResponse struct {
	// node id
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// height
	Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// batch list
	TxBatches []*TxBatch `protobuf:"bytes,3,rep,name=tx_batches,json=txBatches,proto3" json:"tx_batches,omitempty"`
}

batch recover response, used to return transactions to the validators by proposer

func (*TxBatchRecoverResponse) Descriptor 

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

func (*TxBatchRecoverResponse) GetHeight 

func (m *TxBatchRecoverResponse) GetHeight() uint64

func (*TxBatchRecoverResponse) GetNodeId 

func (m *TxBatchRecoverResponse) GetNodeId() string

func (*TxBatchRecoverResponse) GetTxBatches 

func (m *TxBatchRecoverResponse) GetTxBatches() []*TxBatch

func (*TxBatchRecoverResponse) Marshal 

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

func (*TxBatchRecoverResponse) MarshalTo 

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

func (*TxBatchRecoverResponse) MarshalToSizedBuffer 

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

func (*TxBatchRecoverResponse) ProtoMessage 

func (*TxBatchRecoverResponse) ProtoMessage()

func (*TxBatchRecoverResponse) Reset 

func (m *TxBatchRecoverResponse) Reset()

func (*TxBatchRecoverResponse) Size 

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

func (*TxBatchRecoverResponse) String 

func (m *TxBatchRecoverResponse) String() string

func (*TxBatchRecoverResponse) Unmarshal 

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

func (*TxBatchRecoverResponse) XXX_DiscardUnknown 

func (m *TxBatchRecoverResponse) XXX_DiscardUnknown()

func (*TxBatchRecoverResponse) XXX_Marshal 

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

func (*TxBatchRecoverResponse) XXX_Merge 

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

func (*TxBatchRecoverResponse) XXX_Size 

func (m *TxBatchRecoverResponse) XXX_Size() int

func (*TxBatchRecoverResponse) XXX_Unmarshal 

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

type TxPoolMsg 

type TxPoolMsg struct {
	// txPool message type
	Type TxPoolMsgType `protobuf:"varint,1,opt,name=type,proto3,enum=txpool.TxPoolMsgType" json:"type,omitempty"`
	// message bytes
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

TxPoolMsg contains all txPool msg type and msg body

func (*TxPoolMsg) Descriptor 

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

func (*TxPoolMsg) GetPayload 

func (m *TxPoolMsg) GetPayload() []byte

func (*TxPoolMsg) GetType 

func (m *TxPoolMsg) GetType() TxPoolMsgType

func (*TxPoolMsg) Marshal 

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

func (*TxPoolMsg) MarshalTo 

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

func (*TxPoolMsg) MarshalToSizedBuffer 

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

func (*TxPoolMsg) ProtoMessage 

func (*TxPoolMsg) ProtoMessage()

func (*TxPoolMsg) Reset 

func (m *TxPoolMsg) Reset()

func (*TxPoolMsg) Size 

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

func (*TxPoolMsg) String 

func (m *TxPoolMsg) String() string

func (*TxPoolMsg) Unmarshal 

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

func (*TxPoolMsg) XXX_DiscardUnknown 

func (m *TxPoolMsg) XXX_DiscardUnknown()

func (*TxPoolMsg) XXX_Marshal 

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

func (*TxPoolMsg) XXX_Merge 

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

func (*TxPoolMsg) XXX_Size 

func (m *TxPoolMsg) XXX_Size() int

func (*TxPoolMsg) XXX_Unmarshal 

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

type TxPoolMsgType 

type TxPoolMsgType int32

TxPoolMsgType defines different type message in txPool 

const (
	// single transaction type
	TxPoolMsgType_SINGLE_TX TxPoolMsgType = 0
	// batch transaction type
	TxPoolMsgType_BATCH_TX TxPoolMsgType = 1
	// transaction recover request type
	TxPoolMsgType_RECOVER_REQ TxPoolMsgType = 2
	// transaction recover response type
	TxPoolMsgType_RECOVER_RESP TxPoolMsgType = 3
)

func (TxPoolMsgType) EnumDescriptor 

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

func (TxPoolMsgType) String 

func (x TxPoolMsgType) String() string

type TxPoolSignal 

type TxPoolSignal struct {
	// transaction event type
	SignalType SignalType `protobuf:"varint,1,opt,name=signal_type,json=signalType,proto3,enum=txpool.SignalType" json:"signal_type,omitempty"`
	// chainId
	ChainId string `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
}

TxPoolSignal is used by tx pool to send signal to block proposer

func (*TxPoolSignal) Descriptor 

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

func (*TxPoolSignal) GetChainId 

func (m *TxPoolSignal) GetChainId() string

func (*TxPoolSignal) GetSignalType 

func (m *TxPoolSignal) GetSignalType() SignalType

func (*TxPoolSignal) Marshal 

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

func (*TxPoolSignal) MarshalTo 

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

func (*TxPoolSignal) MarshalToSizedBuffer 

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

func (*TxPoolSignal) ProtoMessage 

func (*TxPoolSignal) ProtoMessage()

func (*TxPoolSignal) Reset 

func (m *TxPoolSignal) Reset()

func (*TxPoolSignal) Size 

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

func (*TxPoolSignal) String 

func (m *TxPoolSignal) String() string

func (*TxPoolSignal) Unmarshal 

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

func (*TxPoolSignal) XXX_DiscardUnknown 

func (m *TxPoolSignal) XXX_DiscardUnknown()

func (*TxPoolSignal) XXX_Marshal 

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

func (*TxPoolSignal) XXX_Merge 

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

func (*TxPoolSignal) XXX_Size 

func (m *TxPoolSignal) XXX_Size() int

func (*TxPoolSignal) XXX_Unmarshal 

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

type TxPoolStatus 

type TxPoolStatus struct {
	// the max size of config tx pool
	ConfigTxPoolSize int32 `protobuf:"varint,1,opt,name=config_tx_pool_size,json=configTxPoolSize,proto3" json:"config_tx_pool_size,omitempty"`
	// the max size of common tx pool
	CommonTxPoolSize int32 `protobuf:"varint,2,opt,name=common_tx_pool_size,json=commonTxPoolSize,proto3" json:"common_tx_pool_size,omitempty"`
	// the num of config tx in queue cache
	ConfigTxNumInQueue int32 `protobuf:"varint,3,opt,name=config_tx_num_in_queue,json=configTxNumInQueue,proto3" json:"config_tx_num_in_queue,omitempty"`
	// the num of config tx in pending cache
	ConfigTxNumInPending int32 `` /* 128-byte string literal not displayed */
	// the num of common tx in queue cache
	CommonTxNumInQueue int32 `protobuf:"varint,5,opt,name=common_tx_num_in_queue,json=commonTxNumInQueue,proto3" json:"common_tx_num_in_queue,omitempty"`
	// the num of common tx in pending cache
	CommonTxNumInPending int32 `` /* 128-byte string literal not displayed */
}

TxPoolStatus defines txPool status

func (*TxPoolStatus) Descriptor 

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

func (*TxPoolStatus) GetCommonTxNumInPending 

func (m *TxPoolStatus) GetCommonTxNumInPending() int32

func (*TxPoolStatus) GetCommonTxNumInQueue 

func (m *TxPoolStatus) GetCommonTxNumInQueue() int32

func (*TxPoolStatus) GetCommonTxPoolSize 

func (m *TxPoolStatus) GetCommonTxPoolSize() int32

func (*TxPoolStatus) GetConfigTxNumInPending 

func (m *TxPoolStatus) GetConfigTxNumInPending() int32

func (*TxPoolStatus) GetConfigTxNumInQueue 

func (m *TxPoolStatus) GetConfigTxNumInQueue() int32

func (*TxPoolStatus) GetConfigTxPoolSize 

func (m *TxPoolStatus) GetConfigTxPoolSize() int32

func (*TxPoolStatus) Marshal 

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

func (*TxPoolStatus) MarshalTo 

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

func (*TxPoolStatus) MarshalToSizedBuffer 

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

func (*TxPoolStatus) ProtoMessage 

func (*TxPoolStatus) ProtoMessage()

func (*TxPoolStatus) Reset 

func (m *TxPoolStatus) Reset()

func (*TxPoolStatus) Size 

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

func (*TxPoolStatus) String 

func (m *TxPoolStatus) String() string

func (*TxPoolStatus) Unmarshal 

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

func (*TxPoolStatus) XXX_DiscardUnknown 

func (m *TxPoolStatus) XXX_DiscardUnknown()

func (*TxPoolStatus) XXX_Marshal 

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

func (*TxPoolStatus) XXX_Merge 

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

func (*TxPoolStatus) XXX_Size 

func (m *TxPoolStatus) XXX_Size() int

func (*TxPoolStatus) XXX_Unmarshal 

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

type TxRecoverRequest 

type TxRecoverRequest struct {
	// node id
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// height
	Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// txId list
	TxIds []string `protobuf:"bytes,3,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
}

transaction recover request, used to request transactions from proposer

func (*TxRecoverRequest) Descriptor 

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

func (*TxRecoverRequest) GetHeight 

func (m *TxRecoverRequest) GetHeight() uint64

func (*TxRecoverRequest) GetNodeId 

func (m *TxRecoverRequest) GetNodeId() string

func (*TxRecoverRequest) GetTxIds 

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

func (*TxRecoverRequest) Marshal 

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

func (*TxRecoverRequest) MarshalTo 

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

func (*TxRecoverRequest) MarshalToSizedBuffer 

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

func (*TxRecoverRequest) ProtoMessage 

func (*TxRecoverRequest) ProtoMessage()

func (*TxRecoverRequest) Reset 

func (m *TxRecoverRequest) Reset()

func (*TxRecoverRequest) Size 

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

func (*TxRecoverRequest) String 

func (m *TxRecoverRequest) String() string

func (*TxRecoverRequest) Unmarshal 

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

func (*TxRecoverRequest) XXX_DiscardUnknown 

func (m *TxRecoverRequest) XXX_DiscardUnknown()

func (*TxRecoverRequest) XXX_Marshal 

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

func (*TxRecoverRequest) XXX_Merge 

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

func (*TxRecoverRequest) XXX_Size 

func (m *TxRecoverRequest) XXX_Size() int

func (*TxRecoverRequest) XXX_Unmarshal 

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

type TxRecoverResponse 

type TxRecoverResponse struct {
	// node id
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// height
	Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// tx list
	Txs []*common.Transaction `protobuf:"bytes,3,rep,name=txs,proto3" json:"txs,omitempty"`
}

transaction recover response, used to return transactions to the validators by proposer

func (*TxRecoverResponse) Descriptor 

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

func (*TxRecoverResponse) GetHeight 

func (m *TxRecoverResponse) GetHeight() uint64

func (*TxRecoverResponse) GetNodeId 

func (m *TxRecoverResponse) GetNodeId() string

func (*TxRecoverResponse) GetTxs 

func (m *TxRecoverResponse) GetTxs() []*common.Transaction

func (*TxRecoverResponse) Marshal 

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

func (*TxRecoverResponse) MarshalTo 

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

func (*TxRecoverResponse) MarshalToSizedBuffer 

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

func (*TxRecoverResponse) ProtoMessage 

func (*TxRecoverResponse) ProtoMessage()

func (*TxRecoverResponse) Reset 

func (m *TxRecoverResponse) Reset()

func (*TxRecoverResponse) Size 

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

func (*TxRecoverResponse) String 

func (m *TxRecoverResponse) String() string

func (*TxRecoverResponse) Unmarshal 

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

func (*TxRecoverResponse) XXX_DiscardUnknown 

func (m *TxRecoverResponse) XXX_DiscardUnknown()

func (*TxRecoverResponse) XXX_Marshal 

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

func (*TxRecoverResponse) XXX_Merge 

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

func (*TxRecoverResponse) XXX_Size 

func (m *TxRecoverResponse) XXX_Size() int

func (*TxRecoverResponse) XXX_Unmarshal 

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

type TxStage 

type TxStage int32

TxStage is the current transaction stage 

const (
	// unknown
	TxStage_UNKNOWN_STAGE TxStage = 0
	//  in queue
	TxStage_IN_QUEUE TxStage = 1
	// in pending
	TxStage_IN_PENDING TxStage = 2
	// in queue and in pending
	TxStage_ALL_STAGE TxStage = 3
)

func (TxStage) EnumDescriptor 

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

func (TxStage) String 

func (x TxStage) String() string

type TxStatus 

type TxStatus int32

TxStage is the current transaction stage 

const (
	// unknown
	TxStatus_UNKNOWN_STATUS TxStatus = 0
	// transaction is unpackaged, it is in the queue of pool
	TxStatus_UNPACKAGED TxStatus = 1
	// transaction is packaged, it is in the pending of pool
	TxStatus_PACKAGED TxStatus = 2
	// transaction has been committed to chain, it is in the db
	TxStatus_COMMITTED TxStatus = 3
	// transaction is timeout and removed from pool
	TxStatus_TIMEOUT_REMOVED TxStatus = 4
	// transaction is double spend, there is a same transaction has exist in db
	TxStatus_DOUBLE_SPEND_REMOVED TxStatus = 5
	// transaction is evil, such as rwset is inconsistent in different node, and removed from pool
	TxStatus_EVIL_REMOVED TxStatus = 6
)

func (TxStatus) EnumDescriptor 

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

func (TxStatus) String 

func (x TxStatus) String() string

type TxType 

type TxType int32

TxType is the transaction type 

const (
	// unknown
	TxType_UNKNOWN_TYPE TxType = 0
	// config transaction
	TxType_CONFIG_TX TxType = 1
	// common transaction
	TxType_COMMON_TX TxType = 2
	// config and common transaction
	TxType_ALL_TYPE TxType = 3
)

func (TxType) EnumDescriptor 

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

func (TxType) String 

func (x TxType) String() string

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.