handlers

Documentation

Index

• Constants
• type AMReceiverAlert
• type AMReceiverData
• type AMReceiverResponse
• type ClusterHandler
  • func NewClusterHandler(o ocm.OCMClient, clusterId string) *ClusterHandler
  • func (g *ClusterHandler) ServeClusterGet(w http.ResponseWriter, r *http.Request)
• type LivezHandler
  • func NewLivezHandler() *LivezHandler
  • func (h *LivezHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type LivezResponse
• type OCMResponseBody
• type ReadyzHandler
  • func NewReadyzHandler() *ReadyzHandler
  • func (h *ReadyzHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ReadyzResponse
• type UpgradePoliciesHandler
  • func NewUpgradePoliciesHandler(o ocm.OCMClient, clusterId string) *UpgradePoliciesHandler
  • func (g *UpgradePoliciesHandler) ServeUpgradePolicyGet(w http.ResponseWriter, r *http.Request)
  • func (g *UpgradePoliciesHandler) ServeUpgradePolicyList(w http.ResponseWriter, r *http.Request)
  • func (g *UpgradePoliciesHandler) ServeUpgradePolicyState(w http.ResponseWriter, r *http.Request)
• type WebhookRHOBSReceiverHandler
  • func NewWebhookRHOBSReceiverHandler(c client.Client, o ocm.OCMClient) *WebhookRHOBSReceiverHandler
  • func (h *WebhookRHOBSReceiverHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type WebhookReceiverHandler
  • func NewWebhookReceiverHandler(c client.Client, o ocm.OCMClient) *WebhookReceiverHandler
  • func (h *WebhookReceiverHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants

const (
	AMLabelAlertName           = "alertname"
	AMLabelTemplateName        = "managed_notification_template"
	AMLabelManagedNotification = "send_managed_notification"
	AMLabelAlertMCID           = "_mc_id"
	AMLabelAlertHCID           = "_id"

	LogFieldNotificationName           = "notification"
	LogFieldNotificationRecordName     = "notification_record"
	LogFieldResendInterval             = "resend_interval"
	LogFieldAlertname                  = "alertname"
	LogFieldAlert                      = "alert"
	LogFieldIsFiring                   = "is_firing"
	LogFieldManagedNotification        = "managed_notification_cr"
	LogFieldPostServiceLogOpId         = "post_servicelog_operation_id"
	LogFieldPostServiceLogFailedReason = "post_servicelog_failed_reason"

	// Header returned in OCM responses
	HeaderOperationId = "X-Operation-Id"
)

const (
	OCMAgentNamespaceName = "openshift-ocm-agent-operator"
)

const OCM_OPERATION_ID_HEADER = "X-Operation-Id"

Types

type AMReceiverAlert

type AMReceiverAlert template.Alert

type AMReceiverData

type AMReceiverData template.Data

Use prometheus alertmanager template type for post data

type AMReceiverResponse

type AMReceiverResponse struct {
	Error  error
	Code   int
	Status string
}

Alert Manager receiver response

type ClusterHandler

type ClusterHandler struct {
	// contains filtered or unexported fields
}

func NewClusterHandler

func NewClusterHandler(o ocm.OCMClient, clusterId string) *ClusterHandler

For /api/clusters_mgmt/v1/clusters/{cluster_id} https://api.openshift.com/#/default/get_api_clusters_mgmt_v1_clusters__cluster_id_

func (*ClusterHandler) ServeClusterGet

func (g *ClusterHandler) ServeClusterGet(w http.ResponseWriter, r *http.Request)

Proxies to https://api.openshift.com/#/default/get_api_clusters_mgmt_v1_clusters__cluster_id_

type LivezHandler

type LivezHandler struct {
}

func NewLivezHandler

func NewLivezHandler() *LivezHandler

func (*LivezHandler) ServeHTTP

func (h *LivezHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type LivezResponse

type LivezResponse struct {
	Status string
}

live probe endpoint response

type OCMResponseBody

type OCMResponseBody struct {
	Reason string `json:"reason"`
}

type ReadyzHandler

type ReadyzHandler struct {
}

func NewReadyzHandler

func NewReadyzHandler() *ReadyzHandler

func (*ReadyzHandler) ServeHTTP

func (h *ReadyzHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ReadyzResponse

type ReadyzResponse struct {
	Status string
}

ready probe endpoint response

type UpgradePoliciesHandler

type UpgradePoliciesHandler struct {
	// contains filtered or unexported fields
}

UpgradePoliciesHandler represents a request or requests to the upgrade policies endpoint set in OCM.

func NewUpgradePoliciesHandler

func NewUpgradePoliciesHandler(o ocm.OCMClient, clusterId string) *UpgradePoliciesHandler

Creates a new UpgradePoliciesHandler instance.

func (*UpgradePoliciesHandler) ServeUpgradePolicyGet

func (g *UpgradePoliciesHandler) ServeUpgradePolicyGet(w http.ResponseWriter, r *http.Request)

ServeUpgradePolicyGet reads and writes raw HTTP requests and proxies them to the 'get', 'update', and 'delete' endpoints for upgrade policies

func (*UpgradePoliciesHandler) ServeUpgradePolicyList

func (g *UpgradePoliciesHandler) ServeUpgradePolicyList(w http.ResponseWriter, r *http.Request)

ServeUpgradePolicyList reads and writes raw HTTP requests and proxies them to the 'list' endpoints for upgrade policies

func (*UpgradePoliciesHandler) ServeUpgradePolicyState

func (g *UpgradePoliciesHandler) ServeUpgradePolicyState(w http.ResponseWriter, r *http.Request)

ServeUpgradePolicyState reads and writes raw HTTP requests and proxies them to the 'get' and 'update' endpoints for upgrade policy states.

type WebhookRHOBSReceiverHandler

type WebhookRHOBSReceiverHandler struct {
	// contains filtered or unexported fields
}

func NewWebhookRHOBSReceiverHandler

func NewWebhookRHOBSReceiverHandler(c client.Client, o ocm.OCMClient) *WebhookRHOBSReceiverHandler

func (*WebhookRHOBSReceiverHandler) ServeHTTP

func (h *WebhookRHOBSReceiverHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type WebhookReceiverHandler

type WebhookReceiverHandler struct {
	// contains filtered or unexported fields
}

func NewWebhookReceiverHandler

func NewWebhookReceiverHandler(c client.Client, o ocm.OCMClient) *WebhookReceiverHandler

func (*WebhookReceiverHandler) ServeHTTP

func (h *WebhookReceiverHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)