Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultDNSValidationTaskConfig = DNSValidationTaskConfig{
TaskName: "dns:validate",
DNSTXTRecord: "routehub_domainkey",
TaskQueue: "dns-validation",
TaskPriority: 4,
}
View Source
var DefaultTaskServerConfig = TaskServerConfig{
RedisAddr: "localhost:6379",
MonitoringPath: "/monitoring",
MonitoringPort: "8081",
Concurrency: 10,
}
View Source
var DefaultURLValidationTaskConfig = URLValidationTaskConfig{
TaskName: "url:validate",
TaskQueue: "url-validation",
TaskPriority: 3,
}
Functions ¶
This section is empty.
Types ¶
type DNSValidationPayload ¶
type DNSValidationTask ¶
type DNSValidationTask struct {
Settings Settings
TaskConfig DNSValidationTaskConfig
}
func NewDNSValidationTask ¶
func NewDNSValidationTask(settings Settings, DNSValidationTaskConfig DNSValidationTaskConfig) *DNSValidationTask
func NewDNSValidationTaskWithConfig ¶
func NewDNSValidationTaskWithConfig(config DNSValidationTaskConfig) *DNSValidationTask
func NewDNSValidationTaskWithDefaults ¶
func NewDNSValidationTaskWithDefaults() *DNSValidationTask
func (*DNSValidationTask) HandleDNSValidationTask ¶
func (*DNSValidationTask) NewURLValidationTask ¶
func (*DNSValidationTask) SetTaskConfig ¶
func (t *DNSValidationTask) SetTaskConfig(DNSValidationTaskConfig DNSValidationTaskConfig)
type DNSValidationTaskConfig ¶
type InfoPayload ¶
type InfoPayload struct {
ID string `json:"id"`
}
type Settings ¶
type Settings struct {
MaxRetry int
Timeout time.Duration
DeadlineTimeout time.Duration
Queue string
QueuePriority int
Retention time.Duration
}
func DefaultSettings ¶
func (Settings) GetPriority ¶
type TaskResultPayload ¶
type TaskResultPayload struct {
IsValid bool `json:"isValid"`
Message *string `json:"message,omitempty"`
Error *string `json:"error,omitempty"`
}
func (TaskResultPayload) FromJson ¶
func (p TaskResultPayload) FromJson(data []byte) error
func (TaskResultPayload) New ¶
func (p TaskResultPayload) New(isValid bool, message string, err string) *TaskResultPayload
func (TaskResultPayload) ToJson ¶
func (p TaskResultPayload) ToJson() ([]byte, error)
type TaskServer ¶
type TaskServer struct {
Config TaskServerConfig
DNSValidationTask *DNSValidationTask
URLValidationTask *URLValidationTask
}
func (*TaskServer) AsynqmonServe ¶
func (t *TaskServer) AsynqmonServe()
func (*TaskServer) NewClient ¶
func (t *TaskServer) NewClient() *asynq.Client
func (*TaskServer) NewInspector ¶
func (t *TaskServer) NewInspector() *asynq.Inspector
func (*TaskServer) Serve ¶
func (t *TaskServer) Serve()
type TaskServerConfig ¶
type URLValidationPayload ¶
type URLValidationPayload struct {
Link string `json:"link"`
}
type URLValidationTask ¶
type URLValidationTask struct {
Settings Settings
TaskConfig URLValidationTaskConfig
}
func NewURLValidationTask ¶
func NewURLValidationTask(settings Settings) *URLValidationTask
func NewURLValidationTaskWithConfig ¶
func NewURLValidationTaskWithConfig(config URLValidationTaskConfig) *URLValidationTask
func NewURLValidationTaskWithDefaults ¶
func NewURLValidationTaskWithDefaults() *URLValidationTask
func (*URLValidationTask) HandleURLValidationTask ¶
func (*URLValidationTask) NewURLValidationTask ¶
func (t *URLValidationTask) NewURLValidationTask(link string) (*asynq.Task, error)
type URLValidationTaskConfig ¶
Click to show internal directories.
Click to hide internal directories.