Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { RetryInterval time.Duration `yaml:"retryInterval" default:"60s"` NodeRecords []string `yaml:"nodeRecords"` TransactionFilters TransactionFilterConfig `yaml:"transactionFilters"` }
type Coordinator ¶
type Coordinator struct {
// contains filtered or unexported fields
}
func NewCoordinator ¶
func NewCoordinator(config *Config, broadcast func(ctx context.Context, transactions *mimicry.Transactions) error, log logrus.FieldLogger) (*Coordinator, error)
type CoordinatorStatus ¶
type Peer ¶
type Peer struct {
// contains filtered or unexported fields
}
func NewPeer ¶
func NewPeer(ctx context.Context, log logrus.FieldLogger, nodeRecord string, handler func(ctx context.Context, transactions *mimicry.Transactions) error, sharedCache *cache.SharedCache, txFilterConfig *TransactionFilterConfig) (*Peer, error)
func (*Peer) ExportTransactions ¶
type TransactionExporter ¶
type TransactionExporter struct {
// contains filtered or unexported fields
}
func NewTransactionExporter ¶
func NewTransactionExporter(log logrus.FieldLogger, handler func(ctx context.Context, items []*common.Hash) error) (TransactionExporter, error)
func (TransactionExporter) ExportItems ¶
type TransactionFilterConfig ¶
Click to show internal directories.
Click to hide internal directories.