View create_in_order.rs
#[test]
fn create_in_order() {
let core = Core::new().unwrap();
let mut client = TestClient::new(core);
let requests: Vec<FutureKeySpaceInfo> = (1..4).map(|_| {
kv::create_in_order( &client, "/test/foo", "bar", None)
}).collect();
let work = join_all(requests).and_then(|mut ksis: Vec<KeySpaceInfo>| {
View first_ok.rs
struct Client {
members: Vec<Member>,
}
impl Client {
fn first_ok<F>(&self, callback: F) -> Result<GoodThing, Vec<BadThing>>
where
F: Fn(&Member) -> Result<GoodThing, BadThing>
{
let mut errors = Vec::with_capacity(self.members.len());
View Cargo.toml
[package]
name = "ruma-client-test"
version = "0.1.0"
[dependencies]
futures = "0.1.13"
tokio-service = "0.1.0"
[dependencies.hyper]
git = "https://github.com/hyperium/hyper"
View generic_assoc_type_constraint.rs
// In crate `endpoint`:
pub trait Endpoint {
type Request: TryInto<hyper::Request>;
type Response: TryFrom<hyper::Response>;
}
// In crate `client`:
pub struct Client;
View algo.txt
$ ./algo
What provider would you like to use?
1. DigitalOcean
2. Amazon EC2
3. Microsoft Azure
4. Google Compute Engine (only for testing, see issue #369)
5. Install to existing Ubuntu 16.04 server
Enter the number of your desired provider
View kubelet.log
$ sudo journalctl -u kubelet
-- Logs begin at Fri 2017-04-14 13:36:03 PDT, end at Fri 2017-04-14 14:53:40 PDT. --
Apr 14 13:36:03 pearkube-03 kubelet[30954]: I0414 13:36:02.080311 30954 reconciler.go:190] UnmountVolume operation started for volume "kubernetes.io/secret/5b810d2c-2033-11e7-8e6e-b827ebfa0d18-wrapped_wrapped_wrapped_wrapped_wrapped_wra
Apr 14 13:36:03 pearkube-03 kubelet[30954]: I0414 13:36:02.080599 30954 reconciler.go:190] UnmountVolume operation started for volume "kubernetes.io/secret/5b810d2c-2033-11e7-8e6e-b827ebfa0d18-wrapped_wrapped_wrapped_wrapped_wrapped_wra
Apr 14 13:36:03 pearkube-03 kubelet[30954]: I0414 13:36:02.081036 30954 reconciler.go:190] UnmountVolume operation started for volume "kubernetes.io/secret/5b810d2c-2033-11e7-8e6e-b827ebfa0d18-wrapped_wrapped_wrapped_wrapped_wrapped_wra
Apr 14 13:36:03 pearkube-03 kubelet[30954]: I0414 13:36:02.081583 30954 reconciler.go:190] UnmountVolume operation started for volume "kubernetes.io/secret/5b810d2c-2033-11e7-8e6e-b827ebfa0d1
View compiler_output.txt
error[E0495]: cannot infer an appropriate lifetime for lifetime parameter in function call due to conflicting requirements
--> src/main.rs:39:37
|
39 | for item in self.collection.iter() {
| ^^^^
|
note: first, the lifetime cannot outlive the anonymous lifetime #1 defined on the body at 36:90...
--> src/main.rs:36:91
|
36 | fn dispatch(&self, input: &'static str) -> Box<Stream<Item = Success, Error = Error>> {
View clusterrolebindings.yml
apiVersion: v1
items:
- apiVersion: rbac.authorization.k8s.io/v1alpha1
kind: ClusterRoleBinding
metadata:
creationTimestamp: 2017-02-23T00:03:51Z
name: cluster-admin
namespace: ""
resourceVersion: "35"
selfLink: /apis/rbac.authorization.k8s.io/v1alpha1/clusterrolebindingscluster-admin
View main.rs
trait HasEndpoint {
type Endpoint: Endpoint;
}
trait Endpoint {
type Request: Default + ToString;
}
struct Foo;
View Cargo.lock
[root]
name = "ruma"
version = "0.1.0"
dependencies = [
"argon2rs 0.2.5 (registry+https://github.com/rust-lang/crates.io-index)",
"base64 0.3.0 (registry+https://github.com/rust-lang/crates.io-index)",
"bodyparser 0.5.0 (git+https://github.com/jimmycuadra/body-parser?branch=serde-0.9)",
"chrono 0.2.25 (registry+https://github.com/rust-lang/crates.io-index)",
"clap 2.20.0 (registry+https://github.com/rust-lang/crates.io-index)",
"diesel 0.9.1 (registry+https://github.com/rust-lang/crates.io-index)",