unit

Documentation

Index

• Constants
• func AgentDone(logger corelogger.Logger, err error) error
• func LifeFilter(err error) error
• func Manifolds(config manifoldsConfig) dependency.Manifolds
• func New(ctx *cmd.Context, bufferedLogger *logsender.BufferedLogWriter) (cmd.Command, error)

Constants

const ErrRemoved = errors.ConstError("unit removed")

ErrRemoved may be returned by some worker started from Manifolds to indicate that the unit under management no longer exists.

Functions

func AgentDone

func AgentDone(logger corelogger.Logger, err error) error

AgentDone processes the error returned by an exiting agent.

func LifeFilter

func LifeFilter(err error) error

LifeFilter is used with the lifeflag manifolds -- which do not depend on runFlag -- to return appropriate errors for consumption by the enclosing dependency.Engine (and/or its IsFatal check).

func Manifolds

func Manifolds(config manifoldsConfig) dependency.Manifolds

Manifolds returns a set of co-configured manifolds covering the various responsibilities of a k8s agent unit command. It also accepts the logSource argument because we haven't figured out how to thread all the logging bits through a dependency engine yet.

Thou Shalt Not Use String Literals In This Function. Or Else.

func New

func New(ctx *cmd.Context, bufferedLogger *logsender.BufferedLogWriter) (cmd.Command, error)

New creates containeragent unit command.