Skip to content

Instantly share code, notes, and snippets.

View rrichardson's full-sized avatar
💭
⚔️ Hacking Away

Rick Richardson rrichardson

💭
⚔️ Hacking Away
View GitHub Profile
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
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");
### 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:
# Maintainer: Tony Lambiris <tony@libpcap.net>
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)
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();
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
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
rrichardson / stream.rs
Created January 15, 2018 17:54
idea for streaming
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();
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
rrichardson / stream.rs
Created January 2, 2018 07:57
sender stream termination
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;