Introduce multitenant reserved label

VERSION

@@ -1 +1 @@
-v0.38.0-dev
+v0.37.1-dev

pkg/batch/batch.go

@@ -49,6 +49,7 @@ func (b *Batch) Add(ls model.LabelSet, t time.Time, line string) {
 	b.Bytes += len(line)
 
 	// Append the entry to an already existing stream (if any)
+	// Not efficient string building.
 	labels := ls.String()
 	if stream, ok := b.Streams[labels]; ok {
 		stream.add(t, line)

pkg/client/multi_tenant_client.go

@@ -36,8 +36,8 @@ const (
 	MultiTenantClientsSeparator = ";"
 )
 
-// NewMultiTenantClientWrapper returns Loki client which support more than one tenant id specified
-// under `_gardener_multitenamt_id__` labale separated with semicolumn.
+// NewMultiTenantClientWrapper returns Loki client which supports more than one tenant id specified
+// under `_gardener_multitenamt_id__` label. The tenants are separated by semicolon.
 func NewMultiTenantClientWrapper(clientToWrap types.LokiClient, copyLabelSet bool) types.LokiClient {
 	return &multiTenantClient{
 		lokiclient:   clientToWrap,

pkg/client/multi_tenant_client_test.go

@@ -114,6 +114,12 @@ var _ = Describe("Multi Tenant Client", func() {
 			s:             "test1",
 			wantedTenants: []model.LabelValue{"operator", "user"},
 		}),
+		ginkotable.Entry("Handle record with __gardener_multitenant_id__ reserved label with one empty. Separator \" ; \" and leading and trailing spaces.", handleArgs{
+			ls:            model.LabelSet{"hostname": "test", "__gardener_multitenant_id__": "  operator ; ; user  "},
+			t:             time.Now(),
+			s:             "test1",
+			wantedTenants: []model.LabelValue{"operator", "user"},
+		}),
 		ginkotable.Entry("Handle record with __gardener_multitenant_id__ and __tenant_id__ reserved labels.", handleArgs{
 			ls:            model.LabelSet{"hostname": "test", "__tenant_id__": "pinokio", "__gardener_multitenant_id__": "operator; user"},
 			t:             time.Now(),