store

type Collection struct {
	Databases    string           // SQL Query that returns a list of databases to scope the query.
	Enabled      bool             // Enabled is true if the metrics needs to be collected.
	Frequency    pgtype.Interval  // Frequency determines how often the metrics are collected.
	Labels       []string         // Labels provide dimensions to the metrics.
	LastModified pgtype.Timestamp // LastModified the last time the collection was updated in the database.
	MaxResult    int              // Maximun number of results to be retrieved from the database.
	Metrics      []Metric         // Metrics available in this collection
	Name         string           // Name of the collection
	Query        string           // Query is the SQL query used to retrieve the metric values.
	Scope        Scope            // Scope of the collection (global vs local)
}

type Histogram struct {
	Enabled      bool             // Enabled is true if the histograms needs to be translated.
	Name         string           // Name of the config rule
	Bins         int              // Bins is the number of linear bins with a logarithm bucket.
	Start        int              // Start is the minimun value in the histogram
	End          int              // End is the maximum value in the histogram
	Regex        string           // Regex to match for incoming histograms to be converted.
	LastModified pgtype.Timestamp // LastModified when the definition was updated.
}

type Kind string

type LogFormat string

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

type Metric struct {
	Name string // Name of the metric, which represents the property being measured.
	Kind Kind   // Kind is the type of the metric.
	Help string // Help to used to describe the metric.
}

type Pattern struct {
	Help    string // Help to used to describe the pattern.
	Name    string // Name of the pattern, which represents the property being measured.
	Exclude string // Regex for excluding lines.
	Regex   string // Regex to match.
}

type Scan struct {
	Enabled      bool             // Enabled is true if the patterns needs to be collected.
	Format       LogFormat        // Format of the log.
	LastModified pgtype.Timestamp // LastModified the last time the log was updated in the database.
	Name         string           // Name of the log
	Path         string           // Location of the log file
	Patterns     []Pattern        // The patterns to look for
}

type Scope string

type Store interface {
	// DeleteCollection deletes the collection with the given name from the store.
	DeleteCollection(ctx context.Context, name string) error
	// DeleteHistogram deletes the histogram with the given name from the store.
	DeleteHistogram(ctx context.Context, regex string) error
	// DeleteScan deletes the log target with the given name from the store.
	DeleteScan(ctx context.Context, name string) error
	// GetCollection returns the collection with the given name.
	GetCollection(ctx context.Context, name string) (*Collection, error)
	// GetCollectionNames returns the collection names present in the store.
	GetCollectionNames(ctx context.Context) ([]string, error)
	// GetHistogram returns the histogram with the given name.
	GetHistogram(ctx context.Context, name string) (*Histogram, error)
	// GetHistogramNames returns the histogram names present in the store.
	GetHistogramNames(ctx context.Context) ([]string, error)
	// GetMetrics returns the metrics associated to a collection.
	GetMetrics(ctx context.Context, name string) ([]Metric, error)
	// GetScan returns the log target with the given name.
	GetScan(ctx context.Context, name string) (*Scan, error)
	// GetScanNames returns the log target names present in the store.
	GetScanNames(ctx context.Context) ([]string, error)
	// GetScanPatterns returns the patterns associated to a log target.
	GetScanPatterns(ctx context.Context, name string) ([]Pattern, error)
	// Init initializes the schema in the database
	Init(ctx context.Context) error
	// IsMainNode returns true if the current node is the main node.
	// A main node is a node with max(id) in the cluster.
	IsMainNode(ctx context.Context, lastUpdated time.Time) (bool, error)
	// PutCollection adds a collection configuration to the database.
	PutCollection(ctx context.Context, collection *Collection) error
	// PutHistogram adds a histogram configuration to the database.
	PutHistogram(ctx context.Context, histogram *Histogram) error
	// PutScan adds a log target configuration to the database.
	PutScan(ctx context.Context, scan *Scan) error
}