executor

Documentation

Index

• type HttpConfig
• type HttpExecutor
  • func NewHttpExecutor(maxConcurrency int) HttpExecutor
  • func (h HttpExecutor) Run(job qron.Job)
• type Signer

Types

type HttpConfig

type HttpConfig struct {
	Url    string `json:"url,omitempty"`
	Method string `json:"method,omitempty"`
}

type HttpExecutor

type HttpExecutor struct {
	Signer func(job qron.Job, r *http.Request) error
	// contains filtered or unexported fields
}

func NewHttpExecutor

func NewHttpExecutor(maxConcurrency int) HttpExecutor

func (HttpExecutor) Run

func (h HttpExecutor) Run(job qron.Job)

type Signer

type Signer func(job qron.Job, r *http.Request) error