Struct scylla::transport::connection::Connection

pub struct Connection { /* fields omitted */ }

Implementations

impl Connection

pub async fn new(
    addr: SocketAddr,
    source_port: Option<u16>,
    compression: Option<Compression>
) -> Result<Self>

pub async fn startup<'_>(
    &'_ self,
    options: HashMap<String, String>
) -> Result<Response>

pub async fn get_options<'_>(&'_ self) -> Result<Response>

pub async fn prepare<'_>(&'_ self, query: String) -> Result<Response>

pub async fn query_single_page<'_, '_>(
    &'_ self,
    query: impl Into<Query>,
    values: &'_ [Value]
) -> Result<Option<Vec<Row>>>

pub async fn query<'_, '_, '_>(
    &'_ self,
    query: &'_ Query,
    values: &'_ [Value],
    paging_state: Option<Bytes>
) -> Result<Response>

pub async fn execute<'_, '_, '_>(
    &'_ self,
    prepared_statement: &'_ PreparedStatement,
    values: &'_ [Value],
    paging_state: Option<Bytes>
) -> Result<Response>

pub fn get_shard_info(&self) -> &Option<ShardInfo>

pub fn get_is_shard_aware(&self) -> bool

Are we connected to Scylla's shard aware port?

pub fn get_source_port(&self) -> u16