Example proto for incremented float values

- Fix parsing `OK` value returned from the storage

cmd/protoc-gen-go-kvstore/internal/generators/kvstore.tmpl

@@ -170,7 +170,7 @@ func (s *{{$codeSafeName|untitle}}Storage) Set(ctx context.Context, key *{{$pair
 		return 0, err
 	}
 
-	if v != "" {
+	if v != "" && v != "OK" {
 		{{if $pairSpecs.ValueSpecs.NumericInt}}
 		return strconv.ParseInt(v, 10, 64)
 		{{else}}
@@ -213,7 +213,7 @@ func (s *{{$codeSafeName|untitle}}Storage) Set(ctx context.Context, key *{{$pair
 		return nil, err
 	}
 
-	if v != "" {
+	if v != "" && v != "OK" {
 		msg := &{{$pairSpecs.ValueSpecs.MessageName}}{}
 		err = msg.unmarshal(v)
 		if err != nil {

examples/balance/app/main.go

@@ -0,0 +1,7 @@
+package main
+
+func main() {
+	// see test file to usage examples
+	// you may try your custom usage of kvstore here
+	return
+}

examples/balance/app/main_test.go

@@ -0,0 +1,53 @@
+package main
+
+import (
+	"context"
+	"testing"
+
+	"github.com/redis/go-redis/v9"
+	"github.com/stretchr/testify/suite"
+
+	"github.com/ehsundar/kvstore"
+	"github.com/ehsundar/kvstore/examples/balance"
+)
+
+type BalanceTestSuite struct {
+	suite.Suite
+
+	r *redis.Client
+}
+
+func TestBalanceTestSuite(t *testing.T) {
+	suite.Run(t, new(BalanceTestSuite))
+}
+
+func (s *BalanceTestSuite) SetupSuite() {
+	r := redis.NewClient(&redis.Options{
+		Network:    "tcp",
+		Addr:       "localhost:6379",
+		ClientName: "tests",
+	})
+
+	_, err := r.FlushAll(context.Background()).Result()
+	s.Nil(err)
+
+	s.r = r
+}
+
+func (s *BalanceTestSuite) TearDownTest() {
+	_, err := s.r.FlushAll(context.Background()).Result()
+	s.Nil(err)
+}
+
+func (s *BalanceTestSuite) TestShouldReadWriteToStorageRespectingTTL() {
+	ctx := context.Background()
+	storage := balance.NewBalanceStore(s.r)
+
+	bal, err := storage.Set(ctx, &balance.BalanceKey{Username: "username"}, 11.11, kvstore.WithRetrieveDisabled())
+	s.Nil(err)
+	s.InDelta(0, bal, 0.001)
+
+	bal, err = storage.Incr(ctx, &balance.BalanceKey{Username: "username"}, -3.01)
+	s.Nil(err)
+	s.InDelta(8.1, bal, 0.001)
+}

examples/balance/balance.proto

@@ -0,0 +1,21 @@
+syntax = "proto3";
+
+package balance;
+
+option go_package = "github.com/ehsundar/kvstore/examples/balance";
+
+import "kvstore/options.proto";
+
+message BalanceKey {
+  option (kvstore.key_options) = {};
+
+  string username = 1;
+}
+
+message BalanceValue {
+  option (kvstore.value_options) = {
+    numeral: {}
+  };
+
+  double balance = 1;
+}