Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 configure_alertmanager.go // This file is safe to edit. Once it exists it will not be overwritten // Copyright Prometheus Team // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // package restapi import ( "crypto/tls" "net/http" "github.com/go-openapi/errors" "github.com/go-openapi/runtime" "github.com/go-openapi/runtime/middleware" "github.com/prometheus/alertmanager/api/v2/restapi/operations" "github.com/prometheus/alertmanager/api/v2/restapi/operations/alert" "github.com/prometheus/alertmanager/api/v2/restapi/operations/alertgroup" "github.com/prometheus/alertmanager/api/v2/restapi/operations/general" "github.com/prometheus/alertmanager/api/v2/restapi/operations/receiver" "github.com/prometheus/alertmanager/api/v2/restapi/operations/silence" ) //go:generate swagger generate server --target ../../v2 --name Alertmanager --spec ../openapi.yaml --principal interface{} --exclude-main func configureFlags(api operations.AlertmanagerAPI) { // api.CommandLineOptionsGroups = []swag.CommandLineOptionsGroup{ ... } } func configureAPI(api operations.AlertmanagerAPI) http.Handler { // configure the api here api.ServeError = errors.ServeError // Set your custom logger if needed. Default one is log.Printf // Expected interface func(string, ...interface{}) // // Example: // api.Logger = log.Printf api.UseSwaggerUI() // To continue using redoc as your UI, uncomment the following line // api.UseRedoc() api.JSONConsumer = runtime.JSONConsumer() api.JSONProducer = runtime.JSONProducer() if api.SilenceDeleteSilenceHandler == nil { api.SilenceDeleteSilenceHandler = silence.DeleteSilenceHandlerFunc(func(params silence.DeleteSilenceParams) middleware.Responder { return middleware.NotImplemented("operation silence.DeleteSilence has not yet been implemented") }) } if api.AlertgroupGetAlertGroupsHandler == nil { api.AlertgroupGetAlertGroupsHandler = alertgroup.GetAlertGroupsHandlerFunc(func(params alertgroup.GetAlertGroupsParams) middleware.Responder { return middleware.NotImplemented("operation alertgroup.GetAlertGroups has not yet been implemented") }) } if api.AlertGetAlertsHandler == nil { api.AlertGetAlertsHandler = alert.GetAlertsHandlerFunc(func(params alert.GetAlertsParams) middleware.Responder { return middleware.NotImplemented("operation alert.GetAlerts has not yet been implemented") }) } if api.ReceiverGetReceiversHandler == nil { api.ReceiverGetReceiversHandler = receiver.GetReceiversHandlerFunc(func(params receiver.GetReceiversParams) middleware.Responder { return middleware.NotImplemented("operation receiver.GetReceivers has not yet been implemented") }) } if api.SilenceGetSilenceHandler == nil { api.SilenceGetSilenceHandler = silence.GetSilenceHandlerFunc(func(params silence.GetSilenceParams) middleware.Responder { return middleware.NotImplemented("operation silence.GetSilence has not yet been implemented") }) } if api.SilenceGetSilencesHandler == nil { api.SilenceGetSilencesHandler = silence.GetSilencesHandlerFunc(func(params silence.GetSilencesParams) middleware.Responder { return middleware.NotImplemented("operation silence.GetSilences has not yet been implemented") }) } if api.GeneralGetStatusHandler == nil { api.GeneralGetStatusHandler = general.GetStatusHandlerFunc(func(params general.GetStatusParams) middleware.Responder { return middleware.NotImplemented("operation general.GetStatus has not yet been implemented") }) } if api.AlertPostAlertsHandler == nil { api.AlertPostAlertsHandler = alert.PostAlertsHandlerFunc(func(params alert.PostAlertsParams) middleware.Responder { return middleware.NotImplemented("operation alert.PostAlerts has not yet been implemented") }) } if api.SilencePostSilencesHandler == nil { api.SilencePostSilencesHandler = silence.PostSilencesHandlerFunc(func(params silence.PostSilencesParams) middleware.Responder { return middleware.NotImplemented("operation silence.PostSilences has not yet been implemented") }) } api.PreServerShutdown = func() {} api.ServerShutdown = func() {} return setupGlobalMiddleware(api.Serve(setupMiddlewares)) } // The TLS configuration before HTTPS server starts. func configureTLS(tlsConfig tls.Config) { // Make all necessary changes to the TLS configuration here. } // As soon as server is initialized but not run yet, this function will be called. // If you need to modify a config, store server instance to stop it individually later, this is the place. // This function can be called multiple times, depending on the number of serving schemes. // scheme value will be set accordingly: "http", "https" or "unix". func configureServer(s http.Server, scheme, addr string) { } // The middleware configuration is for the handler executors. These do not apply to the swagger.json document. // The middleware executes after routing but before authentication, binding and validation. func setupMiddlewares(handler http.Handler) http.Handler { return handler } // The middleware configuration happens before anything, this middleware also applies to serving the swagger.json document. // So this is a good place to plug in a panic handling middleware, logging and metrics. func setupGlobalMiddleware(handler http.Handler) http.Handler { return handler }	5.64 KB	2025-05-25 12:27
📄 doc.go // Code generated by go-swagger; DO NOT EDIT. // Copyright Prometheus Team // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // // Package restapi Alertmanager API // // API of the Prometheus Alertmanager (https://github.com/prometheus/alertmanager) // Schemes: // http // Host: localhost // BasePath: /api/v2/ // Version: 0.0.1 // License: Apache 2.0 http://www.apache.org/licenses/LICENSE-2.0.html // // Consumes: // - application/json // // Produces: // - application/json // // swagger:meta package restapi	1019 B	2025-05-25 12:27
📄 embedded_spec.go // Code generated by go-swagger; DO NOT EDIT. // Copyright Prometheus Team // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // package restapi // This file was generated by the swagger tool. // Editing this file might prove futile when you re-run the swagger generate command import ( "encoding/json" ) var ( // SwaggerJSON embedded version of the swagger document used at generation time SwaggerJSON json.RawMessage // FlatSwaggerJSON embedded flattened version of the swagger document used at generation time FlatSwaggerJSON json.RawMessage ) func init() { SwaggerJSON = json.RawMessage([]byte(`{ "consumes": [ "application/json" ], "produces": [ "application/json" ], "swagger": "2.0", "info": { "description": "API of the Prometheus Alertmanager (https://github.com/prometheus/alertmanager)", "title": "Alertmanager API", "license": { "name": "Apache 2.0", "url": "http://www.apache.org/licenses/LICENSE-2.0.html" }, "version": "0.0.1" }, "basePath": "/api/v2/", "paths": { "/alerts": { "get": { "description": "Get a list of alerts", "tags": [ "alert" ], "operationId": "getAlerts", "parameters": [ { "type": "boolean", "default": true, "description": "Show active alerts", "name": "active", "in": "query" }, { "type": "boolean", "default": true, "description": "Show silenced alerts", "name": "silenced", "in": "query" }, { "type": "boolean", "default": true, "description": "Show inhibited alerts", "name": "inhibited", "in": "query" }, { "type": "boolean", "default": true, "description": "Show unprocessed alerts", "name": "unprocessed", "in": "query" }, { "type": "array", "items": { "type": "string" }, "collectionFormat": "multi", "description": "A list of matchers to filter alerts by", "name": "filter", "in": "query" }, { "type": "string", "description": "A regex matching receivers to filter alerts by", "name": "receiver", "in": "query" } ], "responses": { "200": { "description": "Get alerts response", "schema": { "$ref": "#/definitions/gettableAlerts" } }, "400": { "$ref": "#/responses/BadRequest" }, "500": { "$ref": "#/responses/InternalServerError" } } }, "post": { "description": "Create new Alerts", "tags": [ "alert" ], "operationId": "postAlerts", "parameters": [ { "description": "The alerts to create", "name": "alerts", "in": "body", "required": true, "schema": { "$ref": "#/definitions/postableAlerts" } } ], "responses": { "200": { "description": "Create alerts response" }, "400": { "$ref": "#/responses/BadRequest" }, "500": { "$ref": "#/responses/InternalServerError" } } } }, "/alerts/groups": { "get": { "description": "Get a list of alert groups", "tags": [ "alertgroup" ], "operationId": "getAlertGroups", "parameters": [ { "type": "boolean", "default": true, "description": "Show active alerts", "name": "active", "in": "query" }, { "type": "boolean", "default": true, "description": "Show silenced alerts", "name": "silenced", "in": "query" }, { "type": "boolean", "default": true, "description": "Show inhibited alerts", "name": "inhibited", "in": "query" }, { "type": "boolean", "default": true, "description": "Show muted alerts", "name": "muted", "in": "query" }, { "type": "array", "items": { "type": "string" }, "collectionFormat": "multi", "description": "A list of matchers to filter alerts by", "name": "filter", "in": "query" }, { "type": "string", "description": "A regex matching receivers to filter alerts by", "name": "receiver", "in": "query" } ], "responses": { "200": { "description": "Get alert groups response", "schema": { "$ref": "#/definitions/alertGroups" } }, "400": { "$ref": "#/responses/BadRequest" }, "500": { "$ref": "#/responses/InternalServerError" } } } }, "/receivers": { "get": { "description": "Get list of all receivers (name of notification integrations)", "tags": [ "receiver" ], "operationId": "getReceivers", "responses": { "200": { "description": "Get receivers response", "schema": { "type": "array", "items": { "$ref": "#/definitions/receiver" } } } } } }, "/silence/{silenceID}": { "get": { "description": "Get a silence by its ID", "tags": [ "silence" ], "operationId": "getSilence", "responses": { "200": { "description": "Get silence response", "schema": { "$ref": "#/definitions/gettableSilence" } }, "404": { "description": "A silence with the specified ID was not found" }, "500": { "$ref": "#/responses/InternalServerError" } } }, "delete": { "description": "Delete a silence by its ID", "tags": [ "silence" ], "operationId": "deleteSilence", "parameters": [ { "type": "string", "format": "uuid", "description": "ID of the silence to get", "name": "silenceID", "in": "path", "required": true } ], "responses": { "200": { "description": "Delete silence response" }, "404": { "description": "A silence with the specified ID was not found" }, "500": { "$ref": "#/responses/InternalServerError" } } }, "parameters": [ { "type": "string", "format": "uuid", "description": "ID of the silence to get", "name": "silenceID", "in": "path", "required": true } ] }, "/silences": { "get": { "description": "Get a list of silences", "tags": [ "silence" ], "operationId": "getSilences", "parameters": [ { "type": "array", "items": { "type": "string" }, "collectionFormat": "multi", "description": "A list of matchers to filter silences by", "name": "filter", "in": "query" } ], "responses": { "200": { "description": "Get silences response", "schema": { "$ref": "#/definitions/gettableSilences" } }, "400": { "$ref": "#/responses/BadRequest" }, "500": { "$ref": "#/responses/InternalServerError" } } }, "post": { "description": "Post a new silence or update an existing one", "tags": [ "silence" ], "operationId": "postSilences", "parameters": [ { "description": "The silence to create", "name": "silence", "in": "body", "required": true, "schema": { "$ref": "#/definitions/postableSilence" } } ], "responses": { "200": { "description": "Create / update silence response", "schema": { "type": "object", "properties": { "silenceID": { "type": "string" } } } }, "400": { "$ref": "#/responses/BadRequest" }, "404": { "description": "A silence with the specified ID was not found", "schema": { "type": "string" } } } } }, "/status": { "get": { "description": "Get current status of an Alertmanager instance and its cluster", "tags": [ "general" ], "operationId": "getStatus", "responses": { "200": { "description": "Get status response", "schema": { "$ref": "#/definitions/alertmanagerStatus" } } } } } }, "definitions": { "alert": { "type": "object", "required": [ "labels" ], "properties": { "generatorURL": { "type": "string", "format": "uri" }, "labels": { "$ref": "#/definitions/labelSet" } } }, "alertGroup": { "type": "object", "required": [ "labels", "receiver", "alerts" ], "properties": { "alerts": { "type": "array", "items": { "$ref": "#/definitions/gettableAlert" } }, "labels": { "$ref": "#/definitions/labelSet" }, "receiver": { "$ref": "#/definitions/receiver" } } }, "alertGroups": { "type": "array", "items": { "$ref": "#/definitions/alertGroup" } }, "alertStatus": { "type": "object", "required": [ "state", "silencedBy", "inhibitedBy", "mutedBy" ], "properties": { "inhibitedBy": { "type": "array", "items": { "type": "string" } }, "mutedBy": { "type": "array", "items": { "type": "string" } }, "silencedBy": { "type": "array", "items": { "type": "string" } }, "state": { "type": "string", "enum": [ "unprocessed", "active", "suppressed" ] } } }, "alertmanagerConfig": { "type": "object", "required": [ "original" ], "properties": { "original": { "type": "string" } } }, "alertmanagerStatus": { "type": "object", "required": [ "cluster", "versionInfo", "config", "uptime" ], "properties": { "cluster": { "$ref": "#/definitions/clusterStatus" }, "config": { "$ref": "#/definitions/alertmanagerConfig" }, "uptime": { "type": "string", "format": "date-time" }, "versionInfo": { "$ref": "#/definitions/versionInfo" } } }, "clusterStatus": { "type": "object", "required": [ "status" ], "properties": { "name": { "type": "string" }, "peers": { "type": "array", "items": { "$ref": "#/definitions/peerStatus" } }, "status": { "type": "string", "enum": [ "ready", "settling", "disabled" ] } } }, "gettableAlert": { "allOf": [ { "type": "object", "required": [ "receivers", "fingerprint", "startsAt", "updatedAt", "endsAt", "annotations", "status" ], "properties": { "annotations": { "$ref": "#/definitions/labelSet" }, "endsAt": { "type": "string", "format": "date-time" }, "fingerprint": { "type": "string" }, "receivers": { "type": "array", "items": { "$ref": "#/definitions/receiver" } }, "startsAt": { "type": "string", "format": "date-time" }, "status": { "$ref": "#/definitions/alertStatus" }, "updatedAt": { "type": "string", "format": "date-time" } } }, { "$ref": "#/definitions/alert" } ] }, "gettableAlerts": { "type": "array", "items": { "$ref": "#/definitions/gettableAlert" } }, "gettableSilence": { "allOf": [ { "type": "object", "required": [ "id", "status", "updatedAt" ], "properties": { "id": { "type": "string" }, "status": { "$ref": "#/definitions/silenceStatus" }, "updatedAt": { "type": "string", "format": "date-time" } } }, { "$ref": "#/definitions/silence" } ] }, "gettableSilences": { "type": "array", "items": { "$ref": "#/definitions/gettableSilence" } }, "labelSet": { "type": "object", "additionalProperties": { "type": "string" } }, "matcher": { "type": "object", "required": [ "name", "value", "isRegex" ], "properties": { "isEqual": { "type": "boolean", "default": true }, "isRegex": { "type": "boolean" }, "name": { "type": "string" }, "value": { "type": "string" } } }, "matchers": { "type": "array", "minItems": 1, "items": { "$ref": "#/definitions/matcher" } }, "peerStatus": { "type": "object", "required": [ "name", "address" ], "properties": { "address": { "type": "string" }, "name": { "type": "string" } } }, "postableAlert": { "allOf": [ { "type": "object", "properties": { "annotations": { "$ref": "#/definitions/labelSet" }, "endsAt": { "type": "string", "format": "date-time" }, "startsAt": { "type": "string", "format": "date-time" } } }, { "$ref": "#/definitions/alert" } ] }, "postableAlerts": { "type": "array", "items": { "$ref": "#/definitions/postableAlert" } }, "postableSilence": { "allOf": [ { "type": "object", "properties": { "id": { "type": "string" } } }, { "$ref": "#/definitions/silence" } ] }, "receiver": { "type": "object", "required": [ "name" ], "properties": { "name": { "type": "string" } } }, "silence": { "type": "object", "required": [ "matchers", "startsAt", "endsAt", "createdBy", "comment" ], "properties": { "comment": { "type": "string" }, "createdBy": { "type": "string" }, "endsAt": { "type": "string", "format": "date-time" }, "matchers": { "$ref": "#/definitions/matchers" }, "startsAt": { "type": "string", "format": "date-time" } } }, "silenceStatus": { "type": "object", "required": [ "state" ], "properties": { "state": { "type": "string", "enum": [ "expired", "active", "pending" ] } } }, "versionInfo": { "type": "object", "required": [ "version", "revision", "branch", "buildUser", "buildDate", "goVersion" ], "properties": { "branch": { "type": "string" }, "buildDate": { "type": "string" }, "buildUser": { "type": "string" }, "goVersion": { "type": "string" }, "revision": { "type": "string" }, "version": { "type": "string" } } } }, "responses": { "BadRequest": { "description": "Bad request", "schema": { "type": "string" } }, "InternalServerError": { "description": "Internal server error", "schema": { "type": "string" } } }, "tags": [ { "description": "General Alertmanager operations", "name": "general" }, { "description": "Everything related to Alertmanager receivers", "name": "receiver" }, { "description": "Everything related to Alertmanager silences", "name": "silence" }, { "description": "Everything related to Alertmanager alerts", "name": "alert" } ] }`)) FlatSwaggerJSON = json.RawMessage([]byte(`{ "consumes": [ "application/json" ], "produces": [ "application/json" ], "swagger": "2.0", "info": { "description": "API of the Prometheus Alertmanager (https://github.com/prometheus/alertmanager)", "title": "Alertmanager API", "license": { "name": "Apache 2.0", "url": "http://www.apache.org/licenses/LICENSE-2.0.html" }, "version": "0.0.1" }, "basePath": "/api/v2/", "paths": { "/alerts": { "get": { "description": "Get a list of alerts", "tags": [ "alert" ], "operationId": "getAlerts", "parameters": [ { "type": "boolean", "default": true, "description": "Show active alerts", "name": "active", "in": "query" }, { "type": "boolean", "default": true, "description": "Show silenced alerts", "name": "silenced", "in": "query" }, { "type": "boolean", "default": true, "description": "Show inhibited alerts", "name": "inhibited", "in": "query" }, { "type": "boolean", "default": true, "description": "Show unprocessed alerts", "name": "unprocessed", "in": "query" }, { "type": "array", "items": { "type": "string" }, "collectionFormat": "multi", "description": "A list of matchers to filter alerts by", "name": "filter", "in": "query" }, { "type": "string", "description": "A regex matching receivers to filter alerts by", "name": "receiver", "in": "query" } ], "responses": { "200": { "description": "Get alerts response", "schema": { "$ref": "#/definitions/gettableAlerts" } }, "400": { "description": "Bad request", "schema": { "type": "string" } }, "500": { "description": "Internal server error", "schema": { "type": "string" } } } }, "post": { "description": "Create new Alerts", "tags": [ "alert" ], "operationId": "postAlerts", "parameters": [ { "description": "The alerts to create", "name": "alerts", "in": "body", "required": true, "schema": { "$ref": "#/definitions/postableAlerts" } } ], "responses": { "200": { "description": "Create alerts response" }, "400": { "description": "Bad request", "schema": { "type": "string" } }, "500": { "description": "Internal server error", "schema": { "type": "string" } } } } }, "/alerts/groups": { "get": { "description": "Get a list of alert groups", "tags": [ "alertgroup" ], "operationId": "getAlertGroups", "parameters": [ { "type": "boolean", "default": true, "description": "Show active alerts", "name": "active", "in": "query" }, { "type": "boolean", "default": true, "description": "Show silenced alerts", "name": "silenced", "in": "query" }, { "type": "boolean", "default": true, "description": "Show inhibited alerts", "name": "inhibited", "in": "query" }, { "type": "boolean", "default": true, "description": "Show muted alerts", "name": "muted", "in": "query" }, { "type": "array", "items": { "type": "string" }, "collectionFormat": "multi", "description": "A list of matchers to filter alerts by", "name": "filter", "in": "query" }, { "type": "string", "description": "A regex matching receivers to filter alerts by", "name": "receiver", "in": "query" } ], "responses": { "200": { "description": "Get alert groups response", "schema": { "$ref": "#/definitions/alertGroups" } }, "400": { "description": "Bad request", "schema": { "type": "string" } }, "500": { "description": "Internal server error", "schema": { "type": "string" } } } } }, "/receivers": { "get": { "description": "Get list of all receivers (name of notification integrations)", "tags": [ "receiver" ], "operationId": "getReceivers", "responses": { "200": { "description": "Get receivers response", "schema": { "type": "array", "items": { "$ref": "#/definitions/receiver" } } } } } }, "/silence/{silenceID}": { "get": { "description": "Get a silence by its ID", "tags": [ "silence" ], "operationId": "getSilence", "responses": { "200": { "description": "Get silence response", "schema": { "$ref": "#/definitions/gettableSilence" } }, "404": { "description": "A silence with the specified ID was not found" }, "500": { "description": "Internal server error", "schema": { "type": "string" } } } }, "delete": { "description": "Delete a silence by its ID", "tags": [ "silence" ], "operationId": "deleteSilence", "parameters": [ { "type": "string", "format": "uuid", "description": "ID of the silence to get", "name": "silenceID", "in": "path", "required": true } ], "responses": { "200": { "description": "Delete silence response" }, "404": { "description": "A silence with the specified ID was not found" }, "500": { "description": "Internal server error", "schema": { "type": "string" } } } }, "parameters": [ { "type": "string", "format": "uuid", "description": "ID of the silence to get", "name": "silenceID", "in": "path", "required": true } ] }, "/silences": { "get": { "description": "Get a list of silences", "tags": [ "silence" ], "operationId": "getSilences", "parameters": [ { "type": "array", "items": { "type": "string" }, "collectionFormat": "multi", "description": "A list of matchers to filter silences by", "name": "filter", "in": "query" } ], "responses": { "200": { "description": "Get silences response", "schema": { "$ref": "#/definitions/gettableSilences" } }, "400": { "description": "Bad request", "schema": { "type": "string" } }, "500": { "description": "Internal server error", "schema": { "type": "string" } } } }, "post": { "description": "Post a new silence or update an existing one", "tags": [ "silence" ], "operationId": "postSilences", "parameters": [ { "description": "The silence to create", "name": "silence", "in": "body", "required": true, "schema": { "$ref": "#/definitions/postableSilence" } } ], "responses": { "200": { "description": "Create / update silence response", "schema": { "type": "object", "properties": { "silenceID": { "type": "string" } } } }, "400": { "description": "Bad request", "schema": { "type": "string" } }, "404": { "description": "A silence with the specified ID was not found", "schema": { "type": "string" } } } } }, "/status": { "get": { "description": "Get current status of an Alertmanager instance and its cluster", "tags": [ "general" ], "operationId": "getStatus", "responses": { "200": { "description": "Get status response", "schema": { "$ref": "#/definitions/alertmanagerStatus" } } } } } }, "definitions": { "alert": { "type": "object", "required": [ "labels" ], "properties": { "generatorURL": { "type": "string", "format": "uri" }, "labels": { "$ref": "#/definitions/labelSet" } } }, "alertGroup": { "type": "object", "required": [ "labels", "receiver", "alerts" ], "properties": { "alerts": { "type": "array", "items": { "$ref": "#/definitions/gettableAlert" } }, "labels": { "$ref": "#/definitions/labelSet" }, "receiver": { "$ref": "#/definitions/receiver" } } }, "alertGroups": { "type": "array", "items": { "$ref": "#/definitions/alertGroup" } }, "alertStatus": { "type": "object", "required": [ "state", "silencedBy", "inhibitedBy", "mutedBy" ], "properties": { "inhibitedBy": { "type": "array", "items": { "type": "string" } }, "mutedBy": { "type": "array", "items": { "type": "string" } }, "silencedBy": { "type": "array", "items": { "type": "string" } }, "state": { "type": "string", "enum": [ "unprocessed", "active", "suppressed" ] } } }, "alertmanagerConfig": { "type": "object", "required": [ "original" ], "properties": { "original": { "type": "string" } } }, "alertmanagerStatus": { "type": "object", "required": [ "cluster", "versionInfo", "config", "uptime" ], "properties": { "cluster": { "$ref": "#/definitions/clusterStatus" }, "config": { "$ref": "#/definitions/alertmanagerConfig" }, "uptime": { "type": "string", "format": "date-time" }, "versionInfo": { "$ref": "#/definitions/versionInfo" } } }, "clusterStatus": { "type": "object", "required": [ "status" ], "properties": { "name": { "type": "string" }, "peers": { "type": "array", "items": { "$ref": "#/definitions/peerStatus" } }, "status": { "type": "string", "enum": [ "ready", "settling", "disabled" ] } } }, "gettableAlert": { "allOf": [ { "type": "object", "required": [ "receivers", "fingerprint", "startsAt", "updatedAt", "endsAt", "annotations", "status" ], "properties": { "annotations": { "$ref": "#/definitions/labelSet" }, "endsAt": { "type": "string", "format": "date-time" }, "fingerprint": { "type": "string" }, "receivers": { "type": "array", "items": { "$ref": "#/definitions/receiver" } }, "startsAt": { "type": "string", "format": "date-time" }, "status": { "$ref": "#/definitions/alertStatus" }, "updatedAt": { "type": "string", "format": "date-time" } } }, { "$ref": "#/definitions/alert" } ] }, "gettableAlerts": { "type": "array", "items": { "$ref": "#/definitions/gettableAlert" } }, "gettableSilence": { "allOf": [ { "type": "object", "required": [ "id", "status", "updatedAt" ], "properties": { "id": { "type": "string" }, "status": { "$ref": "#/definitions/silenceStatus" }, "updatedAt": { "type": "string", "format": "date-time" } } }, { "$ref": "#/definitions/silence" } ] }, "gettableSilences": { "type": "array", "items": { "$ref": "#/definitions/gettableSilence" } }, "labelSet": { "type": "object", "additionalProperties": { "type": "string" } }, "matcher": { "type": "object", "required": [ "name", "value", "isRegex" ], "properties": { "isEqual": { "type": "boolean", "default": true }, "isRegex": { "type": "boolean" }, "name": { "type": "string" }, "value": { "type": "string" } } }, "matchers": { "type": "array", "minItems": 1, "items": { "$ref": "#/definitions/matcher" } }, "peerStatus": { "type": "object", "required": [ "name", "address" ], "properties": { "address": { "type": "string" }, "name": { "type": "string" } } }, "postableAlert": { "allOf": [ { "type": "object", "properties": { "annotations": { "$ref": "#/definitions/labelSet" }, "endsAt": { "type": "string", "format": "date-time" }, "startsAt": { "type": "string", "format": "date-time" } } }, { "$ref": "#/definitions/alert" } ] }, "postableAlerts": { "type": "array", "items": { "$ref": "#/definitions/postableAlert" } }, "postableSilence": { "allOf": [ { "type": "object", "properties": { "id": { "type": "string" } } }, { "$ref": "#/definitions/silence" } ] }, "receiver": { "type": "object", "required": [ "name" ], "properties": { "name": { "type": "string" } } }, "silence": { "type": "object", "required": [ "matchers", "startsAt", "endsAt", "createdBy", "comment" ], "properties": { "comment": { "type": "string" }, "createdBy": { "type": "string" }, "endsAt": { "type": "string", "format": "date-time" }, "matchers": { "$ref": "#/definitions/matchers" }, "startsAt": { "type": "string", "format": "date-time" } } }, "silenceStatus": { "type": "object", "required": [ "state" ], "properties": { "state": { "type": "string", "enum": [ "expired", "active", "pending" ] } } }, "versionInfo": { "type": "object", "required": [ "version", "revision", "branch", "buildUser", "buildDate", "goVersion" ], "properties": { "branch": { "type": "string" }, "buildDate": { "type": "string" }, "buildUser": { "type": "string" }, "goVersion": { "type": "string" }, "revision": { "type": "string" }, "version": { "type": "string" } } } }, "responses": { "BadRequest": { "description": "Bad request", "schema": { "type": "string" } }, "InternalServerError": { "description": "Internal server error", "schema": { "type": "string" } } }, "tags": [ { "description": "General Alertmanager operations", "name": "general" }, { "description": "Everything related to Alertmanager receivers", "name": "receiver" }, { "description": "Everything related to Alertmanager silences", "name": "silence" }, { "description": "Everything related to Alertmanager alerts", "name": "alert" } ] }`)) }	37.49 KB	2025-05-25 12:27
📁 operations	-	2025-05-25 12:27
📄 server.go // Code generated by go-swagger; DO NOT EDIT. // Copyright Prometheus Team // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // package restapi import ( "context" "crypto/tls" "crypto/x509" "errors" "fmt" "log" "net" "net/http" "os" "os/signal" "strconv" "sync" "sync/atomic" "syscall" "time" "github.com/go-openapi/runtime/flagext" "github.com/go-openapi/swag" flags "github.com/jessevdk/go-flags" "golang.org/x/net/netutil" "github.com/prometheus/alertmanager/api/v2/restapi/operations" ) const ( schemeHTTP = "http" schemeHTTPS = "https" schemeUnix = "unix" ) var defaultSchemes []string func init() { defaultSchemes = []string{ schemeHTTP, } } // NewServer creates a new api alertmanager server but does not configure it func NewServer(api operations.AlertmanagerAPI) Server { s := new(Server) s.shutdown = make(chan struct{}) s.api = api s.interrupt = make(chan os.Signal, 1) return s } // ConfigureAPI configures the API and handlers. func (s Server) ConfigureAPI() { if s.api != nil { s.handler = configureAPI(s.api) } } // ConfigureFlags configures the additional flags defined by the handlers. Needs to be called before the parser.Parse func (s Server) ConfigureFlags() { if s.api != nil { configureFlags(s.api) } } // Server for the alertmanager API type Server struct { EnabledListeners []string `long:"scheme" description:"the listeners to enable, this can be repeated and defaults to the schemes in the swagger spec"` CleanupTimeout time.Duration `long:"cleanup-timeout" description:"grace period for which to wait before killing idle connections" default:"10s"` GracefulTimeout time.Duration `long:"graceful-timeout" description:"grace period for which to wait before shutting down the server" default:"15s"` MaxHeaderSize flagext.ByteSize `long:"max-header-size" description:"controls the maximum number of bytes the server will read parsing the request header's keys and values, including the request line. It does not limit the size of the request body." default:"1MiB"` SocketPath flags.Filename `long:"socket-path" description:"the unix socket to listen on" default:"/var/run/alertmanager.sock"` domainSocketL net.Listener Host string `long:"host" description:"the IP to listen on" default:"localhost" env:"HOST"` Port int `long:"port" description:"the port to listen on for insecure connections, defaults to a random value" env:"PORT"` ListenLimit int `long:"listen-limit" description:"limit the number of outstanding requests"` KeepAlive time.Duration `long:"keep-alive" description:"sets the TCP keep-alive timeouts on accepted connections. It prunes dead TCP connections ( e.g. closing laptop mid-download)" default:"3m"` ReadTimeout time.Duration `long:"read-timeout" description:"maximum duration before timing out read of the request" default:"30s"` WriteTimeout time.Duration `long:"write-timeout" description:"maximum duration before timing out write of the response" default:"60s"` httpServerL net.Listener TLSHost string `long:"tls-host" description:"the IP to listen on for tls, when not specified it's the same as --host" env:"TLS_HOST"` TLSPort int `long:"tls-port" description:"the port to listen on for secure connections, defaults to a random value" env:"TLS_PORT"` TLSCertificate flags.Filename `long:"tls-certificate" description:"the certificate to use for secure connections" env:"TLS_CERTIFICATE"` TLSCertificateKey flags.Filename `long:"tls-key" description:"the private key to use for secure connections" env:"TLS_PRIVATE_KEY"` TLSCACertificate flags.Filename `long:"tls-ca" description:"the certificate authority file to be used with mutual tls auth" env:"TLS_CA_CERTIFICATE"` TLSListenLimit int `long:"tls-listen-limit" description:"limit the number of outstanding requests"` TLSKeepAlive time.Duration `long:"tls-keep-alive" description:"sets the TCP keep-alive timeouts on accepted connections. It prunes dead TCP connections ( e.g. closing laptop mid-download)"` TLSReadTimeout time.Duration `long:"tls-read-timeout" description:"maximum duration before timing out read of the request"` TLSWriteTimeout time.Duration `long:"tls-write-timeout" description:"maximum duration before timing out write of the response"` httpsServerL net.Listener api operations.AlertmanagerAPI handler http.Handler hasListeners bool shutdown chan struct{} shuttingDown int32 interrupted bool interrupt chan os.Signal } // Logf logs message either via defined user logger or via system one if no user logger is defined. func (s Server) Logf(f string, args ...interface{}) { if s.api != nil && s.api.Logger != nil { s.api.Logger(f, args...) } else { log.Printf(f, args...) } } // Fatalf logs message either via defined user logger or via system one if no user logger is defined. // Exits with non-zero status after printing func (s Server) Fatalf(f string, args ...interface{}) { if s.api != nil && s.api.Logger != nil { s.api.Logger(f, args...) os.Exit(1) } else { log.Fatalf(f, args...) } } // SetAPI configures the server with the specified API. Needs to be called before Serve func (s Server) SetAPI(api operations.AlertmanagerAPI) { if api == nil { s.api = nil s.handler = nil return } s.api = api s.handler = configureAPI(api) } func (s Server) hasScheme(scheme string) bool { schemes := s.EnabledListeners if len(schemes) == 0 { schemes = defaultSchemes } for _, v := range schemes { if v == scheme { return true } } return false } // Serve the api func (s Server) Serve() (err error) { if !s.hasListeners { if err = s.Listen(); err != nil { return err } } // set default handler, if none is set if s.handler == nil { if s.api == nil { return errors.New("can't create the default handler, as no api is set") } s.SetHandler(s.api.Serve(nil)) } wg := new(sync.WaitGroup) once := new(sync.Once) signalNotify(s.interrupt) go handleInterrupt(once, s) servers := []http.Server{} if s.hasScheme(schemeUnix) { domainSocket := new(http.Server) domainSocket.MaxHeaderBytes = int(s.MaxHeaderSize) domainSocket.Handler = s.handler if int64(s.CleanupTimeout) > 0 { domainSocket.IdleTimeout = s.CleanupTimeout } configureServer(domainSocket, "unix", string(s.SocketPath)) servers = append(servers, domainSocket) wg.Add(1) s.Logf("Serving alertmanager at unix://%s", s.SocketPath) go func(l net.Listener) { defer wg.Done() if err := domainSocket.Serve(l); err != nil && err != http.ErrServerClosed { s.Fatalf("%v", err) } s.Logf("Stopped serving alertmanager at unix://%s", s.SocketPath) }(s.domainSocketL) } if s.hasScheme(schemeHTTP) { httpServer := new(http.Server) httpServer.MaxHeaderBytes = int(s.MaxHeaderSize) httpServer.ReadTimeout = s.ReadTimeout httpServer.WriteTimeout = s.WriteTimeout httpServer.SetKeepAlivesEnabled(int64(s.KeepAlive) > 0) if s.ListenLimit > 0 { s.httpServerL = netutil.LimitListener(s.httpServerL, s.ListenLimit) } if int64(s.CleanupTimeout) > 0 { httpServer.IdleTimeout = s.CleanupTimeout } httpServer.Handler = s.handler configureServer(httpServer, "http", s.httpServerL.Addr().String()) servers = append(servers, httpServer) wg.Add(1) s.Logf("Serving alertmanager at http://%s", s.httpServerL.Addr()) go func(l net.Listener) { defer wg.Done() if err := httpServer.Serve(l); err != nil && err != http.ErrServerClosed { s.Fatalf("%v", err) } s.Logf("Stopped serving alertmanager at http://%s", l.Addr()) }(s.httpServerL) } if s.hasScheme(schemeHTTPS) { httpsServer := new(http.Server) httpsServer.MaxHeaderBytes = int(s.MaxHeaderSize) httpsServer.ReadTimeout = s.TLSReadTimeout httpsServer.WriteTimeout = s.TLSWriteTimeout httpsServer.SetKeepAlivesEnabled(int64(s.TLSKeepAlive) > 0) if s.TLSListenLimit > 0 { s.httpsServerL = netutil.LimitListener(s.httpsServerL, s.TLSListenLimit) } if int64(s.CleanupTimeout) > 0 { httpsServer.IdleTimeout = s.CleanupTimeout } httpsServer.Handler = s.handler // Inspired by https://blog.bracebin.com/achieving-perfect-ssl-labs-score-with-go httpsServer.TLSConfig = &tls.Config{ // Causes servers to use Go's default ciphersuite preferences, // which are tuned to avoid attacks. Does nothing on clients. PreferServerCipherSuites: true, // Only use curves which have assembly implementations // https://github.com/golang/go/tree/master/src/crypto/elliptic CurvePreferences: []tls.CurveID{tls.CurveP256}, // Use modern tls mode https://wiki.mozilla.org/Security/Server_Side_TLS#Modern_compatibility NextProtos: []string{"h2", "http/1.1"}, // https://www.owasp.org/index.php/Transport_Layer_Protection_Cheat_Sheet#Rule_-_Only_Support_Strong_Protocols MinVersion: tls.VersionTLS12, // These ciphersuites support Forward Secrecy: https://en.wikipedia.org/wiki/Forward_secrecy CipherSuites: []uint16{ tls.TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384, tls.TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384, tls.TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256, tls.TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256, tls.TLS_ECDHE_ECDSA_WITH_CHACHA20_POLY1305, tls.TLS_ECDHE_RSA_WITH_CHACHA20_POLY1305, }, } // build standard config from server options if s.TLSCertificate != "" && s.TLSCertificateKey != "" { httpsServer.TLSConfig.Certificates = make([]tls.Certificate, 1) httpsServer.TLSConfig.Certificates[0], err = tls.LoadX509KeyPair(string(s.TLSCertificate), string(s.TLSCertificateKey)) if err != nil { return err } } if s.TLSCACertificate != "" { // include specified CA certificate caCert, caCertErr := os.ReadFile(string(s.TLSCACertificate)) if caCertErr != nil { return caCertErr } caCertPool := x509.NewCertPool() ok := caCertPool.AppendCertsFromPEM(caCert) if !ok { return fmt.Errorf("cannot parse CA certificate") } httpsServer.TLSConfig.ClientCAs = caCertPool httpsServer.TLSConfig.ClientAuth = tls.RequireAndVerifyClientCert } // call custom TLS configurator configureTLS(httpsServer.TLSConfig) if len(httpsServer.TLSConfig.Certificates) == 0 && httpsServer.TLSConfig.GetCertificate == nil { // after standard and custom config are passed, this ends up with no certificate if s.TLSCertificate == "" { if s.TLSCertificateKey == "" { s.Fatalf("the required flags `--tls-certificate` and `--tls-key` were not specified") } s.Fatalf("the required flag `--tls-certificate` was not specified") } if s.TLSCertificateKey == "" { s.Fatalf("the required flag `--tls-key` was not specified") } // this happens with a wrong custom TLS configurator s.Fatalf("no certificate was configured for TLS") } configureServer(httpsServer, "https", s.httpsServerL.Addr().String()) servers = append(servers, httpsServer) wg.Add(1) s.Logf("Serving alertmanager at https://%s", s.httpsServerL.Addr()) go func(l net.Listener) { defer wg.Done() if err := httpsServer.Serve(l); err != nil && err != http.ErrServerClosed { s.Fatalf("%v", err) } s.Logf("Stopped serving alertmanager at https://%s", l.Addr()) }(tls.NewListener(s.httpsServerL, httpsServer.TLSConfig)) } wg.Add(1) go s.handleShutdown(wg, &servers) wg.Wait() return nil } // Listen creates the listeners for the server func (s Server) Listen() error { if s.hasListeners { // already done this return nil } if s.hasScheme(schemeHTTPS) { // Use http host if https host wasn't defined if s.TLSHost == "" { s.TLSHost = s.Host } // Use http listen limit if https listen limit wasn't defined if s.TLSListenLimit == 0 { s.TLSListenLimit = s.ListenLimit } // Use http tcp keep alive if https tcp keep alive wasn't defined if int64(s.TLSKeepAlive) == 0 { s.TLSKeepAlive = s.KeepAlive } // Use http read timeout if https read timeout wasn't defined if int64(s.TLSReadTimeout) == 0 { s.TLSReadTimeout = s.ReadTimeout } // Use http write timeout if https write timeout wasn't defined if int64(s.TLSWriteTimeout) == 0 { s.TLSWriteTimeout = s.WriteTimeout } } if s.hasScheme(schemeUnix) { domSockListener, err := net.Listen("unix", string(s.SocketPath)) if err != nil { return err } s.domainSocketL = domSockListener } if s.hasScheme(schemeHTTP) { listener, err := net.Listen("tcp", net.JoinHostPort(s.Host, strconv.Itoa(s.Port))) if err != nil { return err } h, p, err := swag.SplitHostPort(listener.Addr().String()) if err != nil { return err } s.Host = h s.Port = p s.httpServerL = listener } if s.hasScheme(schemeHTTPS) { tlsListener, err := net.Listen("tcp", net.JoinHostPort(s.TLSHost, strconv.Itoa(s.TLSPort))) if err != nil { return err } sh, sp, err := swag.SplitHostPort(tlsListener.Addr().String()) if err != nil { return err } s.TLSHost = sh s.TLSPort = sp s.httpsServerL = tlsListener } s.hasListeners = true return nil } // Shutdown server and clean up resources func (s Server) Shutdown() error { if atomic.CompareAndSwapInt32(&s.shuttingDown, 0, 1) { close(s.shutdown) } return nil } func (s Server) handleShutdown(wg sync.WaitGroup, serversPtr []http.Server) { // wg.Done must occur last, after s.api.ServerShutdown() // (to preserve old behaviour) defer wg.Done() <-s.shutdown servers := serversPtr ctx, cancel := context.WithTimeout(context.TODO(), s.GracefulTimeout) defer cancel() // first execute the pre-shutdown hook s.api.PreServerShutdown() shutdownChan := make(chan bool) for i := range servers { server := servers[i] go func() { var success bool defer func() { shutdownChan <- success }() if err := server.Shutdown(ctx); err != nil { // Error from closing listeners, or context timeout: s.Logf("HTTP server Shutdown: %v", err) } else { success = true } }() } // Wait until all listeners have successfully shut down before calling ServerShutdown success := true for range servers { success = success && <-shutdownChan } if success { s.api.ServerShutdown() } } // GetHandler returns a handler useful for testing func (s Server) GetHandler() http.Handler { return s.handler } // SetHandler allows for setting a http handler on this server func (s Server) SetHandler(handler http.Handler) { s.handler = handler } // UnixListener returns the domain socket listener func (s Server) UnixListener() (net.Listener, error) { if !s.hasListeners { if err := s.Listen(); err != nil { return nil, err } } return s.domainSocketL, nil } // HTTPListener returns the http listener func (s Server) HTTPListener() (net.Listener, error) { if !s.hasListeners { if err := s.Listen(); err != nil { return nil, err } } return s.httpServerL, nil } // TLSListener returns the https listener func (s Server) TLSListener() (net.Listener, error) { if !s.hasListeners { if err := s.Listen(); err != nil { return nil, err } } return s.httpsServerL, nil } func handleInterrupt(once sync.Once, s Server) { once.Do(func() { for range s.interrupt { if s.interrupted { s.Logf("Server already shutting down") continue } s.interrupted = true s.Logf("Shutting down... ") if err := s.Shutdown(); err != nil { s.Logf("HTTP server Shutdown: %v", err) } } }) } func signalNotify(interrupt chan<- os.Signal) { signal.Notify(interrupt, syscall.SIGINT, syscall.SIGTERM) }	15.75 KB	2025-05-25 12:27

Terminal