events

Documentation

Index

• func CreateFullyQualifiedTopicName(topic string, source types.NamespacedName) string
• type Event
  • func (e Event) Key() string
• type EventData
  • func (d *EventData) Get(key string) string

Functions

func CreateFullyQualifiedTopicName

func CreateFullyQualifiedTopicName(topic string, source types.NamespacedName) string

CreateFullyQualifiedTopicName creates a FQTN from the topic name and event source but if the source is empty then the topic will be returned as is.

Types

type Event

type Event struct {
	Name       string    `json:"name,omitempty"`
	ActiveTime time.Time `json:"activeTime,omitempty"`
	// Data is a pointer ref so these events can be added into the workqueue of the Dispatcher
	Data *EventData `json:"data,omitempty"`
}

func (Event) Key

func (e Event) Key() string

Key hash the EventData into a key that can be used to de-duplicate events.

type EventData

type EventData map[string]string

func (*EventData) Get

func (d *EventData) Get(key string) string