events

Documentation

Index

• func WithDelay(duration time.Duration) func(*v1.EventPublishRequest)
• type Event
• type Events
  • func New() (Events, error)
• type PublishOption
• type Topic

Functions

func WithDelay

func WithDelay(duration time.Duration) func(*v1.EventPublishRequest)

WithDelay - Delay event publishing by the given duration

Types

type Event

type Event struct {
	Payload     map[string]interface{} `json:"payload"`
	PayloadType string                 `json:"payloadType"`
	ID          string                 `json:"id"`
}

type Events

type Events interface {
	// Topic - Retrieve a Topic reference
	Topic(name string) Topic
	// Topics - Retrievs a list of available Topic references
	Topics() ([]Topic, error)
}

Events

func New

func New() (Events, error)

New - Construct a new Eventing Client with default options

type PublishOption

type PublishOption = func(*v1.EventPublishRequest)

type Topic

type Topic interface {
	// Name returns the Topic name.
	Name() string

	// Publish will publish the provided events on the topic.
	Publish(*Event, ...PublishOption) (*Event, error)
}

Topic for pub/sub async messaging.