Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + type CountResourceInput struct + InlineFilters []common.InlineFilter + JoinTableEntities map[common.Entity]bool + MapFilters []common.MapFilter + type DescriptionEntityCollectionOutput struct + Entities []models.DescriptionEntity + type DescriptionEntityRepoInterface interface + Get func(ctx context.Context, input GetDescriptionEntityInput) (models.DescriptionEntity, error) + List func(ctx context.Context, input ListResourceInput) (DescriptionEntityCollectionOutput, error) + type ExecutionCollectionOutput struct + Executions []models.Execution + type ExecutionEventRepoInterface interface + Create func(ctx context.Context, input models.ExecutionEvent) error + type ExecutionRepoInterface interface + Count func(ctx context.Context, input CountResourceInput) (int64, error) + Create func(ctx context.Context, input models.Execution) error + Get func(ctx context.Context, input Identifier) (models.Execution, error) + List func(ctx context.Context, input ListResourceInput) (ExecutionCollectionOutput, error) + Update func(ctx context.Context, execution models.Execution) error + type GetDescriptionEntityInput struct + Domain string + Name string + Project string + ResourceType core.ResourceType + Version string + type GetNamedEntityInput struct + Domain string + Name string + Project string + ResourceType core.ResourceType + type GetSignalInput struct + SignalID core.SignalIdentifier + type GetTaskExecutionInput struct + TaskExecutionID core.TaskExecutionIdentifier + type Identifier struct + Domain string + Name string + Project string + Version string + type LaunchPlanCollectionOutput struct + LaunchPlans []models.LaunchPlan + type LaunchPlanRepoInterface interface + Create func(ctx context.Context, input models.LaunchPlan) error + Get func(ctx context.Context, input Identifier) (models.LaunchPlan, error) + List func(ctx context.Context, input ListResourceInput) (LaunchPlanCollectionOutput, error) + ListLaunchPlanIdentifiers func(ctx context.Context, input ListResourceInput) (LaunchPlanCollectionOutput, error) + SetActive func(ctx context.Context, toEnable models.LaunchPlan, toDisable *models.LaunchPlan) error + Update func(ctx context.Context, input models.LaunchPlan) error + type ListNamedEntityInput struct + Domain string + Project string + ResourceType core.ResourceType + type ListResourceInput struct + InlineFilters []common.InlineFilter + JoinTableEntities map[common.Entity]bool + Limit int + MapFilters []common.MapFilter + Offset int + SortParameter common.SortParameter + type NamedEntityCollectionOutput struct + Entities []models.NamedEntity + type NamedEntityRepoInterface interface + Get func(ctx context.Context, input GetNamedEntityInput) (models.NamedEntity, error) + List func(ctx context.Context, input ListNamedEntityInput) (NamedEntityCollectionOutput, error) + Update func(ctx context.Context, input models.NamedEntity) error + type NodeExecutionCollectionOutput struct + NodeExecutions []models.NodeExecution + type NodeExecutionEventCollectionOutput struct + NodeExecutionEvents []models.NodeExecutionEvent + type NodeExecutionEventRepoInterface interface + Create func(ctx context.Context, input models.NodeExecutionEvent) error + type NodeExecutionRepoInterface interface + Count func(ctx context.Context, input CountResourceInput) (int64, error) + Create func(ctx context.Context, execution *models.NodeExecution) error + Exists func(ctx context.Context, input NodeExecutionResource) (bool, error) + Get func(ctx context.Context, input NodeExecutionResource) (models.NodeExecution, error) + GetWithChildren func(ctx context.Context, input NodeExecutionResource) (models.NodeExecution, error) + List func(ctx context.Context, input ListResourceInput) (NodeExecutionCollectionOutput, error) + Update func(ctx context.Context, execution *models.NodeExecution) error + type NodeExecutionResource struct + NodeExecutionIdentifier core.NodeExecutionIdentifier + type ProjectRepoInterface interface + Create func(ctx context.Context, project models.Project) error + Get func(ctx context.Context, projectID string) (models.Project, error) + List func(ctx context.Context, input ListResourceInput) ([]models.Project, error) + UpdateProject func(ctx context.Context, projectUpdate models.Project) error + type Repository interface + DescriptionEntityRepo func() DescriptionEntityRepoInterface + ExecutionEventRepo func() ExecutionEventRepoInterface + ExecutionRepo func() ExecutionRepoInterface + GetGormDB func() *gorm.DB + LaunchPlanRepo func() LaunchPlanRepoInterface + NamedEntityRepo func() NamedEntityRepoInterface + NodeExecutionEventRepo func() NodeExecutionEventRepoInterface + NodeExecutionRepo func() NodeExecutionRepoInterface + ProjectRepo func() ProjectRepoInterface + ResourceRepo func() ResourceRepoInterface + SchedulableEntityRepo func() schedulerInterfaces.SchedulableEntityRepoInterface + ScheduleEntitiesSnapshotRepo func() schedulerInterfaces.ScheduleEntitiesSnapShotRepoInterface + SignalRepo func() SignalRepoInterface + TaskExecutionRepo func() TaskExecutionRepoInterface + TaskRepo func() TaskRepoInterface + WorkflowRepo func() WorkflowRepoInterface + type ResourceID struct + Domain string + LaunchPlan string + Project string + ResourceType string + Workflow string + type ResourceRepoInterface interface + CreateOrUpdate func(ctx context.Context, input models.Resource) error + Delete func(ctx context.Context, ID ResourceID) error + Get func(ctx context.Context, ID ResourceID) (models.Resource, error) + GetProjectLevel func(ctx context.Context, ID ResourceID) (models.Resource, error) + GetRaw func(ctx context.Context, ID ResourceID) (models.Resource, error) + ListAll func(ctx context.Context, resourceType string) ([]models.Resource, error) + type SetStateInput struct + Closure []byte + Identifier core.Identifier + Version string + type SignalRepoInterface interface + Get func(ctx context.Context, input models.SignalKey) (models.Signal, error) + GetOrCreate func(ctx context.Context, input *models.Signal) error + List func(ctx context.Context, input ListResourceInput) ([]models.Signal, error) + Update func(ctx context.Context, input models.SignalKey, value []byte) error + type TaskCollectionOutput struct + Tasks []models.Task + type TaskExecutionCollectionOutput struct + TaskExecutions []models.TaskExecution + type TaskExecutionRepoInterface interface + Count func(ctx context.Context, input CountResourceInput) (int64, error) + Create func(ctx context.Context, input models.TaskExecution) error + Get func(ctx context.Context, input GetTaskExecutionInput) (models.TaskExecution, error) + List func(ctx context.Context, input ListResourceInput) (TaskExecutionCollectionOutput, error) + Update func(ctx context.Context, execution models.TaskExecution) error + type TaskRepoInterface interface + Create func(ctx context.Context, input models.Task, ...) error + Get func(ctx context.Context, input Identifier) (models.Task, error) + List func(ctx context.Context, input ListResourceInput) (TaskCollectionOutput, error) + ListTaskIdentifiers func(ctx context.Context, input ListResourceInput) (TaskCollectionOutput, error) + type UpdateResourceInput struct + Attributes map[string]interface{} + Filters []common.InlineFilter + type WorkflowCollectionOutput struct + Workflows []models.Workflow + type WorkflowRepoInterface interface + Create func(ctx context.Context, input models.Workflow, ...) error + Get func(ctx context.Context, input Identifier) (models.Workflow, error) + List func(ctx context.Context, input ListResourceInput) (WorkflowCollectionOutput, error) + ListIdentifiers func(ctx context.Context, input ListResourceInput) (WorkflowCollectionOutput, error)