Lines Matching refs:new
44 GRPC::Core::ChannelCredentials.new()
58 call_creds = GRPC::Core::CallCredentials.new(auth_proc(opts))
60 stub_clz.new(address, creds: combined_creds,
69 call_creds = GRPC::Core::CallCredentials.new(auth_proc(opts))
71 stub_clz.new(address, creds: combined_creds,
94 @pub.delete_topic(DeleteTopicRequest.new(topic: name))
104 resp = @pub.create_topic(Topic.new(name: name))
134 @sub.create_subscription(Subscription.new(name: sub_name,
138 msg = PubsubMessage.new(data: "message #{x}")
139 @pub.publish(PublishRequest.new(topic: topic_name, message: msg))
142 batch = @sub.pull_batch(PullBatchRequest.new(subscription: sub_name,
146 @sub.acknowledge(AcknowledgeRequest.new(subscription: sub_name,
149 del_req = DeleteSubscriptionRequest.new(subscription: sub_name)
183 @pub.create_topic(Topic.new(name: name))
188 @pub.list_topics(ListTopicsRequest.new(query: q))
193 Args = Struct.new(:host, :port, :action, :project_id, :topic_name,
198 args = Args.new('pubsub-staging.googleapis.com',
200 OptionParser.new do |opts|
229 raise OptionParser::MissingArgument.new("please specify --#{a}")
238 NamedActions.new(pub, sub, args).method(args.action).call
