supervisor

Documentation

Index

• type Context
• type Repository
• type Snapshot
• type Supervisor
  • func New(ctx context.Context, delay int, repo Repository, ...) *Supervisor
  • func (s *Supervisor) Check(proc process.ProcessBuilder) (lifecycle.HistoryNode, error)
  • func (s *Supervisor) CreateProcess(projectName, activityName, requestID string, maxRetries int) (process.ProcessBuilder, error)
  • func (s *Supervisor) Monitor()
  • func (s *Supervisor) RegisterProcess(proc process.ProcessBuilder)
  • func (s *Supervisor) Resume(proc process.ProcessBuilder, st state.State, event string, payload interface{})
  • func (s *Supervisor) Shutdown()
  • func (s *Supervisor) Start(proc process.ProcessBuilder, payload interface{})
  • func (s *Supervisor) Stop(proc process.ProcessBuilder)

Types

type Context

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

type Repository

type Repository interface {
	SaveSnapshot(ctx context.Context, s Snapshot) error
}

type Snapshot

type Snapshot struct {
	PID     string
	State   state.State
	Event   string
	Action  action.Action
	Payload interface{}
}

type Supervisor

type Supervisor struct {
	*core.Component
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, delay int, repo Repository, repoCoord coordinator.Repository, uidGen uid.UUID, meta metadata.WorkFlowAggregateBuilder, handler runner.RunnerBuilder) *Supervisor

func (*Supervisor) Check

func (s *Supervisor) Check(proc process.ProcessBuilder) (lifecycle.HistoryNode, error)

func (*Supervisor) CreateProcess

func (s *Supervisor) CreateProcess(projectName, activityName, requestID string, maxRetries int) (process.ProcessBuilder, error)

func (*Supervisor) Monitor

func (s *Supervisor) Monitor()

func (*Supervisor) RegisterProcess

func (s *Supervisor) RegisterProcess(proc process.ProcessBuilder)

func (*Supervisor) Resume

func (s *Supervisor) Resume(proc process.ProcessBuilder, st state.State, event string, payload interface{})

func (*Supervisor) Shutdown

func (s *Supervisor) Shutdown()

func (*Supervisor) Start

func (s *Supervisor) Start(proc process.ProcessBuilder, payload interface{})

func (*Supervisor) Stop

func (s *Supervisor) Stop(proc process.ProcessBuilder)