synnax/client/cpp/transport.h at 9f062a8cf7270d10a78f8582d42655eba87c3f6e · synnaxlabs/synnax · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
// Copyright 2026 Synnax Labs, Inc.
//
// Use of this software is governed by the Business Source License included in the file
// licenses/BSL.txt.
//
// As of the Change Date specified in that file, in accordance with the Business Source
// License, use of this software will be governed by the Apache License, Version 2.0,
// included in the file licenses/APL.txt.

#pragma once

#include "client/cpp/arc/arc.h"
#include "client/cpp/auth/auth.h"
#include "client/cpp/channel/channel.h"
#include "client/cpp/connection/checker.h"
#include "client/cpp/device/device.h"
#include "client/cpp/framer/framer.h"
#include "client/cpp/rack/rack.h"
#include "client/cpp/ranger/ranger.h"
#include "client/cpp/status/status.h"
#include "client/cpp/view/view.h"

namespace synnax::details {
struct Transport {
    Transport(
        uint16_t port,
        const std::string &ip,
        const std::string &ca_cert_file,
        const std::string &client_cert_file,
        const std::string &client_key_file
    );

    void use(const std::shared_ptr<freighter::Middleware> &) const;

    std::unique_ptr<auth::LoginClient> auth_login;
    std::unique_ptr<framer::StreamerClient> frame_stream;
    std::unique_ptr<framer::WriterClient> frame_write;
    std::shared_ptr<channel::CreateClient> chan_create;
    std::shared_ptr<channel::RetrieveClient> chan_retrieve;
    std::unique_ptr<ranger::RetrieveClient> range_retrieve;
    std::unique_ptr<ranger::CreateClient> range_create;
    std::unique_ptr<ranger::SetEndClient> range_set_end;
    std::shared_ptr<ranger::kv::DeleteClient> range_kv_delete;
    std::shared_ptr<ranger::kv::GetClient> range_kv_get;
    std::shared_ptr<ranger::kv::SetClient> range_kv_set;
    std::unique_ptr<rack::CreateClient> rack_create_client;
    std::unique_ptr<rack::RetrieveClient> rack_retrieve;
    std::unique_ptr<rack::DeleteClient> rack_delete;
    std::shared_ptr<task::CreateClient> task_create;
    std::shared_ptr<task::RetrieveClient> task_retrieve;
    std::shared_ptr<task::DeleteClient> task_delete;
    std::unique_ptr<device::CreateClient> device_create;
    std::unique_ptr<device::RetrieveClient> device_retrieve;
    std::unique_ptr<device::DeleteClient> device_delete;
    std::shared_ptr<status::RetrieveClient> status_retrieve;
    std::shared_ptr<status::SetClient> status_set;
    std::shared_ptr<status::DeleteClient> status_delete;
    std::shared_ptr<status::SetByKeyOrNameClient> status_set_by_key_or_name;
    std::shared_ptr<arc::CreateClient> arc_create;
    std::shared_ptr<arc::RetrieveClient> arc_retrieve;
    std::shared_ptr<arc::DeleteClient> arc_delete;
    std::unique_ptr<view::CreateClient> view_create;
    std::unique_ptr<view::RetrieveClient> view_retrieve;
    std::unique_ptr<view::DeleteClient> view_delete;
    std::unique_ptr<connection::CheckClient> connectivity_check;
};
}