Lines Matching refs:pubc
128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
242 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
287 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
301 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
327 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
372 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
380 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
392 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
399 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
567 res, err = t.c.pubc.Publish(ctx, &pb.PublishRequest{