exar 0.1.0

Exar DB's core event store engine with streaming support
Documentation 
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

extern crate exar;
extern crate rand;

#[cfg(test)] #[macro_use]
extern crate exar_testkit;

use exar::*;
use exar_testkit::*;

#[test]
fn integration_test() {
    let mut db = Database::new(DatabaseConfig::default());

    let ref collection_name = random_collection_name();
    let connection = db.connect(collection_name).expect("Unable to connect");

    let test_event = Event::new("data", vec!["tag1", "tag2"]);
    assert!(connection.publish(test_event.clone()).is_ok());

    let query = Query::current();
    let retrieved_events: Vec<_> = connection.subscribe(query).unwrap().take(1).collect();
    let expected_event = test_event.clone().with_id(1).with_timestamp(retrieved_events[0].timestamp);
    assert_eq!(retrieved_events, vec![expected_event]);

    assert!(db.drop_collection(collection_name).is_ok());
    assert!(!db.contains_collection(collection_name));
}