Documentation ¶
Index ¶
- func NewGooglePubSub(config config.MQConfig, logger zerolog.Logger) (mq.MQ, error)
- type GooglePubSub
- func (googlepubsub *GooglePubSub) InitSubscriber(ctx context.Context, projectID, topicID string, subIDs ...string) error
- func (googlepubsub *GooglePubSub) InitTopic(ctx context.Context, projectID, topicID string) error
- func (googlepubsub *GooglePubSub) Publish(distributedID int64, projectID, topicID string, message []byte) error
- func (googlepubsub *GooglePubSub) Stop()
- func (googlepubsub *GooglePubSub) Subscribe(projectID, subscription string, process func(context.Context, []byte) error) error
- type Receiver
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type GooglePubSub ¶
type GooglePubSub struct {
// contains filtered or unexported fields
}
GooglePubSub implements methods of MQ through google pub/sub
func (*GooglePubSub) InitSubscriber ¶
func (*GooglePubSub) InitTopic ¶
func (googlepubsub *GooglePubSub) InitTopic(ctx context.Context, projectID, topicID string) error
func (*GooglePubSub) Publish ¶
func (googlepubsub *GooglePubSub) Publish(distributedID int64, projectID, topicID string, message []byte) error
func (*GooglePubSub) Stop ¶
func (googlepubsub *GooglePubSub) Stop()
Click to show internal directories.
Click to hide internal directories.