daemon

package
v1.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 22, 2025 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Daemon

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

func NewDaemon

func NewDaemon(parentCtx context.Context, logger logrus.FieldLogger, clientPool *spamoor.ClientPool, rootWallet *spamoor.RootWallet, txpool *spamoor.TxPool, db *db.Database) *Daemon

func (*Daemon) AddStartupSpammers added in v1.1.1

func (d *Daemon) AddStartupSpammers(spammers []StartupSpammerConfig) error

AddStartupSpammers adds the startup spammers to the daemon

func (*Daemon) DeleteSpammer

func (d *Daemon) DeleteSpammer(id int64) error

func (*Daemon) GetAllSpammers

func (d *Daemon) GetAllSpammers() []*Spammer

func (*Daemon) GetClientPool

func (d *Daemon) GetClientPool() *spamoor.ClientPool

func (*Daemon) GetGlobalCfg added in v1.1.3

func (d *Daemon) GetGlobalCfg() map[string]interface{}

func (*Daemon) GetRootWallet

func (d *Daemon) GetRootWallet() *spamoor.RootWallet

func (*Daemon) GetSpammer

func (d *Daemon) GetSpammer(id int64) *Spammer

func (*Daemon) LoadStartupSpammers added in v1.1.1

func (d *Daemon) LoadStartupSpammers(configFile string, logger logrus.FieldLogger) ([]StartupSpammerConfig, error)

LoadStartupSpammers loads the startup spammers configuration from a file

func (*Daemon) NewSpammer

func (d *Daemon) NewSpammer(scenarioName string, config string, name string, description string, startImmediately bool) (*Spammer, error)

func (*Daemon) Run

func (d *Daemon) Run() (bool, error)

func (*Daemon) SetGlobalCfg added in v1.1.3

func (d *Daemon) SetGlobalCfg(name string, value interface{})

func (*Daemon) Shutdown

func (d *Daemon) Shutdown()

func (*Daemon) UpdateSpammer

func (d *Daemon) UpdateSpammer(id int64, name string, description string, config string) error

type Spammer

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

func (*Spammer) GetConfig

func (s *Spammer) GetConfig() string

func (*Spammer) GetCreatedAt

func (s *Spammer) GetCreatedAt() int64

func (*Spammer) GetDescription

func (s *Spammer) GetDescription() string

func (*Spammer) GetID

func (s *Spammer) GetID() int64

func (*Spammer) GetLogScope

func (s *Spammer) GetLogScope() *logscope.LogScope

func (*Spammer) GetName

func (s *Spammer) GetName() string

func (*Spammer) GetScenario

func (s *Spammer) GetScenario() string

func (*Spammer) GetStatus

func (s *Spammer) GetStatus() int

func (*Spammer) GetWalletPool

func (s *Spammer) GetWalletPool() *spamoor.WalletPool

func (*Spammer) Pause

func (s *Spammer) Pause() error

func (*Spammer) Start

func (s *Spammer) Start() error

type SpammerConfig

type SpammerConfig struct {
	Seed           string       `yaml:"seed"`
	RefillAmount   *uint256.Int `yaml:"refill_amount"`
	RefillBalance  *uint256.Int `yaml:"refill_balance"`
	RefillInterval uint64       `yaml:"refill_interval"`
	WalletCount    int          `yaml:"wallet_count"`
}

type SpammerStatus

type SpammerStatus int
const (
	SpammerStatusPaused SpammerStatus = iota
	SpammerStatusRunning
	SpammerStatusFinished
	SpammerStatusFailed
)

type StartupSpammerConfig added in v1.1.1

type StartupSpammerConfig struct {
	Scenario    string                 `yaml:"scenario"`
	Name        string                 `yaml:"name"`
	Description string                 `yaml:"description"`
	Config      map[string]interface{} `yaml:"config"`
}

StartupSpammerConfig represents a single spammer configuration in the startup config file

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL