runner

Documentation

Overview

Package runner provides implementation of process runner

Index

• func Do(ctx context.Context, opts ...Option) error
• func Run(ctx context.Context, run Runner, name string) (err error)
• type Option
  • func WithConfigLoader(f func(string) (interface{}, *config.GlobalConfig, error)) Option
  • func WithDaemonInitializer(f func(interface{}) (Runner, error)) Option
  • func WithName(name string) Option
  • func WithVersion(ver, max, min string) Option
• type Runner

Functions

func Do

func Do(ctx context.Context, opts ...Option) error

func Run

func Run(ctx context.Context, run Runner, name string) (err error)

Types

type Option

type Option func(*runner)

func WithConfigLoader

func WithConfigLoader(f func(string) (interface{}, *config.GlobalConfig, error)) Option

func WithDaemonInitializer

func WithDaemonInitializer(f func(interface{}) (Runner, error)) Option

func WithName

func WithName(name string) Option

func WithVersion

func WithVersion(ver, max, min string) Option

type Runner

type Runner interface {
	PreStart(ctx context.Context) error
	Start(ctx context.Context) (<-chan error, error)
	PreStop(ctx context.Context) error
	Stop(ctx context.Context) error
	PostStop(ctx context.Context) error
}