Struct Connection 

pub struct Connection(/* private fields */);

Represents a connection to a remote or embedded KDB instance, which can be used to send and query data on that instance.

Implementations

impl Connection

pub fn connect( hostname: &str, port: u16, credentials: &str, timeout: Option<Duration>, ) -> Result<Self, ConnectionError>

[non-embedded only] Connect to a remote instance of KDB.

Examples found in repository

examples/publishing.rs (line 5)

fn main() {
    let conn = Connection::connect("127.0.0.1", 4200, "", None).unwrap();
    let l = list![i32; 1, 2, 3];
    if let Err(err) = conn.publish("upd", symbol("some_topic"), l) {
        println!("Publishing failed: {}", err);
    }
    println!("Publish succeeded! Probably.");
}

examples/connecting_to_kdb.rs (line 4)

fn main() -> Result<(), ConnectionError> {
    let conn = Connection::connect("127.0.0.1", 4200, "", None)?;
    let result = cast!(conn.eval("2+2").unwrap(); Atom<i64>);
    println!("{}", result.value());

    //Returning a list of symbols
    let result = cast!(conn.eval("`a`b`c").unwrap(); List<Symbol>);
    println!("{:?}", &result[0..]);

    Ok(())
}

pub fn new() -> Self

[embedded only] Connect to an embedded KDB instance.

pub fn publish( &self, callback: &str, topic: impl Into<KBox<Any>>, object: impl Into<KBox<Any>>, ) -> Result<(), Error>

[non-embedded only] Publish a value asynchronously to KDB.

Examples found in repository

examples/publishing.rs (line 7)

fn main() {
    let conn = Connection::connect("127.0.0.1", 4200, "", None).unwrap();
    let l = list![i32; 1, 2, 3];
    if let Err(err) = conn.publish("upd", symbol("some_topic"), l) {
        println!("Publishing failed: {}", err);
    }
    println!("Publish succeeded! Probably.");
}

pub fn eval(&self, query: &str) -> Result<KBox<Any>, Error>

Evaluate a q expression with no parameters and return a result.

Examples found in repository

examples/connecting_to_kdb.rs (line 5)

fn main() -> Result<(), ConnectionError> {
    let conn = Connection::connect("127.0.0.1", 4200, "", None)?;
    let result = cast!(conn.eval("2+2").unwrap(); Atom<i64>);
    println!("{}", result.value());

    //Returning a list of symbols
    let result = cast!(conn.eval("`a`b`c").unwrap(); List<Symbol>);
    println!("{:?}", &result[0..]);

    Ok(())
}

pub fn eval_1( &self, function: &str, param: impl Into<KBox<Any>>, ) -> Result<KBox<Any>, Error>

Evaluate a q function with a single parameter and return the result.

pub fn eval_2( &self, function: &str, param: impl Into<KBox<Any>>, param_2: impl Into<KBox<Any>>, ) -> Result<KBox<Any>, Error>

Evaluate a q function with two parameters and return the result.

pub fn eval_3( &self, function: &str, param: impl Into<KBox<Any>>, param_2: impl Into<KBox<Any>>, param_3: impl Into<KBox<Any>>, ) -> Result<KBox<Any>, Error>

Evaluate a q function with three parameters and return the result.

pub fn eval_4( &self, function: &str, param: impl Into<KBox<Any>>, param_2: impl Into<KBox<Any>>, param_3: impl Into<KBox<Any>>, param_4: impl Into<KBox<Any>>, ) -> Result<KBox<Any>, Error>

Evaluate a q function with four parameters and return the result.

pub fn eval_5( &self, function: &str, param: impl Into<KBox<Any>>, param_2: impl Into<KBox<Any>>, param_3: impl Into<KBox<Any>>, param_4: impl Into<KBox<Any>>, param_5: impl Into<KBox<Any>>, ) -> Result<KBox<Any>, Error>

Evaluate a q function with five parameters and return the result.

pub fn eval_6( &self, function: &str, param: impl Into<KBox<Any>>, param_2: impl Into<KBox<Any>>, param_3: impl Into<KBox<Any>>, param_4: impl Into<KBox<Any>>, param_5: impl Into<KBox<Any>>, param_6: impl Into<KBox<Any>>, ) -> Result<KBox<Any>, Error>

Evaluate a q function with six parameters and return the result.

pub fn eval_7( &self, function: &str, param: impl Into<KBox<Any>>, param_2: impl Into<KBox<Any>>, param_3: impl Into<KBox<Any>>, param_4: impl Into<KBox<Any>>, param_5: impl Into<KBox<Any>>, param_6: impl Into<KBox<Any>>, param_7: impl Into<KBox<Any>>, ) -> Result<KBox<Any>, Error>

Evaluate a q function with seven parameters and return the result.

pub fn eval_8( &self, function: &str, param: impl Into<KBox<Any>>, param_2: impl Into<KBox<Any>>, param_3: impl Into<KBox<Any>>, param_4: impl Into<KBox<Any>>, param_5: impl Into<KBox<Any>>, param_6: impl Into<KBox<Any>>, param_7: impl Into<KBox<Any>>, param_8: impl Into<KBox<Any>>, ) -> Result<KBox<Any>, Error>

See above and add one parameter.

Trait Implementations

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.