rrichardson

error: failed to select a version for `wasm-bindgen-shared`.
    ... required by package `wasm-bindgen-macro-support v0.2.70`
    ... which satisfies dependency `wasm-bindgen-macro-support = "=0.2.70"` of package `wasm-bindgen-macro v0.2.70`
    ... which satisfies dependency `wasm-bindgen-macro = "=0.2.70"` of package `wasm-bindgen v0.2.70`
    ... which satisfies dependency `wasm-bindgen = "^0.2.70"` of package `web-time v1.1.0`
    ... which satisfies dependency `web-time = "^1.0"` of package `minstant v0.1.7`
    ... which satisfies dependency `minstant = "^0.1.7"` of package `glommio v0.8.0 (/home/ririchardson/Projects/glommio/glommio)`
    ... which satisfies path dependency `glommio` (locked to 0.8.0) of package `examples v0.0.0 (/home/ririchardson/Projects/glommio/examples)`
versions that meet the requirements `=0.2.70` are: 0.2.70

rrichardson

 pub mod envoy {
    pub mod config {
        pub mod cluster {
            pub mod v3 {
                tonic::include_proto!("envoy.config.cluster.v3");
            }
        }
        pub mod listener {
            pub mod v3 {
                tonic::include_proto!("envoy.config.listener.v3");

rrichardson

### Keybase proof

I hereby claim:

  * I am rrichardson on github.
  * I am eigenrick (https://keybase.io/eigenrick) on keybase.
  * I have a public key ASArCGeDOPOl4j8uNnNRqK0W0mYb3s7bc-mb_VErXT20awo

To claim this, I am signing this object:

rrichardson

# Maintainer: Tony Lambiris <[email protected]>

pkgname=cri-o
pkgver=1.18.3
pkgrel=1
pkgdesc='Open Container Initiative-based implementation of Kubernetes Container Runtime Interface'
arch=(x86_64)
url='https://github.com/cri-o/cri-o'
license=(Apache)
makedepends=(go go-md2man ostree)

rrichardson

    let jobs = myvec
        .into_iter()
        .map(|url| {
            // we use the end of the supplied URL to create the directory
            let uri = url.parse::<Uri>().unwrap();
            let p = uri.path();
            let segments = p.split('/').collect::<Vec<_>>();
            let end = &segments[segments.len() - 4..];
            let fullpath = Path::new(&ctx.config.data_dir).join(end.join("/"));
            std::fs::create_dir_all(fullpath.parent().unwrap()).unwrap();

rrichardson

impl From<StoreError> for MegadexError {
   |      ^^^^^^^^^^^^^^^^ doesn't have a size known at compile-time
   |
   = help: within `error::MegadexError`, the trait `std::marker::Sized` is not implemented for `(dyn std::error::Error + 'static)`
   = note: to learn more, visit <https://doc.rust-lang.org/book/second-edition/ch19-04-advanced-types.html#dynamically-sized-types-and-the-sized-trait>
   = note: required because it appears within the type `error::MegadexError`

error[E0277]: the size for values of type `(dyn std::error::Error + 'static)` cannot be known at compilation time

rrichardson

const path = require('path');
const webpack = require('webpack');
const nodeExternals = require('webpack-node-externals');

module.exports = {
    entry: {
        index: './src/index.js',
        cass: './src/cass.js',
        api: './src/api.js',
    },

rrichardson

fn kinesis_pipeline(client: DefaultKinesisClient, stream_name: String, num_puts: usize, puts_size: usize) {
    use futures::sync::mpsc::{ unbounded, UnboundedSender, UnboundedReceiver };
    use futures::{ Sink, Future, Stream };
    use futures::stream::Sender;
    use rusoto_core::reactor::DEFAULT_REACTOR;
    use tokio_core::reactor::Core; 
    
    let client = Arc::new(KinesisClient::simple(Region::UsWest2));
    let data = FauxData::new();
    

rrichardson

struct RecordIoConnection {
  buf: BytesMut,
  body: hyper::Body,
}


impl RecordIoConnection {
  pub fn connect(url: &str, buf_sz: usize) -> FutureResponse<Item=RecordIoConnection, Error=hyper::error::Error> {
    let response = create_hyper_get(); 

rrichardson

extern crate futures;
extern crate time;
extern crate tokio_core;
extern crate tokio_timer;

use std::thread::{self, JoinHandle};
use std::time::Duration;
use std::sync::atomic::{AtomicBool, Ordering};
use std::sync::Arc;
use time::Duration as TDuration;