Struct kdb::Connection [−][src]
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
[src]
pub fn connect(
hostname: &str,
port: u16,
credentials: &str,
timeout: Option<Duration>
) -> Result<Self, ConnectionError>
[src]
hostname: &str,
port: u16,
credentials: &str,
timeout: Option<Duration>
) -> Result<Self, ConnectionError>
[non-embedded only] Connect to a remote instance of KDB.
pub fn new() -> Self
[src]
[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>
[src]
&self,
callback: &str,
topic: impl Into<KBox<Any>>,
object: impl Into<KBox<Any>>
) -> Result<(), Error>
[non-embedded only] Publish a value asynchronously to KDB.
pub fn eval(&self, query: &str) -> Result<KBox<Any>, Error>
[src]
Evaluate a q expression with no parameters and return a result.
pub fn eval_1(
&self,
function: &str,
param: impl Into<KBox<Any>>
) -> Result<KBox<Any>, Error>
[src]
&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>
[src]
&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>
[src]
&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>
[src]
&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>
[src]
&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>
[src]
&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>
[src]
&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>
[src]
&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
[src]
Auto Trait Implementations
impl RefUnwindSafe for Connection
[src]
impl Send for Connection
[src]
impl Sync for Connection
[src]
impl Unpin for Connection
[src]
impl UnwindSafe for Connection
[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,