cache

Documentation

Index

• type LocalCacheItem
  • func NewLocalCacheItem(msg *message.TaskMessage, hash string) *LocalCacheItem
  • func (l *LocalCacheItem) GetPeers() []string
  • func (l *LocalCacheItem) TotalConfirmParty() int
  • func (l *LocalCacheItem) UpdateConfirmList(partyID, hash string)

Types

type LocalCacheItem

type LocalCacheItem struct {
	Msg  *message.TaskMessage
	Hash string
	Lock *sync.Mutex
	// parytyID.id -> msgHash
	ConfirmedList map[string]string
}

LocalCacheItem used to cache the unconfirmed broadcast message

func NewLocalCacheItem

func NewLocalCacheItem(msg *message.TaskMessage, hash string) *LocalCacheItem

func (*LocalCacheItem) GetPeers

func (l *LocalCacheItem) GetPeers() []string

func (*LocalCacheItem) TotalConfirmParty

func (l *LocalCacheItem) TotalConfirmParty() int

TotalConfirmParty counts the number of parties that already confirmed their hash

func (*LocalCacheItem) UpdateConfirmList

func (l *LocalCacheItem) UpdateConfirmList(partyID, hash string)

UpdateConfirmList add the given party's hash into the confirm list