worker

Documentation

Index

• Variables
• type EventHandler
• type MetricsReporter
  • func NewMetricsReporter(pipelineClient client.PipelineClientInterface) *MetricsReporter
  • func (r MetricsReporter) ReportMetrics(workflow *util.Workflow) error
• type PersistenceWorker
  • func NewPersistenceWorker(time util.TimeInterface, name string, eventHandler EventHandler, ...) *PersistenceWorker
  • func (p *PersistenceWorker) Len() int
  • func (p *PersistenceWorker) RunWorker()
  • func (p *PersistenceWorker) Shutdown()
• type Saver
• type ScheduledWorkflowSaver
  • func NewScheduledWorkflowSaver(client client.ScheduledWorkflowClientInterface, ...) *ScheduledWorkflowSaver
  • func (c *ScheduledWorkflowSaver) Save(key string, namespace string, name string, nowEpoch int64) error
• type WorkflowSaver
  • func NewWorkflowSaver(client client.WorkflowClientInterface, ...) *WorkflowSaver
  • func (s *WorkflowSaver) Save(key string, namespace string, name string, nowEpoch int64) error

Variables

var (
	// DefaultJobBackOff is the default backoff period
	DefaultJobBackOff = 1 * time.Second
	// MaxJobBackOff is the max backoff period
	MaxJobBackOff = 360 * time.Second
)

Types

type EventHandler

type EventHandler interface {
	AddEventHandler(handler cache.ResourceEventHandler)
}

type MetricsReporter

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

MetricsReporter reports metrics of a workflow to pipeline server.

func NewMetricsReporter

func NewMetricsReporter(pipelineClient client.PipelineClientInterface) *MetricsReporter

NewMetricsReporter creates a new instance of NewMetricsReporter.

func (MetricsReporter) ReportMetrics

func (r MetricsReporter) ReportMetrics(workflow *util.Workflow) error

ReportMetrics reports workflow metrics to pipeline server.

type PersistenceWorker

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

PersistenceWorker is a generic worker to persist objects from a queue.

func NewPersistenceWorker

func NewPersistenceWorker(
	time util.TimeInterface,
	name string,
	eventHandler EventHandler,
	enforceRequeueDelays bool,
	saver Saver) *PersistenceWorker

NewPersistenceWorker returns a new PersistenceWorker

func (*PersistenceWorker) Len

func (p *PersistenceWorker) Len() int

func (*PersistenceWorker) RunWorker

func (p *PersistenceWorker) RunWorker()

RunWorker is a long-running function that will continually call the processNextWorkItem function in order to read and process a message on the workqueue. It enforces that the syncHandler is never invoked concurrently with the same key.

func (*PersistenceWorker) Shutdown

func (p *PersistenceWorker) Shutdown()

type Saver

type Saver interface {
	Save(key string, namespace string, name string, nowEpoch int64) error
}

type ScheduledWorkflowSaver

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

ScheduledWorkflowSaver provides a function to persist a workflow to a database.

func NewScheduledWorkflowSaver

func NewScheduledWorkflowSaver(
	client client.ScheduledWorkflowClientInterface,
	pipelineClient client.PipelineClientInterface) *ScheduledWorkflowSaver

func (*ScheduledWorkflowSaver) Save

func (c *ScheduledWorkflowSaver) Save(key string, namespace string, name string, nowEpoch int64) error

type WorkflowSaver

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

WorkflowSaver provides a function to persist a workflow to a database.

func NewWorkflowSaver

func NewWorkflowSaver(client client.WorkflowClientInterface,
	pipelineClient client.PipelineClientInterface, ttlSecondsAfterWorkflowFinish int64) *WorkflowSaver

func (*WorkflowSaver) Save

func (s *WorkflowSaver) Save(key string, namespace string, name string, nowEpoch int64) error