Documentation
¶
Index ¶
- Variables
- func AWSProcessorType() string
- func AlertmanagerProcessorType() string
- func CloudflareProcessorType() string
- func CustomJsonProcessorType() string
- func DataDogProcessorType() string
- func GitlabProcessorType() string
- func GoogleProcessorType() string
- func K8sProcessorType() string
- func KubeProcessorType() string
- func RancherProcessorType() string
- func Site24x7ProcessorType() string
- func VCenterProcessorType() string
- func WinEventProcessorType() string
- type AWSProcessor
- type AWSRequest
- type AWSResponse
- type AlertmanagerProcessor
- type AlertmanagerResponse
- type CloudflareProcessor
- type CloudflareRequest
- type CloudflareResponse
- type CustomJsonProcessor
- type CustomJsonResponse
- type DataDogAlert
- type DataDogEvent
- type DataDogIncident
- type DataDogMetric
- type DataDogOrg
- type DataDogProcessor
- type DataDogRequest
- type DataDogResponse
- type DataDogSecurity
- type EnhancedEvent
- type EnhancedObjectReference
- type GitlabProcessor
- type GitlabResponse
- type GoogleCondition
- type GoogleConditionThreshold
- type GoogleIncident
- type GoogleMetadata
- type GoogleMetric
- type GoogleProcessor
- type GoogleRequest
- type GoogleResource
- type GoogleResponse
- type K8sData
- type K8sProcessor
- type K8sUser
- type KubeData
- type KubeProcessor
- type RancherProcessor
- type Site24x7Processor
- type Site24x7Request
- type Site24x7Response
- type VCenterProcessor
- type VCenterResponse
- type WinEvent
- type WinEventOriginalRequest
- type WinEventProcessor
- type WinEventPubsubRequest
- type WinEventResponse
- type WinEventTags
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrorEventNotImpemented = errors.New("vcenter event not implemented yet")
Functions ¶
func AWSProcessorType ¶ added in v0.3.4
func AWSProcessorType() string
func AlertmanagerProcessorType ¶ added in v0.2.0
func AlertmanagerProcessorType() string
func CloudflareProcessorType ¶ added in v0.2.3
func CloudflareProcessorType() string
func CustomJsonProcessorType ¶ added in v0.2.0
func CustomJsonProcessorType() string
func DataDogProcessorType ¶ added in v0.2.2
func DataDogProcessorType() string
func GitlabProcessorType ¶ added in v0.2.0
func GitlabProcessorType() string
func GoogleProcessorType ¶ added in v0.2.4
func GoogleProcessorType() string
func K8sProcessorType ¶ added in v0.2.0
func K8sProcessorType() string
func KubeProcessorType ¶ added in v0.4.5
func KubeProcessorType() string
func RancherProcessorType ¶ added in v0.2.0
func RancherProcessorType() string
func Site24x7ProcessorType ¶ added in v0.2.3
func Site24x7ProcessorType() string
func VCenterProcessorType ¶ added in v0.3.25
func VCenterProcessorType() string
func WinEventProcessorType ¶ added in v0.3.24
func WinEventProcessorType() string
Types ¶
type AWSProcessor ¶ added in v0.3.4
type AWSProcessor struct {
// contains filtered or unexported fields
}
func NewAWSProcessor ¶ added in v0.3.4
func NewAWSProcessor(outputs *common.Outputs, observability *common.Observability) *AWSProcessor
func (*AWSProcessor) EventType ¶ added in v0.3.4
func (p *AWSProcessor) EventType() string
func (*AWSProcessor) HandleEvent ¶ added in v0.3.4
func (p *AWSProcessor) HandleEvent(e *common.Event) error
func (*AWSProcessor) HandleHttpRequest ¶ added in v0.3.4
func (p *AWSProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type AWSRequest ¶ added in v0.3.4
type AWSResponse ¶ added in v0.3.4
type AWSResponse struct {
Message string
}
type AlertmanagerProcessor ¶
type AlertmanagerProcessor struct {
// contains filtered or unexported fields
}
func NewAlertmanagerProcessor ¶
func NewAlertmanagerProcessor(outputs *common.Outputs, observability *common.Observability) *AlertmanagerProcessor
func (*AlertmanagerProcessor) EventType ¶ added in v0.2.0
func (p *AlertmanagerProcessor) EventType() string
func (*AlertmanagerProcessor) HandleEvent ¶ added in v0.2.0
func (p *AlertmanagerProcessor) HandleEvent(e *common.Event) error
func (*AlertmanagerProcessor) HandleHttpRequest ¶
func (p *AlertmanagerProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type AlertmanagerResponse ¶
type AlertmanagerResponse struct {
Message string
}
type CloudflareProcessor ¶ added in v0.2.3
type CloudflareProcessor struct {
// contains filtered or unexported fields
}
func NewCloudflareProcessor ¶ added in v0.2.3
func NewCloudflareProcessor(outputs *common.Outputs, observability *common.Observability) *CloudflareProcessor
func (*CloudflareProcessor) EventType ¶ added in v0.2.3
func (p *CloudflareProcessor) EventType() string
func (*CloudflareProcessor) HandleEvent ¶ added in v0.2.3
func (p *CloudflareProcessor) HandleEvent(e *common.Event) error
func (*CloudflareProcessor) HandleHttpRequest ¶ added in v0.2.3
func (p *CloudflareProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type CloudflareRequest ¶ added in v0.2.3
type CloudflareRequest struct {
Text string `json:"text"`
}
type CloudflareResponse ¶ added in v0.2.3
type CloudflareResponse struct {
Message string
}
type CustomJsonProcessor ¶ added in v0.1.0
type CustomJsonProcessor struct {
// contains filtered or unexported fields
}
func NewCustomJsonProcessor ¶ added in v0.1.0
func NewCustomJsonProcessor(outputs *common.Outputs, observability *common.Observability) *CustomJsonProcessor
func (*CustomJsonProcessor) EventType ¶ added in v0.2.0
func (p *CustomJsonProcessor) EventType() string
func (*CustomJsonProcessor) HandleEvent ¶ added in v0.2.0
func (p *CustomJsonProcessor) HandleEvent(e *common.Event) error
func (*CustomJsonProcessor) HandleHttpRequest ¶ added in v0.1.0
func (p *CustomJsonProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type CustomJsonResponse ¶ added in v0.1.0
type CustomJsonResponse struct {
Message string
}
type DataDogAlert ¶ added in v0.2.3
type DataDogAlert struct {
ID string `json:"id"`
Metric string `json:"metric"`
Priority string `json:"priority"`
Query string `json:"query"`
Scope string `json:"scope,omitempty"`
Status string `json:"status"`
Title string `json:"title"`
Transition string `json:"transition"`
Type string `json:"type"`
}
type DataDogEvent ¶ added in v0.2.3
type DataDogIncident ¶ added in v0.2.3
type DataDogIncident struct {
Title string `json:"title"`
}
type DataDogMetric ¶ added in v0.2.3
type DataDogMetric struct {
Namespace string `json:"namespace"`
}
type DataDogOrg ¶ added in v0.2.3
type DataDogProcessor ¶ added in v0.2.2
type DataDogProcessor struct {
// contains filtered or unexported fields
}
func NewDataDogProcessor ¶ added in v0.2.2
func NewDataDogProcessor(outputs *common.Outputs, observability *common.Observability) *DataDogProcessor
func (*DataDogProcessor) EventType ¶ added in v0.2.2
func (p *DataDogProcessor) EventType() string
func (*DataDogProcessor) HandleEvent ¶ added in v0.2.2
func (p *DataDogProcessor) HandleEvent(e *common.Event) error
func (*DataDogProcessor) HandleHttpRequest ¶ added in v0.2.2
func (p *DataDogProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type DataDogRequest ¶ added in v0.2.3
type DataDogRequest struct {
ID string `json:"id"`
Date int64 `json:"date"`
LastUpdated int64 `json:"last_updated"`
Link string `json:"link"`
Priority string `json:"priority"`
Snapshot string `json:"snapshot"`
Event *DataDogEvent `json:"event"`
Alert *DataDogAlert `json:"alert,omitempty"`
Incident *DataDogIncident `json:"incident,omitempty"`
Metric *DataDogMetric `json:"metric,omitempty"`
Security *DataDogSecurity `json:"security,omitempty"`
Org *DataDogOrg `json:"org,omitempty"`
Tags string `json:"tags,omitempty"`
TextOnlyMsg string `json:"text_only_msg,omitempty"`
User string `json:"user,omitempty"`
UserName string `json:"username,omitempty"`
}
type DataDogResponse ¶ added in v0.2.2
type DataDogResponse struct {
Message string
}
type DataDogSecurity ¶ added in v0.2.3
type DataDogSecurity struct {
RuleName string `json:"rule_name"`
}
type EnhancedEvent ¶ added in v0.4.5
type EnhancedEvent struct {
v1.Event `json:",inline"`
InvolvedObject EnhancedObjectReference `json:"involvedObject"`
}
EnhancedEvent Original file https://github.com/opsgenie/kubernetes-event-exporter/blob/master/pkg/kube/event.go
func (EnhancedEvent) DeDot ¶ added in v0.4.5
func (e EnhancedEvent) DeDot() EnhancedEvent
DeDot replaces all dots in the labels and annotations with underscores. This is required for example in the elasticsearch sink. The dynamic mapping generation interprets dots in JSON keys as path in an object. For reference see this logstash filter: https://www.elastic.co/guide/en/logstash/current/plugins-filters-de_dot.html
func (EnhancedEvent) GetTimestampISO8601 ¶ added in v0.4.5
func (e EnhancedEvent) GetTimestampISO8601() string
func (EnhancedEvent) GetTimestampMs ¶ added in v0.4.5
func (e EnhancedEvent) GetTimestampMs() int64
func (EnhancedEvent) ToJSON ¶ added in v0.4.5
func (e EnhancedEvent) ToJSON() []byte
ToJSON does not return an error because we are %99 confident it is JSON serializable.
type EnhancedObjectReference ¶ added in v0.4.5
type GitlabProcessor ¶ added in v0.1.0
type GitlabProcessor struct {
// contains filtered or unexported fields
}
func NewGitlabProcessor ¶ added in v0.1.0
func NewGitlabProcessor(outputs *common.Outputs, observability *common.Observability) *GitlabProcessor
func (*GitlabProcessor) EventType ¶ added in v0.2.0
func (p *GitlabProcessor) EventType() string
func (*GitlabProcessor) HandleEvent ¶ added in v0.2.0
func (p *GitlabProcessor) HandleEvent(e *common.Event) error
func (*GitlabProcessor) HandleHttpRequest ¶ added in v0.1.0
func (p *GitlabProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type GitlabResponse ¶ added in v0.1.0
type GitlabResponse struct {
Message string
}
type GoogleCondition ¶ added in v0.2.4
type GoogleCondition struct {
Name string `json:"name"`
DisplayName string `json:"displayName"`
ConditionThreshold *GoogleConditionThreshold `json:"conditionThreshold"`
}
type GoogleConditionThreshold ¶ added in v0.2.4
type GoogleIncident ¶ added in v0.2.4
type GoogleIncident struct {
IncidentID string `json:"incident_id"`
ScopingProjectID string `json:"scoping_project_id"`
ScopingProjectNumber string `json:"scoping_project_number"`
URL string `json:"url"`
StartedAt int64 `json:"started_at"`
EndedAt int64 `json:"ended_at,omitempty"`
State string `json:"state"`
Summary string `json:"summary"`
ApigeeURL string `json:"apigee_url"`
ObservedValue string `json:"observed_value"`
Resource *GoogleResource `json:"resource"`
ResourceTypeDisplayName string `json:"resource_type_display_name"`
ResourceID string `json:"resource_id"`
ResourceDisplayName string `json:"resource_display_name"`
ResourceName string `json:"resource_name"`
Metric *GoogleMetric `json:"metric"`
Metadata *GoogleMetadata `json:"metadata"`
PolicyName string `json:"policy_name"`
PolicyUserLabels map[string]string `json:"policy_user_labels"`
Documentation string `json:"documentation"`
Condition *GoogleCondition `json:"condition"`
ConditionName string `json:"condition_name"`
ThresholdValue string `json:"threshold_value"`
}
type GoogleMetadata ¶ added in v0.2.4
type GoogleMetric ¶ added in v0.2.4
type GoogleProcessor ¶ added in v0.2.4
type GoogleProcessor struct {
// contains filtered or unexported fields
}
func NewGoogleProcessor ¶ added in v0.2.4
func NewGoogleProcessor(outputs *common.Outputs, observability *common.Observability) *GoogleProcessor
func (*GoogleProcessor) EventType ¶ added in v0.2.4
func (p *GoogleProcessor) EventType() string
func (*GoogleProcessor) HandleEvent ¶ added in v0.2.4
func (p *GoogleProcessor) HandleEvent(e *common.Event) error
func (*GoogleProcessor) HandleHttpRequest ¶ added in v0.2.4
func (p *GoogleProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type GoogleRequest ¶ added in v0.2.4
type GoogleRequest struct {
Version string `json:"version"`
Incident *GoogleIncident `json:"incident"`
}
type GoogleResource ¶ added in v0.2.4
type GoogleResponse ¶ added in v0.2.4
type GoogleResponse struct {
Message string
}
type K8sProcessor ¶
type K8sProcessor struct {
// contains filtered or unexported fields
}
func NewK8sProcessor ¶
func NewK8sProcessor(outputs *common.Outputs, observability *common.Observability) *K8sProcessor
func (*K8sProcessor) EventType ¶ added in v0.2.0
func (p *K8sProcessor) EventType() string
func (*K8sProcessor) HandleEvent ¶ added in v0.2.0
func (p *K8sProcessor) HandleEvent(e *common.Event) error
func (*K8sProcessor) HandleHttpRequest ¶
func (p *K8sProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type KubeProcessor ¶ added in v0.4.5
type KubeProcessor struct {
// contains filtered or unexported fields
}
func NewKubeProcessor ¶ added in v0.4.5
func NewKubeProcessor(outputs *common.Outputs, observability *common.Observability) *KubeProcessor
func (*KubeProcessor) EventType ¶ added in v0.4.5
func (p *KubeProcessor) EventType() string
func (*KubeProcessor) HandleEvent ¶ added in v0.4.5
func (p *KubeProcessor) HandleEvent(e *common.Event) error
func (*KubeProcessor) HandleHttpRequest ¶ added in v0.4.5
func (p *KubeProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type RancherProcessor ¶
type RancherProcessor struct {
// contains filtered or unexported fields
}
func NewRancherProcessor ¶
func NewRancherProcessor(outputs *common.Outputs, observability *common.Observability) *RancherProcessor
func (*RancherProcessor) EventType ¶ added in v0.2.0
func (p *RancherProcessor) EventType() string
func (*RancherProcessor) HandleEvent ¶ added in v0.2.0
func (p *RancherProcessor) HandleEvent(e *common.Event) error
func (*RancherProcessor) HandleHttpRequest ¶
func (p *RancherProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type Site24x7Processor ¶ added in v0.2.3
type Site24x7Processor struct {
// contains filtered or unexported fields
}
func NewSite24x7Processor ¶ added in v0.2.3
func NewSite24x7Processor(outputs *common.Outputs, observability *common.Observability) *Site24x7Processor
func (*Site24x7Processor) EventType ¶ added in v0.2.3
func (p *Site24x7Processor) EventType() string
func (*Site24x7Processor) HandleEvent ¶ added in v0.2.3
func (p *Site24x7Processor) HandleEvent(e *common.Event) error
func (*Site24x7Processor) HandleHttpRequest ¶ added in v0.2.3
func (p *Site24x7Processor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type Site24x7Request ¶ added in v0.2.3
type Site24x7Request struct {
MonitorID int64 `json:"MONITOR_ID"`
MonitorDashboardLink string `json:"MONITOR_DASHBOARD_LINK"`
MonitorType string `json:"MONITORTYPE"`
MonitorName string `json:"MONITORNAME"`
MonitorURL string `json:"MONITORURL"`
MonitorGroupName string `json:"MONITOR_GROUPNAME"`
IncidentReason string `json:"INCIDENT_REASON"`
IncidentTime string `json:"INCIDENT_TIME"`
IncidentTimeISO string `json:"INCIDENT_TIME_ISO"`
PollFrequency int `json:"POLLFREQUENCY"`
Status string `json:"STATUS"`
FailedLocations string `json:"FAILED_LOCATIONS"`
GroupTags []string `json:"GROUP_TAGS,omitempty"`
Tags []string `json:"TAGS,omitempty"`
}
type Site24x7Response ¶ added in v0.2.3
type Site24x7Response struct {
Message string
}
type VCenterProcessor ¶ added in v0.3.25
type VCenterProcessor struct {
// contains filtered or unexported fields
}
func NewVCenterProcessor ¶ added in v0.3.25
func NewVCenterProcessor(outputs *common.Outputs, observability *common.Observability) *VCenterProcessor
func (*VCenterProcessor) EventType ¶ added in v0.3.25
func (p *VCenterProcessor) EventType() string
func (*VCenterProcessor) HandleEvent ¶ added in v0.3.25
func (p *VCenterProcessor) HandleEvent(e *common.Event) error
type VCenterResponse ¶ added in v0.3.25
type VCenterResponse struct {
Message string
}
type WinEvent ¶ added in v0.3.24
type WinEvent struct {
Name string `json:"name"`
Tags *WinEventTags `json:"tags"`
Timestamp int64 `json:"timestamp"`
}
type WinEventOriginalRequest ¶ added in v0.3.24
type WinEventOriginalRequest struct {
Events []WinEvent `json:"metrics"`
}
type WinEventProcessor ¶ added in v0.3.24
type WinEventProcessor struct {
// contains filtered or unexported fields
}
func NewWinEventProcessor ¶ added in v0.3.24
func NewWinEventProcessor(outputs *common.Outputs, observability *common.Observability) *WinEventProcessor
func (*WinEventProcessor) EventType ¶ added in v0.3.24
func (p *WinEventProcessor) EventType() string
func (*WinEventProcessor) HandleEvent ¶ added in v0.3.24
func (p *WinEventProcessor) HandleEvent(e *common.Event) error
func (*WinEventProcessor) HandleHttpRequest ¶ added in v0.3.24
func (p *WinEventProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
type WinEventPubsubRequest ¶ added in v0.3.24
type WinEventPubsubRequest struct {
Time string `json:"time"`
Channel string `json:"channel"`
Original *WinEventOriginalRequest `json:"data"`
}
type WinEventResponse ¶ added in v0.3.24
type WinEventResponse struct {
Message string
}
type WinEventTags ¶ added in v0.3.24
type WinEventTags struct {
Message string `json:"Message"`
MessageLevel string `json:"LevelText"`
Keywords string `json:"Keywords"`
EventID string `json:"EventRecordID"`
Provider string `json:"provider"`
City string `json:"city"`
Country string `json:"country,omitempty"`
MT string `json:"mt"`
Host string `json:"host"`
}
Click to show internal directories.
Click to hide internal directories.