Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

txpool

package

Go to main page

Versions in this module

v1

v1.5.1

Dec 9, 2022

v1.5.0

Dec 8, 2022

v1.0.0

Nov 11, 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 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 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 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