eventutil

package
v0.0.0-...-833cb33 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 29, 2020 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenerateEventMetadata

func GenerateEventMetadata(event eventbus.Event) map[string]string

Generate required event metadata

func PublishResilientEvent

func PublishResilientEvent(ctx context.Context, ag EventAggregate) error

PublishResilientEvent make a call to an message broker safely

func SpanCtxToJSON

func SpanCtxToJSON(ctx context.Context) ([]byte, error)

Parse OpenCensus span context to JSON safely

Types

type EventAggregate

type EventAggregate struct {
	Name    string
	Prefix  string
	Topic   *pubsub.Topic
	Message *pubsub.Message
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL