Struct InternalConfig 

pub struct InternalConfig {
    pub specific: YozefuConfig,
    /* private fields */
}

Fields

specific: YozefuConfig

Implementations

impl InternalConfig

pub fn new(specific: YozefuConfig, workspace: Workspace) -> Self

pub fn url_template_of(&self, cluster: &str) -> String

web URL template for a given cluster

pub fn cluster(&self) -> &str

pub fn consumer_config(&self, cluster: &str) -> ConsumerConfig

Consumer configuration for the given cluster.

pub fn schema_registry_config_of( &self, cluster: &str, ) -> Option<SchemaRegistryConfig>

Returns the schema registry configuration for the given cluster.

pub fn output_file(&self) -> &PathBuf

Returns the output file path for exported kafka records.

pub fn workspace(&self) -> &Workspace

pub fn history(&self) -> &[String]

pub fn push_history(&mut self, prompt: &str)

pub fn initial_query(&self) -> &str

pub fn theme(&self) -> &str

pub fn save_config(&mut self) -> Result<(), Error>

Trait Implementations

impl Clone for InternalConfig

fn clone(&self) -> InternalConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Configuration for InternalConfig

fn kafka_config_map(&self) -> HashMap<String, String>

Returns the kafka properties

fn create_kafka_consumer<T>(&self) -> Result<T, Error>

where T: FromClientConfig,

Properties you can set for the kafka consumer: https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md

fn client_config(&self) -> ClientConfig

Properties you can set for the kafka consumer: https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md

fn kafka_client_config_from_properties( kafka_properties: HashMap<String, String>, ) -> ClientConfig

impl Debug for InternalConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.