MCPcopy Create free account
hub / github.com/google/go-cloud / PublisherClient

Function PublisherClient

pubsub/gcppubsub/gcppubsub.go:321–323  ·  view source on GitHub ↗

PublisherClient returns a *raw.PublisherClient that can be used in OpenTopic.

(ctx context.Context, conn *grpc.ClientConn)

Source from the content-addressed store, hash-verified

319
320// PublisherClient returns a *raw.PublisherClient that can be used in OpenTopic.
321func PublisherClient(ctx context.Context, conn *grpc.ClientConn) (*raw.PublisherClient, error) {
322 return raw.NewPublisherClient(ctx, option.WithGRPCConn(conn))
323}
324
325// SubscriberClient returns a *raw.SubscriberClient that can be used in OpenSubscription.
326func SubscriberClient(ctx context.Context, conn *grpc.ClientConn) (*raw.SubscriberClient, error) {

Callers 5

ExampleOpenTopicFunction · 0.92
newHarnessFunction · 0.85
BenchmarkGcpPubSubFunction · 0.85
TestOpenTopicFunction · 0.85
OpenTopicURLMethod · 0.85

Calls

no outgoing calls

Tested by 4

ExampleOpenTopicFunction · 0.74
newHarnessFunction · 0.68
BenchmarkGcpPubSubFunction · 0.68
TestOpenTopicFunction · 0.68