Source file src/edge-infra.dev/pkg/edge/datasync/shoot/pubsub/publisher.go

Documentation: edge-infra.dev/pkg/edge/datasync/shoot/pubsub

     1  // package pubsub handle the publishing of messages into Google Pub/Sub
     2  package pubsub
     3  
     4  import (
     5  	"cloud.google.com/go/pubsub"
     6  
     7  	"edge-infra.dev/pkg/edge/datasync/shoot/model"
     8  )
     9  
    10  type Publisher interface {
    11  	Publish(messages []*model.Message) []*PublishFailureResult
    12  }
    13  
    14  type PublishFailureResult struct {
    15  	Message *model.Message
    16  	Result  *pubsub.PublishResult
    17  }
    18  

View as plain text