db

package

Go to main page

Versions in this module

v0

v0.3.0

Jan 17, 2025

Changes in this version

type ClickHouseProvider

+ func (p *ClickHouseProvider) GetDashboardUsage(ctx context.Context, serie string, page, pageSize int) (*PagedResult, error)

+ func (p *ClickHouseProvider) GetQueriesBySerieName(ctx context.Context, serieName string, page int, pageSize int) (*PagedResult, error)

+ func (p *ClickHouseProvider) GetRulesUsage(ctx context.Context, serie string, kind string, page int, pageSize int) (*PagedResult, error)

+ func (p *ClickHouseProvider) InsertDashboardUsage(ctx context.Context, dashboardUsage []DashboardUsage) error

+ func (p *ClickHouseProvider) InsertRulesUsage(ctx context.Context, rulesUsage []RulesUsage) error

+ type DashboardUsage struct

+ CreatedAt time.Time

+ Id string

+ Name string

+ Serie string

+ URL string

+ type PagedResult struct

+ Data interface{}

+ Total int

+ TotalPages int

type PostGreSQLProvider

+ func (p *PostGreSQLProvider) GetDashboardUsage(ctx context.Context, serie string, page, pageSize int) (*PagedResult, error)

+ func (p *PostGreSQLProvider) GetQueriesBySerieName(ctx context.Context, serieName string, page int, pageSize int) (*PagedResult, error)

+ func (p *PostGreSQLProvider) GetRulesUsage(ctx context.Context, serie string, kind string, page int, pageSize int) (*PagedResult, error)

+ func (p *PostGreSQLProvider) InsertDashboardUsage(ctx context.Context, dashboardUsage []DashboardUsage) error

+ func (p *PostGreSQLProvider) InsertRulesUsage(ctx context.Context, rulesUsage []RulesUsage) error

type Provider

+ GetDashboardUsage func(ctx context.Context, serieName string, page int, pageSize int) (*PagedResult, error)

+ GetQueriesBySerieName func(ctx context.Context, serieName string, page int, pageSize int) (*PagedResult, error)

+ GetRulesUsage func(ctx context.Context, serie string, kind string, page int, pageSize int) (*PagedResult, error)

+ InsertDashboardUsage func(ctx context.Context, dashboardUsage []DashboardUsage) error

+ InsertRulesUsage func(ctx context.Context, rulesUsage []RulesUsage) error

+ type QueriesBySerieNameResult struct

+ AvgDuration float64

+ AvgPeakySamples float64

+ MaxPeakSamples int

+ QueryParam string

+ TS time.Time

+ type RuleUsageKind string

+ const RuleUsageKindAlert

+ const RuleUsageKindRecord

+ type RulesUsage struct

+ CreatedAt time.Time

+ Expression string

+ GroupName string

+ Kind string

+ Labels []string

+ Name string

+ Serie string

type SQLiteProvider

+ func (p *SQLiteProvider) GetDashboardUsage(ctx context.Context, serie string, page, pageSize int) (*PagedResult, error)

+ func (p *SQLiteProvider) GetQueriesBySerieName(ctx context.Context, serieName string, page int, pageSize int) (*PagedResult, error)

+ func (p *SQLiteProvider) GetRulesUsage(ctx context.Context, serie string, kind string, page, pageSize int) (*PagedResult, error)

+ func (p *SQLiteProvider) InsertDashboardUsage(ctx context.Context, dashboardUsage []DashboardUsage) error

+ func (p *SQLiteProvider) InsertRulesUsage(ctx context.Context, rulesUsage []RulesUsage) error

v0.2.0

Oct 31, 2024

Changes in this version

+ const SQLite

+ func RegisterSqliteFlags(flagSet *flag.FlagSet)

+ func ValidateSQLQuery(query string) error

type ClickHouseProvider

+ func (p *ClickHouseProvider) QueryShortCuts() []QueryShortCut

type PostGreSQLProvider

+ func (p *PostGreSQLProvider) QueryShortCuts() []QueryShortCut

type Provider

+ QueryShortCuts func() []QueryShortCut

+ type QueryShortCut struct

+ Query string

+ Title string

+ type SQLiteProvider struct

+ func (p *SQLiteProvider) Close() error

+ func (p *SQLiteProvider) Insert(ctx context.Context, queries []Query) error

+ func (p *SQLiteProvider) Query(ctx context.Context, query string) (*QueryResult, error)

+ func (p *SQLiteProvider) QueryShortCuts() []QueryShortCut

+ func (p *SQLiteProvider) WithDB(f func(db *sql.DB))

+ type SQLiteProviderConfig struct

+ Path string

v0.1.0

Oct 14, 2024

Changes in this version

+ const ClickHouse

+ const PostGreSQL

+ const QueryTypeInstant

+ const QueryTypeRange

+ func RegisterClickHouseFlags(flagSet *flag.FlagSet)

+ func RegisterPostGreSQLFlags(flagSet *flag.FlagSet)

+ type ClickHouseProvider struct

+ func (c *ClickHouseProvider) Close() error

+ func (c *ClickHouseProvider) Insert(ctx context.Context, queries []Query) error

+ func (c *ClickHouseProvider) Query(ctx context.Context, query string) (*QueryResult, error)

+ func (c *ClickHouseProvider) WithDB(f func(db *sql.DB))

+ type ClickHouseProviderConfig struct

+ Addr string

+ Auth clickhouse.Auth

+ DiamTimeout time.Duration

+ type DatabaseProvider string

+ type LabelMatchers []map[string]string

+ type PostGreSQLProvider struct

+ func (p *PostGreSQLProvider) Close() error

+ func (p *PostGreSQLProvider) Insert(ctx context.Context, queries []Query) error

+ func (p *PostGreSQLProvider) Query(ctx context.Context, query string) (*QueryResult, error)

+ func (p *PostGreSQLProvider) WithDB(f func(db *sql.DB))

+ type PostGreSQLProviderConfig struct

+ Addr string

+ Database string

+ DiamTimeout time.Duration

+ Password string

+ Port int

+ SSLMode string

+ User string

+ type Provider interface

+ Close func() error

+ Insert func(ctx context.Context, queries []Query) error

+ Query func(ctx context.Context, query string) (*QueryResult, error)

+ WithDB func(func(db *sql.DB))

+ func GetDbProvider(ctx context.Context, dbProvider DatabaseProvider) (Provider, error)

+ type Query struct

+ BodySize int

+ Duration time.Duration

+ End time.Time

+ Fingerprint string

+ LabelMatchers LabelMatchers

+ PeakSamples int

+ QueryParam string

+ Start time.Time

+ StatusCode int

+ Step float64

+ TS time.Time

+ TimeParam time.Time

+ TotalQueryableSamples int

+ Type QueryType

+ type QueryResult struct

+ Columns []string

+ Data []map[string]interface{}

+ type QueryType string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL