Lines Matching refs:pubc
89 pubc *vkit.PublisherClient member
94 pubc, err := vkit.NewPublisherClient(ctx, opts...)
98 subc, err := vkit.NewSubscriberClient(ctx, option.WithGRPCConn(pubc.Connection()))
100 _ = pubc.Close() // ignore error
103 pubc.SetGoogleClientInfo("gccl", version.Repo)
105 return &apiService{pubc: pubc, subc: subc}, nil
110 err := s.pubc.Close()
198 _, err := s.pubc.CreateTopic(ctx, &pb.Topic{Name: name})
203 it := s.pubc.ListTopics(ctx, &pb.ListTopicsRequest{
216 return s.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: name})
220 _, err := s.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: name})
231 it := s.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
313 resp, err := s.pubc.Publish(ctx, &pb.PublishRequest{
334 return iam.InternalNewHandle(s.pubc.Connection(), resourceName)