runner

Documentation

Index

• Constants
• type Config
• type Options
• type Runnable
  • func New(log *zap.Logger, c Config) (Runnable, error)

Constants

const (
	ExitTimeout     = -1
	ExitACK         = 0
	ExitFailed      = 1
	ExitNACK        = 3
	ExitNACKRequeue = 4
	ExitRetry       = 5
)

Exit constants used to know how handle the message. The consumer runnig is the responsible to understand this status and handle them properly.

Types

type Config

type Config struct {
	Type         string  `mapstructure:"type"`
	IgnoreOutput bool    `mapstructure:"ignore-output"`
	Options      Options `mapstructure:"options"`
}

Config is an composition of all options and configurations used by this runnables.

type Options

type Options struct {
	Path string   `mapstructure:"path"`
	Args []string `mapstructure:"args"`
}

type Runnable

type Runnable interface {
	Process(context.Context, []byte) int
}

Runnable represent an runnable used by consumers to handle messages.

func New

func New(log *zap.Logger, c Config) (Runnable, error)

New create and return a Runnable based on the config type. if the type didn't exist an error is returned.