Introduce a ChunkRef type as part of logproto (#5643)

* Change protobuf definitions

* Adapt to an embedded ChunkRef struct

* Move the Checksum to the ChunkRef

cmd/migrate/main.go

@@ -360,7 +360,7 @@ func (m *chunkMover) moveChunks(ctx context.Context, threadID int, syncRangeCh <
 						}
 						if m.sourceUser != m.destUser {
 							// Because the incoming chunks are already encoded, to change the username we have to make a new chunk
-							nc := chunk.NewChunk(m.destUser, chk.Fingerprint, chk.Metric, chk.Data, chk.From, chk.Through)
+							nc := chunk.NewChunk(m.destUser, chk.FingerprintModel(), chk.Metric, chk.Data, chk.From, chk.Through)
 							err := nc.Encode()
 							if err != nil {
 								log.Println(threadID, "Failed to encode new chunk with new user:", err)

pkg/ingester/client/ingester.proto

@@ -2,7 +2,7 @@ syntax = "proto3";
 
 package ingesterpb;
 
-option go_package = "client";
+option go_package = "github.com/grafana/loki/pkg/ingester/client";
 
 import "github.com/gogo/protobuf/gogoproto/gogo.proto";
 import "pkg/logproto/metrics.proto";

pkg/ingester/flush_test.go

@@ -179,8 +179,8 @@ func TestFlushingCollidingLabels(t *testing.T) {
 	// make sure all chunks have different fingerprint, even colliding ones.
 	chunkFingerprints := map[model.Fingerprint]bool{}
 	for _, c := range store.getChunksForUser(userID) {
-		require.False(t, chunkFingerprints[c.Fingerprint])
-		chunkFingerprints[c.Fingerprint] = true
+		require.False(t, chunkFingerprints[c.FingerprintModel()])
+		chunkFingerprints[c.FingerprintModel()] = true
 	}
 }