processor

package
v0.6.14 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 13, 2023 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrorEventDefinitelySkip = errors.New("vcenter event for trash only")
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 NomadProcessorType added in v0.6.9 

func NomadProcessorType() string

func ObserviumEventProcessorType added in v0.5.8 

func ObserviumEventProcessorType() string

func RancherProcessorType added in v0.2.0 

func RancherProcessorType() string

func Site24x7ProcessorType added in v0.2.3 

func Site24x7ProcessorType() string

func TeamcityProcessorType added in v0.6.3 

func TeamcityProcessorType() string

func VCenterProcessorType added in v0.3.25 

func VCenterProcessorType() string

func WinEventProcessorType added in v0.3.24 

func WinEventProcessorType() string

func ZabbixProcessorType added in v0.5.5 

func ZabbixProcessorType() 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 AWSRequest struct {
	Version    string      `json:"version"`
	Source     string      `json:"source"`
	Account    string      `json:"account"`
	Time       time.Time   `json:"time"`
	Region     string      `json:"region"`
	DetailType string      `json:"detail-type,omitempty"`
	Detail     interface{} `json:"detail,omitempty"`
}

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 DataDogEvent struct {
	Type  string `json:"type"`
	Msg   string `json:"msg"`
	Title string `json:"title"`
}

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 DataDogOrg struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

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 EnhancedObjectReference struct {
	v1.ObjectReference `json:",inline"`
	Labels             map[string]string `json:"labels,omitempty"`
	Annotations        map[string]string `json:"annotations,omitempty"`
}

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 GoogleConditionThreshold struct {
	Filter         string      `json:"filter"`
	Comparison     string      `json:"comparison"`
	ThresholdValue float32     `json:"thresholdValue"`
	Duration       string      `json:"duration"`
	Trigger        interface{} `json:"trigger"`
}

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 GoogleMetadata struct {
	SystemLabels map[string]string `json:"system_labels"`
	UserLabels   map[string]string `json:"user_labels"`
}

type GoogleMetric added in v0.2.4 

type GoogleMetric struct {
	Type        string            `json:"type"`
	DisplayName string            `json:"displayName"`
	Labels      map[string]string `json:"labels"`
}

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 GoogleResource struct {
	Type   string            `json:"type"`
	Labels map[string]string `json:"labels"`
}

type GoogleResponse added in v0.2.4 

type GoogleResponse struct {
	Message string
}

type K8sData 

type K8sData struct {
	Kind      string      `json:"kind"`
	Location  string      `json:"location"`
	Operation string      `json:"operation"`
	Namespace string      `json:"namespace"`
	Object    interface{} `json:"object,omitempty"`
	User      *K8sUser    `json:"user"`
}

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 K8sUser 

type K8sUser struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type KubeData added in v0.4.5 

type KubeData struct {
	Type     string      `json:"type"`
	Source   string      `json:"source"`
	Reason   string      `json:"reason"`
	Location string      `json:"location"`
	Message  string      `json:"message"`
	Object   interface{} `json:"object,omitempty"`
}

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 NomadProcessor added in v0.6.9 

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

func NewNomadProcessor added in v0.6.9 

func NewNomadProcessor(outputs *common.Outputs, observability *common.Observability) *NomadProcessor

func (*NomadProcessor) EventType added in v0.6.9 

func (p *NomadProcessor) EventType() string

func (*NomadProcessor) HandleEvent added in v0.6.9 

func (p *NomadProcessor) HandleEvent(e *common.Event) error

func (*NomadProcessor) ProcessEvent added in v0.6.9 

func (p *NomadProcessor) ProcessEvent(ne nomad.Event) error

type ObserviumEventProcessor added in v0.5.8 

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

func NewObserviumEventProcessor added in v0.5.8 

func NewObserviumEventProcessor(outputs *common.Outputs, observability *common.Observability) *ObserviumEventProcessor

func (*ObserviumEventProcessor) EventType added in v0.5.8 

func (p *ObserviumEventProcessor) EventType() string

func (*ObserviumEventProcessor) HandleEvent added in v0.5.8 

func (p *ObserviumEventProcessor) HandleEvent(e *common.Event) error

func (*ObserviumEventProcessor) HandleHttpRequest added in v0.5.8 

func (p *ObserviumEventProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error

type ObserviumRequest added in v0.5.8 

type ObserviumRequest struct {
	Title          string `json:"TITLE"`
	AlertState     string `json:"ALERT_STATE"`
	AlertURL       string `json:"ALERT_URL"`
	AlertUnixTime  int64  `json:"ALERT_UNIXTIME"`
	DeviceHostname string `json:"DEVICE_HOSTNAME"`
	DeviceLocation string `json:"DEVICE_LOCATION"`
	Metrics        string `json:"METRICS"`
}

type ObserviumResponse added in v0.5.8 

type ObserviumResponse struct {
	Message string
}

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 TeamcityEvent added in v0.6.3 

type TeamcityEvent struct {
	Timestamp      time.Time `json:"timestamp"`
	BuildEvent     string    `json:"build_event"`
	BuildName      string    `json:"build_name"`
	BuildStatusUrl string    `json:"build_status_url,omitempty"`
	TriggeredBy    string    `json:"triggered_by,omitempty"`
	BuildResult    string    `json:"build_result,omitempty"`
	Target         string    `json:"target,omitempty"`
}

type TeamcityProcessor added in v0.6.3 

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

func NewTeamcityProcessor added in v0.6.3 

func NewTeamcityProcessor(outputs *common.Outputs, observability *common.Observability) *TeamcityProcessor

func (TeamcityProcessor) EventType added in v0.6.3 

func (p TeamcityProcessor) EventType() string

func (TeamcityProcessor) HandleEvent added in v0.6.3 

func (p TeamcityProcessor) HandleEvent(e *common.Event) error

func (TeamcityProcessor) HandleHttpRequest added in v0.6.3 

func (p TeamcityProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error

type TeamcityResponse added in v0.6.3 

type TeamcityResponse 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"`
}

type ZabbixEvent added in v0.5.5 

type ZabbixEvent struct {
	AlertURL           string `json:"AlertURL,omitempty"`
	Environment        string `json:"Environment,omitempty"`
	EventDate          string `json:"EventDate,omitempty"`
	EventID            string `json:"EventID,omitempty"`
	EventName          string `json:"EventName,omitempty"`
	EventNSeverity     string `json:"EventNSeverity,omitempty"`
	EventOpData        string `json:"EventOpData,omitempty"`
	Status             string `json:"Status,omitempty"`
	EventTags          string `json:"EventTags,omitempty"`
	EventTime          string `json:"EventTime,omitempty"`
	EventType          string `json:"EventType,omitempty"`
	HostName           string `json:"HostName,omitempty"`
	ItemID             string `json:"ItemID,omitempty"`
	ItemLastValue      string `json:"ItemLastValue,omitempty"`
	TriggerDescription string `json:"TriggerDescription,omitempty"`
	TriggerExpression  string `json:"TriggerExpression,omitempty"`
	TriggerName        string `json:"TriggerName,omitempty"`
}

type ZabbixProcessor added in v0.5.5 

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

func NewZabbixProcessor added in v0.5.5 

func NewZabbixProcessor(outputs *common.Outputs, observability *common.Observability) *ZabbixProcessor

func (*ZabbixProcessor) EventType added in v0.5.5 

func (p *ZabbixProcessor) EventType() string

func (*ZabbixProcessor) HandleEvent added in v0.5.5 

func (p *ZabbixProcessor) HandleEvent(e *common.Event) error

func (*ZabbixProcessor) HandleHttpRequest added in v0.5.5 

func (p *ZabbixProcessor) HandleHttpRequest(w http.ResponseWriter, r *http.Request) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.