feat: add delete commands to logcli (#18375)

Author: trevorwhitney

cmd/logcli/main.go

@@ -16,6 +16,7 @@ import (
 	"github.com/prometheus/common/version"
 
 	"github.com/grafana/loki/v3/pkg/logcli/client"
+	"github.com/grafana/loki/v3/pkg/logcli/delete"
 	"github.com/grafana/loki/v3/pkg/logcli/detected"
 	"github.com/grafana/loki/v3/pkg/logcli/index"
 	"github.com/grafana/loki/v3/pkg/logcli/labelquery"
@@ -315,6 +316,40 @@ The query is limited to processing 1000 lines per subquery; use --line-limit to
 `)
 
 	detectedFieldsQuery = newDetectedFieldsQuery(detectedFieldsCmd)
+
+	deleteCmd = app.Command("delete", "Manage log deletion requests.")
+
+	deleteCreateCmd = deleteCmd.Command("create", `Create a new log deletion request.
+
+The "delete create" command creates a new log deletion request for the specified query and time range.
+
+Example:
+
+	logcli delete create '{job="app"}' --from="2023-01-01T00:00:00Z" --to="2023-01-02T00:00:00Z"
+`)
+	deleteCreateQuery = newDeleteCreateQuery(deleteCreateCmd)
+
+	deleteListCmd = deleteCmd.Command("list", `List existing log deletion requests.
+
+The "delete list" command lists all existing log deletion requests for the tenant.
+
+Example:
+
+	logcli delete list
+	logcli delete list --output=json
+`)
+	deleteListQuery = newDeleteListQuery(deleteListCmd)
+
+	deleteCancelCmd = deleteCmd.Command("cancel", `Cancel a log deletion request.
+
+The "delete cancel" command cancels an existing log deletion request by ID.
+
+Example:
+
+	logcli delete cancel --request-id="abc123"
+	logcli delete cancel --request-id="abc123" --force
+`)
+	deleteCancelQuery = newDeleteCancelQuery(deleteCancelCmd)
 )
 
 func main() {
@@ -471,6 +506,24 @@ func main() {
 		}
 	case detectedFieldsCmd.FullCommand():
 		detectedFieldsQuery.Do(queryClient, *outputMode)
+	case deleteCreateCmd.FullCommand():
+		if err := deleteCreateQuery.CreateQuery(queryClient); err != nil {
+			log.Fatalf("Error creating delete request: %s", err)
+		}
+	case deleteListCmd.FullCommand():
+		if *outputMode == "jsonl" {
+			if err := deleteListQuery.ListQueryJSON(queryClient); err != nil {
+				log.Fatalf("Error listing delete requests: %s", err)
+			}
+		} else {
+			if err := deleteListQuery.ListQuery(queryClient); err != nil {
+				log.Fatalf("Error listing delete requests: %s", err)
+			}
+		}
+	case deleteCancelCmd.FullCommand():
+		if err := deleteCancelQuery.CancelQuery(queryClient, deleteCancelQuery.RequestID, deleteCancelQuery.Force); err != nil {
+			log.Fatalf("Error cancelling delete request: %s", err)
+		}
 	}
 }
 
@@ -781,3 +834,54 @@ func newDetectedFieldsQuery(cmd *kingpin.CmdClause) *detected.FieldsQuery {
 
 	return q
 }
+
+func newDeleteCreateQuery(cmd *kingpin.CmdClause) *delete.Query {
+	var from, to string
+	var since time.Duration
+
+	q := &delete.Query{}
+
+	cmd.Action(func(_ *kingpin.ParseContext) error {
+		defaultEnd := time.Now()
+		defaultStart := defaultEnd.Add(-since)
+
+		q.Start = mustParse(from, defaultStart)
+		q.End = mustParse(to, defaultEnd)
+		q.Quiet = *quiet
+
+		return nil
+	})
+
+	cmd.Arg("query", "LogQL query to match log lines for deletion (e.g. '{job=\"app\"}')").Required().StringVar(&q.QueryString)
+	cmd.Flag("since", "Lookback window.").Default("1h").DurationVar(&since)
+	cmd.Flag("from", "Start time for deletion (inclusive)").StringVar(&from)
+	cmd.Flag("to", "End time for deletion (exclusive)").StringVar(&to)
+	cmd.Flag("max-interval", "Maximum time interval for delete request").StringVar(&q.MaxInterval)
+
+	return q
+}
+
+func newDeleteListQuery(cmd *kingpin.CmdClause) *delete.Query {
+	q := &delete.Query{}
+
+	cmd.Action(func(_ *kingpin.ParseContext) error {
+		q.Quiet = *quiet
+		return nil
+	})
+
+	return q
+}
+
+func newDeleteCancelQuery(cmd *kingpin.CmdClause) *delete.Query {
+	q := &delete.Query{}
+
+	cmd.Action(func(_ *kingpin.ParseContext) error {
+		q.Quiet = *quiet
+		return nil
+	})
+
+	cmd.Flag("request-id", "ID of the delete request to cancel").Required().StringVar(&q.RequestID)
+	cmd.Flag("force", "Force cancellation of partially completed request").BoolVar(&q.Force)
+
+	return q
+}