queue

Documentation

Index

• Constants
• type DebugRequest
• 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) DebugRequests() []*DebugRequest
  • func (s *RequestQueue) GetCache() *lru_cache.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 DebugRequest

type DebugRequest struct {
	Hash        string `json:"hash"`
	IsReceived  bool   `json:"received"`
	IsProcessed bool   `json:"processed"`
	InCache     bool   `json:"inCache"`
	InPending   bool   `json:"inPending"`
	InLifo      bool   `json:"inLifo"`
	TxExists    bool   `json:"txExists"`
}

Request struct

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) DebugRequests

func (s *RequestQueue) DebugRequests() []*DebugRequest

func (*RequestQueue) GetCache

func (s *RequestQueue) GetCache() *lru_cache.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()