topics

Documentation

Index

• func WithDelay(duration time.Duration) func(*v1.TopicPublishRequest)
• type PublishOption
• type Topic
• type Topics
  • func New() (Topics, error)

Functions

func WithDelay

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

WithDelay - Delay event publishing by the given duration

Types

type PublishOption

type PublishOption = func(*v1.TopicPublishRequest)

type Topic

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

	// Publish will publish the provided events on the topic.
	Publish(context.Context, map[string]interface{}, ...PublishOption) error
}

Topic for pub/sub async messaging.

type Topics

type Topics interface {
	// Topic - Retrieve a Topic reference
	Topic(name string) Topic
}

Topics

func New

func New() (Topics, error)

New - Construct a new Eventing Client with default options