Versions in this module Expand all Collapse all v0 v0.17.1 Oct 26, 2019 Changes in this version + const Scheme + var Set = wire.NewSet(Dial, PublisherClient, SubscriberClient, wire.Struct(new(SubscriptionOptions)), ...) + func Dial(ctx context.Context, ts gcp.TokenSource) (*grpc.ClientConn, func(), error) + func OpenSubscription(client *raw.SubscriberClient, projectID gcp.ProjectID, subscriptionName string, ...) *pubsub.Subscription + func OpenSubscriptionByPath(client *raw.SubscriberClient, subscriptionPath string, ...) (*pubsub.Subscription, error) + func OpenTopic(client *raw.PublisherClient, projectID gcp.ProjectID, topicName string, ...) *pubsub.Topic + func OpenTopicByPath(client *raw.PublisherClient, topicPath string, opts *TopicOptions) (*pubsub.Topic, error) + func PublisherClient(ctx context.Context, conn *grpc.ClientConn) (*raw.PublisherClient, error) + func SubscriberClient(ctx context.Context, conn *grpc.ClientConn) (*raw.SubscriberClient, error) + type SubscriptionOptions struct + type TopicOptions struct + type URLOpener struct + Conn *grpc.ClientConn + SubscriptionOptions SubscriptionOptions + TopicOptions TopicOptions + func (o *URLOpener) OpenSubscriptionURL(ctx context.Context, u *url.URL) (*pubsub.Subscription, error) + func (o *URLOpener) OpenTopicURL(ctx context.Context, u *url.URL) (*pubsub.Topic, error)
Go to main page