vladimirvivien

Start libStorage Server
`#> go/bin# LIBSTORAGE_DEBUG=true ./lss-linux -h "tcp://:7979" virtualbox -l debug`

...
                 _ _ _     _____ _
                 | (_) |   / ____| |
                 | |_| |__| (___ | |_ ___  _ __ __ _  __ _  ___
                 | | | '_ \\___ \| __/ _ \| '__/ _' |/ _' |/ _ \
                 | | | |_) |___) | || (_) | | | (_| | (_| |  __/
                 |_|_|_.__/_____/ \__\___/|_|  \__,_|\__, |\___|

vladimirvivien

Start libStorage Server

#> go/bin# LIBSTORAGE_DEBUG=true ./lss-linux -h "tcp://:7979" virtualbox -l debug

...
                 _ _ _     _____ _
                 | (_) |   / ____| |
                 | |_| |__| (___ | |_ ___  _ __ __ _  __ _  ___
                 | | | '_ \\___ \| __/ _ \| '__/ _' |/ _' |/ _ \
                 | | | |_) |___) | || (_) | | | (_| | (_| |  __/

vladimirvivien

server config

libstorage:
  embedded: true
  host:    tcp://localhost:7979

  logging:
    level: debug
    httpRequests: true
    httpResponse: true

vladimirvivien

package main

import (
	"flag"
	"fmt"
	"os"
	"path/filepath"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"

vladimirvivien

type alphaReader struct {
	src string
	cur int
}

func newAlphaReader(src string) *alphaReader {
	return &alphaReader{src: src}
}

func alpha(r byte) byte {

vladimirvivien

package main

import (
	"fmt"
	"io"
	"strings"
)

// a simple example of streaming data from a reader.
func main() {

vladimirvivien

type alphaReader struct {
	reader io.Reader
}

func newAlphaReader(reader io.Reader) *alphaReader {
	return &alphaReader{reader: reader}
}

func alpha(r byte) byte {
	if (r >= 'A' && r <= 'Z') || (r >= 'a' && r <= 'z') {

vladimirvivien

func main() {
	// use an os.File as source for alphaReader
	file, err := os.Open("./alpha_reader3.go")
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}
	defer file.Close()
	
	reader := newAlphaReader(file)

vladimirvivien

func main() {
	proverbs := []string{
		"Channels orchestrate mutexes serialize",
		"Cgo is not Go",
		"Errors are values",
		"Don't panic",
	}
	var writer bytes.Buffer

	for _, p := range proverbs {

vladimirvivien

type chanWriter struct {
	ch chan byte
}

func newChanWriter() *chanWriter {
	return &chanWriter{make(chan byte, 1024)}
}

func (w *chanWriter) Chan() <-chan byte {
	return w.ch