Documentation ¶
Index ¶
- Variables
- func BindFlags(flags *pflag.FlagSet)
- func CheckSummary(ctx DBContext, checkID string) (*models.CheckSummary, error)
- func DefaultGormConfig() *gorm.Config
- func Delete(ctx dutyContext.Context, model Table) error
- func DeleteNotificationSendHistory(ctx DBContext, days int) (int64, error)
- func FindCachedAgent(ctx DBContext, id string) (*models.Agent, error)
- func FindCachedCanary(ctx DBContext, id string) (*models.Canary, error)
- func FindCachedCheck(ctx DBContext, id string) (*models.Check, error)
- func FindCachedComponent(ctx DBContext, id string) (*models.Component, error)
- func FindCachedConfig(ctx DBContext, id string) (*models.ConfigItem, error)
- func FindCachedIncident(ctx DBContext, id string) (*models.Incident, error)
- func FindChecks(ctx context.Context, resourceSelectors types.ResourceSelectors, ...) (components []models.Check, err error)
- func FindChecksByLabel(ctx context.Context, labelSelector string, opts ...FindOption) (components []models.Check, err error)
- func FindComponents(ctx context.Context, resourceSelectors types.ResourceSelectors, ...) (components []models.Component, err error)
- func FindComponentsByField(ctx context.Context, fieldSelector string, opts ...FindOption) ([]models.Component, error)
- func FindComponentsByLabel(ctx context.Context, labelSelector string, opts ...FindOption) (components []models.Component, err error)
- func FindPerson(ctx DBContext, identifier string, opts ...GetterOption) (*models.Person, error)
- func FindTeam(ctx DBContext, identifier string, opts ...GetterOption) (*models.Team, error)
- func GetComponent(ctx gocontext.Context, db *gorm.DB, id string) (*models.Component, error)
- func GetConfigMapFromCache(c kubernetes.Interface, namespace, name, key string) (string, error)
- func GetEnvStringFromCache(c kubernetes.Interface, env string, namespace string) (string, error)
- func GetEnvValueFromCache(c kubernetes.Interface, input types.EnvVar, namespace string) (string, error)
- func GetSecretFromCache(c kubernetes.Interface, namespace, name, key string) (string, error)
- func InitDB(connection string, migrateOpts *migrate.MigrateOptions) (*dutyContext.Context, error)
- func LookupComponents(ctx context.Context, lookup LookupSpec, labels map[string]string, ...) ([]uuid.UUID, error)
- func LookupConfigs(ctx context.Context, lookup LookupSpec, labels map[string]string, ...) ([]uuid.UUID, error)
- func Migrate(connection string, opts *migrate.MigrateOptions) error
- func NewDB(connection string) (*sql.DB, error)
- func NewGorm(connection string, config *gorm.Config) (*gorm.DB, error)
- func NewPgxPool(connection string) (*pgxpool.Pool, error)
- func Now() clause.Expr
- func ParsePropertiesFile(filename string) (map[string]string, error)
- func QueryCheckSummary(ctx gocontext.Context, dbpool *pgxpool.Pool, opts ...query.CheckSummaryOptions) ([]models.CheckSummary, error)
- func SetupDB(connection string, migrateOpts *migrate.MigrateOptions) (gormDB *gorm.DB, pgxpool *pgxpool.Pool, err error)
- func UpdateProperties(ctx context.Context, props map[string]string) error
- func UpdatePropertiesFromFile(ctx context.Context, filename string) error
- func UpdateProperty(ctx context.Context, key, value string) error
- type DBContext
- type FindOption
- type GetterOption
- type GetterOptions
- type Lookup
- type LookupEvalResult
- type LookupSpec
- type Table
- type TopologyOptions
- type TopologyResponse
Constants ¶
This section is empty.
Variables ¶
var DefaultQueryTimeout = 30 * time.Second
var LocalFilter = "deleted_at is NULL AND agent_id = '00000000-0000-0000-0000-000000000000' OR agent_id IS NULL"
var LogLevel string
LogLevel is the log level for gorm logger
Functions ¶
func CheckSummary ¶ added in v1.0.164
func CheckSummary(ctx DBContext, checkID string) (*models.CheckSummary, error)
deprecated use query.CheckSummaryByID
func DefaultGormConfig ¶ added in v1.0.6
func DeleteNotificationSendHistory ¶ added in v1.0.181
DeleteNotificationSendHistory deletes notification send history older than the given duration.
func FindCachedAgent ¶ added in v1.0.172
func FindCachedCanary ¶ added in v1.0.172
func FindCachedCheck ¶ added in v1.0.172
func FindCachedComponent ¶ added in v1.0.172
func FindCachedConfig ¶ added in v1.0.172
func FindCachedConfig(ctx DBContext, id string) (*models.ConfigItem, error)
func FindCachedIncident ¶ added in v1.0.172
func FindChecks ¶ added in v1.0.253
func FindChecks(ctx context.Context, resourceSelectors types.ResourceSelectors, opts ...FindOption) (components []models.Check, err error)
func FindChecksByLabel ¶ added in v1.0.253
func FindComponents ¶ added in v1.0.253
func FindComponents(ctx context.Context, resourceSelectors types.ResourceSelectors, opts ...FindOption) (components []models.Component, err error)
func FindComponentsByField ¶ added in v1.0.253
func FindComponentsByLabel ¶ added in v1.0.253
func FindPerson ¶ added in v1.0.178
FindPerson looks up a person by the given identifier which can either be
- UUID
func FindTeam ¶ added in v1.0.178
FindTeam looks up a team by the given identifier which can either be
- UUID
- team name
func GetComponent ¶ added in v1.0.45
deprecated use query.GetComponent
func GetConfigMapFromCache ¶ added in v1.0.45
func GetConfigMapFromCache(c kubernetes.Interface, namespace, name, key string) (string, error)
deprecated use the methods in the context package
func GetEnvStringFromCache ¶ added in v1.0.45
deprecated use the methods in the context package
func GetEnvValueFromCache ¶ added in v1.0.45
func GetEnvValueFromCache(c kubernetes.Interface, input types.EnvVar, namespace string) (string, error)
deprecated use the methods in the context package
func GetSecretFromCache ¶ added in v1.0.45
func GetSecretFromCache(c kubernetes.Interface, namespace, name, key string) (string, error)
deprecated use the methods in the context package
func InitDB ¶ added in v1.0.207
func InitDB(connection string, migrateOpts *migrate.MigrateOptions) (*dutyContext.Context, error)
func LookupComponents ¶ added in v1.0.236
func LookupConfigs ¶ added in v1.0.236
func NewGorm ¶
creates a new Gorm DB connection using the global pgx connection pool, must be called after NewPgxPool
func ParsePropertiesFile ¶ added in v1.0.245
func QueryCheckSummary ¶ added in v1.0.34
func QueryCheckSummary(ctx gocontext.Context, dbpool *pgxpool.Pool, opts ...query.CheckSummaryOptions) ([]models.CheckSummary, error)
deprecated use query.CheckSummary
func SetupDB ¶ added in v1.0.141
func SetupDB(connection string, migrateOpts *migrate.MigrateOptions) (gormDB *gorm.DB, pgxpool *pgxpool.Pool, err error)
SetupDB runs migrations for the connection and returns a gorm.DB and a pgxpool.Pool
func UpdateProperties ¶ added in v1.0.245
func UpdatePropertiesFromFile ¶ added in v1.0.245
Types ¶
type FindOption ¶ added in v1.0.253
func PickColumns ¶ added in v1.0.253
func PickColumns(columns ...string) FindOption
type GetterOption ¶ added in v1.0.178
type GetterOption uint8
const (
GetterOptionNoCache GetterOption = iota + 1
)
type GetterOptions ¶ added in v1.0.178
type GetterOptions []GetterOption
func (GetterOptions) IsSet ¶ added in v1.0.178
func (t GetterOptions) IsSet(option GetterOption) bool
type Lookup ¶ added in v1.0.236
type Lookup struct { // Expr is a cel-expression. Expr string `json:"expr,omitempty" yaml:"expr,omitempty"` // Value is the static value to use. Value string `json:"value,omitempty" yaml:"value,omitempty"` // Label specifies the key to lookup on the label. Label string `json:"label,omitempty" yaml:"label,omitempty"` }
Lookup specifies the type of lookup to perform.
type LookupEvalResult ¶ added in v1.0.236
LookupEvalResult is the result of evaluation of a LookupSpec.
type LookupSpec ¶ added in v1.0.236
type LookupSpec struct { Name Lookup `json:"name,omitempty" yaml:"name,omitempty"` Namespace Lookup `json:"namespace,omitempty" yaml:"namespace,omitempty"` Type Lookup `json:"type,omitempty" yaml:"type,omitempty"` }
LookupSpec defines a tuple of fields to lookup.
func (*LookupSpec) Eval ¶ added in v1.0.236
func (t *LookupSpec) Eval(labels map[string]string, envVar map[string]any) (*LookupEvalResult, error)
Eval evaluates all the fields in the lookup spec based on labels and environment variables. Returns nil if any non-empty lookup evaluates to an empty value.
type TopologyOptions ¶ added in v1.0.11
type TopologyOptions = query.TopologyOptions
type TopologyResponse ¶ added in v1.0.71
type TopologyResponse = query.TopologyResponse
func QueryTopology ¶ added in v1.0.24
func QueryTopology(ctx gocontext.Context, dbpool *pgxpool.Pool, params TopologyOptions) (*TopologyResponse, error)
deprecated use query.Topology