executor

Documentation

Index

• Constants
• type JobExecutor
  • func NewJobExecutor(parentId, cluster, topic string, mc *mysql.MysqlCluster, ...) *JobExecutor
  • func (this *JobExecutor) Ident() string
  • func (this *JobExecutor) Run()
• type WebhookExecutor
  • func NewWebhookExecutor(parentId, cluster, topic string, endpoints []string, stopper <-chan struct{}, ...) *WebhookExecutor
  • func (this *WebhookExecutor) Run()

Constants

const (
	LagWarnThreshold   = 3  // in sec
	HandlerConcurrentN = 10 // FIXME breaks the delivery order guarantee
)

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

func (*JobExecutor) Run

func (this *JobExecutor) Run()

poll mysql for due jobs and send to kafka.

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()