blob: ec9b2219e6cd16dcc31949eb9cef4cd370b38d20 [file] [log] [blame]
package org.apache.airavata.resource.profile.service;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import org.apache.airavata.resource.profile.service.s3.*;
import org.apache.airavata.resource.profile.stubs.common.AuthzToken;
import org.apache.airavata.resource.profile.stubs.s3.S3Storage;
public class SampleClient {
public static void main(String args[]) {
ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 17002).usePlaintext().build();
S3StorageServiceGrpc.S3StorageServiceBlockingStub s3StorageServiceBlockingStub = S3StorageServiceGrpc.newBlockingStub(channel);
S3StorageCreateResponse s3Storage = s3StorageServiceBlockingStub.createS3Storage(S3StorageCreateRequest.newBuilder()
.setAuthzToken(AuthzToken.newBuilder().setAuthorizationToken("token").build())
.setS3Storage(S3Storage.newBuilder().setBucketName("bucket-1").setRegion("us-east").build()).build());
System.out.println(s3Storage.getS3Storage());
S3StorageFetchResponse s3StorageFetchResponse = s3StorageServiceBlockingStub.fetchS3Storage(S3StorageFetchRequest.newBuilder().setS3StorageId(s3Storage.getS3Storage().getS3StorageId()).setAuthzToken(AuthzToken.newBuilder().setAuthorizationToken("token").build()).build());
System.out.println(s3StorageFetchResponse.getS3Storage());
}
}