Class: Utils::ProbeClient

Inherits:
Object show all
Includes:
ServerHandling
Defined in:
lib/utils/probe_server.rb

Overview

A client for interacting with the probe server through Unix domain sockets.

This class provides an interface for enqueueing process jobs and managing environment variables on a remote probe server. It uses Unix domain sockets to communicate with the server, enabling distributed task execution and configuration management.

Defined Under Namespace

Classes: EnvProxy

Instance Method Summary collapse

Methods included from ServerHandling

#create_server

Constructor Details

#initialize(server_type: :unix, port: 6666) ⇒ Utils::ProbeServer

The initialize method sets up a new probe server instance.

This method creates and configures a Unix domain socket server for handling probe jobs and communication. It initializes the server with a specific socket name and runtime directory, preparing it to listen for incoming connections and process jobs.



230
231
232
 
# File 'lib/utils/probe_server.rb', line 230

def initialize(server_type: :unix, port: 6666)
  @server = create_server(server_type, port)
end

Instance Method Details

#enqueue(args) ⇒ Object

The enqueue method submits a new process job to the probe server for execution.

This method transmits a process job request to the underlying Unix domain socket server, which then adds the job to the processing queue. The job includes the specified command arguments that will be executed by the probe server.

job



257
258
259
 
# File 'lib/utils/probe_server.rb', line 257

def enqueue(args)
  @server.transmit({ type: 'process_job', args: })
end

#env ⇒ Utils::ProbeServer::EnvProxy

The env method provides access to environment variable management through a proxy object.

This method returns an EnvProxy instance that allows for setting and retrieving environment variables via the probe server communication channel.

variable operations



243
244
245
 
# File 'lib/utils/probe_server.rb', line 243

def env
  EnvProxy.new(@server)
end