events

Documentation

Overview

Copyright 2020 BlackRock, Inc.

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.

Index

• type AMQPEventData
• type AzureEventsHubEventData
• type CalendarEventData
• type EmitterEventData
• type GitLabEventData
• type GithubEventData
• type KafkaEventData
• type MQTTEventData
• type MinioEventData
• type NATSEventData
• type NSQEventData
• type PubSubEventData
• type RedisEventData
• type ResourceEventData
• type SNSEventData
• type SQSEventData
• type WebhookEventData

Types

type AMQPEventData

type AMQPEventData struct {
	// ContentType is the MIME content type
	ContentType string `json:"contentType"`
	// ContentEncoding is the MIME content encoding
	ContentEncoding string `json:"contentEncoding"`
	// Delivery mode can be either - non-persistent (1) or persistent (2)
	DeliveryMode int `json:"deliveryMode"`
	// Priority refers to the use - 0 to 9
	Priority int `json:"priority"`
	// CorrelationId is the correlation identifier
	CorrelationId string `json:"correlationId"`
	// ReplyTo is the address to reply to (ex: RPC)
	ReplyTo string `json:"replyTo"`
	// Expiration refers to message expiration spec
	Expiration string `json:"expiration"`
	// MessageId is message identifier
	MessageId string `json:"messageId"`
	// Timestamp refers to the message timestamp
	Timestamp string `json:"timestamp"`
	// Type refers to the message type name
	Type string `json:"type"`
	// AppId refers to the application id
	AppId string `json:"appId"`
	// Exchange is basic.publish exchange
	Exchange string `json:"exchange"`
	// RoutingKey is basic.publish routing key
	RoutingKey string `json:"routingKey"`
	// Body represents the messsage body
	Body interface{} `json:"body"`
}

AMQPEventData represents the event data generated by AMQP gateway.

type AzureEventsHubEventData

type AzureEventsHubEventData struct {
	// Id of the message
	Id string `json:"id"`
	// PartitionKey
	PartitionKey string `json:"partitionKey"`
	// Message body
	Body interface{} `json:"body"`
}

AzureEventsHubEventData represents to the event data generated by Azure Events Hub gateway. +k8s:openapi-gen=true

type CalendarEventData

type CalendarEventData struct {
	// EventTime is time at which event occurred
	EventTime string `json:"eventTime"`
	// UserPayload if any
	// +optional
	UserPayload json.RawMessage `json:"userPayload,omitempty"`
}

CalendarEventData represents the event data generated by the Calendar gateway. +k8s:openapi-gen=true

type EmitterEventData

type EmitterEventData struct {
	// Topic name
	Topic string `json:"topic"`
	// Body represents the message body
	Body interface{} `json:"body"`
}

EmitterEventData represents the event data generated by the Emitter gateway.

type GitLabEventData

type GitLabEventData struct {
	// Headers from the Gitlab http request.
	Headers http.Header `json:"headers"`
	// Body represents the message body
	Body *json.RawMessage `json:"body"`
}

GitLabEventData represents the event data generated by the GitLab gateway.

type GithubEventData

type GithubEventData struct {
	// Headers from the Gitlab http request.
	Headers http.Header `json:"headers"`
	// Body represents the message body
	Body *json.RawMessage `json:"body"`
}

GithubEventData represents the event data generated by the GitHub gateway.

type KafkaEventData

type KafkaEventData struct {
	// Topic refers to the Kafka topic
	Topic string `json:"topic"`
	// Partition refers to the Kafka partition
	Partition int `json:"partition"`
	// Body refers to the message value
	Body interface{} `json:"body"`
	// Timestamp of the message
	Timestamp string `json:"timestamp"`
}

KafkaEventData represents the event data generated by the Kafka gateway.

type MQTTEventData

type MQTTEventData struct {
	// Topic refers to the MQTT topic name.
	Topic string `json:"topic"`
	// MessageID is the unique ID for the message
	MessageID int `json:"messageId"`
	// Body is the message payload.
	Body interface{} `json:"body"`
}

MQTTEventData represents the event data generated by the MQTT gateway.

type MinioEventData

type MinioEventData struct {
	Notification []minio.NotificationEvent `json:"notification"`
}

MinioEventData represents the event data generated by the Minio gateway.

type NATSEventData

type NATSEventData struct {
	// Name of the subject.
	Subject string `json:"subject"`
	// Message data.
	Body interface{} `json:"body"`
}

NATSEventData represents the event data generated by the NATS gateway.

type NSQEventData

type NSQEventData struct {
	// Body is the message data.
	Body interface{} `json:"body"`
	// Timestamp of the message.
	Timestamp string `json:"timestamp"`
	// NSQDAddress is the address of the nsq host.
	NSQDAddress string `json:"nsqdAddress"`
}

NSQEventData represents the event data generated by the NSQ gateway.

type PubSubEventData

type PubSubEventData struct {
	// ID of the message
	ID string `json:"id"`
	// Body is the actual data in the message.
	Body interface{} `json:"body"`
	// Attributes represents the key-value pairs the current message
	// is labelled with.
	Attributes map[string]string `json:"attributes"`
	// The time at which the message was published.
	PublishTime string `json:"publishTime"`
}

PubSubEventData represents the event data generated by the GCP PubSub gateway.

type RedisEventData

type RedisEventData struct {
	// Subscription channel.
	Channel string `json:"channel"`
	// Message pattern
	Pattern string `json:"pattern"`
	// Message body
	Body string `json:"body"`
}

RedisEventData represents the event data generated by the Redis gateway.

type ResourceEventData

type ResourceEventData struct {
	// EventType of the type of the event.
	EventType string `json:"type"`
	// Resource body.
	Body *json.RawMessage `json:"body"`
	// Resource group name.
	Group string `json:"group"`
	// Resource version.
	Version string `json:"version"`
	// Resource name.
	Resource string `json:"resource"`
}

ResourceEventData represents the event data generated by the Resource gateway.

type SNSEventData

type SNSEventData struct {
	// Header is the http request header
	Header http.Header `json:"header"`
	// Body is http request body
	Body *json.RawMessage `json:"body"`
}

SNSEventData represents the event data generated by SNS gateway. +k8s:openapi-gen=true

type SQSEventData

type SQSEventData struct {
	// A unique identifier for the message. A MessageId is considered unique across
	// all AWS accounts for an extended period of time.
	MessageId string `json:"messageId"`
	// Each message attribute consists of a Name, Type, and Value. For more information,
	// see Amazon SQS Message Attributes
	// (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-attributes.html)
	// in the Amazon Simple Queue Service Developer Guide.
	MessageAttributes map[string]*sqslib.MessageAttributeValue `json:"messageAttributes"`
	// The message's contents (not URL-encoded).
	Body interface{} `json:"body"`
}

SQSEventData represents the event data generated by SQS gateway. +k8s:openapi-gen=true

type WebhookEventData

type WebhookEventData struct {
	// Header is the http request header
	Header http.Header `json:"header"`
	// Body is http request body
	Body *json.RawMessage `json:"body"`
}

WebhookEventData represents the event data generated by the Webhook gateway.