Struct dbq::SchemaConfig

pub struct SchemaConfig { /* fields omitted */ }

Configures the tables for storing the job queue and dead letters. The default SchemaConfig uses the default schema and prefixes the tables with dbq_

Examples

Default configuration

use dbq::*;
let config = SchemaConfig::default();
assert_eq!("dbq_job_queue", config.queue_table());
assert_eq!("dbq_job_dead_letters", config.dead_letters_table());

Change the table prefix

use dbq::*;
let config = SchemaConfig::new("my".to_string());
assert_eq!("my_job_queue", config.queue_table());
assert_eq!("my_job_dead_letters", config.dead_letters_table());

Remove the table prefix

use dbq::*;
let config = SchemaConfig::new("".to_string());
assert_eq!("job_queue", config.queue_table());
assert_eq!("job_dead_letters", config.dead_letters_table());

Use a custom schema

use dbq::*;
let mut config = SchemaConfig::new("".to_string());
config.set_schema(Some("jobs".to_string()));
assert_eq!("jobs.job_queue", config.queue_table());
assert_eq!("jobs.job_dead_letters", config.dead_letters_table());

Methods

impl SchemaConfig

pub fn new(table_prefix: String) -> Self

pub fn schema(&self) -> &Option<String>

pub fn set_schema(&mut self, schema: Option<String>)

pub fn table_prefix(&self) -> &str

pub fn queue_table(&self) -> &str

pub fn dead_letters_table(&self) -> &str

Trait Implementations

impl Clone for SchemaConfig

fn clone(&self) -> SchemaConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for SchemaConfig

fn default() -> Self

Returns the "default value" for a type.

impl Debug for SchemaConfig

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

Formats the value using the given formatter.