(deps commandDeps)
| 1006 | } |
| 1007 | |
| 1008 | func newMemoryExtractorListPendingCommand(deps commandDeps) *cobra.Command { |
| 1009 | return &cobra.Command{ |
| 1010 | Use: "list-pending", |
| 1011 | Short: "List Memory v2 extractor pending/DLQ records", |
| 1012 | Args: cobra.NoArgs, |
| 1013 | RunE: func(cmd *cobra.Command, _ []string) error { |
| 1014 | client, err := clientFromDeps(deps) |
| 1015 | if err != nil { |
| 1016 | return err |
| 1017 | } |
| 1018 | response, err := client.ListMemoryExtractorFailures(cmd.Context()) |
| 1019 | if err != nil { |
| 1020 | return err |
| 1021 | } |
| 1022 | return writeCommandOutput(cmd, memoryObjectBundle("Memory Extractor Pending", response)) |
| 1023 | }, |
| 1024 | } |
| 1025 | } |
| 1026 | |
| 1027 | func newMemoryExtractorReplayCommand(deps commandDeps) *cobra.Command { |
| 1028 | var sessionID string |
no test coverage detected