service

Documentation

Index

• type CacheOption
  • func WithGzip() CacheOption
• type CloudStorageCache
  • 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
  • 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
  • func NewNotifyPubSub(client interfaces.PubSubClient, topic string) *NotifyPubSub
  • func (x *NotifyPubSub) Publish(ctx context.Context, alert model.Alert) error
• type NotifyWriter
  • func NewNotifyWriter(w io.Writer) *NotifyWriter
  • func (x *NotifyWriter) Publish(ctx context.Context, alert model.Alert) error
• type Policy
  • 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

Types

type CacheOption

type CacheOption func(opt *cacheOptions)

func WithGzip

func WithGzip() CacheOption

type CloudStorageCache

type CloudStorageCache struct {
	// contains filtered or unexported fields
}

func NewCloudStorageCache

func NewCloudStorageCache(id model.JobID, bucket string, prefix string, client interfaces.CloudStorageClient, options ...CacheOption) *CloudStorageCache

func (*CloudStorageCache) NewReader

func (x *CloudStorageCache) NewReader(ctx context.Context, ID model.QueryID) (io.ReadCloser, error)

func (*CloudStorageCache) NewWriter

func (x *CloudStorageCache) NewWriter(ctx context.Context, ID model.QueryID) (io.WriteCloser, error)

func (*CloudStorageCache) String

func (x *CloudStorageCache) String() string

type FileCache

type FileCache struct {
	// contains filtered or unexported fields
}

func NewFileCache

func NewFileCache(id model.JobID, baseDir string, options ...CacheOption) (*FileCache, error)

func (*FileCache) NewReader

func (x *FileCache) NewReader(_ context.Context, ID model.QueryID) (io.ReadCloser, error)

func (*FileCache) NewWriter

func (x *FileCache) NewWriter(_ context.Context, ID model.QueryID) (io.WriteCloser, error)

func (*FileCache) String

func (x *FileCache) String() string

type NotifyPubSub

type NotifyPubSub struct {
	// contains filtered or unexported fields
}

func NewNotifyPubSub

func NewNotifyPubSub(client interfaces.PubSubClient, topic string) *NotifyPubSub

func (*NotifyPubSub) Publish

func (x *NotifyPubSub) Publish(ctx context.Context, alert model.Alert) error

type NotifyWriter

type NotifyWriter struct {
	// contains filtered or unexported fields
}

func NewNotifyWriter

func NewNotifyWriter(w io.Writer) *NotifyWriter

func (*NotifyWriter) Publish

func (x *NotifyWriter) Publish(ctx context.Context, alert model.Alert) error

type Policy

type Policy struct {
	// contains filtered or unexported fields
}

func NewPolicy

func NewPolicy(client interfaces.PolicyClient, selector model.PolicySelector) (*Policy, error)

func (*Policy) Client

func (x *Policy) Client() interfaces.PolicyClient

func (*Policy) MetadataSet

func (x *Policy) MetadataSet() model.PolicyMetadataSet

func (*Policy) SelectRequiredQueries

func (x *Policy) SelectRequiredQueries(base model.Queries) model.Queries