Versions in this module Expand all Collapse all v1 v1.0.18-beta.1 Apr 20, 2023 v1.0.15 Apr 20, 2023 v1.0.11 Apr 19, 2023 Changes in this version + const Description + const Domain + const ID + const Name + const Project + const ResourceType + const State + const Version + func NewDescriptionEntityRepo(db *gorm.DB, errorTransformer flyteAdminDbErrors.ErrorTransformer, ...) interfaces.DescriptionEntityRepoInterface + func NewExecutionEventRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.ExecutionEventRepoInterface + func NewExecutionRepo(db *gorm.DB, errorTransformer adminErrors.ErrorTransformer, ...) interfaces.ExecutionRepoInterface + func NewLaunchPlanRepo(db *gorm.DB, errorTransformer adminErrors.ErrorTransformer, ...) interfaces.LaunchPlanRepoInterface + func NewNamedEntityRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.NamedEntityRepoInterface + func NewNodeExecutionEventRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.NodeExecutionEventRepoInterface + func NewNodeExecutionRepo(db *gorm.DB, errorTransformer adminErrors.ErrorTransformer, ...) interfaces.NodeExecutionRepoInterface + func NewProjectRepo(db *gorm.DB, errorTransformer flyteAdminDbErrors.ErrorTransformer, ...) interfaces.ProjectRepoInterface + func NewResourceRepo(db *gorm.DB, errorTransformer flyteAdminDbErrors.ErrorTransformer, ...) interfaces.ResourceRepoInterface + func NewSignalRepo(db *gorm.DB, errorTransformer flyteAdminDbErrors.ErrorTransformer, ...) interfaces.SignalRepoInterface + func NewTaskExecutionRepo(db *gorm.DB, errorTransformer flyteAdminDbErrors.ErrorTransformer, ...) interfaces.TaskExecutionRepoInterface + func NewTaskRepo(db *gorm.DB, errorTransformer flyteAdminDbErrors.ErrorTransformer, ...) interfaces.TaskRepoInterface + func NewWorkflowRepo(db *gorm.DB, errorTransformer flyteAdminDbErrors.ErrorTransformer, ...) interfaces.WorkflowRepoInterface + func ValidateListInput(input interfaces.ListResourceInput) adminErrors.FlyteAdminError + type DescriptionEntityRepo struct + func (r *DescriptionEntityRepo) Get(ctx context.Context, input interfaces.GetDescriptionEntityInput) (models.DescriptionEntity, error) + func (r *DescriptionEntityRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.DescriptionEntityCollectionOutput, error) + type ExecutionEventRepo struct + func (r *ExecutionEventRepo) Create(ctx context.Context, input models.ExecutionEvent) error + type ExecutionRepo struct + func (r *ExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error) + func (r *ExecutionRepo) Create(ctx context.Context, input models.Execution) error + func (r *ExecutionRepo) Get(ctx context.Context, input interfaces.Identifier) (models.Execution, error) + func (r *ExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.ExecutionCollectionOutput, error) + func (r *ExecutionRepo) Update(ctx context.Context, execution models.Execution) error + type LaunchPlanRepo struct + func (r *LaunchPlanRepo) Create(ctx context.Context, input models.LaunchPlan) error + func (r *LaunchPlanRepo) Get(ctx context.Context, input interfaces.Identifier) (models.LaunchPlan, error) + func (r *LaunchPlanRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.LaunchPlanCollectionOutput, error) + func (r *LaunchPlanRepo) ListLaunchPlanIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (interfaces.LaunchPlanCollectionOutput, error) + func (r *LaunchPlanRepo) SetActive(ctx context.Context, toEnable models.LaunchPlan, toDisable *models.LaunchPlan) error + func (r *LaunchPlanRepo) Update(ctx context.Context, input models.LaunchPlan) error + type NamedEntityRepo struct + func (r *NamedEntityRepo) Get(ctx context.Context, input interfaces.GetNamedEntityInput) (models.NamedEntity, error) + func (r *NamedEntityRepo) List(ctx context.Context, input interfaces.ListNamedEntityInput) (interfaces.NamedEntityCollectionOutput, error) + func (r *NamedEntityRepo) Update(ctx context.Context, input models.NamedEntity) error + type NodeExecutionEventRepo struct + func (r *NodeExecutionEventRepo) Create(ctx context.Context, input models.NodeExecutionEvent) error + type NodeExecutionRepo struct + func (r *NodeExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error) + func (r *NodeExecutionRepo) Create(ctx context.Context, execution *models.NodeExecution) error + func (r *NodeExecutionRepo) Exists(ctx context.Context, input interfaces.NodeExecutionResource) (bool, error) + func (r *NodeExecutionRepo) Get(ctx context.Context, input interfaces.NodeExecutionResource) (models.NodeExecution, error) + func (r *NodeExecutionRepo) GetWithChildren(ctx context.Context, input interfaces.NodeExecutionResource) (models.NodeExecution, error) + func (r *NodeExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.NodeExecutionCollectionOutput, error) + func (r *NodeExecutionRepo) Update(ctx context.Context, nodeExecution *models.NodeExecution) error + type ProjectRepo struct + func (r *ProjectRepo) Create(ctx context.Context, project models.Project) error + func (r *ProjectRepo) Get(ctx context.Context, projectID string) (models.Project, error) + func (r *ProjectRepo) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Project, error) + func (r *ProjectRepo) UpdateProject(ctx context.Context, projectUpdate models.Project) error + type ResourceRepo struct + func (r *ResourceRepo) CreateOrUpdate(ctx context.Context, input models.Resource) error + func (r *ResourceRepo) Delete(ctx context.Context, ID interfaces.ResourceID) error + func (r *ResourceRepo) Get(ctx context.Context, ID interfaces.ResourceID) (models.Resource, error) + func (r *ResourceRepo) GetProjectLevel(ctx context.Context, ID interfaces.ResourceID) (models.Resource, error) + func (r *ResourceRepo) GetRaw(ctx context.Context, ID interfaces.ResourceID) (models.Resource, error) + func (r *ResourceRepo) ListAll(ctx context.Context, resourceType string) ([]models.Resource, error) + type SignalRepo struct + func (s *SignalRepo) Get(ctx context.Context, input models.SignalKey) (models.Signal, error) + func (s *SignalRepo) GetOrCreate(ctx context.Context, input *models.Signal) error + func (s *SignalRepo) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Signal, error) + func (s *SignalRepo) Update(ctx context.Context, input models.SignalKey, value []byte) error + type TaskExecutionRepo struct + func (r *TaskExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error) + func (r *TaskExecutionRepo) Create(ctx context.Context, input models.TaskExecution) error + func (r *TaskExecutionRepo) Get(ctx context.Context, input interfaces.GetTaskExecutionInput) (models.TaskExecution, error) + func (r *TaskExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskExecutionCollectionOutput, error) + func (r *TaskExecutionRepo) Update(ctx context.Context, execution models.TaskExecution) error + type TaskRepo struct + func (r *TaskRepo) Create(_ context.Context, input models.Task, ...) error + func (r *TaskRepo) Get(ctx context.Context, input interfaces.Identifier) (models.Task, error) + func (r *TaskRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskCollectionOutput, error) + func (r *TaskRepo) ListTaskIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskCollectionOutput, error) + type WorkflowRepo struct + func (r *WorkflowRepo) Create(_ context.Context, input models.Workflow, ...) error + func (r *WorkflowRepo) Get(ctx context.Context, input interfaces.Identifier) (models.Workflow, error) + func (r *WorkflowRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.WorkflowCollectionOutput, error) + func (r *WorkflowRepo) ListIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (interfaces.WorkflowCollectionOutput, error)
Go to main page