github/karma
1
0
Fork 0
mirror of https://github.com/prymitive/karma synced 2026-02-13 20:59:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(backend): update alertmanager client code

Browse Source
This commit is contained in:
Łukasz Mierzwa
2020-07-18 21:56:00 +01:00
committed by Łukasz Mierzwa
parent 1690ad3a67
commit ffdc843245
11 changed files with 24 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/mapper/v017/api.go
View File

@@ -18,7 +18,7 @@ import (
"github.com/prymitive/karma/internal/models"
)
func newClient(uri string, headers map[string]string, httpTransport http.RoundTripper) *client.Alertmanager {
func newClient(uri string, headers map[string]string, httpTransport http.RoundTripper) *client.AlertmanagerAPI {
u, _ := url.Parse(uri)
transport := httptransport.New(u.Host, path.Join(u.Path, "/api/v2"), []string{u.Scheme})
@@ -40,7 +40,7 @@ func newClient(uri string, headers map[string]string, httpTransport http.RoundTr
}
// Alerts will fetch all alert groups from the API
func groups(c *client.Alertmanager, timeout time.Duration) ([]models.AlertGroup, error) {
func groups(c *client.AlertmanagerAPI, timeout time.Duration) ([]models.AlertGroup, error) {
groups, err := c.Alertgroup.GetAlertGroups(alertgroup.NewGetAlertGroupsParamsWithTimeout(timeout))
if err != nil {
return []models.AlertGroup{}, err
@@ -77,7 +77,7 @@ func groups(c *client.Alertmanager, timeout time.Duration) ([]models.AlertGroup,
return ret, nil
}
func silences(c *client.Alertmanager, timeout time.Duration) ([]models.Silence, error) {
func silences(c *client.AlertmanagerAPI, timeout time.Duration) ([]models.Silence, error) {
silences, err := c.Silence.GetSilences(silence.NewGetSilencesParamsWithTimeout(timeout))
if err != nil {
return []models.Silence{}, err
@@ -107,7 +107,7 @@ func silences(c *client.Alertmanager, timeout time.Duration) ([]models.Silence,
return ret, nil
}
func status(c *client.Alertmanager, timeout time.Duration) (models.AlertmanagerStatus, error) {
func status(c *client.AlertmanagerAPI, timeout time.Duration) (models.AlertmanagerStatus, error) {
ret := models.AlertmanagerStatus{}
status, err := c.General.GetStatus(general.NewGetStatusParamsWithTimeout(timeout))

2
internal/mapper/v017/client/alert/get_alerts_responses.go
View File

@@ -43,7 +43,7 @@ func (o *GetAlertsReader) ReadResponse(response runtime.ClientResponse, consumer
return nil, result
default:
return nil, runtime.NewAPIError("unknown error", response, response.Code())
return nil, runtime.NewAPIError("response status code does not match any response statuses defined for this endpoint in the swagger spec", response, response.Code())
}
}

2
internal/mapper/v017/client/alert/post_alerts_responses.go
View File

@@ -41,7 +41,7 @@ func (o *PostAlertsReader) ReadResponse(response runtime.ClientResponse, consume
return nil, result
default:
return nil, runtime.NewAPIError("unknown error", response, response.Code())
return nil, runtime.NewAPIError("response status code does not match any response statuses defined for this endpoint in the swagger spec", response, response.Code())
}
}

2
internal/mapper/v017/client/alertgroup/get_alert_groups_responses.go
View File

@@ -43,7 +43,7 @@ func (o *GetAlertGroupsReader) ReadResponse(response runtime.ClientResponse, con
return nil, result
default:
return nil, runtime.NewAPIError("unknown error", response, response.Code())
return nil, runtime.NewAPIError("response status code does not match any response statuses defined for this endpoint in the swagger spec", response, response.Code())
}
}

22
internal/mapper/v017/client/alertmanager_client.go → internal/mapper/v017/client/alertmanager_api_client.go
View File

@@ -17,7 +17,7 @@ import (
"github.com/prymitive/karma/internal/mapper/v017/client/silence"
)
// Default alertmanager HTTP client.
// Default alertmanager API HTTP client.
var Default = NewHTTPClient(nil)
const (
@@ -32,14 +32,14 @@ const (
// DefaultSchemes are the default schemes found in Meta (info) section of spec file
var DefaultSchemes = []string{"http"}
// NewHTTPClient creates a new alertmanager HTTP client.
func NewHTTPClient(formats strfmt.Registry) *Alertmanager {
// NewHTTPClient creates a new alertmanager API HTTP client.
func NewHTTPClient(formats strfmt.Registry) *AlertmanagerAPI {
return NewHTTPClientWithConfig(formats, nil)
}
// NewHTTPClientWithConfig creates a new alertmanager HTTP client,
// NewHTTPClientWithConfig creates a new alertmanager API HTTP client,
// using a customizable transport config.
func NewHTTPClientWithConfig(formats strfmt.Registry, cfg *TransportConfig) *Alertmanager {
func NewHTTPClientWithConfig(formats strfmt.Registry, cfg *TransportConfig) *AlertmanagerAPI {
// ensure nullable parameters have default
if cfg == nil {
cfg = DefaultTransportConfig()
@@ -50,14 +50,14 @@ func NewHTTPClientWithConfig(formats strfmt.Registry, cfg *TransportConfig) *Ale
return New(transport, formats)
}
// New creates a new alertmanager client
func New(transport runtime.ClientTransport, formats strfmt.Registry) *Alertmanager {
// New creates a new alertmanager API client
func New(transport runtime.ClientTransport, formats strfmt.Registry) *AlertmanagerAPI {
// ensure nullable parameters have default
if formats == nil {
formats = strfmt.Default
}
cli := new(Alertmanager)
cli := new(AlertmanagerAPI)
cli.Transport = transport
cli.Alert = alert.New(transport, formats)
cli.Alertgroup = alertgroup.New(transport, formats)
@@ -106,8 +106,8 @@ func (cfg *TransportConfig) WithSchemes(schemes []string) *TransportConfig {
return cfg
}
// Alertmanager is a client for alertmanager
type Alertmanager struct {
// AlertmanagerAPI is a client for alertmanager API
type AlertmanagerAPI struct {
Alert alert.ClientService
Alertgroup alertgroup.ClientService
@@ -122,7 +122,7 @@ type Alertmanager struct {
}
// SetTransport changes the transport on the client and all its subresources
func (c *Alertmanager) SetTransport(transport runtime.ClientTransport) {
func (c *AlertmanagerAPI) SetTransport(transport runtime.ClientTransport) {
c.Transport = transport
c.Alert.SetTransport(transport)
c.Alertgroup.SetTransport(transport)

2
internal/mapper/v017/client/general/get_status_responses.go
View File

@@ -31,7 +31,7 @@ func (o *GetStatusReader) ReadResponse(response runtime.ClientResponse, consumer
return result, nil
default:
return nil, runtime.NewAPIError("unknown error", response, response.Code())
return nil, runtime.NewAPIError("response status code does not match any response statuses defined for this endpoint in the swagger spec", response, response.Code())
}
}

2
internal/mapper/v017/client/receiver/get_receivers_responses.go
View File

@@ -31,7 +31,7 @@ func (o *GetReceiversReader) ReadResponse(response runtime.ClientResponse, consu
return result, nil
default:
return nil, runtime.NewAPIError("unknown error", response, response.Code())
return nil, runtime.NewAPIError("response status code does not match any response statuses defined for this endpoint in the swagger spec", response, response.Code())
}
}

2
internal/mapper/v017/client/silence/delete_silence_responses.go
View File

@@ -35,7 +35,7 @@ func (o *DeleteSilenceReader) ReadResponse(response runtime.ClientResponse, cons
return nil, result
default:
return nil, runtime.NewAPIError("unknown error", response, response.Code())
return nil, runtime.NewAPIError("response status code does not match any response statuses defined for this endpoint in the swagger spec", response, response.Code())
}
}

2
internal/mapper/v017/client/silence/get_silence_responses.go
View File

@@ -43,7 +43,7 @@ func (o *GetSilenceReader) ReadResponse(response runtime.ClientResponse, consume
return nil, result
default:
return nil, runtime.NewAPIError("unknown error", response, response.Code())
return nil, runtime.NewAPIError("response status code does not match any response statuses defined for this endpoint in the swagger spec", response, response.Code())
}
}

2
internal/mapper/v017/client/silence/get_silences_responses.go
View File

@@ -37,7 +37,7 @@ func (o *GetSilencesReader) ReadResponse(response runtime.ClientResponse, consum
return nil, result
default:
return nil, runtime.NewAPIError("unknown error", response, response.Code())
return nil, runtime.NewAPIError("response status code does not match any response statuses defined for this endpoint in the swagger spec", response, response.Code())
}
}

2
internal/mapper/v017/client/silence/post_silences_responses.go
View File

@@ -42,7 +42,7 @@ func (o *PostSilencesReader) ReadResponse(response runtime.ClientResponse, consu
return nil, result
default:
return nil, runtime.NewAPIError("unknown error", response, response.Code())
return nil, runtime.NewAPIError("response status code does not match any response statuses defined for this endpoint in the swagger spec", response, response.Code())
}
}