当前位置：源码 > Java源码 >

Java源码示例：com.google.api.gax.core.NoCredentialsProvider

示例1

@Override
public void open(Configuration configuration) throws Exception {
	Publisher.Builder builder = Publisher
		.newBuilder(ProjectTopicName.of(projectName, topicName))
		.setCredentialsProvider(FixedCredentialsProvider.create(credentials));

	if (hostAndPortForEmulator != null) {
		managedChannel = ManagedChannelBuilder
			.forTarget(hostAndPortForEmulator)
			.usePlaintext(true) // This is 'Ok' because this is ONLY used for testing.
			.build();
		channel = GrpcTransportChannel.newBuilder().setManagedChannel(managedChannel).build();
		builder.setChannelProvider(FixedTransportChannelProvider.create(channel))
				.setCredentialsProvider(NoCredentialsProvider.create());
	}

	publisher = builder.build();
	isRunning = true;
}

示例2

@Override
public void open(Configuration configuration) throws Exception {
	serializationSchema.open(() -> getRuntimeContext().getMetricGroup().addGroup("user"));

	Publisher.Builder builder = Publisher
		.newBuilder(ProjectTopicName.of(projectName, topicName))
		.setCredentialsProvider(FixedCredentialsProvider.create(credentials));

	if (hostAndPortForEmulator != null) {
		managedChannel = ManagedChannelBuilder
			.forTarget(hostAndPortForEmulator)
			.usePlaintext(true) // This is 'Ok' because this is ONLY used for testing.
			.build();
		channel = GrpcTransportChannel.newBuilder().setManagedChannel(managedChannel).build();
		builder.setChannelProvider(FixedTransportChannelProvider.create(channel))
				.setCredentialsProvider(NoCredentialsProvider.create());
	}

	publisher = builder.build();
	isRunning = true;
}

示例3

private static void createTopic(final String hostPort,
                                final TransportChannelProvider channelProvider,
                                final ProjectTopicName topic) {
    final TopicAdminClient topicClient;
    try {
        final TopicAdminSettings topicAdminSettings = TopicAdminSettings.newBuilder()
            .setTransportChannelProvider(channelProvider)
            .setCredentialsProvider(NoCredentialsProvider.create())
            .build();
        topicClient = TopicAdminClient.create(topicAdminSettings);
    } catch (final IOException e) {
        throw new UncheckedIOException(String.format("Error creating topic %s for pub/sub emulator %s",
                                                     topic, hostPort), e);
    }
    final ProjectName project = ProjectName.of(topic.getProject());
    if (Streams.stream(topicClient.listTopics(project).iterateAll())
               .map(Topic::getName)
               .map(ProjectTopicName::parse)
               .noneMatch(topic::equals)) {
        logger.info("Initializing Pub/Sub emulator topic: {}", topic);
        topicClient.createTopic(topic);
    }
}

示例4

public GcpPubSubAutoConfiguration(GcpPubSubProperties gcpPubSubProperties,
		GcpProjectIdProvider gcpProjectIdProvider,
		CredentialsProvider credentialsProvider) throws IOException {
	this.gcpPubSubProperties = gcpPubSubProperties;
	this.finalProjectIdProvider = (gcpPubSubProperties.getProjectId() != null)
			? gcpPubSubProperties::getProjectId
			: gcpProjectIdProvider;

	if (gcpPubSubProperties.getEmulatorHost() == null
			|| "false".equals(gcpPubSubProperties.getEmulatorHost())) {
		this.finalCredentialsProvider = gcpPubSubProperties.getCredentials().hasKey()
				? new DefaultCredentialsProvider(gcpPubSubProperties)
				: credentialsProvider;
	}
	else {
		// Since we cannot create a general NoCredentialsProvider if the emulator host is enabled
		// (because it would also be used for the other components), we have to create one here
		// for this particular case.
		this.finalCredentialsProvider = NoCredentialsProvider.create();
	}
}

示例5

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  AccountBudgetServiceSettings settings =
      AccountBudgetServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = AccountBudgetServiceClient.create(settings);
}

示例6

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  AdGroupAudienceViewServiceSettings settings =
      AdGroupAudienceViewServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = AdGroupAudienceViewServiceClient.create(settings);
}

示例7

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  ParentalStatusViewServiceSettings settings =
      ParentalStatusViewServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = ParentalStatusViewServiceClient.create(settings);
}

示例8

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  CarrierConstantServiceSettings settings =
      CarrierConstantServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = CarrierConstantServiceClient.create(settings);
}

示例9

public Publisher createPublisher(String project, String topic) throws IOException {
	return Publisher
		.newBuilder(ProjectTopicName.of(project, topic))
		.setChannelProvider(channelProvider)
		.setCredentialsProvider(NoCredentialsProvider.create())
		.build();
}

示例10

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  SharedCriterionServiceSettings settings =
      SharedCriterionServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = SharedCriterionServiceClient.create(settings);
}

示例11

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  MobileAppCategoryConstantServiceSettings settings =
      MobileAppCategoryConstantServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = MobileAppCategoryConstantServiceClient.create(settings);
}

示例12

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  AdGroupAdServiceSettings settings =
      AdGroupAdServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = AdGroupAdServiceClient.create(settings);
}

示例13

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  HotelGroupViewServiceSettings settings =
      HotelGroupViewServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = HotelGroupViewServiceClient.create(settings);
}

示例14

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  KeywordPlanCampaignServiceSettings settings =
      KeywordPlanCampaignServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = KeywordPlanCampaignServiceClient.create(settings);
}

示例15

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  GenderViewServiceSettings settings =
      GenderViewServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = GenderViewServiceClient.create(settings);
}

示例16

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  CampaignLabelServiceSettings settings =
      CampaignLabelServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = CampaignLabelServiceClient.create(settings);
}

示例17

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  AdGroupCriterionSimulationServiceSettings settings =
      AdGroupCriterionSimulationServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = AdGroupCriterionSimulationServiceClient.create(settings);
}

示例18

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  ConversionUploadServiceSettings settings =
      ConversionUploadServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = ConversionUploadServiceClient.create(settings);
}

示例19

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  TopicViewServiceSettings settings =
      TopicViewServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = TopicViewServiceClient.create(settings);
}

示例20

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  CampaignServiceSettings settings =
      CampaignServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = CampaignServiceClient.create(settings);
}

示例21

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  KeywordPlanNegativeKeywordServiceSettings settings =
      KeywordPlanNegativeKeywordServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = KeywordPlanNegativeKeywordServiceClient.create(settings);
}

示例22

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  DetailPlacementViewServiceSettings settings =
      DetailPlacementViewServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = DetailPlacementViewServiceClient.create(settings);
}

示例23

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  AdServiceSettings settings =
      AdServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = AdServiceClient.create(settings);
}

示例24

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  AdGroupCriterionSimulationServiceSettings settings =
      AdGroupCriterionSimulationServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = AdGroupCriterionSimulationServiceClient.create(settings);
}

示例25

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  PaidOrganicSearchTermViewServiceSettings settings =
      PaidOrganicSearchTermViewServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = PaidOrganicSearchTermViewServiceClient.create(settings);
}

示例26

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  AdGroupBidModifierServiceSettings settings =
      AdGroupBidModifierServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = AdGroupBidModifierServiceClient.create(settings);
}

示例27

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  ChangeStatusServiceSettings settings =
      ChangeStatusServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = ChangeStatusServiceClient.create(settings);
}

示例28

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  ReachPlanServiceSettings settings =
      ReachPlanServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = ReachPlanServiceClient.create(settings);
}

示例29

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  CustomerClientServiceSettings settings =
      CustomerClientServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = CustomerClientServiceClient.create(settings);
}

示例30

@Before
public void setUp() throws IOException {
  serviceHelper.reset();
  channelProvider = serviceHelper.createChannelProvider();
  FeedItemTargetServiceSettings settings =
      FeedItemTargetServiceSettings.newBuilder()
          .setTransportChannelProvider(channelProvider)
          .setCredentialsProvider(NoCredentialsProvider.create())
          .build();
  client = FeedItemTargetServiceClient.create(settings);
}

Java源码示例：com.google.api.gax.core.NoCredentialsProvider

微信关注