events

Documentation

Index

• Constants
• Variables
• func CalculateEventSignature(secret, contentType string, eventType EventType, subscriptionID string, ...) string
• type Device
• type DevicesOffline
• type DevicesOnline
• type DevicesRegistered
• type DevicesUnregistered
• type EventHeader
  • func ParseEventHeader(r *http.Request) (h EventHeader, _ error)
  • func (h EventHeader) GetContentDecoder() (func(w []byte, v interface{}) error, error)
• type EventType
• type EventTypes
  • func (e EventTypes) Has(ev EventType) bool
• type ResourceChanged
• type ResourcesPublished
• type ResourcesUnpublished
• type SubscriptionRequest
• type SubscriptionResponse

Constants

const AcceptEncodingKey = "Accept-Encoding"

const AcceptKey = "Accept"

const ContentEncodingKey = "Content-Encoding"

const ContentTypeKey = "Content-Type"

const CorrelationIDKey = "Correlation-ID"

const EventSignatureKey = "Event-Signature"

const EventTimestampKey = "Event-Timestamp"

const EventTypeKey = "Event-Type"

const SequenceNumberKey = "Sequence-Number"

const SubscriptionIDKey = "Subscription-ID"

Variables

var AllDeviceEvents = []EventType{EventType_ResourcesPublished, EventType_ResourcesUnpublished}

var AllDevicesEvents = []EventType{EventType_DevicesOnline, EventType_DevicesOffline, EventType_DevicesRegistered, EventType_DevicesUnregistered}

var AllResourceEvents = []EventType{EventType_ResourceChanged}

var ContentType_JSON = message.AppJSON.String()

var ContentType_VNDOCFCBOR = message.AppOcfCbor.String()

Functions

func CalculateEventSignature

func CalculateEventSignature(secret, contentType string, eventType EventType, subscriptionID string, seqNum uint64, timeStamp time.Time, body []byte) string

Types

type Device

type Device struct {
	ID string `json:"di"`
}

type DevicesOffline

type DevicesOffline []Device

type DevicesOnline

type DevicesOnline []Device

type DevicesRegistered

type DevicesRegistered []Device

type DevicesUnregistered

type DevicesUnregistered []Device

type EventHeader

type EventHeader struct {
	CorrelationID   string
	ID              string
	ContentType     string
	EventType       EventType
	SequenceNumber  uint64
	EventTimestamp  time.Time
	EventSignature  string
	AcceptEncoding  []string
	ContentEncoding string
}

func ParseEventHeader

func ParseEventHeader(r *http.Request) (h EventHeader, _ error)

func (EventHeader) GetContentDecoder

func (h EventHeader) GetContentDecoder() (func(w []byte, v interface{}) error, error)

type EventType

type EventType string

const (
	// resource
	EventType_ResourceChanged EventType = "resource_contentchanged"

	// device
	EventType_ResourcesPublished   EventType = "resources_published"
	EventType_ResourcesUnpublished EventType = "resources_unpublished"

	// devices
	EventType_DevicesOnline       EventType = "devices_online"
	EventType_DevicesOffline      EventType = "devices_offline"
	EventType_DevicesRegistered   EventType = "devices_registered"
	EventType_DevicesUnregistered EventType = "devices_unregistered"

	// among all
	EventType_SubscriptionCanceled EventType = "subscription_cancelled"
)

type EventTypes

type EventTypes []EventType

func (EventTypes) Has

func (e EventTypes) Has(ev EventType) bool

type ResourceChanged

type ResourceChanged []byte

type ResourcesPublished

type ResourcesPublished []schema.ResourceLink

type ResourcesUnpublished

type ResourcesUnpublished []schema.ResourceLink

type SubscriptionRequest

type SubscriptionRequest struct {
	URL           string      `json:"eventsUrl"`
	EventTypes    []EventType `json:"eventTypes"`
	SigningSecret string      `json:"signingSecret"`
}

type SubscriptionResponse

type SubscriptionResponse struct {
	SubscriptionId string `json:"subscriptionId"`
}