Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobFrequency ¶
type JobFrequency string
JobFrequency defines the frequency that triggered this batch refresh.
const ( FrequencyUnknown JobFrequency = "UNKNOWN" FrequencyImmediate JobFrequency = "IMMEDIATE" FrequencyWeekly JobFrequency = "WEEKLY" FrequencyMonthly JobFrequency = "MONTHLY" )
func (JobFrequency) ToWorkerTypeJobFrequency ¶
func (f JobFrequency) ToWorkerTypeJobFrequency() workertypes.JobFrequency
type RefreshSearchCommand ¶
type RefreshSearchCommand struct {
// SearchID is the target saved search to check.
SearchID string `json:"search_id"`
// Query is the current search filter (e.g. "browsers:chrome").
Query string `json:"query"`
// Frequency indicates which schedule triggered this refresh.
Frequency JobFrequency `json:"frequency"`
// Timestamp is when the batch process started (generated by the Fan-Out worker).
// Useful for identifying lag (if the worker processes it 10m later).
Timestamp time.Time `json:"timestamp"`
}
RefreshSearchCommand is the signal sent by the Fan-Out Worker to the Event Producer. One of these is published for EACH active search found in the database matching the batch frequency.
func (RefreshSearchCommand) APIVersion ¶
func (RefreshSearchCommand) APIVersion() string
func (RefreshSearchCommand) Kind ¶
func (RefreshSearchCommand) Kind() string
Source Files
Click to show internal directories.
Click to hide internal directories.