unsigned

Documentation

Index

• type InterceptedUnsignedTransaction
  • func NewInterceptedUnsignedTransaction(uTxBuff []byte, marshalizer marshal.Marshalizer, hasher hashing.Hasher, ...) (*InterceptedUnsignedTransaction, error)
  • func (inUTx *InterceptedUnsignedTransaction) Hash() []byte
  • func (inUTx *InterceptedUnsignedTransaction) IsAddressedToOtherShards() bool
  • func (inUTx *InterceptedUnsignedTransaction) RcvShard() uint32
  • func (inUTx *InterceptedUnsignedTransaction) SndShard() uint32
  • func (inUTx *InterceptedUnsignedTransaction) UnsignedTransaction() data.TransactionHandler
• type UnsignedTxInterceptor
  • func NewUnsignedTxInterceptor(marshalizer marshal.Marshalizer, ...) (*UnsignedTxInterceptor, error)
  • func (utxi *UnsignedTxInterceptor) ProcessReceivedMessage(message p2p.MessageP2P) error
  • func (utxi *UnsignedTxInterceptor) SetBroadcastCallback(callback func(buffToSend []byte))

Types

type InterceptedUnsignedTransaction

type InterceptedUnsignedTransaction struct {
	// contains filtered or unexported fields
}

InterceptedUnsignedTransaction holds and manages a transaction based struct with extended functionality

func NewInterceptedUnsignedTransaction

func NewInterceptedUnsignedTransaction(
	uTxBuff []byte,
	marshalizer marshal.Marshalizer,
	hasher hashing.Hasher,
	addrConv state.AddressConverter,
	coordinator sharding.Coordinator,
) (*InterceptedUnsignedTransaction, error)

NewInterceptedUnsignedTransaction returns a new instance of InterceptedUnsignedTransaction

func (*InterceptedUnsignedTransaction) Hash

func (inUTx *InterceptedUnsignedTransaction) Hash() []byte

Hash gets the hash of this transaction

func (*InterceptedUnsignedTransaction) IsAddressedToOtherShards

func (inUTx *InterceptedUnsignedTransaction) IsAddressedToOtherShards() bool

IsAddressedToOtherShards returns true if this transaction is not meant to be processed by the node from this shard

func (*InterceptedUnsignedTransaction) RcvShard

func (inUTx *InterceptedUnsignedTransaction) RcvShard() uint32

RcvShard returns the receiver shard

func (*InterceptedUnsignedTransaction) SndShard

func (inUTx *InterceptedUnsignedTransaction) SndShard() uint32

SndShard returns the sender shard

func (*InterceptedUnsignedTransaction) UnsignedTransaction

func (inUTx *InterceptedUnsignedTransaction) UnsignedTransaction() data.TransactionHandler

UnsignedTransaction returns the unsigned transaction pointer that actually holds the data

type UnsignedTxInterceptor

type UnsignedTxInterceptor struct {
	// contains filtered or unexported fields
}

UnsignedTxInterceptor is used for intercepting unsigned transaction and storing them into a datapool

func NewUnsignedTxInterceptor

func NewUnsignedTxInterceptor(
	marshalizer marshal.Marshalizer,
	uTxPool dataRetriever.ShardedDataCacherNotifier,
	uTxStorer storage.Storer,
	addrConverter state.AddressConverter,
	hasher hashing.Hasher,
	shardCoordinator sharding.Coordinator,
) (*UnsignedTxInterceptor, error)

NewUnsignedTxInterceptor hooks a new interceptor for unsigned transactions

func (*UnsignedTxInterceptor) ProcessReceivedMessage

func (utxi *UnsignedTxInterceptor) ProcessReceivedMessage(message p2p.MessageP2P) error

ProcessReceivedMessage will be the callback func from the p2p.Messenger and will be called each time a new message was received (for the topic this validator was registered to)

func (*UnsignedTxInterceptor) SetBroadcastCallback

func (utxi *UnsignedTxInterceptor) SetBroadcastCallback(callback func(buffToSend []byte))

SetBroadcastCallback sets the callback method to send filtered out message