workers

Documentation

Index

• type GitOpsWorker
  • func NewGitOpsWorker(r *services.Repository, m *services.Manifest, c *services.Configuration) *GitOpsWorker
  • func (g *GitOpsWorker) Do(ctx context.Context) error
  • func (g *GitOpsWorker) Name() string
• type Scheduler
  • func New(heartbeat time.Duration) *Scheduler
  • func (s *Scheduler) AddWorker(w Worker) *Scheduler
  • func (s *Scheduler) Start(ctx context.Context)
• type Worker

Types

type GitOpsWorker

type GitOpsWorker struct {
	// contains filtered or unexported fields
}

func NewGitOpsWorker

func NewGitOpsWorker(r *services.Repository, m *services.Manifest, c *services.Configuration) *GitOpsWorker

func (*GitOpsWorker) Do

func (g *GitOpsWorker) Do(ctx context.Context) error

func (*GitOpsWorker) Name

func (g *GitOpsWorker) Name() string

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

func New

func New(heartbeat time.Duration) *Scheduler

func (*Scheduler) AddWorker

func (s *Scheduler) AddWorker(w Worker) *Scheduler

func (*Scheduler) Start

func (s *Scheduler) Start(ctx context.Context)

type Worker

type Worker interface {
	Do(ctx context.Context) error
	Name() string
}