queue

Documentation

Index

• Constants
• type CachedRequest
  • func (c *CachedRequest) GetRequest() *request
• type DebugRequest
• type RequestQueue
  • func NewRequestQueue() *RequestQueue
  • func (s *RequestQueue) Add(txHash trinary.Hash, msIndex milestone_index.MilestoneIndex, ...) bool
  • func (s *RequestQueue) AddMulti(hashes trinary.Hashes, msIndex milestone_index.MilestoneIndex, ...) []bool
  • func (s *RequestQueue) ContainsRequest(transactionHash trinary.Hash) bool
  • func (s *RequestQueue) CurrentMilestoneIndexAndSize() (index milestone_index.MilestoneIndex, size int)
  • func (s *RequestQueue) DebugRequests() []*DebugRequest
  • func (s *RequestQueue) DeleteRequest(txHash trinary.Hash)
  • func (s *RequestQueue) GetCachedRequestOrNil(transactionHash trinary.Hash) *CachedRequest
  • 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) GetStorageSize() int
  • func (s *RequestQueue) IsEmpty() bool
  • func (s *RequestQueue) MarkProcessed(txHash trinary.Hash)
  • func (s *RequestQueue) MarkReceived(txHash trinary.Hash) (bool, milestone_index.MilestoneIndex)
  • func (s *RequestQueue) PutRequest(request *request) *CachedRequest
  • func (s *RequestQueue) Stop()

Constants

const (
	RequestQueueTickerInterval = 2 * time.Second
)

Types

type CachedRequest

type CachedRequest struct {
	objectstorage.CachedObject
}

func (*CachedRequest) GetRequest

func (c *CachedRequest) GetRequest() *request

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, msIndex milestone_index.MilestoneIndex, markRequested bool) bool

func (*RequestQueue) AddMulti

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

func (*RequestQueue) ContainsRequest

func (s *RequestQueue) ContainsRequest(transactionHash trinary.Hash) bool

request +-0

func (*RequestQueue) CurrentMilestoneIndexAndSize

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

func (*RequestQueue) DebugRequests

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

func (*RequestQueue) DeleteRequest

func (s *RequestQueue) DeleteRequest(txHash trinary.Hash)

request +-0

func (*RequestQueue) GetCachedRequestOrNil

func (s *RequestQueue) GetCachedRequestOrNil(transactionHash trinary.Hash) *CachedRequest

request +1

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

func (s *RequestQueue) GetStorageSize() int

func (*RequestQueue) IsEmpty

func (s *RequestQueue) IsEmpty() bool

func (*RequestQueue) MarkProcessed

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

func (*RequestQueue) MarkReceived

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

func (*RequestQueue) PutRequest

func (s *RequestQueue) PutRequest(request *request) *CachedRequest

request +1

func (*RequestQueue) Stop

func (s *RequestQueue) Stop()