Skip to content

Add functionality to tag every http request #1015

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 1 commit into from
Closed

Add functionality to tag every http request #1015

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
104 changes: 58 additions & 46 deletions ...ent-reactor/src/main/java/org/cloudfoundry/reactor/client/_ReactorCloudFoundryClient.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -111,6 +111,8 @@
import reactor.core.publisher.Mono;

import javax.annotation.PostConstruct;
import java.util.Collections;
import java.util.Map;

/**
* The Reactor-based implementation of {@link CloudFoundryClient}
Expand All @@ -121,37 +123,37 @@ abstract class _ReactorCloudFoundryClient implements CloudFoundryClient {
@Override
@Value.Derived
public ApplicationUsageEvents applicationUsageEvents() {
return new ReactorApplicationUsageEvents(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorApplicationUsageEvents(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ApplicationsV2 applicationsV2() {
return new ReactorApplicationsV2(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorApplicationsV2(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ApplicationsV3 applicationsV3() {
return new ReactorApplicationsV3(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorApplicationsV3(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Blobstores blobstores() {
return new ReactorBlobstores(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorBlobstores(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Buildpacks buildpacks() {
return new ReactorBuildpacks(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorBuildpacks(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Builds builds() {
return new ReactorBuilds(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorBuilds(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@PostConstruct
Expand All @@ -162,244 +164,254 @@ public void checkCompatibility() {
@Override
@Value.Derived
public DeploymentsV3 deploymentsV3() {
return new ReactorDeploymentsV3(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorDeploymentsV3(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Domains domains() {
return new ReactorDomains(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorDomains(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Droplets droplets() {
return new ReactorDroplets(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorDroplets(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public EnvironmentVariableGroups environmentVariableGroups() {
return new ReactorEnvironmentVariableGroups(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorEnvironmentVariableGroups(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Events events() {
return new ReactorEvents(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorEvents(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public FeatureFlags featureFlags() {
return new ReactorFeatureFlags(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorFeatureFlags(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Info info() {
return new ReactorInfo(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorInfo(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public IsolationSegments isolationSegments() {
return new ReactorIsolationSegments(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorIsolationSegments(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Jobs jobs() {
return new ReactorJobs(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorJobs(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public JobsV3 jobsV3() {
return new ReactorJobsV3(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorJobsV3(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public OrganizationQuotaDefinitions organizationQuotaDefinitions() {
return new ReactorOrganizationQuotaDefinitions(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorOrganizationQuotaDefinitions(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Organizations organizations() {
return new ReactorOrganizations(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorOrganizations(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public OrganizationsV3 organizationsV3() {
return new ReactorOrganizationsV3(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorOrganizationsV3(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Packages packages() {
return new ReactorPackages(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorPackages(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public PrivateDomains privateDomains() {
return new ReactorPrivateDomains(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorPrivateDomains(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Processes processes() {
return new ReactorProcesses(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorProcesses(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ResourceMatch resourceMatch() {
return new ReactorResourceMatch(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorResourceMatch(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public RouteMappings routeMappings() {
return new ReactorRouteMappings(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorRouteMappings(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Routes routes() {
return new ReactorRoutes(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorRoutes(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public SecurityGroups securityGroups() {
return new ReactorSecurityGroups(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorSecurityGroups(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ServiceBindingsV2 serviceBindingsV2() {
return new ReactorServiceBindingsV2(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorServiceBindingsV2(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ServiceBindingsV3 serviceBindingsV3() {
return new ReactorServiceBindingsV3(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorServiceBindingsV3(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ServiceBrokers serviceBrokers() {
return new ReactorServiceBrokers(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorServiceBrokers(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ServiceInstances serviceInstances() {
return new ReactorServiceInstances(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorServiceInstances(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ServiceInstancesV3 serviceInstancesV3() {
return new ReactorServiceInstancesV3(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorServiceInstancesV3(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ServiceKeys serviceKeys() {
return new ReactorServiceKeys(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorServiceKeys(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ServicePlanVisibilities servicePlanVisibilities() {
return new ReactorServicePlanVisibilities(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorServicePlanVisibilities(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ServicePlans servicePlans() {
return new ReactorServicePlans(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorServicePlans(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public ServiceUsageEvents serviceUsageEvents() {
return new ReactorServiceUsageEvents(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorServiceUsageEvents(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Services services() {
return new ReactorServices(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorServices(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public SharedDomains sharedDomains() {
return new ReactorSharedDomains(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorSharedDomains(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public SpaceQuotaDefinitions spaceQuotaDefinitions() {
return new ReactorSpaceQuotaDefinitions(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorSpaceQuotaDefinitions(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Spaces spaces() {
return new ReactorSpaces(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorSpaces(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public SpacesV3 spacesV3() {
return new ReactorSpacesV3(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorSpacesV3(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Stacks stacks() {
return new ReactorStacks(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorStacks(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Tasks tasks() {
return new ReactorTasks(getConnectionContext(), getRootV3(), getTokenProvider());
return new ReactorTasks(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public UserProvidedServiceInstances userProvidedServiceInstances() {
return new ReactorUserProvidedServiceInstances(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorUserProvidedServiceInstances(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

@Override
@Value.Derived
public Users users() {
return new ReactorUsers(getConnectionContext(), getRootV2(), getTokenProvider());
return new ReactorUsers(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
}

/**
* The connection context
*/
abstract ConnectionContext getConnectionContext();

/**
* Map of http header name and value which will be added to every request to the controller
*/
@Value.Default
Map<String, String> getRequestTags() {
return Collections.emptyMap();
}

@Value.Default
Mono<String> getRootV2() {
return getConnectionContext().getRootProvider().getRoot("cloud_controller_v2", getConnectionContext());
return getConnectionContext().getRootProvider()
.getRoot("cloud_controller_v2", getConnectionContext());
}

@Value.Default
Mono<String> getRootV3() {
return getConnectionContext().getRootProvider().getRoot("cloud_controller_v3", getConnectionContext());
return getConnectionContext().getRootProvider()
.getRoot("cloud_controller_v3", getConnectionContext());
}

/**
Expand Down
Loading