Documentation ¶
Index ¶
- Variables
- func BindFlags(flags *pflag.FlagSet)
- func BindGoFlags()
- func CheckSummary(ctx context.Context, checkID string) (*models.CheckSummary, error)
- func DefaultGormConfig() *gorm.Config
- func Delete(ctx dutyContext.Context, model Table) 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 HasMigrationsRun(ctx context.Context, pool *pgxpool.Pool) (bool, error)
- func InitDB(connection string, migrateOpts *migrate.MigrateOptions) (*dutyContext.Context, error)
- func LookupComponents(ctx context.Context, lookup RelationshipSelectorTemplate, ...) ([]uuid.UUID, error)
- func LookupConfigs(ctx context.Context, lookup RelationshipSelectorTemplate, ...) ([]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 QueryCheckSummary(ctx context.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)
- type FindOption
- type Lookup
- type RelationshipSelector
- type RelationshipSelectorTemplate
- func (in *RelationshipSelectorTemplate) DeepCopy() *RelationshipSelectorTemplate
- func (in *RelationshipSelectorTemplate) DeepCopyInto(out *RelationshipSelectorTemplate)
- func (t *RelationshipSelectorTemplate) Eval(labels map[string]string, env map[string]any) (*RelationshipSelector, error)
- func (t *RelationshipSelectorTemplate) IsEmpty() bool
- 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 BindGoFlags ¶ added in v1.0.310
func BindGoFlags()
func CheckSummary ¶ added in v1.0.164
deprecated use query.CheckSummaryByID
func DefaultGormConfig ¶ added in v1.0.6
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 HasMigrationsRun ¶ added in v1.0.447
HasMigrationsRun performs a rudimentary check to see if the migrations have run at least once.
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 QueryCheckSummary ¶ added in v1.0.34
func QueryCheckSummary(ctx context.Context, dbpool *pgxpool.Pool, opts ...query.CheckSummaryOptions) ([]models.CheckSummary, error)
deprecated use query.CheckSummary
Types ¶
type FindOption ¶ added in v1.0.253
func PickColumns ¶ added in v1.0.253
func PickColumns(columns ...string) FindOption
func WhereClause ¶ added in v1.0.287
func WhereClause(query any, args ...any) FindOption
type Lookup ¶ added in v1.0.236
type Lookup struct { Expr string `json:"expr,omitempty"` Value string `json:"value,omitempty"` Label string `json:"label,omitempty"` }
Lookup offers different ways to specify a lookup value
+kubebuilder:object:generate=true
func (*Lookup) DeepCopy ¶ added in v1.0.532
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Lookup.
func (*Lookup) DeepCopyInto ¶ added in v1.0.532
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RelationshipSelector ¶ added in v1.0.532
type RelationshipSelector struct { ID string `json:"id,omitempty"` ExternalID string `json:"external_id,omitempty"` Name string `json:"name,omitempty"` Namespace string `json:"namespace,omitempty"` Type string `json:"type,omitempty"` Agent string `json:"agent,omitempty"` Labels map[string]string `json:"labels,omitempty"` // Scope is the id parent of the resource to select. // Example: For config items, the scope is the scraper id // - for checks, it's canaries and // - for components, it's topology. Scope string `json:"scope,omitempty"` }
+kubebuilder:object:generate=true RelationshipSelector is the evaluated output of RelationshipSelectorTemplate.
func (*RelationshipSelector) DeepCopy ¶ added in v1.0.532
func (in *RelationshipSelector) DeepCopy() *RelationshipSelector
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RelationshipSelector.
func (*RelationshipSelector) DeepCopyInto ¶ added in v1.0.532
func (in *RelationshipSelector) DeepCopyInto(out *RelationshipSelector)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RelationshipSelector) IsEmpty ¶ added in v1.0.532
func (t *RelationshipSelector) IsEmpty() bool
func (*RelationshipSelector) ToResourceSelector ¶ added in v1.0.532
func (t *RelationshipSelector) ToResourceSelector() types.ResourceSelector
type RelationshipSelectorTemplate ¶ added in v1.0.532
type RelationshipSelectorTemplate struct { ID Lookup `json:"id,omitempty"` ExternalID Lookup `json:"external_id,omitempty"` Name Lookup `json:"name,omitempty"` Namespace Lookup `json:"namespace,omitempty"` Type Lookup `json:"type,omitempty"` // Agent can be one of // - agent id // - agent name // - 'self' (no agent) Agent Lookup `json:"agent,omitempty"` // Scope is the id of the parent of the resource to select. // Example: For config items, the scope is the scraper id // - for checks, it's canaries and // - for components, it's topology. // If left empty, the scope is the requester's scope. // Use `all` to disregard scope. Scope Lookup `json:"scope,omitempty"` Labels map[string]string `json:"labels,omitempty"` }
+kubebuilder:object:generate=true
func (*RelationshipSelectorTemplate) DeepCopy ¶ added in v1.0.532
func (in *RelationshipSelectorTemplate) DeepCopy() *RelationshipSelectorTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RelationshipSelectorTemplate.
func (*RelationshipSelectorTemplate) DeepCopyInto ¶ added in v1.0.532
func (in *RelationshipSelectorTemplate) DeepCopyInto(out *RelationshipSelectorTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RelationshipSelectorTemplate) Eval ¶ added in v1.0.532
func (t *RelationshipSelectorTemplate) Eval(labels map[string]string, env map[string]any) (*RelationshipSelector, error)
Eval evaluates the template and returns a RelationshipSelector. If any of the filter returns an empty value, the evaluation results to a nil selector. i.e. if a lookup is non-empty, it must return a non-empty value.
func (*RelationshipSelectorTemplate) IsEmpty ¶ added in v1.0.532
func (t *RelationshipSelectorTemplate) IsEmpty() bool
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
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
hack
|
|
migrate
Module
|
|
pkg
|
|
kube/labels
Package labels implements a simple label system, parsing and matching selectors with sets of labels.
|
Package labels implements a simple label system, parsing and matching selectors with sets of labels. |