Method RunAdhocStream

internal/plugins/ansible/runner.go:183–203

RunAdhocStream executes ansible ad-hoc commands and streams output lines when handler is provided.

(
	ctx context.Context,
	inventoryText,
	inventoryFormat string,
	opts AdhocOptions,
	handler OutputLineHandler,
)

// RunAdhocStream executes ansible ad-hoc commands and streams output lines when handler is provided.
func (r *Runner) RunAdhocStream(
	ctx context.Context,
	inventoryText,
	inventoryFormat string,
	opts AdhocOptions,
	handler OutputLineHandler,
) CommandResult {
	module := strings.TrimSpace(opts.Module)
	if module == "" {
		return CommandResult{Err: fmt.Errorf("module is required")}
	}

	inventoryPath, cleanup, err := writeTempInventory(inventoryText, inventoryFormat)
	if err != nil {
		return CommandResult{Err: fmt.Errorf("create temp inventory: %w", err)}
	}
	defer cleanup()

	args := buildAdhocArgs(inventoryPath, opts)
	return runAnsibleCommand(ctx, r.env, args, handler)
}

// PlaybookOptions describes ansible-playbook invocation options.
type PlaybookOptions struct {