worker

Documentation

Index

• type AuditJob
  • func (j *AuditJob) Run()
• type BankJob
  • func (j *BankJob) Run()
• type BlockUnlockJob
  • func (j *BlockUnlockJob) Run()
• type ChartJob
  • func (j *ChartJob) Run()
• type MinerJob
  • func (j *MinerJob) Run()
• type MinerNotifyJob
  • func (j *MinerNotifyJob) Run()
• type NodeBackupJob
  • func (j *NodeBackupJob) Run()
• type NodeCheckJob
  • func (j *NodeCheckJob) Run()
• type NodeInstanceChangeJob
  • func (j *NodeInstanceChangeJob) Run()
• type NodeStatusJob
  • func (j *NodeStatusJob) Run()
• type PayoutJob
  • func (j *PayoutJob) Run()
• type TradeJob
  • func (j *TradeJob) Run()
• type Worker
  • func NewWorker(env string, mainnet bool, logger *log.Logger, miningNodes []types.MiningNode, ...) (*Worker, error)
  • func (w *Worker) Start()
  • func (w *Worker) Stop()

Types

type AuditJob

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

func (*AuditJob) Run

func (j *AuditJob) Run()

type BankJob

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

func (*BankJob) Run

func (j *BankJob) Run()

type BlockUnlockJob

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

func (*BlockUnlockJob) Run

func (j *BlockUnlockJob) Run()

type ChartJob

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

func (*ChartJob) Run

func (j *ChartJob) Run()

type MinerJob

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

func (*MinerJob) Run

func (j *MinerJob) Run()

type MinerNotifyJob

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

func (*MinerNotifyJob) Run

func (j *MinerNotifyJob) Run()

type NodeBackupJob

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

func (*NodeBackupJob) Run

func (j *NodeBackupJob) Run()

type NodeCheckJob

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

func (*NodeCheckJob) Run

func (j *NodeCheckJob) Run()

type NodeInstanceChangeJob

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

func (*NodeInstanceChangeJob) Run

func (j *NodeInstanceChangeJob) Run()

type NodeStatusJob

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

func (*NodeStatusJob) Run

func (j *NodeStatusJob) Run()

type PayoutJob

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

func (*PayoutJob) Run

func (j *PayoutJob) Run()

type TradeJob

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

func (*TradeJob) Run

func (j *TradeJob) Run()

type Worker

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

func NewWorker

func NewWorker(
	env string,
	mainnet bool,
	logger *log.Logger,
	miningNodes []types.MiningNode,
	payoutNodes []types.PayoutNode,
	pooldbClient, tsdbClient *dbcl.Client,
	redisClient *redis.Client,
	awsClient *aws.Client,
	metricsClient *metrics.Client,
	exchanges []types.Exchange,
	telegramClient *telegram.Client,
) (*Worker, error)

func (*Worker) Start

func (w *Worker) Start()

func (*Worker) Stop

func (w *Worker) Stop()