Documentation ¶
Index ¶
- func Register() error
- type PipelineRepository
- func (p *PipelineRepository) FindByStatus(ctx context.Context, s pipeline.Status) ([]*pipeline.Pipeline, error)
- func (p *PipelineRepository) FindByUuid(ctx context.Context, uuid string) (*pipeline.Pipeline, error)
- func (p *PipelineRepository) IncreaseDispatchTimes(ctx context.Context, id uint32) (int64, error)
- func (p *PipelineRepository) Update(ctx context.Context, pl *pipeline.Pipeline) (int64, error)
- func (p *PipelineRepository) UpdateEnvs(ctx context.Context, pl *pipeline.Pipeline) (int64, error)
- func (p *PipelineRepository) UpdateRawlog(ctx context.Context, id uint32, raw string) (int64, error)
- func (p *PipelineRepository) UpdateStatus(ctx context.Context, m *pipeline.Pipeline, opts ...pipeline.StatusOption) (int64, error)
- type Repository
- type RunnerRepository
- type WorkflowRepository
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type PipelineRepository ¶
type PipelineRepository struct { orm.BaseRepository[pipeline.Pipeline] // contains filtered or unexported fields }
func NewPipelineRepository ¶
func NewPipelineRepository(db *gorm.DB) *PipelineRepository
func (*PipelineRepository) FindByStatus ¶
func (*PipelineRepository) FindByUuid ¶
func (*PipelineRepository) IncreaseDispatchTimes ¶
func (*PipelineRepository) UpdateEnvs ¶
func (*PipelineRepository) UpdateRawlog ¶
func (*PipelineRepository) UpdateStatus ¶
func (p *PipelineRepository) UpdateStatus(ctx context.Context, m *pipeline.Pipeline, opts ...pipeline.StatusOption) (int64, error)
type Repository ¶
type Repository struct { WorkflowRepository *WorkflowRepository PipelineRepository *PipelineRepository RunnerRepository *RunnerRepository }
var Repositories *Repository
func NewRepository ¶
func NewRepository(workflowRepository *WorkflowRepository, pipelineRepository *PipelineRepository, runnerRepository *RunnerRepository) *Repository
type RunnerRepository ¶
type RunnerRepository struct { orm.BaseRepository[runner.Runner] // contains filtered or unexported fields }
func NewRunnerRepository ¶
func NewRunnerRepository(db *gorm.DB) *RunnerRepository
func (*RunnerRepository) FindByUuid ¶
func (*RunnerRepository) UpdateStatus ¶
type WorkflowRepository ¶
type WorkflowRepository struct { orm.BaseRepository[workflow.Workflow] // contains filtered or unexported fields }
func NewWorkflowRepository ¶
func NewWorkflowRepository(db *gorm.DB) *WorkflowRepository
Click to show internal directories.
Click to hide internal directories.