queue

Documentation

Index

• Constants
• type RequestQueue
  • func NewRequestQueue() *RequestQueue
  • func (s *RequestQueue) Add(txHash trinary.Hash, ms milestone_index.MilestoneIndex, markRequested bool) bool
  • func (s *RequestQueue) AddMulti(hashes trinary.Hashes, ms milestone_index.MilestoneIndex, markRequested bool) []bool
  • func (s *RequestQueue) Contains(txHash trinary.Hash) (bool, milestone_index.MilestoneIndex)
  • func (s *RequestQueue) CurrentMilestoneIndexAndSize() (index milestone_index.MilestoneIndex, size int)
  • func (s *RequestQueue) GetCache() *datastructure.LRUCache
  • func (s *RequestQueue) GetNext() ([]byte, trinary.Hash, milestone_index.MilestoneIndex)
  • func (s *RequestQueue) GetNextInRange(startIndex milestone_index.MilestoneIndex, ...) ([]byte, trinary.Hash, milestone_index.MilestoneIndex)
  • func (s *RequestQueue) MarkProcessed(txHash trinary.Hash) bool
  • func (s *RequestQueue) MarkReceived(txHash trinary.Hash) bool
  • func (s *RequestQueue) Stop()

Constants

const (
	RequestQueueTickerInterval = 2 * time.Second
)

Types

type RequestQueue

type RequestQueue struct {
	syncutils.Mutex
	// contains filtered or unexported fields
}

func NewRequestQueue

func NewRequestQueue() *RequestQueue

func (*RequestQueue) Add

func (s *RequestQueue) Add(txHash trinary.Hash, ms milestone_index.MilestoneIndex, markRequested bool) bool

func (*RequestQueue) AddMulti

func (s *RequestQueue) AddMulti(hashes trinary.Hashes, ms milestone_index.MilestoneIndex, markRequested bool) []bool

func (*RequestQueue) Contains

func (s *RequestQueue) Contains(txHash trinary.Hash) (bool, milestone_index.MilestoneIndex)

func (*RequestQueue) CurrentMilestoneIndexAndSize

func (s *RequestQueue) CurrentMilestoneIndexAndSize() (index milestone_index.MilestoneIndex, size int)

func (*RequestQueue) GetCache

func (s *RequestQueue) GetCache() *datastructure.LRUCache

func (*RequestQueue) GetNext

func (s *RequestQueue) GetNext() ([]byte, trinary.Hash, milestone_index.MilestoneIndex)

func (*RequestQueue) GetNextInRange

func (s *RequestQueue) GetNextInRange(startIndex milestone_index.MilestoneIndex, endIndex milestone_index.MilestoneIndex) ([]byte, trinary.Hash, milestone_index.MilestoneIndex)

func (*RequestQueue) MarkProcessed

func (s *RequestQueue) MarkProcessed(txHash trinary.Hash) bool

func (*RequestQueue) MarkReceived

func (s *RequestQueue) MarkReceived(txHash trinary.Hash) bool

func (*RequestQueue) Stop

func (s *RequestQueue) Stop()