Documentation ¶
Index ¶
- type Cache
- type ITxListDB
- type MsgManagement
- func (t *MsgManagement) Close() error
- func (t *MsgManagement) Count() int
- func (t *MsgManagement) Delete(msg types.IMessage)
- func (t *MsgManagement) DeleteEnd(newTx types.IMessage)
- func (t *MsgManagement) DeleteExpired(timeThreshold int64)
- func (t *MsgManagement) Exist(msg types.IMessage) bool
- func (t *MsgManagement) GetAll() ([]types.IMessage, []types.IMessage)
- func (t *MsgManagement) NeedPackaged(count int) []types.IMessage
- func (t *MsgManagement) Put(msg types.IMessage) error
- func (t *MsgManagement) Read() error
- func (t *MsgManagement) StagnantMsgs() []types.IMessage
- func (t *MsgManagement) Update()
- type Sorted
- func (t *Sorted) All() []types.IMessage
- func (t *Sorted) Exist(from string, msgHash string) bool
- func (t *Sorted) GetByAddress(addr string) types.IMessage
- func (t *Sorted) Len() int
- func (t *Sorted) NeedPackaged(count int) []types.IMessage
- func (t *Sorted) PopMin(fees uint64) types.IMessage
- func (t *Sorted) Put(msg types.IMessage)
- func (t *Sorted) Remove(msg types.IMessage)
- func (t *Sorted) RemoveExecuted(v validator.IValidator)
- func (t *Sorted) RemoveExpiredTx(timeThreshold int64)
- func (t *Sorted) StagnantMsgs() []types.IMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MsgManagement ¶
type MsgManagement struct {
// contains filtered or unexported fields
}
func NewMsgManagement ¶
func NewMsgManagement(validator validator.IValidator, actStatus types.IActStatus) (*MsgManagement, error)
func (*MsgManagement) Close ¶
func (t *MsgManagement) Close() error
func (*MsgManagement) Count ¶
func (t *MsgManagement) Count() int
func (*MsgManagement) Delete ¶
func (t *MsgManagement) Delete(msg types.IMessage)
func (*MsgManagement) DeleteEnd ¶
func (t *MsgManagement) DeleteEnd(newTx types.IMessage)
func (*MsgManagement) DeleteExpired ¶
func (t *MsgManagement) DeleteExpired(timeThreshold int64)
func (*MsgManagement) GetAll ¶
func (t *MsgManagement) GetAll() ([]types.IMessage, []types.IMessage)
func (*MsgManagement) NeedPackaged ¶
func (t *MsgManagement) NeedPackaged(count int) []types.IMessage
func (*MsgManagement) Read ¶
func (t *MsgManagement) Read() error
func (*MsgManagement) StagnantMsgs ¶
func (t *MsgManagement) StagnantMsgs() []types.IMessage
func (*MsgManagement) Update ¶
func (t *MsgManagement) Update()
type Sorted ¶
type Sorted struct {
// contains filtered or unexported fields
}
func (*Sorted) RemoveExecuted ¶
func (t *Sorted) RemoveExecuted(v validator.IValidator)
Delete already packed messages
func (*Sorted) RemoveExpiredTx ¶
Delete expired messages
func (*Sorted) StagnantMsgs ¶
Click to show internal directories.
Click to hide internal directories.