Documentation ¶
Index ¶
Constants ¶
View Source
const ( // BackendHTTPID is a known backend implementation BackendHTTPID = "http" // BackendKafkaID is a known backend implementation BackendKafkaID = "kafka" )
Variables ¶
View Source
var ( // RetryBackoffDuration indicates the time to wait between retries. RetryBackoffDuration = 10 * time.Minute )
Functions ¶
This section is empty.
Types ¶
type Notifier ¶
type Notifier struct { Storage *storage.Storage Log *log.Logger DownloadURL *url.URL StatsIntvl time.Duration // DeletionIntvl indicates the time after which downloaded files must be // enqueued for deletion. DeletionIntvl time.Duration // contains filtered or unexported fields }
Notifier is the the component responsible for consuming the result of jobs and notifying back the respective users by issuing HTTP requests to their provided callback URLs.
func (*Notifier) Notify ¶
Notify posts callback info to job's destination by calling Notify on each backend.
Click to show internal directories.
Click to hide internal directories.