public package name

Author: alexdebril

.example/main.go

@@ -5,15 +5,15 @@ import (
 	"embed"
 	"encoding/json"
 	"fmt"
-	"github.com/DTSL/go-bigtable-access-layer/repository"
 	"io"
 	"log"
 	"os"
 	"time"
 
 	"cloud.google.com/go/bigtable"
-	"github.com/DTSL/go-bigtable-access-layer/aggregation"
-	"github.com/DTSL/go-bigtable-access-layer/mapping"
+	"github.com/sendinblue/bigtable-access-layer/aggregation"
+	"github.com/sendinblue/bigtable-access-layer/mapping"
+	"github.com/sendinblue/bigtable-access-layer/repository"
 )
 
 const (
@@ -74,8 +74,8 @@ func readAndUseMapping(ctx context.Context, client *bigtable.Client, out io.Writ
 		cols, events := mapper.GetMappedEvents(items)
 		fmt.Fprintf(out, "Columns: %+v\n", cols)
 		for _, event := range events {
-            fmt.Fprintf(out, "Event: %+v\n", event)
-        }
+			fmt.Fprintf(out, "Event: %+v\n", event)
+		}
 	}
 	return nil
 }
@@ -110,9 +110,9 @@ func aggregate(ctx context.Context, client *bigtable.Client, out io.Writer, tabl
 	}
 	j, err := json.Marshal(jsonOutput)
 	if err != nil {
-		_,_ = fmt.Fprintf(out, "error while formatting JSON: %v. Delivering the raw content instead:\n %+v \n", err, jsonOutput)
+		_, _ = fmt.Fprintf(out, "error while formatting JSON: %v. Delivering the raw content instead:\n %+v \n", err, jsonOutput)
 	}
-	_,_ = fmt.Fprintf(out, "%s\n", j)
+	_, _ = fmt.Fprintf(out, "%s\n", j)
 	return nil
 }
 
@@ -129,8 +129,8 @@ func printTwoEvents(ctx context.Context, client *bigtable.Client, out io.Writer,
 	repo := repository.NewRepository(client.Open(table), mapper)
 	eventSet, err := repo.Read(ctx, "contact-3")
 	if err != nil {
-        return err
-    }
+		return err
+	}
 	jsonOutput := make(map[string]interface{})
 	jsonOutput["columns"] = eventSet.Columns
 	for fam, events := range eventSet.Events {
@@ -139,9 +139,9 @@ func printTwoEvents(ctx context.Context, client *bigtable.Client, out io.Writer,
 	}
 	j, err := json.Marshal(jsonOutput)
 	if err != nil {
-        _,_ = fmt.Fprintf(out, "error while formatting JSON: %v. Delivering the raw content instead:\n %+v \n", err, jsonOutput)
-    }
-	_,_ = fmt.Fprintf(out, "%s\n", j)
+		_, _ = fmt.Fprintf(out, "error while formatting JSON: %v. Delivering the raw content instead:\n %+v \n", err, jsonOutput)
+	}
+	_, _ = fmt.Fprintf(out, "%s\n", j)
 	return nil
 }
 

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2021 DTSL
+Copyright (c) 2021-2022 Sendinblue
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

README.md

@@ -1,10 +1,6 @@
-# go-bigtable-access-layer
+# bigtable-access-layer
 
-[![Maintainability](https://api.codeclimate.com/v1/badges/e06e7c0df20da7a298fc/maintainability)](https://codeclimate.com/repos/619e604df3947401b701334c/maintainability)
-[![Test Coverage](https://api.codeclimate.com/v1/badges/e06e7c0df20da7a298fc/test_coverage)](https://codeclimate.com/repos/619e604df3947401b701334c/test_coverage)
-
-
-`go-bigtable-access-layer` is a library designed to ease reading data from Big Table. it features:
+`bigtable-access-layer` is a library designed to ease reading data from Big Table. it features:
 
 - cells grouping to build events using the timestamp
 - schema mapping to transform the data into a human-readable format
@@ -133,20 +129,6 @@ for name, event := range groupByEventAndDevice {
 }
 ```
 
-## Documentation
-
-### Godoc
-
-To browse the documentation, you can use `godoc` in the root folder of the library.
-
-```shell
-go get -u golang.org/x/tools/godoc
-cd $GOPATH/src/github.com/DTSL/go-bigtable-access-layer
-godoc
-```
-
-Then head to http://localhost:6060/pkg/github.com/DTSL/go-bigtable-access-layer/
-
 ### Example code
 
 Please see the code in the ['example folder](.example) for a complete example that you can run on your local machine using the emulator provided with Google Cloud SDK.

aggregation/aggregate.go

@@ -1,6 +1,6 @@
 /*
 Package aggregation provides aggregation functions to group events as if we were using SQL statement such as GROUP BY.
- */
+*/
 /*
 Two main functions are provided:
  - GetLatestBy to get the latest event for each group. A group is defined by one or more columns.
@@ -13,7 +13,7 @@ package aggregation
 import (
 	"strconv"
 
-	"github.com/DTSL/go-bigtable-access-layer/data"
+	"github.com/sendinblue/bigtable-access-layer/data"
 )
 
 // GetLatestBy groups lines by the given columns keeping the most recent one, thus without performing any aggregation.
@@ -91,8 +91,8 @@ func NewMax(column string, projection string) *Max {
 
 func (m *Max) Compute(e *data.Event, events []*data.Event) *data.Event {
 	e.Cells[m.projection] = selectOne(e, events, m.column, func(c, s float64) bool {
-        return c > s
-    })
+		return c > s
+	})
 	return e
 }
 

aggregation/aggregate_test.go

@@ -5,19 +5,19 @@ import (
 	"cloud.google.com/go/bigtable/bttest"
 	"context"
 	"fmt"
-	"github.com/DTSL/go-bigtable-access-layer/mapping"
-	"github.com/DTSL/go-bigtable-access-layer/repository"
+	"github.com/sendinblue/bigtable-access-layer/mapping"
+	"github.com/sendinblue/bigtable-access-layer/repository"
 	"google.golang.org/api/option"
 	"google.golang.org/grpc"
 	"log"
 	"testing"
 	"time"
 
-	"github.com/DTSL/go-bigtable-access-layer/data"
+	"github.com/sendinblue/bigtable-access-layer/data"
 )
 
 const (
-	projectID = "project-id"
+	projectID    = "project-id"
 	instance     = "instance-id"
 	table        = "ecommerce_events"
 	columnFamily = "front"
@@ -405,7 +405,7 @@ func TestAverage_Compute(t *testing.T) {
 			},
 		},
 	}
-	comp(t,  result, expected)
+	comp(t, result, expected)
 }
 
 func TestSum_Compute(t *testing.T) {
@@ -734,11 +734,11 @@ func comp(t *testing.T, result, expected map[string]*data.Event) {
 		t.Fatalf("wrong number of events, wanted: %v, got :%v \n", len(expected), len(result))
 	}
 	for name, events := range result {
-		if _, ok := expected[name]; ! ok {
+		if _, ok := expected[name]; !ok {
 			t.Fatalf("unexpected group %s \n", name)
 		}
 		for cname, cvalue := range events.Cells {
-			if v, ok := expected[name].Cells[cname]; ! ok {
+			if v, ok := expected[name].Cells[cname]; !ok {
 				t.Fatalf("unexpected column")
 			} else {
 				if cvalue != v {
@@ -810,7 +810,7 @@ func generateMutations(numEvents int) []*bigtable.Mutation {
 		default:
 			mut.Set("front", "1", t, []byte("1"))
 		}
-		mut.Set("front", "a", t, []byte(fmt.Sprintf("%d", mod * 10)))
+		mut.Set("front", "a", t, []byte(fmt.Sprintf("%d", mod*10)))
 		mut.Set("front", "d", t, []byte(fmt.Sprintf("%d", 1+(i%2))))
 		mutations = append(mutations, mut)
 	}

doc.go

@@ -1,9 +1,9 @@
 /*
 Copyright 2021 Sendinblue S.A.S
- */
+*/
 
 /*
-Package go_bigtable_access_layer is a library designed to ease reading data from Big Table. it features:
+Package bigtable_access_layer is a library designed to ease reading data from Big Table. it features:
 
  - Cells grouping to build events using the timestamp
  - Schema mapping to transform the data into a human-readable format
@@ -123,4 +123,4 @@ the required logic to search filtered data and collect all properties for each e
 	}
 
 */
-package go_bigtable_access_layer // import "github.com/sendinblue/go-bigtable-access-layer"
+package bigtable_access_layer // import "github.com/sendinblue/bigtable-access-layer"

go.mod

@@ -1,28 +1,36 @@
-module github.com/DTSL/go-bigtable-access-layer
+module github.com/sendinblue/bigtable-access-layer
 
 go 1.17
 
 require (
-	cloud.google.com/go/bigtable v1.11.0
-	google.golang.org/api v0.59.0
-	google.golang.org/grpc v1.40.0
+	cloud.google.com/go/bigtable v1.13.0
+	google.golang.org/api v0.70.0
+	google.golang.org/grpc v1.44.0
 )
 
 require (
-	cloud.google.com/go v0.97.0 // indirect
+	cloud.google.com/go v0.100.2 // indirect
+	cloud.google.com/go/compute v1.3.0 // indirect
+	cloud.google.com/go/iam v0.1.1 // indirect
+	github.com/census-instrumentation/opencensus-proto v0.2.1 // indirect
+	github.com/cespare/xxhash/v2 v2.1.1 // indirect
+	github.com/cncf/udpa/go v0.0.0-20210930031921-04548b0d99d4 // indirect
+	github.com/cncf/xds/go v0.0.0-20211011173535-cb28da3451f1 // indirect
+	github.com/envoyproxy/go-control-plane v0.9.10-0.20210907150352-cf90f659a021 // indirect
+	github.com/envoyproxy/protoc-gen-validate v0.1.0 // indirect
 	github.com/golang/groupcache v0.0.0-20200121045136-8c9f03a8e57e // indirect
 	github.com/golang/protobuf v1.5.2 // indirect
 	github.com/google/btree v1.0.1 // indirect
-	github.com/google/go-cmp v0.5.6 // indirect
+	github.com/google/go-cmp v0.5.7 // indirect
 	github.com/googleapis/gax-go/v2 v2.1.1 // indirect
 	go.opencensus.io v0.23.0 // indirect
-	golang.org/x/net v0.0.0-20210503060351-7fd8e65b6420 // indirect
-	golang.org/x/oauth2 v0.0.0-20211005180243-6b3c2da341f1 // indirect
-	golang.org/x/sys v0.0.0-20211025201205-69cdffdb9359 // indirect
-	golang.org/x/text v0.3.6 // indirect
+	golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd // indirect
+	golang.org/x/oauth2 v0.0.0-20211104180415-d3ed0bb246c8 // indirect
+	golang.org/x/sys v0.0.0-20220209214540-3681064d5158 // indirect
+	golang.org/x/text v0.3.7 // indirect
 	golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 // indirect
 	google.golang.org/appengine v1.6.7 // indirect
-	google.golang.org/genproto v0.0.0-20211027162914-98a5263abeca // indirect
+	google.golang.org/genproto v0.0.0-20220218161850-94dd64e39d7c // indirect
 	google.golang.org/protobuf v1.27.1 // indirect
 	rsc.io/binaryregexp v0.2.0 // indirect
 )