Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 13 additions & 11 deletions internal/cmd/observability/credentials/list/list.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,22 +68,20 @@ func NewCmd(params *types.CmdParams) *cobra.Command {
if err != nil {
return fmt.Errorf("list Observability credentials: %w", err)
}
credentials := *resp.Credentials
if len(credentials) == 0 {
instanceLabel, err := observabilityUtils.GetInstanceName(ctx, apiClient, model.InstanceId, model.ProjectId)
if err != nil {
params.Printer.Debug(print.ErrorLevel, "get instance name: %v", err)
instanceLabel = model.InstanceId
}
params.Printer.Info("No credentials found for instance %q\n", instanceLabel)
return nil

credentials := resp.GetCredentials()

instanceLabel, err := observabilityUtils.GetInstanceName(ctx, apiClient, model.InstanceId, model.ProjectId)
if err != nil {
params.Printer.Debug(print.ErrorLevel, "get instance name: %v", err)
instanceLabel = model.InstanceId
}

// Truncate output
if model.Limit != nil && len(credentials) > int(*model.Limit) {
credentials = credentials[:*model.Limit]
}
return outputResult(params.Printer, model.OutputFormat, credentials)
return outputResult(params.Printer, model.OutputFormat, instanceLabel, credentials)
},
}
configureFlags(cmd)
Expand Down Expand Up @@ -124,8 +122,12 @@ func buildRequest(ctx context.Context, model *inputModel, apiClient *observabili
return req
}

func outputResult(p *print.Printer, outputFormat string, credentials []observability.ServiceKeysList) error {
func outputResult(p *print.Printer, outputFormat, instanceLabel string, credentials []observability.ServiceKeysList) error {
return p.OutputResult(outputFormat, credentials, func() error {
if len(credentials) == 0 {
p.Outputf("No credentials found for instance %q\n", instanceLabel)
return nil
}
table := tables.NewTable()
table.SetHeader("USERNAME")
for i := range credentials {
Expand Down
7 changes: 4 additions & 3 deletions internal/cmd/observability/credentials/list/list_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -173,8 +173,9 @@ func TestBuildRequest(t *testing.T) {

func TestOutputResult(t *testing.T) {
type args struct {
outputFormat string
credentials []observability.ServiceKeysList
outputFormat string
instanceLabel string
credentials []observability.ServiceKeysList
}
tests := []struct {
name string
Expand Down Expand Up @@ -204,7 +205,7 @@ func TestOutputResult(t *testing.T) {
params := testparams.NewTestParams()
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
if err := outputResult(params.Printer, tt.args.outputFormat, tt.args.credentials); (err != nil) != tt.wantErr {
if err := outputResult(params.Printer, tt.args.outputFormat, tt.args.instanceLabel, tt.args.credentials); (err != nil) != tt.wantErr {
t.Errorf("outputResult() error = %v, wantErr %v", err, tt.wantErr)
}
})
Expand Down
24 changes: 13 additions & 11 deletions internal/cmd/observability/instance/list/list.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,23 +66,21 @@ func NewCmd(params *types.CmdParams) *cobra.Command {
if err != nil {
return fmt.Errorf("get Observability instances: %w", err)
}
instances := *resp.Instances
if len(instances) == 0 {
projectLabel, err := projectname.GetProjectName(ctx, params.Printer, params.CliVersion, cmd)
if err != nil {
params.Printer.Debug(print.ErrorLevel, "get project name: %v", err)
projectLabel = model.ProjectId
}
params.Printer.Info("No instances found for project %q\n", projectLabel)
return nil

instances := resp.GetInstances()

projectLabel, err := projectname.GetProjectName(ctx, params.Printer, params.CliVersion, cmd)
if err != nil {
params.Printer.Debug(print.ErrorLevel, "get project name: %v", err)
projectLabel = model.ProjectId
}

// Truncate output
if model.Limit != nil && len(instances) > int(*model.Limit) {
instances = instances[:*model.Limit]
}

return outputResult(params.Printer, model.OutputFormat, instances)
return outputResult(params.Printer, model.OutputFormat, projectLabel, instances)
},
}

Expand Down Expand Up @@ -122,8 +120,12 @@ func buildRequest(ctx context.Context, model *inputModel, apiClient *observabili
return req
}

func outputResult(p *print.Printer, outputFormat string, instances []observability.ProjectInstanceFull) error {
func outputResult(p *print.Printer, outputFormat, projectLabel string, instances []observability.ProjectInstanceFull) error {
return p.OutputResult(outputFormat, instances, func() error {
if len(instances) == 0 {
p.Outputf("No instances found for project %q\n", projectLabel)
return nil
}
table := tables.NewTable()
table.SetHeader("ID", "NAME", "PLAN", "STATUS")
for i := range instances {
Expand Down
3 changes: 2 additions & 1 deletion internal/cmd/observability/instance/list/list_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,7 @@ func TestBuildRequest(t *testing.T) {
func TestOutputResult(t *testing.T) {
type args struct {
outputFormat string
projectLabel string
instances []observability.ProjectInstanceFull
}
tests := []struct {
Expand Down Expand Up @@ -180,7 +181,7 @@ func TestOutputResult(t *testing.T) {
params := testparams.NewTestParams()
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
if err := outputResult(params.Printer, tt.args.outputFormat, tt.args.instances); (err != nil) != tt.wantErr {
if err := outputResult(params.Printer, tt.args.outputFormat, tt.args.projectLabel, tt.args.instances); (err != nil) != tt.wantErr {
t.Errorf("outputResult() error = %v, wantErr %v", err, tt.wantErr)
}
})
Expand Down
24 changes: 13 additions & 11 deletions internal/cmd/observability/plans/plans.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,23 +66,21 @@ func NewCmd(params *types.CmdParams) *cobra.Command {
if err != nil {
return fmt.Errorf("get Observability service plans: %w", err)
}
plans := *resp.Plans
if len(plans) == 0 {
projectLabel, err := projectname.GetProjectName(ctx, params.Printer, params.CliVersion, cmd)
if err != nil {
params.Printer.Debug(print.ErrorLevel, "get project name: %v", err)
projectLabel = model.ProjectId
}
params.Printer.Info("No plans found for project %q\n", projectLabel)
return nil

plans := resp.GetPlans()

projectLabel, err := projectname.GetProjectName(ctx, params.Printer, params.CliVersion, cmd)
if err != nil {
params.Printer.Debug(print.ErrorLevel, "get project name: %v", err)
projectLabel = model.ProjectId
}

// Truncate output
if model.Limit != nil && len(plans) > int(*model.Limit) {
plans = plans[:*model.Limit]
}

return outputResult(params.Printer, model.OutputFormat, plans)
return outputResult(params.Printer, model.OutputFormat, projectLabel, plans)
},
}

Expand Down Expand Up @@ -122,8 +120,12 @@ func buildRequest(ctx context.Context, model *inputModel, apiClient *observabili
return req
}

func outputResult(p *print.Printer, outputFormat string, plans []observability.Plan) error {
func outputResult(p *print.Printer, outputFormat, projectLabel string, plans []observability.Plan) error {
return p.OutputResult(outputFormat, plans, func() error {
if len(plans) == 0 {
p.Outputf("No plans found for project %q\n", projectLabel)
return nil
}
table := tables.NewTable()
table.SetHeader("ID", "PLAN NAME", "DESCRIPTION")
for i := range plans {
Expand Down
3 changes: 2 additions & 1 deletion internal/cmd/observability/plans/plans_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,7 @@ func TestBuildRequest(t *testing.T) {
func TestOutputResult(t *testing.T) {
type args struct {
outputFormat string
projectLabel string
plans []observability.Plan
}
tests := []struct {
Expand Down Expand Up @@ -180,7 +181,7 @@ func TestOutputResult(t *testing.T) {
params := testparams.NewTestParams()
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
if err := outputResult(params.Printer, tt.args.outputFormat, tt.args.plans); (err != nil) != tt.wantErr {
if err := outputResult(params.Printer, tt.args.outputFormat, tt.args.projectLabel, tt.args.plans); (err != nil) != tt.wantErr {
t.Errorf("outputResult() error = %v, wantErr %v", err, tt.wantErr)
}
})
Expand Down
24 changes: 13 additions & 11 deletions internal/cmd/observability/scrape-config/list/list.go
Original file line number Diff line number Diff line change
Expand Up @@ -69,23 +69,21 @@ func NewCmd(params *types.CmdParams) *cobra.Command {
if err != nil {
return fmt.Errorf("get scrape configurations: %w", err)
}
configs := *resp.Data
if len(configs) == 0 {
instanceLabel, err := observabilityUtils.GetInstanceName(ctx, apiClient, model.InstanceId, model.ProjectId)
if err != nil {
params.Printer.Debug(print.ErrorLevel, "get instance name: %v", err)
instanceLabel = model.InstanceId
}
params.Printer.Info("No scrape configurations found for instance %q\n", instanceLabel)
return nil

configs := resp.GetData()

instanceLabel, err := observabilityUtils.GetInstanceName(ctx, apiClient, model.InstanceId, model.ProjectId)
if err != nil {
params.Printer.Debug(print.ErrorLevel, "get instance name: %v", err)
instanceLabel = model.InstanceId
}

// Truncate output
if model.Limit != nil && len(configs) > int(*model.Limit) {
configs = configs[:*model.Limit]
}

return outputResult(params.Printer, model.OutputFormat, configs)
return outputResult(params.Printer, model.OutputFormat, instanceLabel, configs)
},
}

Expand Down Expand Up @@ -127,8 +125,12 @@ func buildRequest(ctx context.Context, model *inputModel, apiClient *observabili
return req
}

func outputResult(p *print.Printer, outputFormat string, configs []observability.Job) error {
func outputResult(p *print.Printer, outputFormat, instanceLabel string, configs []observability.Job) error {
return p.OutputResult(outputFormat, configs, func() error {
if len(configs) == 0 {
p.Outputf("No scrape configurations found for instance %q\n", instanceLabel)
return nil
}
table := tables.NewTable()
table.SetHeader("NAME", "TARGETS", "SCRAPE INTERVAL")
for i := range configs {
Expand Down
7 changes: 4 additions & 3 deletions internal/cmd/observability/scrape-config/list/list_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -174,8 +174,9 @@ func TestBuildRequest(t *testing.T) {

func TestOutputResult(t *testing.T) {
type args struct {
outputFormat string
configs []observability.Job
outputFormat string
instanceLabel string
configs []observability.Job
}
tests := []struct {
name string
Expand Down Expand Up @@ -205,7 +206,7 @@ func TestOutputResult(t *testing.T) {
params := testparams.NewTestParams()
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
if err := outputResult(params.Printer, tt.args.outputFormat, tt.args.configs); (err != nil) != tt.wantErr {
if err := outputResult(params.Printer, tt.args.outputFormat, tt.args.instanceLabel, tt.args.configs); (err != nil) != tt.wantErr {
t.Errorf("outputResult() error = %v, wantErr %v", err, tt.wantErr)
}
})
Expand Down
Loading