joule

Documentation

Index

• type CLIRunner
  • func NewCLIRunner[OT any](opts OT, args []string, stdin io.Reader, stdout io.Writer, stderr io.Writer, ...) *CLIRunner[OT]
  • func (cr *CLIRunner[OT]) AddUow(id string, ...) UnitOfWork
  • func (cr *CLIRunner[OT]) CancelFunc() context.CancelFunc
  • func (cr *CLIRunner[OT]) GetUow(id string) UnitOfWork
  • func (cr *CLIRunner[OT]) Run() error
  • func (cr *CLIRunner[OT]) SetWorkDelay(workDelay time.Duration)
• type UnitOfWork

Types

type CLIRunner

type CLIRunner[OT any] struct {
	Ctx *context.Context

	Opts OT
	Args []string
	// contains filtered or unexported fields
}

func NewCLIRunner

func NewCLIRunner[OT any](
	opts OT, args []string,
	stdin io.Reader, stdout io.Writer, stderr io.Writer,
	startup func(cr *CLIRunner[OT]) error,
	shutdown func(cr *CLIRunner[OT]) error,
) *CLIRunner[OT]

func (*CLIRunner[OT]) AddUow

func (cr *CLIRunner[OT]) AddUow(
	id string,
	work func(context.Context, UnitOfWork, interface{}) (interface{}, error),
) UnitOfWork

func (*CLIRunner[OT]) CancelFunc

func (cr *CLIRunner[OT]) CancelFunc() context.CancelFunc

func (*CLIRunner[OT]) GetUow

func (cr *CLIRunner[OT]) GetUow(id string) UnitOfWork

func (*CLIRunner[OT]) Run

func (cr *CLIRunner[OT]) Run() error

func (*CLIRunner[OT]) SetWorkDelay

func (cr *CLIRunner[OT]) SetWorkDelay(workDelay time.Duration)

type UnitOfWork

type UnitOfWork interface {
	GetId() string
	SetInput(interface{})
	GetOutput() interface{}
	GetError() error
	UiSecret(string) string
	UiOut([]byte)
	UiErr([]byte)
	UiStrOut(string)
	UiStrErr(string)
	UiOutWriter() io.Writer
	UiErrWriter() io.Writer
}