pubsub

Documentation

Index

• Variables
• func PublishDataPayload(ctx context.Context, topic string, correlationId string, eventData interface{}) error
• func PublishEvent(ctx context.Context, topic string, event interface{}) error
• func UnwrapDataRequestPayload(e event.Event, to interface{}) (string, error)
• type DataRequestPayload
  • func (p DataRequestPayload) DataAs(target interface{}) error

Variables

var PubsubName string

Functions

func PublishDataPayload

func PublishDataPayload(ctx context.Context, topic string, correlationId string, eventData interface{}) error

func PublishEvent

func PublishEvent(ctx context.Context, topic string, event interface{}) error

func UnwrapDataRequestPayload

func UnwrapDataRequestPayload(e event.Event, to interface{}) (string, error)

Types

type DataRequestPayload

type DataRequestPayload struct {
	CorrelationId string `json:"correlationId"`
	Data          []byte `json:"data"`
}

func (DataRequestPayload) DataAs

func (p DataRequestPayload) DataAs(target interface{}) error