class Obsctl::Server::CommandExecutor

Overview

Executes validated IPC commands against server-owned config, state, and OBS client.

Defined in:

obsctl/server/command_executor.cr

Constant Summary

JSON_SAFE_COUNTER_MAX = Int64::MAX.to_u64

Constructors

.new(config : Config::Config, config_path : String, state : StateStore, supervisor : ObsSupervisor, socket_path : String, started_at : Time = Time.utc, client_count : Proc(Int32) | Nil = nil, dropped_reconnect_diagnostic_logs : Proc(UInt64) | Nil = nil, log_broadcast : Proc(JSON::Any, Nil) | Nil = nil)
Creates a command executor for one server runtime.

Instance Method Summary

#execute(request : IPC::Request) : IPC::Response
Executes a command request and converts domain failures into IPC errors.

Constructor Detail

def self.new(config : Config::Config, config_path : String, state : StateStore, supervisor : ObsSupervisor, socket_path : String, started_at : Time = Time.utc, client_count : Proc(Int32) | Nil = nil, dropped_reconnect_diagnostic_logs : Proc(UInt64) | Nil = nil, log_broadcast : Proc(JSON::Any, Nil) | Nil = nil) #

Creates a command executor for one server runtime.

[View source]

Instance Method Detail

def execute(request : IPC::Request) : IPC::Response #

Executes a command request and converts domain failures into IPC errors.