Client

Object Hierarchy:

Description:

OLLMrpc.Daemon.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",
    args = OLLMrpc.args("is", 1, "my-app")
}, new OLLMrpc.ClientBoot())) {
    GLib.error("%s", rpc.connect_error);
}
var resp = yield rpc.call(new OLLMrpc.Request() {
    method = "ProjectManager.rpc_load_projects_from_db"
});

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",
    args = OLLMrpc.args("o", new OLLMhf.Param.Search() {
        search = "llama",
        filter = "gguf",
        limit = 10
    }),
    result_type = typeof(OLLMhf.ModelArray)
});

var http = new OLLMrpc.Transport.HttpClient("https://host:8443") {
    bin_body = true,
    tls_certificate = leaf.certificate,
    tls_database = leaf.trust
};
var rpc = new OLLMrpc.Client("", "", "https://host:8443") {
    http = http
};
if (!yield rpc.connect(new OLLMrpc.Request() {
    method = "RPC-Daemon.hello",
    args = OLLMrpc.args("is", 1, "ollmchat")
})) {
    GLib.error("%s", rpc.connect_error);
}

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 HttpClient? http { get; set; }
  Bin POST transport to a Transport.HttpServer (the ollmfilesd HTTPS gate).
• 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) throws Error
  Send a request (caller must connect first).
• public Response call_poll (Request request) throws Error
  Blocking call using a manual socket poll loop.
• public Response call_sync (Request request) throws Error
  Blocking call that does not iterate the default GLib.MainContext.
• 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 configure_tls (TlsClientConnection connection)
  Lets the owner supply credentials for a remote TCP TLS connection.
• 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 invoke (Invoke call)
  Server → client GI callback invoke (not a Notification).
• public signal void notification (Notification notif)

Inherited Members: