impl

func ConvertProtoFilters ¶ added in v2.0.12

func ConvertProtoFilters(protoFilters []*common.Filter, allowedColumns sets.Set[string]) (interfaces.Filter, error)

ConvertProtoFilters converts proto filters to our Filter interfaces. allowedColumns is checked to prevent SQL injection via user-supplied field names.

func GetSortByFieldsV2 ¶

func GetSortByFieldsV2(request *common.ListRequest, allowedSortColumns sets.Set[string]) ([]interfaces.SortParameter, error)

GetSortByFieldsV2 converts proto sort fields to our SortParameter interfaces with validation

func NewActionRepo ¶

func NewActionRepo(db *sqlx.DB, dbConfig database.DbConfig) (interfaces.ActionRepo, error)

NewActionRepo creates a new PostgreSQL repository

func NewDeployedByFilter ¶

func NewDeployedByFilter(deployedBy string) interfaces.Filter

NewDeployedByFilter creates a filter for deployed_by = value

func NewEqualFilter ¶

func NewEqualFilter(field string, value interface{}) interfaces.Filter

NewEqualFilter creates a filter for field = value

func NewListResourceInputFromProto ¶

func NewListResourceInputFromProto(request *common.ListRequest, allowedColumns sets.Set[string]) (interfaces.ListResourceInput, error)

NewListResourceInputFromProto converts a proto ListRequest to ListResourceInput for querying DB

func NewNotEqualFilter ¶ added in v2.0.8

func NewNotEqualFilter(field string, value interface{}) interfaces.Filter

NewNotEqualFilter creates a filter for field != value.

func NewProjectIdFilter ¶

func NewProjectIdFilter(projectId *common.ProjectIdentifier) interfaces.Filter

NewProjectIdFilter creates a filter for project identifier (project, domain)

func NewProjectRepo ¶ added in v2.0.8

func NewProjectRepo(db *sqlx.DB) interfaces.ProjectRepo

func NewSortParameter ¶

func NewSortParameter(field string, order interfaces.SortOrder) interfaces.SortParameter

NewSortParameter creates a new sort parameter

func NewTaskNameFilter ¶

func NewTaskNameFilter(taskName *task.TaskName) interfaces.Filter

NewTaskNameFilter creates a filter for task name (project, domain, name)

func NewTaskRepo ¶

func NewTaskRepo(db *sqlx.DB) interfaces.TaskRepo

func NewTriggerRepo ¶ added in v2.0.12

func NewTriggerRepo(db *sqlx.DB) interfaces.TriggerRepo

func ParseStringFilters ¶ added in v2.0.8

func ParseStringFilters(filterString string, allowedColumns sets.Set[string]) (interfaces.Filter, error)

ParseStringFilters parses a compact filter DSL like eq(state,1)+contains(name,foo).