factory

Documentation

Index

• type Builder
• type CoordinatorBuilder
  • func (cb *CoordinatorBuilder) Build(reqID string) coordinator.CoordinatorBuilder
  • func (cb *CoordinatorBuilder) Dependency(query metadata.QueryBuilder, workflow metadata.WorkFlowAggregateBuilder, ...)
  • func (cb *CoordinatorBuilder) Lifecycle(pid, reqID string) lifecycle.LifecycleBuilder
• type Factory
  • func New(builder *Builder) *Factory
• type HelperBuilder
• type MetadataBuilder
  • func (mtb *MetadataBuilder) Build() metadata.WorkFlowAggregateBuilder
• type RunnerBuiler
  • func (rb *RunnerBuiler) Build() runner.RunnerBuilder
• type SupervisorBuilder
  • func (sb *SupervisorBuilder) Build(ctx context.Context, delay int) *supervisor.Supervisor
  • func (sb *SupervisorBuilder) Dependency(repoCoord coordinator.Repository, workflow metadata.WorkFlowAggregateBuilder, ...)
  • func (sb *SupervisorBuilder) Process(maxRetries int) (*process.Process, error)

Types

type Builder

type Builder struct {
	Workflow    MetadataBuilder
	Runner      RunnerBuiler
	Coordinator CoordinatorBuilder
	Supervisor  SupervisorBuilder
}

type CoordinatorBuilder

type CoordinatorBuilder struct {
	Helper     HelperBuilder
	Repository coordinator.Repository
	// contains filtered or unexported fields
}

func (*CoordinatorBuilder) Build

func (cb *CoordinatorBuilder) Build(reqID string) coordinator.CoordinatorBuilder

func (*CoordinatorBuilder) Dependency

func (cb *CoordinatorBuilder) Dependency(query metadata.QueryBuilder, workflow metadata.WorkFlowAggregateBuilder, run runner.RunnerBuilder)

func (*CoordinatorBuilder) Lifecycle

func (cb *CoordinatorBuilder) Lifecycle(pid, reqID string) lifecycle.LifecycleBuilder

type Factory

type Factory struct {
	*Builder
}

func New

func New(builder *Builder) *Factory

type HelperBuilder

type HelperBuilder struct {
	UID     func() uid.UUID
	Backoff func() backoff.Builder
}

type MetadataBuilder

type MetadataBuilder struct {
	RepositoryBuilder metadata.Repository
}

func (*MetadataBuilder) Build

func (mtb *MetadataBuilder) Build() metadata.WorkFlowAggregateBuilder

type RunnerBuiler

type RunnerBuiler struct {
	Helper             HelperBuilder
	TransporterBuilder runner.Transporter
}

func (*RunnerBuiler) Build

func (rb *RunnerBuiler) Build() runner.RunnerBuilder

type SupervisorBuilder

type SupervisorBuilder struct {
	Helper     HelperBuilder
	Repository supervisor.Repository
	// contains filtered or unexported fields
}

func (*SupervisorBuilder) Build

func (sb *SupervisorBuilder) Build(ctx context.Context, delay int) *supervisor.Supervisor

func (*SupervisorBuilder) Dependency

func (sb *SupervisorBuilder) Dependency(repoCoord coordinator.Repository, workflow metadata.WorkFlowAggregateBuilder, run runner.RunnerBuilder)

func (*SupervisorBuilder) Process

func (sb *SupervisorBuilder) Process(maxRetries int) (*process.Process, error)