Enable caching in RoutingNode.

src/action.rs

@@ -17,6 +17,7 @@
 
 use messages::{SignedMessage, Content};
 use authority::Authority;
+use types::CacheOptions;
 
 /// An Action initiates a message flow < A | B > where we are (a part of) A.
 ///    1. Action::SendMessage hands a fully formed SignedMessage over to RoutingNode
@@ -36,6 +37,7 @@ pub enum Action {
     //            | the destination authority
     // RoutingNode will form the RoutingMessage and sign it as its own identity
     Churn(::direct_messages::Churn, Vec<::crust::Endpoint>),
+    SetCacheOptions(CacheOptions),
     WakeUp,
     Terminate,
 }

src/data.rs

@@ -49,6 +49,7 @@ impl Data {
 
 #[derive(Debug, PartialEq, Eq, PartialOrd, Ord, Clone, RustcEncodable, RustcDecodable)]
 pub enum DataRequest {
+    // (Identifier, TypeTag) pair for name resolution.
     StructuredData(NameType, u64),
     ImmutableData(NameType, ImmutableDataType),
     PlainData(NameType),

src/routing.rs

@@ -27,7 +27,7 @@ use messages::SignedToken;
 use routing_node::RoutingNode;
 use NameType;
 use data::{Data, DataRequest};
-use types::Bytes;
+use types::{Bytes, CacheOptions};
 use error::{RoutingError, ResponseError};
 use authority::Authority;
 use sodiumoxide::crypto;
@@ -155,6 +155,12 @@ impl Routing {
 
     }
 
+    /// Dynamically enable/disable caching for Data types.
+    pub fn set_cache_options(&self, cache_options: CacheOptions) {
+        let _ = self.action_sender.send(Action::SetCacheOptions(cache_options));
+
+    }
+
     /// Signal to RoutingNode that it needs to refuse new messages and handle all outstanding
     /// messages.  After handling all messages it will send an Event::Terminated to the user.
     pub fn stop(&mut self) {