add cluster field

naver · Jan 9, 2025 · d98e21d · d98e21d
1 parent 2ea8e90
commit d98e21d
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/docs/design/log_sink.md b/docs/design/log_sink.md
@@ -156,6 +156,7 @@ spec:
 Field | Description
 --- | ---
 `{{TimeLayout "2006-01-02"}}` | Time based directory layout 
+`{{.Cluster}}` | Cluster name
 `{{.Namespace}}` | Log source namespace name
 `{{.SinkName}}` | Lobster sink name
 `{{.RuleName}}` | Rule name in Lobster sink

diff --git a/pkg/lobster/sink/exporter/uploader/basic.go b/pkg/lobster/sink/exporter/uploader/basic.go
@@ -173,6 +173,7 @@ func (b BasicUploader) templateDir(chunk model.Chunk, date time.Time) (string, e
 	return template.GeneratePath(
 		b.Order.LogExportRule.BasicBucket.PathTemplate,
 		template.PathElement{
+			Cluster:    chunk.Cluster,
 			Namespace:  chunk.Namespace,
 			SinkName:   b.Order.SinkName,
 			RuleName:   b.Order.LogExportRule.Name,

diff --git a/pkg/operator/api/v1/template/template.go b/pkg/operator/api/v1/template/template.go
@@ -36,6 +36,7 @@ func init() {
 }
 
 type PathElement struct {
+	Cluster    string
 	Namespace  string
 	SinkName   string
 	RuleName   string