Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultTaskServerConfig = TaskServerConfig{ RedisAddr: "localhost:6379", MonitoringDash: true, MonitoringPath: "/monitoring", MonitoringPort: "8081", Concurrency: 10, }
Functions ¶
This section is empty.
Types ¶
type TaskServer ¶
type TaskServer struct {
Config TaskServerConfig
DNSValidationTask *handler.DNSValidationTask
URLValidationTask *handler.URLValidationTask
SiteValidationTask *handler.SiteValidationTask
}
func NewDefaultTaskServer ¶ added in v0.0.4
func NewDefaultTaskServer(config TaskServerConfig, taskConfigs config.TaskConfigs, validator *validator.Validator) *TaskServer
func (*TaskServer) AsynqmonServe ¶
func (t *TaskServer) AsynqmonServe()
func (*TaskServer) Serve ¶
func (t *TaskServer) Serve()
type TaskServerConfig ¶
type TaskServerConfig struct {
RedisAddr string `koanf:"redis_addr"`
MonitoringDash bool `koanf:"monitoring_dashboard"`
MonitoringPath string `koanf:"monitoring_path"`
MonitoringPort string `koanf:"monitoring_port"`
Concurrency int `koanf:"concurrency"`
}
func (*TaskServerConfig) NewClient ¶ added in v0.0.3
func (t *TaskServerConfig) NewClient() *asynq.Client
func (*TaskServerConfig) NewInspector ¶ added in v0.0.3
func (t *TaskServerConfig) NewInspector() *asynq.Inspector
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.