Client

Object Hierarchy:

Description:

OLLMrpc.Daemon.rpc_register();
OLLMfilesd.DaemonParams.rpc_register();
var rpc = new OLLMrpc.Client(
    GLib.Path.build_filename(
        GLib.Environment.get_user_data_dir(), "ollmchat"),
    "ollmfilesd.pid",
    "ollmfilesd.sock"
);
if (!yield rpc.connect(new OLLMrpc.Request() {
    method = "RPC-Daemon.hello",
    param = new OLLMfilesd.DaemonParams() {
        protocol = 1,
        client = "my-app"
    }
}, new OLLMrpc.ClientBoot())) {
    GLib.error("%s", rpc.connect_error);
}
var resp = yield rpc.call(new OLLMrpc.Request() {
    method = "RPC-ProjectManager.load_projects_from_db",
    param = new OLLMfilesd.ProjectParams()
});

OLLMhf.rpc_register();
var rpc = new OLLMrpc.Client("", "", "https://huggingface.co");
yield rpc.connect(new OLLMrpc.Request());
var resp = yield rpc.call(new OLLMrpc.Request() {
    method = "/api/models",
    param = new OLLMhf.Param.Search() {
        search = "llama",
        filter = "gguf",
        limit = 10
    },
    result_type = typeof(OLLMhf.ModelArray)
});

Content:

Enums:

• Protocol

Properties:

• public Stream? bin { get; }
• public BufferStream? buffer_stream { get; }
• public uint call_timeout_seconds { get; set; }
  Seconds to wait for a matching Response id.
• public string connect_error { get; }
  Last connect failure (boot, socket, or hello). Empty when connected is true. UI reads this from Client.
• public bool connected { get; }
• public string data_dir { get; construct; }
• public bool debug { get; set; }
  Copied onto a blank ClientBoot in connect. When true (default), spawn passes --debug to ollmfilesd.
• public bool live_handles { get; set; }
• public bool pass_data_dir { get; set; }
  When true, spawn passes --data-dir=data_dir; vector test CLIs only. Set in the object initializer when needed.
• public string pid { get; construct; }
• public Protocol protocol { get; }
• public HashMap<int,Object> proxies { get; set; }
  Handle id → local proxy when live_handles is on.
• public string socket_path { get; construct; }

Creation methods:

• public Client (string data_dir, string pid, string socket_name)

Methods:

• public async Response call (Request request)
  Send a request (caller must connect first).
• public async bool connect (Request hello_request, ClientBoot? boot = null)
  Open the channel and send hello_request (e.g. Daemon.hello — built by the caller, not libocrpc).
• public void disconnect ()

Signals:

• public signal void failed (Request request, Error error)
  Emitted when call completes with a daemon Response.error. Transport timeouts and disconnects surface as Response.error and this signal; wire/protocol faults abort. call still returns the response; callers may ignore errors when the UI connects here (e.g. toast / dialog).
• public signal void notification (Notification notif)

Inherited Members: