pub trait State {
Show 40 methods
// Required methods
fn clear_error(&self);
fn last_error(&self) -> Option<String>;
fn set_error(&self, err: Error) -> Error;
fn send(&self, msg: &Event);
fn recv(&self) -> Result<Value>;
fn verbose(&self) -> u8;
fn keyring(&self, namespace: &str) -> Vec<&KeyRingEntry>;
fn dns_config(&self) -> &Resolver;
fn proxy(&self) -> Option<&SocketAddr>;
fn getopt(&self, key: &str) -> Option<&String>;
fn psl(&self) -> Result<Arc<Psl>>;
fn geoip(&self) -> Result<Arc<GeoIP>>;
fn asn(&self) -> Result<Arc<AsnDB>>;
fn sock_connect(
&self,
host: &str,
port: u16,
options: &SocketOptions
) -> Result<String>;
fn get_sock(&self, id: &str) -> Arc<Mutex<Socket>>;
fn sock_upgrade_tls(
&self,
id: &str,
options: &SocketOptions
) -> Result<TlsData>;
fn ws_connect(&self, url: Url, options: &WebSocketOptions) -> Result<String>;
fn get_ws(&self, id: &str) -> Arc<Mutex<WebSocket>>;
fn mqtt_connect(&self, url: Url, options: &MqttOptions) -> Result<String>;
fn get_mqtt(&self, id: &str) -> Arc<Mutex<MqttClient>>;
fn http_mksession(&self) -> String;
fn http_request(
&self,
session_id: &str,
method: String,
url: String,
options: RequestOptions
) -> HttpRequest;
fn get_blob(&self, id: &str) -> Result<Arc<Blob>>;
// Provided methods
fn info(&self, msg: String) { ... }
fn debug(&self, msg: String) { ... }
fn error(&self, msg: String) { ... }
fn warn(&self, msg: String) { ... }
fn warn_once(&self, msg: String) { ... }
fn status(&self, msg: String) { ... }
fn db_recv(&self) -> Result<DatabaseResponse> { ... }
fn db_insert(&self, object: Insert) -> Result<DatabaseResponse> { ... }
fn db_insert_ttl(
&self,
object: Insert,
ttl: i32
) -> Result<DatabaseResponse> { ... }
fn db_activity(&self, activity: InsertActivity) -> Result<bool> { ... }
fn db_select(
&self,
family: Family,
value: String
) -> Result<DatabaseResponse> { ... }
fn db_update(
&self,
family: Family,
value: String,
update: Update
) -> Result<DatabaseResponse> { ... }
fn stdin_read_line(&self) -> Result<Option<String>> { ... }
fn stdin_read_to_end(&self) -> Result<Option<String>> { ... }
fn ratelimit(&self, key: String, passes: u32, time: u32) -> Result<()> { ... }
fn random_id(&self) -> String { ... }
fn persist_blob(&self, id: &str) -> Result<()> { ... }