cli

Documentation

Index

• Variables
• func OptAddStringFlag(name, usage string, aliases []string, value string, destination *string) func()
• func OptSetVersionStamp(version, dateBuilt string) func()
• func OptUseContext(ctx context.Context) func()
• func Run()
• func RunWithOpts(opts ...func())

Variables

var (
	Version   string
	DateBuilt string
)

Build stamps.

Functions

func OptAddStringFlag

func OptAddStringFlag(name, usage string, aliases []string, value string, destination *string) func()

OptAddStringFlag registers a custom CLI flag for the standard Benthos run command.

func OptSetVersionStamp

func OptSetVersionStamp(version, dateBuilt string) func()

OptSetVersionStamp creates an opt func for setting the version and date built stamps that Benthos returns via --version and the /version endpoint.

func OptUseContext

func OptUseContext(ctx context.Context) func()

OptUseContext sets a context to be used for cancellation during the run command. This adds one extra mechanism for graceful termination.

func Run

func Run()

Run the Benthos service, if the pipeline is started successfully then this call blocks until either the pipeline shuts down or a termination signal is received.

func RunWithOpts

func RunWithOpts(opts ...func())

RunWithOpts runs the Benthos service after first applying opt funcs, which are used for specify service customisations.