pubsub_client

type IPubsubClient interface {
	Topic(topicId string) IPubsubTopic
}

type IPubsubPublishResult interface {
	Get(ctx context.Context) (msgID string, err error)
}

type IPubsubTopic interface {
	Publish(ctx context.Context, msg *pubsub.Message) IPubsubPublishResult
}

type PubsubClient struct {
	// contains filtered or unexported fields
}

type PubsubPublishResult struct {
	*pubsub.PublishResult
}

type PubsubTopic struct {
	*pubsub.Topic
}