Versions in this module Expand all Collapse all v0 v0.0.3 Dec 11, 2024 v0.0.2 Oct 31, 2024 Changes in this version + type CacheOption func(opt *cacheOptions) + func WithGzip() CacheOption + type CloudStorageCache struct + func NewCloudStorageCache(id model.JobID, bucket string, prefix string, ...) *CloudStorageCache + func (x *CloudStorageCache) NewReader(ctx context.Context, ID model.QueryID) (io.ReadCloser, error) + func (x *CloudStorageCache) NewWriter(ctx context.Context, ID model.QueryID) (io.WriteCloser, error) + func (x *CloudStorageCache) String() string + type FileCache struct + func NewFileCache(id model.JobID, baseDir string, options ...CacheOption) (*FileCache, error) + func (x *FileCache) NewReader(_ context.Context, ID model.QueryID) (io.ReadCloser, error) + func (x *FileCache) NewWriter(_ context.Context, ID model.QueryID) (io.WriteCloser, error) + func (x *FileCache) String() string + type NotifyPubSub struct + func NewNotifyPubSub(client interfaces.PubSubClient, topic string) *NotifyPubSub + func (x *NotifyPubSub) Publish(ctx context.Context, alert model.Alert) error + type NotifyWriter struct + func NewNotifyWriter(w io.Writer) *NotifyWriter + func (x *NotifyWriter) Publish(ctx context.Context, alert model.Alert) error + type Policy struct + func NewPolicy(client interfaces.PolicyClient, selector model.PolicySelector) (*Policy, error) + func (x *Policy) Client() interfaces.PolicyClient + func (x *Policy) MetadataSet() model.PolicyMetadataSet + func (x *Policy) SelectRequiredQueries(base model.Queries) model.Queries
Go to main page