Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

reconciler

package

Go to main page

Versions in this module

v1

v1.0.1

Aug 15, 2024

Changes in this version

+ type Interface interface

+ InjectLegacyFields func(f *PipelineSvcFuncs)

+ ReconcileOnePipeline func(ctx context.Context, pipelineID uint64)

+ type PipelineReconciler interface

+ CancelReconcile func(ctx context.Context, p *spec.Pipeline)

+ GetTasksCanBeConcurrentlyScheduled func(ctx context.Context, p *spec.Pipeline) ([]*spec.PipelineTask, error)

+ IsReconcileDone func(ctx context.Context, p *spec.Pipeline) bool

+ NeedReconcile func(ctx context.Context, p *spec.Pipeline) bool

+ PrepareBeforeReconcile func(ctx context.Context, p *spec.Pipeline)

+ ReconcileOneSchedulableTask func(ctx context.Context, p *spec.Pipeline, task *spec.PipelineTask)

+ TeardownAfterReconcileDone func(ctx context.Context, p *spec.Pipeline)

+ UpdateCurrentReconcileStatusIfNecessary func(ctx context.Context, p *spec.Pipeline) error

+ type PipelineSvcFuncs struct

+ ConvertSnippetConfig2String func(snippetConfig *pb.SnippetDetailQuery) string

+ CreatePipelineGraph func(p *spec.Pipeline) (stages []spec.PipelineStage, err error)

+ CronNotExecuteCompensate func(id uint64) error

+ HandleQueryPipelineYamlBySnippetConfigs func(sourceSnippetConfigs []*pb.SnippetDetailQuery) (map[string]string, error)

+ MakeSnippetPipeline4Create func(p *spec.Pipeline, snippetTask *spec.PipelineTask, yamlContent string) (*spec.Pipeline, error)

+ MergePipelineYmlTasks func(pipelineYml *pipelineyml.PipelineYml, dbTasks []spec.PipelineTask, ...) (mergeTasks []spec.PipelineTask, err error)

+ PreCheck func(p *spec.Pipeline, stages []spec.PipelineStage, userID string, autoRun bool) error

+ type TaskReconciler interface

+ CreateSnippetPipeline func(ctx context.Context, p *spec.Pipeline, task *spec.PipelineTask) (snippetPipeline *spec.Pipeline, err error)

+ IdempotentSaveTask func(ctx context.Context, p *spec.Pipeline, task *spec.PipelineTask) error

+ NeedReconcile func(ctx context.Context, p *spec.Pipeline, task *spec.PipelineTask) bool

+ PrepareBeforeReconcileSnippetPipeline func(ctx context.Context, snippetPipeline *spec.Pipeline, ...) error

+ ReconcileNormalTask func(ctx context.Context, p *spec.Pipeline, task *spec.PipelineTask) error

+ ReconcileOneTaskUntilDone func(ctx context.Context, p *spec.Pipeline, task *spec.PipelineTask)

+ ReconcileSnippetTask func(ctx context.Context, p *spec.Pipeline, task *spec.PipelineTask) error

+ TeardownAfterReconcileDone func(ctx context.Context, p *spec.Pipeline, task *spec.PipelineTask)