Method RunPingStream

internal/plugins/ansible/runner.go:84–105

RunPingStream executes `ansible -m ping` and streams output lines when handler is provided.

(
	ctx context.Context,
	inventoryText,
	inventoryFormat,
	limit string,
	extraArgs []string,
	handler OutputLineHandler,
)

// RunPingStream executes `ansible -m ping` and streams output lines when handler is provided.
func (r *Runner) RunPingStream(
	ctx context.Context,
	inventoryText,
	inventoryFormat,
	limit string,
	extraArgs []string,
	handler OutputLineHandler,
) CommandResult {
	inventoryPath, cleanup, err := writeTempInventory(inventoryText, inventoryFormat)
	if err != nil {
		return CommandResult{Err: fmt.Errorf("create temp inventory: %w", err)}
	}
	defer cleanup()

	args := buildAdhocArgs(inventoryPath, AdhocOptions{
		Pattern:   "all",
		Module:    "ping",
		Limit:     limit,
		ExtraArgs: extraArgs,
	})
	return runAnsibleCommand(ctx, r.env, args, handler)
}

// RunInventoryList resolves an inventory source with ansible-inventory --list.
func (r *Runner) RunInventoryList(ctx context.Context, inventory InventoryResult) CommandResult {