mrrun

Nov 16, 2024

Changes in this version

type Executer

+ Starting StartingProcess

type Process

+ ReadyTimeout func() time.Duration

+ type StartingProcess struct

+ Caption string

+ Ready chan struct{}

+ ReadyTimeout time.Duration

Sep 28, 2024

Changes in this version

+ func PrepareProbes(probes ...ProbeChecker) func(ctx context.Context) []FinishedProbe

+ func PrepareProbesForCheck(probes ...ProbeChecker) func(ctx context.Context) bool

+ func WithAppReadyProbe(app *AppHealth) func(ctx context.Context) error

+ type AppHealth struct

+ func NewAppHealth() *AppHealth

+ func (a *AppHealth) Continue()

+ func (a *AppHealth) IsReady() bool

+ func (a *AppHealth) IsStarted() bool

+ func (a *AppHealth) Pause()

+ func (a *AppHealth) StartupCompleted()

type AppRunner

+ func (r *AppRunner) AddFirstProcess(ctx context.Context, process Process) (chFirst chan struct{})

+ type Executer struct

+ Execute func() error

+ Interrupt func(error)

+ StartedOk chan struct{}

+ type FinishedProbe struct

+ Caption string

+ Status int

+ type HealthProbe struct

+ func NewHealthProbe(caption string, check func(ctx context.Context) error, timeout time.Duration) *HealthProbe

+ func (p *HealthProbe) Caption() string

+ func (p *HealthProbe) Check(ctx context.Context) (err error)

+ type ProbeChecker interface

+ Caption func() string

+ Check func(ctx context.Context) error

+ type ProcessWaiter interface

+ WaitingForStartup func(chProcesses ...chan struct{})

Sep 15, 2024

Changes in this version

+ func MakeExecuter(ctx context.Context, process Process) (execute func() error, interrupt func(error))

+ func MakeNextExecuter(ctx context.Context, process Process, chPrev chan struct{}) (chNext chan struct{}, execute func() error, interrupt func(error))

+ func MakeSignalHandler(ctx context.Context) (ctxWithCancel context.Context, execute func() error, interrupt func(error))

+ type AppRunner struct

+ func NewAppRunner(runner ProcessRunner) *AppRunner

+ func (r *AppRunner) Add(execute func() error, interrupt func(error))

+ func (r *AppRunner) AddHeadProcess(ctx context.Context, process Process) (chHead chan struct{})

+ func (r *AppRunner) AddNextProcess(ctx context.Context, process Process, chPrev chan struct{}) (chNext chan struct{})

+ func (r *AppRunner) AddProcess(ctx context.Context, process Process)

+ func (r *AppRunner) AddSignalHandler(ctx context.Context) context.Context

+ func (r *AppRunner) Run() error

+ type Process interface

+ Caption func() string

+ Shutdown func(ctx context.Context) error

+ Start func(ctx context.Context, ready func()) error

+ type ProcessRunner interface

+ Add func(execute func() error, interrupt func(error))

+ Run func() error