process

Documentation

Index

• type Process
  • func New(uidGen uid.UUID, maxRetries int) (*Process, error)
  • func (p *Process) Attach(coord coordinator.CoordinatorBuilder)
  • func (p *Process) GetPID() string
  • func (p *Process) Reset()
  • func (p *Process) Retry(ctx context.Context, payload interface{}) error
• type ProcessBuilder

Types

type Process

type Process struct {
	*core.Component
	coordinator.CoordinatorBuilder

	PID string
	// contains filtered or unexported fields
}

func New

func New(uidGen uid.UUID, maxRetries int) (*Process, error)

func (*Process) Attach

func (p *Process) Attach(coord coordinator.CoordinatorBuilder)

func (*Process) GetPID

func (p *Process) GetPID() string

func (*Process) Reset

func (p *Process) Reset()

func (*Process) Retry

func (p *Process) Retry(ctx context.Context, payload interface{}) error

type ProcessBuilder

type ProcessBuilder interface {
	coordinator.CoordinatorBuilder
	GetPID() string
	Attach(coord coordinator.CoordinatorBuilder)
	Retry(ctx context.Context, payload interface{}) error
	Reset()
}