google

type GooglePubSubClient struct {
	Client *pubsub.Client
}

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

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

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

type PubSubClient interface {
	CreateSubscription(ctx context.Context, id string, cfg pubsub.SubscriptionConfig) (Subscription, error)
	Subscription(id string) Subscription
	Topic(id string) Topic
	Close() error
}

type PublishResult interface {
	Get(ctx context.Context) (string, error)
}

type Subscription interface {
	ID() string
	Receive(ctx context.Context, f func(ctx context.Context, msg *pubsub.Message)) error
}

type Topic interface {
	Publish(ctx context.Context, msg *pubsub.Message) PublishResult
	GetInstance() *pubsub.Topic
}