impl

Documentation

Index

• func ConvertProtoFilters(protoFilters []*common.Filter, allowedColumns sets.Set[string]) (interfaces.Filter, error)
• func GetSortByFieldsV2(request *common.ListRequest, allowedSortColumns sets.Set[string]) ([]interfaces.SortParameter, error)
• func NewActionRepo(db *sqlx.DB, dbConfig database.DbConfig) (interfaces.ActionRepo, error)
• func NewDeployedByFilter(deployedBy string) interfaces.Filter
• func NewEqualFilter(field string, value interface{}) interfaces.Filter
• func NewIsRootActionFilter() interfaces.Filter
• func NewListResourceInputFromProto(request *common.ListRequest, allowedColumns sets.Set[string]) (interfaces.ListResourceInput, error)
• func NewNotEqualFilter(field string, value interface{}) interfaces.Filter
• func NewProjectIdFilter(projectId *common.ProjectIdentifier) interfaces.Filter
• func NewProjectRepo(db *sqlx.DB) interfaces.ProjectRepo
• func NewRunActionsFilter(runID *common.RunIdentifier) interfaces.Filter
• func NewRunTaskIdFilter(taskId *task.TaskIdentifier) interfaces.Filter
• func NewRunTaskNameFilter(taskName *task.TaskName) interfaces.Filter
• func NewSortParameter(field string, order interfaces.SortOrder) interfaces.SortParameter
• func NewTaskNameFilter(taskName *task.TaskName) interfaces.Filter
• func NewTaskRepo(db *sqlx.DB) interfaces.TaskRepo
• func NewTriggerNameFilter(triggerName *common.TriggerName) interfaces.Filter
• func NewTriggerRepo(db *sqlx.DB) interfaces.TriggerRepo
• func ParseStringFilters(filterString string, allowedColumns sets.Set[string]) (interfaces.Filter, error)

Functions

func ConvertProtoFilters

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. It prefers sort_by_fields; if empty, it falls back to the deprecated sort_by field.

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 NewIsRootActionFilter

func NewIsRootActionFilter() interfaces.Filter

NewIsRootActionFilter creates a filter for root actions (runs) only.

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

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

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

func NewRunActionsFilter

func NewRunActionsFilter(runID *common.RunIdentifier) interfaces.Filter

NewRunActionsFilter creates a filter for all actions belonging to a specific run.

func NewRunTaskIdFilter

func NewRunTaskIdFilter(taskId *task.TaskIdentifier) interfaces.Filter

NewRunTaskIdFilter creates a filter matching runs by full task identifier on the actions table.

func NewRunTaskNameFilter

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

NewRunTaskNameFilter creates a filter matching runs by task name columns on the actions table.

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 on the tasks table (project, domain, name).

func NewTaskRepo

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

func NewTriggerNameFilter

func NewTriggerNameFilter(triggerName *common.TriggerName) interfaces.Filter

NewTriggerNameFilter creates a filter matching runs by trigger_name on the actions table.

func NewTriggerRepo

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

func ParseStringFilters

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

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