Method RunPlaybookStream

internal/plugins/ansible/runner.go:219–239

RunPlaybookStream executes ansible-playbook and streams output lines when handler is provided.

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

// RunPlaybookStream executes ansible-playbook and streams output lines when handler is provided.
func (r *Runner) RunPlaybookStream(
	ctx context.Context,
	inventoryText,
	inventoryFormat string,
	opts PlaybookOptions,
	handler OutputLineHandler,
) CommandResult {
	playbookPath := strings.TrimSpace(opts.PlaybookPath)
	if playbookPath == "" {
		return CommandResult{Err: fmt.Errorf("playbook path is required")}
	}

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

	args := buildPlaybookArgs(inventoryPath, playbookPath, opts)
	return runAnsiblePlaybookCommand(ctx, r.env, args, handler)
}

func buildAdhocArgs(inventoryPath string, opts AdhocOptions) []string {
	pattern := strings.TrimSpace(opts.Pattern)