Documentation
¶
Index ¶
Constants ¶
View Source
const SendTransactionsPipe = "send transactions pipe"
SendTransactionsPipe is the pipe used for sending new transactions
Variables ¶
This section is empty.
Functions ¶
func NewTxsSenderWithAccumulator ¶
func NewTxsSenderWithAccumulator(args ArgsTxsSenderWithAccumulator) (*txsSender, error)
NewTxsSenderWithAccumulator creates a new instance of TxsSenderHandler, which initializes internally an accumulator.NewTimeAccumulator
Types ¶
type ArgsTxsSenderWithAccumulator ¶
type ArgsTxsSenderWithAccumulator struct {
Marshaller marshal.Marshalizer
ShardCoordinator storage.ShardCoordinator
NetworkMessenger NetworkMessenger
AccumulatorConfig config.TxAccumulatorConfig
DataPacker process.DataPacker
}
ArgsTxsSenderWithAccumulator is a holder struct for all necessary arguments to create a NewTxsSenderWithAccumulator
type NetworkMessenger ¶
type NetworkMessenger interface {
io.Closer
// BroadcastOnChannelBlocking asynchronously waits until it can send a
// message on the channel, but once it is able to, it synchronously sends the
// message, blocking until sending is completed.
BroadcastOnChannelBlocking(channel string, topic string, buff []byte) error
// IsInterfaceNil checks if the underlying pointer is nil
IsInterfaceNil() bool
}
NetworkMessenger defines the basic functionality of a network messenger to broadcast buffer data on a channel, for a given topic
Click to show internal directories.
Click to hide internal directories.