eventutil

Documentation

Index

• func GenerateEventMetadata(event eventbus.Event) map[string]string
• func PublishResilientEvent(ctx context.Context, ag EventAggregate) error
• func SpanCtxToJSON(ctx context.Context) ([]byte, error)
• type EventAggregate

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
}