slok

hand := &handler.HandlerFunc{
    AddFunc: func(ctx context.Context, obj runtime.Object) error {
        // Get the parent span.
        pSpan := opentracing.SpanFromContext(ctx)

        // Create a new span.
        span := tracer.StartSpan("AddFunc", opentracing.ChildOf(pSpan.Context()))
        defer span.Finish()

        // Do stuff...

slok

// Initialize logger.
log := &log.Std{}
// Create the controller that will refresh every 30 seconds.
ctrl := controller.NewSequential(30*time.Second, hand, retr, log)
// Start our controller.
stopC := make(chan struct{})
if err := ctrl.Run(stopC); err != nil {
    log.Errorf("error running controller: %s", err)
    os.Exit(1)
}

slok

// Our domain logic that will print every add/sync/update and delete event we .
hand := &handler.HandlerFunc{
    AddFunc: func(obj runtime.Object) error {
        pod := obj.(*corev1.Pod)
        log.Infof("Pod Add event: %s/%s", pod.Namespace, pod.Name)
        return nil
    },
    DeleteFunc: func(s string) error {
        log.Infof("Pod Delete event: %s", s)
        return nil

slok

// Create our retriever so the controller knows how to get/listen for pod events.
retr := &retrieve.Resource{
    Object: &corev1.Pod{},
    ListerWatcher: &cache.ListWatch{
        ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
            return k8scli.CoreV1().Pods("").List(options)
        },
        WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
            return k8scli.CoreV1().Pods("").Watch(options)
        },

slok

package main

import (
	"bytes"
	"encoding/json"
	"flag"
	"fmt"
	"log"
	"net/http"
	"net/url"

slok

#!/bin/bash

# Wait until consul instance on clust
INSTANCE_IP="127.0.0.1"
NEXT_WAIT_TIME=0
MAX_WAIT_TIME=35


check_consul_sync() {
    # If we don't have leaders _last_log_index then get it

slok

package main

import (
	"flag"
	"fmt"
	"log"
	"net/http"
)

func initFlags(addr *string, port *int, retCode *int, body *string) {

slok

trap 'echo captured;sleep 30;exit' SIGINT SIGTERM && while true; do sleep 1; done

slok

// Package main is an example of how handler pattern works in golang.
//
// At first you will need some sort of start point. To do this we create
// ExampleHandler interface, this interface has a trigger method that will
// execute the chain, in his case is RunExample, it accepts a writer, and a
// custom input object, as you see there is an out and an in parameter.
//
// We could work like this you can create multiple ExampleHandlers in a helper
// function and call them on in another. But this is not very handy and it smells
//

slok

gvm install go1.6.2
gvm use go1.6.2 --default
gvm pkgset create slok
gvm pkgenv slok

# Add this lines
export GOPATH; GOPATH="/home/slok/projects/work/go:/home/slok/projects/personal/go:$GOPATH"
export PATH; PATH="/home/slok/projects/work/go/bin:/home/slok/projects/personal/go/bin:$PATH"

gvm pkgset use slok --default