|
18 | 18 | import com.microsoft.azure.ListOperationCallback; |
19 | 19 | import com.microsoft.azure.management.datafactoryv2.v2018_06_01.FactoryRepoUpdate; |
20 | 20 | import com.microsoft.azure.management.datafactoryv2.v2018_06_01.FactoryUpdateParameters; |
| 21 | +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.GitHubAccessTokenRequest; |
21 | 22 | import com.microsoft.azure.Page; |
22 | 23 | import com.microsoft.azure.PagedList; |
23 | 24 | import com.microsoft.rest.ServiceCallback; |
@@ -96,6 +97,10 @@ interface FactoriesService { |
96 | 97 | @HTTP(path = "subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}", method = "DELETE", hasBody = true) |
97 | 98 | Observable<Response<ResponseBody>> delete(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); |
98 | 99 |
|
| 100 | + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactoryv2.v2018_06_01.Factories getGitHubAccessToken" }) |
| 101 | + @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/getGitHubAccessToken") |
| 102 | + Observable<Response<ResponseBody>> getGitHubAccessToken(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Body GitHubAccessTokenRequest gitHubAccessTokenRequest, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); |
| 103 | + |
99 | 104 | @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactoryv2.v2018_06_01.Factories listNext" }) |
100 | 105 | @GET |
101 | 106 | Observable<Response<ResponseBody>> listNext(@Url String nextUrl, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); |
@@ -952,6 +957,100 @@ private ServiceResponse<Void> deleteDelegate(Response<ResponseBody> response) th |
952 | 957 | .build(response); |
953 | 958 | } |
954 | 959 |
|
| 960 | + /** |
| 961 | + * Get GitHub Access Token. |
| 962 | + * |
| 963 | + * @param resourceGroupName The resource group name. |
| 964 | + * @param factoryName The factory name. |
| 965 | + * @param gitHubAccessTokenRequest Get GitHub access token request definition. |
| 966 | + * @throws IllegalArgumentException thrown if parameters fail the validation |
| 967 | + * @throws CloudException thrown if the request is rejected by server |
| 968 | + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent |
| 969 | + * @return the GitHubAccessTokenResponseInner object if successful. |
| 970 | + */ |
| 971 | + public GitHubAccessTokenResponseInner getGitHubAccessToken(String resourceGroupName, String factoryName, GitHubAccessTokenRequest gitHubAccessTokenRequest) { |
| 972 | + return getGitHubAccessTokenWithServiceResponseAsync(resourceGroupName, factoryName, gitHubAccessTokenRequest).toBlocking().single().body(); |
| 973 | + } |
| 974 | + |
| 975 | + /** |
| 976 | + * Get GitHub Access Token. |
| 977 | + * |
| 978 | + * @param resourceGroupName The resource group name. |
| 979 | + * @param factoryName The factory name. |
| 980 | + * @param gitHubAccessTokenRequest Get GitHub access token request definition. |
| 981 | + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. |
| 982 | + * @throws IllegalArgumentException thrown if parameters fail the validation |
| 983 | + * @return the {@link ServiceFuture} object |
| 984 | + */ |
| 985 | + public ServiceFuture<GitHubAccessTokenResponseInner> getGitHubAccessTokenAsync(String resourceGroupName, String factoryName, GitHubAccessTokenRequest gitHubAccessTokenRequest, final ServiceCallback<GitHubAccessTokenResponseInner> serviceCallback) { |
| 986 | + return ServiceFuture.fromResponse(getGitHubAccessTokenWithServiceResponseAsync(resourceGroupName, factoryName, gitHubAccessTokenRequest), serviceCallback); |
| 987 | + } |
| 988 | + |
| 989 | + /** |
| 990 | + * Get GitHub Access Token. |
| 991 | + * |
| 992 | + * @param resourceGroupName The resource group name. |
| 993 | + * @param factoryName The factory name. |
| 994 | + * @param gitHubAccessTokenRequest Get GitHub access token request definition. |
| 995 | + * @throws IllegalArgumentException thrown if parameters fail the validation |
| 996 | + * @return the observable to the GitHubAccessTokenResponseInner object |
| 997 | + */ |
| 998 | + public Observable<GitHubAccessTokenResponseInner> getGitHubAccessTokenAsync(String resourceGroupName, String factoryName, GitHubAccessTokenRequest gitHubAccessTokenRequest) { |
| 999 | + return getGitHubAccessTokenWithServiceResponseAsync(resourceGroupName, factoryName, gitHubAccessTokenRequest).map(new Func1<ServiceResponse<GitHubAccessTokenResponseInner>, GitHubAccessTokenResponseInner>() { |
| 1000 | + @Override |
| 1001 | + public GitHubAccessTokenResponseInner call(ServiceResponse<GitHubAccessTokenResponseInner> response) { |
| 1002 | + return response.body(); |
| 1003 | + } |
| 1004 | + }); |
| 1005 | + } |
| 1006 | + |
| 1007 | + /** |
| 1008 | + * Get GitHub Access Token. |
| 1009 | + * |
| 1010 | + * @param resourceGroupName The resource group name. |
| 1011 | + * @param factoryName The factory name. |
| 1012 | + * @param gitHubAccessTokenRequest Get GitHub access token request definition. |
| 1013 | + * @throws IllegalArgumentException thrown if parameters fail the validation |
| 1014 | + * @return the observable to the GitHubAccessTokenResponseInner object |
| 1015 | + */ |
| 1016 | + public Observable<ServiceResponse<GitHubAccessTokenResponseInner>> getGitHubAccessTokenWithServiceResponseAsync(String resourceGroupName, String factoryName, GitHubAccessTokenRequest gitHubAccessTokenRequest) { |
| 1017 | + if (this.client.subscriptionId() == null) { |
| 1018 | + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); |
| 1019 | + } |
| 1020 | + if (resourceGroupName == null) { |
| 1021 | + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); |
| 1022 | + } |
| 1023 | + if (factoryName == null) { |
| 1024 | + throw new IllegalArgumentException("Parameter factoryName is required and cannot be null."); |
| 1025 | + } |
| 1026 | + if (this.client.apiVersion() == null) { |
| 1027 | + throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null."); |
| 1028 | + } |
| 1029 | + if (gitHubAccessTokenRequest == null) { |
| 1030 | + throw new IllegalArgumentException("Parameter gitHubAccessTokenRequest is required and cannot be null."); |
| 1031 | + } |
| 1032 | + Validator.validate(gitHubAccessTokenRequest); |
| 1033 | + return service.getGitHubAccessToken(this.client.subscriptionId(), resourceGroupName, factoryName, this.client.apiVersion(), gitHubAccessTokenRequest, this.client.acceptLanguage(), this.client.userAgent()) |
| 1034 | + .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<GitHubAccessTokenResponseInner>>>() { |
| 1035 | + @Override |
| 1036 | + public Observable<ServiceResponse<GitHubAccessTokenResponseInner>> call(Response<ResponseBody> response) { |
| 1037 | + try { |
| 1038 | + ServiceResponse<GitHubAccessTokenResponseInner> clientResponse = getGitHubAccessTokenDelegate(response); |
| 1039 | + return Observable.just(clientResponse); |
| 1040 | + } catch (Throwable t) { |
| 1041 | + return Observable.error(t); |
| 1042 | + } |
| 1043 | + } |
| 1044 | + }); |
| 1045 | + } |
| 1046 | + |
| 1047 | + private ServiceResponse<GitHubAccessTokenResponseInner> getGitHubAccessTokenDelegate(Response<ResponseBody> response) throws CloudException, IOException, IllegalArgumentException { |
| 1048 | + return this.client.restClient().responseBuilderFactory().<GitHubAccessTokenResponseInner, CloudException>newInstance(this.client.serializerAdapter()) |
| 1049 | + .register(200, new TypeToken<GitHubAccessTokenResponseInner>() { }.getType()) |
| 1050 | + .registerError(CloudException.class) |
| 1051 | + .build(response); |
| 1052 | + } |
| 1053 | + |
955 | 1054 | /** |
956 | 1055 | * Lists factories under the specified subscription. |
957 | 1056 | * |
|
0 commit comments