fluvio_sc_schema/
versions.rs

1#![allow(clippy::assign_op_pattern)]
2
3//!
4//! # API Versions
5//!
6//! Public API to retrieve a list of APIs and their version numbers from the SC.
7//! SC supports Kafka as well as Fluvio specific APIs.
8//!
9
10pub use fluvio_protocol::link::versions::{ApiVersionKey, ApiVersions};
11pub use fluvio_protocol::link::versions::{ApiVersionsRequest, ApiVersionsResponse};
12use crate::apis::AdminPublicApiKey;
13
14/// Given an API key, it returns max_version. None if not found
15pub fn lookup_version(api_key: AdminPublicApiKey, versions: &[ApiVersionKey]) -> Option<i16> {
16    for version in versions {
17        if version.api_key == api_key as i16 {
18            return Some(version.max_version);
19        }
20    }
21    None
22}