dvaldivia

---
kind: StorageClass
apiVersion: storage.k8s.io/v1
metadata:
  name: minio-local-storage
provisioner: kubernetes.io/no-provisioner
volumeBindingMode: WaitForFirstConsumer
---
apiVersion: v1
kind: PersistentVolume

dvaldivia

apiVersion: v1
kind: Secret
metadata:
  name: test-minio-creds-secret
type: Opaque
data:
  accesskey: bWluaW8= # base 64 encoded "minio" (echo -n 'minio' | base64)
  secretkey: bWluaW8xMjM= # based 64 encoded "minio123" (echo -n 'minio123' | base64)
---
apiVersion: minio.min.io/v1

dvaldivia

apiVersion: v1
kind: Pod
metadata:
  name: m1
  labels:
    app: message
spec:
  containers:
    - name: message
      image: dvaldivia/message:latest

dvaldivia

use std::time::{Duration, Instant};

use futures::future;
use futures::future::Future;
use futures::stream;
use tokio::timer::Delay;

fn main() {
    println!("Hello tokio rust");

dvaldivia

[package]
name = "hyperserver"
version = "0.1.0"
authors = ["Daniel Valdivia <hola@danielvaldivia.com>"]
edition = "2018"

[dependencies]

futures = "0.1.27"
hyper = "0.12.29"

dvaldivia

[package]
name = "hyperserver"
version = "0.1.0"
authors = ["Daniel Valdivia <hola@danielvaldivia.com>"]
edition = "2018"

[dependencies]

futures = "0.1.27"
hyper = "0.12.29"

dvaldivia

package main

import (
	"encoding/csv"
	"flag"
	"fmt"
	"io"
	"log"
	"os"
	"reflect"

dvaldivia

extern crate futures;
extern crate hyper;

use std::error::Error;

use futures::Async;
use futures::future;
use futures::Poll;
use futures::Stream;
use hyper::{Body, Request, Response, Server};

dvaldivia

extern crate futures;
extern crate hyper;

use std::error::Error;

use futures::Async;
use futures::future;
use futures::Poll;
use futures::Stream;
use hyper::{Body, Request, Response, Server};

dvaldivia

extern crate futures;
extern crate hyper;

use std::error::Error;

use futures::Async;
use futures::future;
use futures::Poll;
use futures::Stream;
use hyper::{Body, Request, Response, Server};