Documentation
¶
Index ¶
Constants ¶
View Source
const ( LagWarnThreshold = 3 // in sec HandlerConcurrentN = 10 // FIXME breaks the delivery order guarantee )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobExecutor ¶
type JobExecutor struct {
// contains filtered or unexported fields
}
JobExecutor polls a single JobQueue and handle each Job.
func NewJobExecutor ¶
func NewJobExecutor(parentId, cluster, topic string, mc *mysql.MysqlCluster, stopper <-chan struct{}, auditor log.Logger) *JobExecutor
func (*JobExecutor) Ident ¶
func (this *JobExecutor) Ident() string
type WebhookExecutor ¶
type WebhookExecutor struct {
// contains filtered or unexported fields
}
func NewWebhookExecutor ¶
func NewWebhookExecutor(parentId, cluster, topic string, endpoints []string, stopper <-chan struct{}, auditor log.Logger) *WebhookExecutor
func (*WebhookExecutor) Run ¶
func (this *WebhookExecutor) Run()
Source Files
Click to show internal directories.
Click to hide internal directories.