command

type ArgumentBuilder struct {
	Builder
	Compressed   bool
	WithMetadata bool
	// contains filtered or unexported fields
}

type Builder interface {
	// SetLogger sets the logger passed to the command used while building.
	SetLogger(l logr.Logger)

	// SetOutputWriter sets the writer used for capturing the commands STDOUT when capturing is enabled.
	SetOutputWriter(w io.Writer)

	// SetErrorWriter sets the writer used for capturing the commands STDERR when capturing is enabled.
	SetErrorWriter(lw io.Writer)

	// SetCaptureOutput enables/disables output capturing of the command.
	SetCaptureOutput(captrue bool)

	// SetCommand sets the command to be executed for each received message.
	SetCommand(cmd string)

	// GetCommand gets the executable command for the given message data.
	GetCommand(p delivery.Properties, d delivery.Info, body []byte) (*exec.Cmd, error)
}

type LogWriter struct {
	io.Writer
	Logger *log.Logger
}

type PipeBuilder struct {
	Builder
	// contains filtered or unexported fields
}