// package pubsub handle the publishing of messages into Google Pub/Sub package pubsub import ( "cloud.google.com/go/pubsub" "edge-infra.dev/pkg/edge/datasync/shoot/model" ) type Publisher interface { Publish(messages []*model.Message) []*PublishFailureResult } type PublishFailureResult struct { Message *model.Message Result *pubsub.PublishResult }