txpool

package
v1.5.1 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2022 License: Apache-2.0 Imports: 6 Imported by: 11

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 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 (*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 (*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 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 (*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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL