cloud_pubsub

type CloudPublisher struct {
	ProjectID string
	TopicID   string
	Client    *pubsub.Client
}

type CloudSubscriber struct {
	ProjectID      string
	SubscriptionID string
	Subscription   *pubsub.Subscription
}

type Data struct {
	Id          string
	Publisher   string
	Action      string
	RequestTime string
	Data        interface{}
}

type Publisher interface {
	PublishMessage(ctx context.Context, data Data) (messageID string, err error)
}

type Subscriber interface {
	Receive(context.Context, func(ctx context.Context, msg *pubsub.Message)) error
}