job

Documentation

Index

• func NewJobScheduler(env Env) *scheduler
• func NewTasksCheckerJob(e Env) *tasksCheckerJob
• func NewTransactionsCheckerJob(e Env) *transactionsCheckerJob
• func NewTransactionsTimeoutCheckerJob(e Env) *transactionsTimeoutCheckerJob
• type Env

Functions

func NewJobScheduler

func NewJobScheduler(env Env) *scheduler

func NewTasksCheckerJob

func NewTasksCheckerJob(e Env) *tasksCheckerJob

func NewTransactionsCheckerJob

func NewTransactionsCheckerJob(e Env) *transactionsCheckerJob

func NewTransactionsTimeoutCheckerJob

func NewTransactionsTimeoutCheckerJob(e Env) *transactionsTimeoutCheckerJob

Types

type Env

type Env interface {
	Logger() *zap.Logger
	Client() interfaces.HttpClient
	Config() *config.Config

	ContractMapper() interfaces.ContractMapper
	FunctionMapper() interfaces.FunctionMapper
	TaskMapper() interfaces.TaskMapper
	TransactionMapper() interfaces.TransactionMapper

	ContractRepo() interfaces.ContractRepo
	FunctionRepo() interfaces.FunctionRepo
	TaskRepo() interfaces.TaskRepo
	TransactionRepo() interfaces.TransactionRepo

	TaskService() interfaces.TaskService
	TransactionService() interfaces.TransactionService

	TaskInputRequestTopic() interfaces.Topic[bus.TaskInputRequestEvent]
	TaskFinishTopic() interfaces.Topic[bus.TaskFinishEvent]

	TasksCheckerJob() interfaces.CronJob
	TransactionsCheckerJob() interfaces.CronJob
	TransactionsTimeoutCheckerJob() interfaces.CronJob

	Deployer() interfaces.Deployer
	Agent() interfaces.Agent
}