Versions in this module Expand all Collapse all v3 v3.0.1 Dec 25, 2023 v3.0.0 Dec 23, 2022 Changes in this version + var ErrIntOverflowTransactionPool = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTransactionPool = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupTransactionPool = fmt.Errorf("proto: unexpected end of group") + var SignalType_name = map[int32]string + var SignalType_value = map[string]int32 + var TxPoolMsgType_name = map[int32]string + var TxPoolMsgType_value = map[string]int32 + var TxStage_name = map[int32]string + var TxStage_value = map[string]int32 + var TxStatus_name = map[int32]string + var TxStatus_value = map[string]int32 + var TxType_name = map[int32]string + var TxType_value = map[string]int32 + type GetPoolStatusRequest struct + ChainId string + func (*GetPoolStatusRequest) Descriptor() ([]byte, []int) + func (*GetPoolStatusRequest) ProtoMessage() + func (m *GetPoolStatusRequest) GetChainId() string + func (m *GetPoolStatusRequest) Marshal() (dAtA []byte, err error) + func (m *GetPoolStatusRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetPoolStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetPoolStatusRequest) Reset() + func (m *GetPoolStatusRequest) Size() (n int) + func (m *GetPoolStatusRequest) String() string + func (m *GetPoolStatusRequest) Unmarshal(dAtA []byte) error + func (m *GetPoolStatusRequest) XXX_DiscardUnknown() + func (m *GetPoolStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPoolStatusRequest) XXX_Merge(src proto.Message) + func (m *GetPoolStatusRequest) XXX_Size() int + func (m *GetPoolStatusRequest) XXX_Unmarshal(b []byte) error + type GetTxIdsByTypeAndStageRequest struct + ChainId string + TxStage TxStage + TxType TxType + func (*GetTxIdsByTypeAndStageRequest) Descriptor() ([]byte, []int) + func (*GetTxIdsByTypeAndStageRequest) ProtoMessage() + func (m *GetTxIdsByTypeAndStageRequest) GetChainId() string + func (m *GetTxIdsByTypeAndStageRequest) GetTxStage() TxStage + func (m *GetTxIdsByTypeAndStageRequest) GetTxType() TxType + func (m *GetTxIdsByTypeAndStageRequest) Marshal() (dAtA []byte, err error) + func (m *GetTxIdsByTypeAndStageRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetTxIdsByTypeAndStageRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetTxIdsByTypeAndStageRequest) Reset() + func (m *GetTxIdsByTypeAndStageRequest) Size() (n int) + func (m *GetTxIdsByTypeAndStageRequest) String() string + func (m *GetTxIdsByTypeAndStageRequest) Unmarshal(dAtA []byte) error + func (m *GetTxIdsByTypeAndStageRequest) XXX_DiscardUnknown() + func (m *GetTxIdsByTypeAndStageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetTxIdsByTypeAndStageRequest) XXX_Merge(src proto.Message) + func (m *GetTxIdsByTypeAndStageRequest) XXX_Size() int + func (m *GetTxIdsByTypeAndStageRequest) XXX_Unmarshal(b []byte) error + type GetTxIdsByTypeAndStageResponse struct + TxIds []string + func (*GetTxIdsByTypeAndStageResponse) Descriptor() ([]byte, []int) + func (*GetTxIdsByTypeAndStageResponse) ProtoMessage() + func (m *GetTxIdsByTypeAndStageResponse) GetTxIds() []string + func (m *GetTxIdsByTypeAndStageResponse) Marshal() (dAtA []byte, err error) + func (m *GetTxIdsByTypeAndStageResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetTxIdsByTypeAndStageResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetTxIdsByTypeAndStageResponse) Reset() + func (m *GetTxIdsByTypeAndStageResponse) Size() (n int) + func (m *GetTxIdsByTypeAndStageResponse) String() string + func (m *GetTxIdsByTypeAndStageResponse) Unmarshal(dAtA []byte) error + func (m *GetTxIdsByTypeAndStageResponse) XXX_DiscardUnknown() + func (m *GetTxIdsByTypeAndStageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetTxIdsByTypeAndStageResponse) XXX_Merge(src proto.Message) + func (m *GetTxIdsByTypeAndStageResponse) XXX_Size() int + func (m *GetTxIdsByTypeAndStageResponse) XXX_Unmarshal(b []byte) error + type GetTxStatusRequest struct + ChainId string + TxId string + func (*GetTxStatusRequest) Descriptor() ([]byte, []int) + func (*GetTxStatusRequest) ProtoMessage() + func (m *GetTxStatusRequest) GetChainId() string + func (m *GetTxStatusRequest) GetTxId() string + func (m *GetTxStatusRequest) Marshal() (dAtA []byte, err error) + func (m *GetTxStatusRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetTxStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetTxStatusRequest) Reset() + func (m *GetTxStatusRequest) Size() (n int) + func (m *GetTxStatusRequest) String() string + func (m *GetTxStatusRequest) Unmarshal(dAtA []byte) error + func (m *GetTxStatusRequest) XXX_DiscardUnknown() + func (m *GetTxStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetTxStatusRequest) XXX_Merge(src proto.Message) + func (m *GetTxStatusRequest) XXX_Size() int + func (m *GetTxStatusRequest) XXX_Unmarshal(b []byte) error + type GetTxStatusResponse struct + TxId string + TxStatus TxStatus + func (*GetTxStatusResponse) Descriptor() ([]byte, []int) + func (*GetTxStatusResponse) ProtoMessage() + func (m *GetTxStatusResponse) GetTxId() string + func (m *GetTxStatusResponse) GetTxStatus() TxStatus + func (m *GetTxStatusResponse) Marshal() (dAtA []byte, err error) + func (m *GetTxStatusResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetTxStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetTxStatusResponse) Reset() + func (m *GetTxStatusResponse) Size() (n int) + func (m *GetTxStatusResponse) String() string + func (m *GetTxStatusResponse) Unmarshal(dAtA []byte) error + func (m *GetTxStatusResponse) XXX_DiscardUnknown() + func (m *GetTxStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetTxStatusResponse) XXX_Merge(src proto.Message) + func (m *GetTxStatusResponse) XXX_Size() int + func (m *GetTxStatusResponse) XXX_Unmarshal(b []byte) error + type GetTxsInPoolByTxIdsRequest struct + ChainId string + TxIds []string + func (*GetTxsInPoolByTxIdsRequest) Descriptor() ([]byte, []int) + func (*GetTxsInPoolByTxIdsRequest) ProtoMessage() + func (m *GetTxsInPoolByTxIdsRequest) GetChainId() string + func (m *GetTxsInPoolByTxIdsRequest) GetTxIds() []string + func (m *GetTxsInPoolByTxIdsRequest) Marshal() (dAtA []byte, err error) + func (m *GetTxsInPoolByTxIdsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetTxsInPoolByTxIdsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetTxsInPoolByTxIdsRequest) Reset() + func (m *GetTxsInPoolByTxIdsRequest) Size() (n int) + func (m *GetTxsInPoolByTxIdsRequest) String() string + func (m *GetTxsInPoolByTxIdsRequest) Unmarshal(dAtA []byte) error + func (m *GetTxsInPoolByTxIdsRequest) XXX_DiscardUnknown() + func (m *GetTxsInPoolByTxIdsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetTxsInPoolByTxIdsRequest) XXX_Merge(src proto.Message) + func (m *GetTxsInPoolByTxIdsRequest) XXX_Size() int + func (m *GetTxsInPoolByTxIdsRequest) XXX_Unmarshal(b []byte) error + type GetTxsInPoolByTxIdsResponse struct + TxIds []string + Txs []*common.Transaction + func (*GetTxsInPoolByTxIdsResponse) Descriptor() ([]byte, []int) + func (*GetTxsInPoolByTxIdsResponse) ProtoMessage() + func (m *GetTxsInPoolByTxIdsResponse) GetTxIds() []string + func (m *GetTxsInPoolByTxIdsResponse) GetTxs() []*common.Transaction + func (m *GetTxsInPoolByTxIdsResponse) Marshal() (dAtA []byte, err error) + func (m *GetTxsInPoolByTxIdsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetTxsInPoolByTxIdsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetTxsInPoolByTxIdsResponse) Reset() + func (m *GetTxsInPoolByTxIdsResponse) Size() (n int) + func (m *GetTxsInPoolByTxIdsResponse) String() string + func (m *GetTxsInPoolByTxIdsResponse) Unmarshal(dAtA []byte) error + func (m *GetTxsInPoolByTxIdsResponse) XXX_DiscardUnknown() + func (m *GetTxsInPoolByTxIdsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetTxsInPoolByTxIdsResponse) XXX_Merge(src proto.Message) + func (m *GetTxsInPoolByTxIdsResponse) XXX_Size() int + func (m *GetTxsInPoolByTxIdsResponse) XXX_Unmarshal(b []byte) error + type SignalType int32 + const SignalType_BLOCK_PROPOSE + const SignalType_NO_EVENT + const SignalType_TRANSACTION_INCOME + func (SignalType) EnumDescriptor() ([]byte, []int) + func (x SignalType) String() string + type TxBatch struct + BatchId string + Endorsement *common.EndorsementEntry + Size_ int32 + TxIdsMap map[string]int32 + Txs []*common.Transaction + func (*TxBatch) Descriptor() ([]byte, []int) + func (*TxBatch) ProtoMessage() + func (m *TxBatch) GetBatchId() string + func (m *TxBatch) GetEndorsement() *common.EndorsementEntry + func (m *TxBatch) GetSize_() int32 + func (m *TxBatch) GetTxIdsMap() map[string]int32 + func (m *TxBatch) GetTxs() []*common.Transaction + func (m *TxBatch) Marshal() (dAtA []byte, err error) + func (m *TxBatch) MarshalTo(dAtA []byte) (int, error) + func (m *TxBatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxBatch) Reset() + func (m *TxBatch) Size() (n int) + func (m *TxBatch) String() string + func (m *TxBatch) Unmarshal(dAtA []byte) error + func (m *TxBatch) XXX_DiscardUnknown() + func (m *TxBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxBatch) XXX_Merge(src proto.Message) + func (m *TxBatch) XXX_Size() int + func (m *TxBatch) XXX_Unmarshal(b []byte) error + type TxBatchRecoverRequest struct + BatchIds []string + Height uint64 + NodeId string + func (*TxBatchRecoverRequest) Descriptor() ([]byte, []int) + func (*TxBatchRecoverRequest) ProtoMessage() + func (m *TxBatchRecoverRequest) GetBatchIds() []string + func (m *TxBatchRecoverRequest) GetHeight() uint64 + func (m *TxBatchRecoverRequest) GetNodeId() string + func (m *TxBatchRecoverRequest) Marshal() (dAtA []byte, err error) + func (m *TxBatchRecoverRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TxBatchRecoverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxBatchRecoverRequest) Reset() + func (m *TxBatchRecoverRequest) Size() (n int) + func (m *TxBatchRecoverRequest) String() string + func (m *TxBatchRecoverRequest) Unmarshal(dAtA []byte) error + func (m *TxBatchRecoverRequest) XXX_DiscardUnknown() + func (m *TxBatchRecoverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxBatchRecoverRequest) XXX_Merge(src proto.Message) + func (m *TxBatchRecoverRequest) XXX_Size() int + func (m *TxBatchRecoverRequest) XXX_Unmarshal(b []byte) error + type TxBatchRecoverResponse struct + Height uint64 + NodeId string + TxBatches []*TxBatch + func (*TxBatchRecoverResponse) Descriptor() ([]byte, []int) + func (*TxBatchRecoverResponse) ProtoMessage() + func (m *TxBatchRecoverResponse) GetHeight() uint64 + func (m *TxBatchRecoverResponse) GetNodeId() string + func (m *TxBatchRecoverResponse) GetTxBatches() []*TxBatch + func (m *TxBatchRecoverResponse) Marshal() (dAtA []byte, err error) + func (m *TxBatchRecoverResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TxBatchRecoverResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxBatchRecoverResponse) Reset() + func (m *TxBatchRecoverResponse) Size() (n int) + func (m *TxBatchRecoverResponse) String() string + func (m *TxBatchRecoverResponse) Unmarshal(dAtA []byte) error + func (m *TxBatchRecoverResponse) XXX_DiscardUnknown() + func (m *TxBatchRecoverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxBatchRecoverResponse) XXX_Merge(src proto.Message) + func (m *TxBatchRecoverResponse) XXX_Size() int + func (m *TxBatchRecoverResponse) XXX_Unmarshal(b []byte) error + type TxPoolMsg struct + Payload []byte + Type TxPoolMsgType + func (*TxPoolMsg) Descriptor() ([]byte, []int) + func (*TxPoolMsg) ProtoMessage() + func (m *TxPoolMsg) GetPayload() []byte + func (m *TxPoolMsg) GetType() TxPoolMsgType + func (m *TxPoolMsg) Marshal() (dAtA []byte, err error) + func (m *TxPoolMsg) MarshalTo(dAtA []byte) (int, error) + func (m *TxPoolMsg) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxPoolMsg) Reset() + func (m *TxPoolMsg) Size() (n int) + func (m *TxPoolMsg) String() string + func (m *TxPoolMsg) Unmarshal(dAtA []byte) error + func (m *TxPoolMsg) XXX_DiscardUnknown() + func (m *TxPoolMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxPoolMsg) XXX_Merge(src proto.Message) + func (m *TxPoolMsg) XXX_Size() int + func (m *TxPoolMsg) XXX_Unmarshal(b []byte) error + type TxPoolMsgType int32 + const TxPoolMsgType_BATCH_TX + const TxPoolMsgType_RECOVER_REQ + const TxPoolMsgType_RECOVER_RESP + const TxPoolMsgType_SINGLE_TX + func (TxPoolMsgType) EnumDescriptor() ([]byte, []int) + func (x TxPoolMsgType) String() string + type TxPoolSignal struct + ChainId string + SignalType SignalType + func (*TxPoolSignal) Descriptor() ([]byte, []int) + func (*TxPoolSignal) ProtoMessage() + func (m *TxPoolSignal) GetChainId() string + func (m *TxPoolSignal) GetSignalType() SignalType + func (m *TxPoolSignal) Marshal() (dAtA []byte, err error) + func (m *TxPoolSignal) MarshalTo(dAtA []byte) (int, error) + func (m *TxPoolSignal) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxPoolSignal) Reset() + func (m *TxPoolSignal) Size() (n int) + func (m *TxPoolSignal) String() string + func (m *TxPoolSignal) Unmarshal(dAtA []byte) error + func (m *TxPoolSignal) XXX_DiscardUnknown() + func (m *TxPoolSignal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxPoolSignal) XXX_Merge(src proto.Message) + func (m *TxPoolSignal) XXX_Size() int + func (m *TxPoolSignal) XXX_Unmarshal(b []byte) error + type TxPoolStatus struct + CommonTxNumInPending int32 + CommonTxNumInQueue int32 + CommonTxPoolSize int32 + ConfigTxNumInPending int32 + ConfigTxNumInQueue int32 + ConfigTxPoolSize int32 + func (*TxPoolStatus) Descriptor() ([]byte, []int) + func (*TxPoolStatus) ProtoMessage() + func (m *TxPoolStatus) GetCommonTxNumInPending() int32 + func (m *TxPoolStatus) GetCommonTxNumInQueue() int32 + func (m *TxPoolStatus) GetCommonTxPoolSize() int32 + func (m *TxPoolStatus) GetConfigTxNumInPending() int32 + func (m *TxPoolStatus) GetConfigTxNumInQueue() int32 + func (m *TxPoolStatus) GetConfigTxPoolSize() int32 + func (m *TxPoolStatus) Marshal() (dAtA []byte, err error) + func (m *TxPoolStatus) MarshalTo(dAtA []byte) (int, error) + func (m *TxPoolStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxPoolStatus) Reset() + func (m *TxPoolStatus) Size() (n int) + func (m *TxPoolStatus) String() string + func (m *TxPoolStatus) Unmarshal(dAtA []byte) error + func (m *TxPoolStatus) XXX_DiscardUnknown() + func (m *TxPoolStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxPoolStatus) XXX_Merge(src proto.Message) + func (m *TxPoolStatus) XXX_Size() int + func (m *TxPoolStatus) XXX_Unmarshal(b []byte) error + type TxRecoverRequest struct + Height uint64 + NodeId string + TxIds []string + func (*TxRecoverRequest) Descriptor() ([]byte, []int) + func (*TxRecoverRequest) ProtoMessage() + func (m *TxRecoverRequest) GetHeight() uint64 + func (m *TxRecoverRequest) GetNodeId() string + func (m *TxRecoverRequest) GetTxIds() []string + func (m *TxRecoverRequest) Marshal() (dAtA []byte, err error) + func (m *TxRecoverRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TxRecoverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxRecoverRequest) Reset() + func (m *TxRecoverRequest) Size() (n int) + func (m *TxRecoverRequest) String() string + func (m *TxRecoverRequest) Unmarshal(dAtA []byte) error + func (m *TxRecoverRequest) XXX_DiscardUnknown() + func (m *TxRecoverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxRecoverRequest) XXX_Merge(src proto.Message) + func (m *TxRecoverRequest) XXX_Size() int + func (m *TxRecoverRequest) XXX_Unmarshal(b []byte) error + type TxRecoverResponse struct + Height uint64 + NodeId string + Txs []*common.Transaction + func (*TxRecoverResponse) Descriptor() ([]byte, []int) + func (*TxRecoverResponse) ProtoMessage() + func (m *TxRecoverResponse) GetHeight() uint64 + func (m *TxRecoverResponse) GetNodeId() string + func (m *TxRecoverResponse) GetTxs() []*common.Transaction + func (m *TxRecoverResponse) Marshal() (dAtA []byte, err error) + func (m *TxRecoverResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TxRecoverResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxRecoverResponse) Reset() + func (m *TxRecoverResponse) Size() (n int) + func (m *TxRecoverResponse) String() string + func (m *TxRecoverResponse) Unmarshal(dAtA []byte) error + func (m *TxRecoverResponse) XXX_DiscardUnknown() + func (m *TxRecoverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxRecoverResponse) XXX_Merge(src proto.Message) + func (m *TxRecoverResponse) XXX_Size() int + func (m *TxRecoverResponse) XXX_Unmarshal(b []byte) error + type TxStage int32 + const TxStage_ALL_STAGE + const TxStage_IN_PENDING + const TxStage_IN_QUEUE + const TxStage_UNKNOWN_STAGE + func (TxStage) EnumDescriptor() ([]byte, []int) + func (x TxStage) String() string + type TxStatus int32 + const TxStatus_COMMITTED + const TxStatus_DOUBLE_SPEND_REMOVED + const TxStatus_EVIL_REMOVED + const TxStatus_PACKAGED + const TxStatus_TIMEOUT_REMOVED + const TxStatus_UNKNOWN_STATUS + const TxStatus_UNPACKAGED + func (TxStatus) EnumDescriptor() ([]byte, []int) + func (x TxStatus) String() string + type TxType int32 + const TxType_ALL_TYPE + const TxType_COMMON_TX + const TxType_CONFIG_TX + const TxType_UNKNOWN_TYPE + func (TxType) EnumDescriptor() ([]byte, []int) + func (x TxType) String() string Other modules containing this package chainmaker.org/chainmaker/pb-go/v2