service

Jun 14, 2024

Changes in this version

type AppRunner

+ func (r *AppRunner) AddInitContextJob(f RunnerFunc)

+ func (r *AppRunner) AddInitContextJobs(jobs []RunnerFunc)

+ type SyncRunnerContextFunc func(context.Context) error

May 22, 2022

Changes in this version

type AppRunner

+ func (r *AppRunner) AddJobRunNow(f RunnerFunc)

May 22, 2022

Changes in this version

type AppRunner

+ func (r *AppRunner) WaitGroup() *sync.WaitGroup

May 21, 2022

Changes in this version

+ type AppRunner struct

+ Logger AppRunnerLogger

+ func NewAppRunner(ctx context.Context, logger AppRunnerLogger) *AppRunner

+ func (r *AppRunner) AddBackgroundJob(f RunnerFunc)

+ func (r *AppRunner) AddInitJob(f SyncRunnerFunc)

+ func (r *AppRunner) AddInitJobs(jobs []SyncRunnerFunc)

+ func (r *AppRunner) AddJob(f RunnerFunc)

+ func (r *AppRunner) AddJobs(jobs []RunnerFunc)

+ func (r *AppRunner) RunForever(enableBg bool)

+ type AppRunnerLogger interface

+ Error func(...interface{})

+ Info func(...interface{})

+ type RunnerFunc func(context.Context, *sync.WaitGroup) error

+ type SyncRunnerFunc func() error