mock

package main

import (
	"testing"

	stats "github.com/lyft/gostats"
	"github.com/lyft/gostats/mock"
)

func main() {
	sink := mock.NewSink()
	store := stats.NewStore(sink, false)

	store.NewCounter("c").Set(2)
	store.Flush()

	// In real test code you would use the *testing.T or *testing.B
	// passed to the test function.
	t := &testing.T{}

	// This will cause the test to immediately fail with .Fatal()
	// if the assertion is false.
	sink.AssertCounterEquals(mock.Fatal(t), "c", 2)
}

package main

import (
	"fmt"
	"reflect"

	stats "github.com/lyft/gostats"
	"github.com/lyft/gostats/mock"
)

func main() {
	sink := mock.NewSink()
	store := stats.NewStore(sink, false)

	tags := map[string]string{
		"key_1": "val_1",
		"key_2": "val_2",
	}
	for i := 0; i < 4; i++ {
		store.NewCounterWithTags(fmt.Sprintf("c_%d", i), tags).Inc()
	}
	store.Flush()

	// Check that the counters all have the same tags
	for stat := range sink.Counters() {
		name, m := mock.ParseTags(stat)
		if !reflect.DeepEqual(m, tags) {
			panic(fmt.Sprintf("Tags: got: %q want: %q", m, tags))
		}
		fmt.Printf("%s: okay\n", name)
	}

}

Output:

c_0: okay
c_1: okay
c_2: okay
c_3: okay

package main

import (
	"fmt"

	stats "github.com/lyft/gostats"
	"github.com/lyft/gostats/mock"
)

func main() {
	sink := mock.NewSink()
	store := stats.NewStore(sink, false)

	tags := map[string]string{
		"key_1": "val_1",
		"key_2": "val_2",
	}
	counter := store.NewCounterWithTags("counter", tags)
	counter.Add(2)

	store.Flush()

	n := sink.Counter(mock.SerializeTags("counter", tags))
	fmt.Println("counter:", n, n == 2)

}

Output:

counter: 2 true