Method Publish

pkg/events/cloud/cloud.go:181–212

Publish an event to Go Cloud.

(evs ...events.Event)

// Publish an event to Go Cloud.
func (ps *PubSub) Publish(evs ...events.Event) {
	logger := log.FromContext(ps.ctx)
	for _, evt := range evs {
		var body []byte
		switch ps.contentType {
		case "application/protobuf":
			evtpb, err := events.Proto(evt)
			if err != nil {
				logger.WithError(err).Warn("Failed to marshal event to protobuf")
				continue
			}
			body, err = proto.Marshal(evtpb)
			if err != nil {
				logger.WithError(err).Warn("Failed to marshal event to binary")
				continue
			}
		case "application/json":
			var err error
			body, err = json.Marshal(evt)
			if err != nil {
				logger.WithError(err).Warn("Failed to marshal event to JSON")
				continue
			}
		}
		if err := ps.topic.Send(evt.Context(), &pubsub.Message{
			Metadata: ps.getMetadata(evt),
			Body:     body,
		}); err != nil {
			logger.WithError(err).Warn("Failed to send event")
		}
	}
}