Struct ControlChannel 

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

The Sonic Channel Control mode is used for administration purposes. Once in this mode, you cannot switch to other modes or gain access to commands from other modes.

Available commands

In this mode you can use consolidate, backup, restore, ping and quit commands.

Note: This mode requires enabling the control feature.

Implementations

impl ControlChannel

pub fn quit(&self) -> Result<<QuitCommand as StreamCommand>::Response>

Stop connection.

let channel = ControlChannel::start(
    "localhost:1491",
    "SecretPassword",
)?;

channel.quit()?;

pub fn ping(&self) -> Result<<PingCommand as StreamCommand>::Response>

Ping server.

let channel = ControlChannel::start(
    "localhost:1491",
    "SecretPassword",
)?;

channel.ping()?;

impl ControlChannel

pub fn trigger( &self, req: TriggerRequest<'_>, ) -> Result<<TriggerCommand<'_> as StreamCommand>::Response>

Trigger control action.

Note: This method requires enabling the control feature and start connection in Control mode

let control_channel = ControlChannel::start(
    "localhost:1491",
    "SecretPassword",
)?;

control_channel.trigger(TriggerRequest::Consolidate)?;

pub fn consolidate(&self) -> Result<()>

Consolidate indexed search data instead of waiting for the next automated consolidation tick.

Note: This method requires enabling the control feature and start connection in Control mode.

let control_channel = ControlChannel::start(
    "localhost:1491",
    "SecretPassword",
)?;

control_channel.consolidate()?;

pub fn backup(&self, path: &str) -> Result<()>

Backup KV + FST to /<BACKUP_{KV/FST}_PATH> See sonic backend source code for more information.

Note: This method requires enabling the control feature and start connection in Control mode.

let control_channel = ControlChannel::start(
    "localhost:1491",
    "SecretPassword",
)?;

control_channel.backup("2020-08-07T23-48")?;

pub fn restore(&self, path: &str) -> Result<()>

Restore KV + FST from if you already have backup with the same name.

Note: This method requires enabling the control feature and start connection in Control mode.

let control_channel = ControlChannel::start(
    "localhost:1491",
    "SecretPassword",
)?;

let result = control_channel.restore("2020-08-07T23-48")?;
assert_eq!(result, ());

Trait Implementations

impl Debug for ControlChannel

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

Formats the value using the given formatter.

impl SonicChannel for ControlChannel

type Channel = ControlChannel

Sonic channel struct

fn stream(&self) -> &SonicStream

Returns reference for sonic stream of connection

fn start<A, S>(addr: A, password: S) -> Result<Self::Channel>

where A: ToSocketAddrs, S: ToString,

Connects to sonic backend and run start command.