consumer

type Consumer struct {
	Context        context.Context
	PubSubClient   *pubsub.Client
	SubscriberName string
	TopicID        string
	Buffer         chan Message
}

type Message struct {
	Data       string
	Attributes map[string]string
}