Versions in this module Expand all Collapse all v0 v0.5.4 Sep 24, 2020 Changes in this version + const WorkerQueueSize + var ErrInvalidTimestamp = errors.New("invalid timestamp") + func BroadcastCaller(handler interface{}, params ...interface{}) + func TransactionProcessedCaller(handler interface{}, params ...interface{}) + type CachedWorkUnit struct + func (c *CachedWorkUnit) WorkUnit() *WorkUnit + type Events struct + BroadcastTransaction *events.Event + TransactionProcessed *events.Event + type Options struct + ValidMWM uint64 + WorkUnitCacheOpts profile.CacheOpts + type Processor struct + Events Events + func New(requestQueue rqueue.Queue, peerManager *peering.Manager, opts *Options) *Processor + func (proc *Processor) CompressAndEmit(tx *transaction.Transaction, txTrits trinary.Trits) error + func (proc *Processor) Process(p *peer.Peer, msgType message.Type, data []byte) + func (proc *Processor) Run(shutdownSignal <-chan struct{}) + func (proc *Processor) ValidateTimestamp(hornetTx *hornet.Transaction) (valid, broadcast bool) + func (proc *Processor) ValidateTransactionTrytesAndEmit(txTrytes trinary.Trytes) error + func (proc *Processor) WorkUnitsSize() int + type WorkUnit struct + func (wu *WorkUnit) Is(state WorkUnitState) bool + func (wu *WorkUnit) ObjectStorageKey() []byte + func (wu *WorkUnit) ObjectStorageValue() []byte + func (wu *WorkUnit) UnmarshalObjectStorageValue(_ []byte) (consumedBytes int, err error) + func (wu *WorkUnit) Update(_ objectstorage.StorableObject) + func (wu *WorkUnit) UpdateState(state WorkUnitState) + type WorkUnitState byte + const Hashed + const Hashing + const Invalid
Go to main page