service

Documentation

Index

• type AppRunner
  • func NewAppRunner(ctx context.Context, logger log.LeveledLogger) *AppRunner
  • func (r *AppRunner) AddBackgroundJob(f RunnerFunc)
  • func (r *AppRunner) AddInitContextJob(f SyncRunnerContextFunc)
  • func (r *AppRunner) AddInitContextJobs(jobs []SyncRunnerContextFunc)
  • func (r *AppRunner) AddInitJob(f SyncRunnerFunc)
  • func (r *AppRunner) AddInitJobs(jobs []SyncRunnerFunc)
  • func (r *AppRunner) AddJob(f RunnerFunc)
  • func (r *AppRunner) AddJobRunNow(f RunnerFunc)
  • func (r *AppRunner) AddJobs(jobs []RunnerFunc)
  • func (r *AppRunner) RunForever(enableBg bool)
• type RunnerFunc
• type SyncRunnerContextFunc
• type SyncRunnerFunc

Types

type AppRunner

type AppRunner struct {
	Logger log.LeveledLogger
	// contains filtered or unexported fields
}

func NewAppRunner

func NewAppRunner(ctx context.Context, logger log.LeveledLogger) *AppRunner

func (*AppRunner) AddBackgroundJob

func (r *AppRunner) AddBackgroundJob(f RunnerFunc)

func (*AppRunner) AddInitContextJob

func (r *AppRunner) AddInitContextJob(f SyncRunnerContextFunc)

func (*AppRunner) AddInitContextJobs

func (r *AppRunner) AddInitContextJobs(jobs []SyncRunnerContextFunc)

func (*AppRunner) AddInitJob

func (r *AppRunner) AddInitJob(f SyncRunnerFunc)

func (*AppRunner) AddInitJobs

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

func (*AppRunner) AddJob

func (r *AppRunner) AddJob(f RunnerFunc)

func (*AppRunner) AddJobRunNow

func (r *AppRunner) AddJobRunNow(f RunnerFunc)

func (*AppRunner) AddJobs

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

func (*AppRunner) RunForever

func (r *AppRunner) RunForever(enableBg bool)

type RunnerFunc

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

type SyncRunnerContextFunc

type SyncRunnerContextFunc func(context.Context) error

type SyncRunnerFunc

type SyncRunnerFunc func() error