gcppubsub

type Adapter struct {
	// ProjectID is the pre-existing gcp project id to use.
	ProjectID string
	// TopicID is the pre-existing gcp pub/sub topic id to use.
	TopicID string
	// SubscriptionID is the pre-existing gcp pub/sub subscription id to use.
	SubscriptionID string
	// SinkURI is the URI messages will be forwarded on to.
	SinkURI string
	// TransformerURI is the URI messages will be forwarded on to for any transformation
	// before they are sent to SinkURI.
	TransformerURI string
	// contains filtered or unexported fields
}

type PubSubMessage interface {
	Ack()
	Nack()
	ID() string
	PublishTime() time.Time
	Data() []byte

	Message() *pubsub.Message
}

type PubSubMessageWrapper struct {
	M *pubsub.Message
}