main.rs 3.1 KB
Newer Older
Ryan Olson's avatar
Ryan Olson committed
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
// SPDX-FileCopyrightText: Copyright (c) 2024-2025 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
// SPDX-License-Identifier: Apache-2.0
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

use std::sync::Arc;
17
18
use clap::Parser;
use std::env;
Ryan Olson's avatar
Ryan Olson committed
19

Neelay Shah's avatar
Neelay Shah committed
20
21
use triton_distributed_runtime::{logging, DistributedRuntime, Result, Runtime, Worker};
use triton_distributed_llm::http::service::{
Ryan Olson's avatar
Ryan Olson committed
22
23
24
25
    discovery::{model_watcher, ModelWatchState},
    service_v2::HttpService,
};

26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
#[derive(Parser)]
#[command(author, version, about, long_about = None)]
struct Args {
    /// Host for the HTTP service
    #[arg(long, default_value = "0.0.0.0")]
    host: String,

    /// Port number for the HTTP service
    #[arg(short, long, default_value = "8080")]
    port: u16,

    /// Namespace for the distributed component
    #[arg(long, default_value = "public")]
    namespace: String,

    /// Component name for the service
    #[arg(long, default_value = "http")]
    component: String,
}

Ryan Olson's avatar
Ryan Olson committed
46
47
48
49
50
51
52
53
54
fn main() -> Result<()> {
    logging::init();
    let worker = Worker::from_settings()?;
    worker.execute(app)
}

async fn app(runtime: Runtime) -> Result<()> {
    let distributed = DistributedRuntime::from_settings(runtime.clone()).await?;

55
56
    let args = Args::parse();

Ryan Olson's avatar
Ryan Olson committed
57
    // create the http service and acquire the model manager
58
59
60
61
    let http_service = HttpService::builder()
        .port(args.port)
        .host(args.host)
        .build()?;
Ryan Olson's avatar
Ryan Olson committed
62
63
64
65
66
67
68
69
70
71
    let manager = http_service.model_manager().clone();

    // todo - use the IntoComponent trait to register the component
    // todo - start a service
    // todo - we want the service to create an entry and register component definition
    // todo - the component definition should be the type of component and it's config
    // in this example we will have an HttpServiceComponentDefinition object which will be
    // written to etcd
    // the cli when operating on an `http` component will validate the namespace.component is
    // registered with HttpServiceComponentDefinition
72
    let component = distributed.namespace(&args.namespace)?.component(&args.component)?;
Ryan Olson's avatar
Ryan Olson committed
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

    let etcd_root = component.etcd_path();
    let etcd_path = format!("{}/models/chat/", etcd_root);

    let state = Arc::new(ModelWatchState {
        prefix: etcd_path.clone(),
        manager,
        drt: distributed.clone(),
    });

    let etcd_client = distributed.etcd_client();
    let models_watcher = etcd_client.kv_get_and_watch_prefix(etcd_path).await?;

    let (_prefix, _watcher, receiver) = models_watcher.dissolve();
    let _watcher_task = tokio::spawn(model_watcher(state, receiver));

    http_service.run(runtime.child_token()).await
}