Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
ConfigsAPIURL util.URLValue
// HTTP timeout duration for requests made to the Weave Cloud configs
// service.
ClientTimeout time.Duration
// This is used for template expansion in alerts. Because we don't support
// alerts yet, this value doesn't matter. However, it must be a valid URL
// in order to navigate Prometheus's code paths.
ExternalURL util.URLValue
// How frequently to evaluate rules by default.
EvaluationInterval time.Duration
NumWorkers int
// URL of the Alertmanager to send notifications to.
AlertmanagerURL util.URLValue
// Whether to use DNS SRV records to discover alertmanagers.
AlertmanagerDiscovery bool
// How long to wait between refreshing the list of alertmanagers based on
// DNS service discovery.
AlertmanagerRefreshInterval time.Duration
// Capacity of the queue for notifications to be sent to the Alertmanager.
NotificationQueueCapacity int
// HTTP timeout duration when sending notifications to the Alertmanager.
NotificationTimeout time.Duration
}
Config is the configuration for the recording rules server.
func (*Config) RegisterFlags ¶
RegisterFlags adds the flags required to config this to the given FlagSet
type Pusher ¶
type Pusher interface {
Push(context.Context, *client.WriteRequest) (*client.WriteResponse, error)
}
Pusher is an ingester server that accepts pushes.
type Ruler ¶
type Ruler struct {
// contains filtered or unexported fields
}
Ruler evaluates rules.
func NewRuler ¶
func NewRuler(cfg Config, d *distributor.Distributor, c *chunk.Store) (*Ruler, error)
NewRuler creates a new ruler from a distributor and chunk store.
type ScheduledItem ¶
type ScheduledItem interface {
Key() string
// Scheduled returns the earliest possible time the time is available for
// dequeueing.
Scheduled() time.Time
}
ScheduledItem is an item in a queue of scheduled items.
type SchedulingQueue ¶
type SchedulingQueue struct {
// contains filtered or unexported fields
}
SchedulingQueue is like a priority queue, but the first item is the oldest scheduled item. Items are only able to be dequeued after the time they are scheduled to be run.
func NewSchedulingQueue ¶
func NewSchedulingQueue(clock clockwork.Clock) *SchedulingQueue
NewSchedulingQueue makes a new scheduling queue.
func (*SchedulingQueue) Close ¶
func (sq *SchedulingQueue) Close()
Close the scheduling queue. No more items can be added. Items can be dequeued until there are none left.
func (*SchedulingQueue) Dequeue ¶
func (sq *SchedulingQueue) Dequeue() ScheduledItem
Dequeue takes an item from the queue. If there are no items, or the first item isn't ready to be scheduled, it blocks. If there queue is closed, this will return nil.
func (*SchedulingQueue) Enqueue ¶
func (sq *SchedulingQueue) Enqueue(item ScheduledItem)
Enqueue schedules an item for later Dequeueing.
Source Files