meta_srv/
pubsub.rs

1// Copyright 2023 Greptime Team
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use api::v1::meta::HeartbeatRequest;
16
17mod publish;
18mod subscribe_manager;
19mod subscriber;
20#[cfg(test)]
21mod tests;
22
23pub use publish::{DefaultPublisher, Publisher, PublisherRef};
24pub use subscribe_manager::{
25    DefaultSubscribeManager, SubscribeRequest, SubscriptionManager, SubscriptionManagerRef,
26    SubscriptionQuery, UnsubscribeRequest,
27};
28pub use subscriber::{Subscriber, SubscriberRef, Transport};
29
30/// Subscribed topic type, determined by the ability of meta.
31#[derive(Debug, Clone, Copy, Hash, PartialEq, Eq)]
32pub enum Topic {
33    Heartbeat,
34}
35
36#[derive(Clone, Debug)]
37pub enum Message {
38    Heartbeat(Box<HeartbeatRequest>),
39}
40
41impl Message {
42    pub fn topic(&self) -> Topic {
43        match self {
44            Message::Heartbeat(_) => Topic::Heartbeat,
45        }
46    }
47}
meta_srv/pubsub.rs

meta_srv/
pubsub.rs
