@@ -721,6 +721,28 @@ function deserialize_openstorage_api_SdkCredentialCreateResponse(buffer_arg) {
721721 return api_pb . SdkCredentialCreateResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
722722}
723723
724+ function serialize_openstorage_api_SdkCredentialDeleteReferencesRequest ( arg ) {
725+ if ( ! ( arg instanceof api_pb . SdkCredentialDeleteReferencesRequest ) ) {
726+ throw new Error ( 'Expected argument of type openstorage.api.SdkCredentialDeleteReferencesRequest' ) ;
727+ }
728+ return Buffer . from ( arg . serializeBinary ( ) ) ;
729+ }
730+
731+ function deserialize_openstorage_api_SdkCredentialDeleteReferencesRequest ( buffer_arg ) {
732+ return api_pb . SdkCredentialDeleteReferencesRequest . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
733+ }
734+
735+ function serialize_openstorage_api_SdkCredentialDeleteReferencesResponse ( arg ) {
736+ if ( ! ( arg instanceof api_pb . SdkCredentialDeleteReferencesResponse ) ) {
737+ throw new Error ( 'Expected argument of type openstorage.api.SdkCredentialDeleteReferencesResponse' ) ;
738+ }
739+ return Buffer . from ( arg . serializeBinary ( ) ) ;
740+ }
741+
742+ function deserialize_openstorage_api_SdkCredentialDeleteReferencesResponse ( buffer_arg ) {
743+ return api_pb . SdkCredentialDeleteReferencesResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
744+ }
745+
724746function serialize_openstorage_api_SdkCredentialDeleteRequest ( arg ) {
725747 if ( ! ( arg instanceof api_pb . SdkCredentialDeleteRequest ) ) {
726748 throw new Error ( 'Expected argument of type openstorage.api.SdkCredentialDeleteRequest' ) ;
@@ -809,6 +831,28 @@ function deserialize_openstorage_api_SdkCredentialValidateResponse(buffer_arg) {
809831 return api_pb . SdkCredentialValidateResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
810832}
811833
834+ function serialize_openstorage_api_SdkEnumerateJobsRequest ( arg ) {
835+ if ( ! ( arg instanceof api_pb . SdkEnumerateJobsRequest ) ) {
836+ throw new Error ( 'Expected argument of type openstorage.api.SdkEnumerateJobsRequest' ) ;
837+ }
838+ return Buffer . from ( arg . serializeBinary ( ) ) ;
839+ }
840+
841+ function deserialize_openstorage_api_SdkEnumerateJobsRequest ( buffer_arg ) {
842+ return api_pb . SdkEnumerateJobsRequest . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
843+ }
844+
845+ function serialize_openstorage_api_SdkEnumerateJobsResponse ( arg ) {
846+ if ( ! ( arg instanceof api_pb . SdkEnumerateJobsResponse ) ) {
847+ throw new Error ( 'Expected argument of type openstorage.api.SdkEnumerateJobsResponse' ) ;
848+ }
849+ return Buffer . from ( arg . serializeBinary ( ) ) ;
850+ }
851+
852+ function deserialize_openstorage_api_SdkEnumerateJobsResponse ( buffer_arg ) {
853+ return api_pb . SdkEnumerateJobsResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
854+ }
855+
812856function serialize_openstorage_api_SdkEnumerateRebalanceJobsRequest ( arg ) {
813857 if ( ! ( arg instanceof api_pb . SdkEnumerateRebalanceJobsRequest ) ) {
814858 throw new Error ( 'Expected argument of type openstorage.api.SdkEnumerateRebalanceJobsRequest' ) ;
@@ -963,6 +1007,28 @@ function deserialize_openstorage_api_SdkFilesystemTrimStopResponse(buffer_arg) {
9631007 return api_pb . SdkFilesystemTrimStopResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
9641008}
9651009
1010+ function serialize_openstorage_api_SdkGetJobStatusRequest ( arg ) {
1011+ if ( ! ( arg instanceof api_pb . SdkGetJobStatusRequest ) ) {
1012+ throw new Error ( 'Expected argument of type openstorage.api.SdkGetJobStatusRequest' ) ;
1013+ }
1014+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1015+ }
1016+
1017+ function deserialize_openstorage_api_SdkGetJobStatusRequest ( buffer_arg ) {
1018+ return api_pb . SdkGetJobStatusRequest . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1019+ }
1020+
1021+ function serialize_openstorage_api_SdkGetJobStatusResponse ( arg ) {
1022+ if ( ! ( arg instanceof api_pb . SdkGetJobStatusResponse ) ) {
1023+ throw new Error ( 'Expected argument of type openstorage.api.SdkGetJobStatusResponse' ) ;
1024+ }
1025+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1026+ }
1027+
1028+ function deserialize_openstorage_api_SdkGetJobStatusResponse ( buffer_arg ) {
1029+ return api_pb . SdkGetJobStatusResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1030+ }
1031+
9661032function serialize_openstorage_api_SdkGetRebalanceJobStatusRequest ( arg ) {
9671033 if ( ! ( arg instanceof api_pb . SdkGetRebalanceJobStatusRequest ) ) {
9681034 throw new Error ( 'Expected argument of type openstorage.api.SdkGetRebalanceJobStatusRequest' ) ;
@@ -1029,6 +1095,50 @@ function deserialize_openstorage_api_SdkIdentityVersionResponse(buffer_arg) {
10291095 return api_pb . SdkIdentityVersionResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
10301096}
10311097
1098+ function serialize_openstorage_api_SdkJobResponse ( arg ) {
1099+ if ( ! ( arg instanceof api_pb . SdkJobResponse ) ) {
1100+ throw new Error ( 'Expected argument of type openstorage.api.SdkJobResponse' ) ;
1101+ }
1102+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1103+ }
1104+
1105+ function deserialize_openstorage_api_SdkJobResponse ( buffer_arg ) {
1106+ return api_pb . SdkJobResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1107+ }
1108+
1109+ function serialize_openstorage_api_SdkNodeCordonAttachmentsRequest ( arg ) {
1110+ if ( ! ( arg instanceof api_pb . SdkNodeCordonAttachmentsRequest ) ) {
1111+ throw new Error ( 'Expected argument of type openstorage.api.SdkNodeCordonAttachmentsRequest' ) ;
1112+ }
1113+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1114+ }
1115+
1116+ function deserialize_openstorage_api_SdkNodeCordonAttachmentsRequest ( buffer_arg ) {
1117+ return api_pb . SdkNodeCordonAttachmentsRequest . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1118+ }
1119+
1120+ function serialize_openstorage_api_SdkNodeCordonAttachmentsResponse ( arg ) {
1121+ if ( ! ( arg instanceof api_pb . SdkNodeCordonAttachmentsResponse ) ) {
1122+ throw new Error ( 'Expected argument of type openstorage.api.SdkNodeCordonAttachmentsResponse' ) ;
1123+ }
1124+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1125+ }
1126+
1127+ function deserialize_openstorage_api_SdkNodeCordonAttachmentsResponse ( buffer_arg ) {
1128+ return api_pb . SdkNodeCordonAttachmentsResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1129+ }
1130+
1131+ function serialize_openstorage_api_SdkNodeDrainAttachmentsRequest ( arg ) {
1132+ if ( ! ( arg instanceof api_pb . SdkNodeDrainAttachmentsRequest ) ) {
1133+ throw new Error ( 'Expected argument of type openstorage.api.SdkNodeDrainAttachmentsRequest' ) ;
1134+ }
1135+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1136+ }
1137+
1138+ function deserialize_openstorage_api_SdkNodeDrainAttachmentsRequest ( buffer_arg ) {
1139+ return api_pb . SdkNodeDrainAttachmentsRequest . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1140+ }
1141+
10321142function serialize_openstorage_api_SdkNodeEnumerateRequest ( arg ) {
10331143 if ( ! ( arg instanceof api_pb . SdkNodeEnumerateRequest ) ) {
10341144 throw new Error ( 'Expected argument of type openstorage.api.SdkNodeEnumerateRequest' ) ;
@@ -1117,6 +1227,28 @@ function deserialize_openstorage_api_SdkNodeInspectResponse(buffer_arg) {
11171227 return api_pb . SdkNodeInspectResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
11181228}
11191229
1230+ function serialize_openstorage_api_SdkNodeUncordonAttachmentsRequest ( arg ) {
1231+ if ( ! ( arg instanceof api_pb . SdkNodeUncordonAttachmentsRequest ) ) {
1232+ throw new Error ( 'Expected argument of type openstorage.api.SdkNodeUncordonAttachmentsRequest' ) ;
1233+ }
1234+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1235+ }
1236+
1237+ function deserialize_openstorage_api_SdkNodeUncordonAttachmentsRequest ( buffer_arg ) {
1238+ return api_pb . SdkNodeUncordonAttachmentsRequest . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1239+ }
1240+
1241+ function serialize_openstorage_api_SdkNodeUncordonAttachmentsResponse ( arg ) {
1242+ if ( ! ( arg instanceof api_pb . SdkNodeUncordonAttachmentsResponse ) ) {
1243+ throw new Error ( 'Expected argument of type openstorage.api.SdkNodeUncordonAttachmentsResponse' ) ;
1244+ }
1245+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1246+ }
1247+
1248+ function deserialize_openstorage_api_SdkNodeUncordonAttachmentsResponse ( buffer_arg ) {
1249+ return api_pb . SdkNodeUncordonAttachmentsResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1250+ }
1251+
11201252function serialize_openstorage_api_SdkNodeVolumeUsageByNodeRequest ( arg ) {
11211253 if ( ! ( arg instanceof api_pb . SdkNodeVolumeUsageByNodeRequest ) ) {
11221254 throw new Error ( 'Expected argument of type openstorage.api.SdkNodeVolumeUsageByNodeRequest' ) ;
@@ -1667,6 +1799,28 @@ function deserialize_openstorage_api_SdkStorageRebalanceResponse(buffer_arg) {
16671799 return api_pb . SdkStorageRebalanceResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
16681800}
16691801
1802+ function serialize_openstorage_api_SdkUpdateJobRequest ( arg ) {
1803+ if ( ! ( arg instanceof api_pb . SdkUpdateJobRequest ) ) {
1804+ throw new Error ( 'Expected argument of type openstorage.api.SdkUpdateJobRequest' ) ;
1805+ }
1806+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1807+ }
1808+
1809+ function deserialize_openstorage_api_SdkUpdateJobRequest ( buffer_arg ) {
1810+ return api_pb . SdkUpdateJobRequest . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1811+ }
1812+
1813+ function serialize_openstorage_api_SdkUpdateJobResponse ( arg ) {
1814+ if ( ! ( arg instanceof api_pb . SdkUpdateJobResponse ) ) {
1815+ throw new Error ( 'Expected argument of type openstorage.api.SdkUpdateJobResponse' ) ;
1816+ }
1817+ return Buffer . from ( arg . serializeBinary ( ) ) ;
1818+ }
1819+
1820+ function deserialize_openstorage_api_SdkUpdateJobResponse ( buffer_arg ) {
1821+ return api_pb . SdkUpdateJobResponse . deserializeBinary ( new Uint8Array ( buffer_arg ) ) ;
1822+ }
1823+
16701824function serialize_openstorage_api_SdkUpdateRebalanceJobRequest ( arg ) {
16711825 if ( ! ( arg instanceof api_pb . SdkUpdateRebalanceJobRequest ) ) {
16721826 throw new Error ( 'Expected argument of type openstorage.api.SdkUpdateRebalanceJobRequest' ) ;
@@ -2697,6 +2851,52 @@ enumerateRebalanceJobs: {
26972851} ;
26982852
26992853exports . OpenStoragePoolClient = grpc . makeGenericClientConstructor ( OpenStoragePoolService ) ;
2854+ // OpenstorageJob is a service that provides a common set of APIs for services
2855+ // that use the asynchronous job framework
2856+ var OpenStorageJobService = exports . OpenStorageJobService = {
2857+ // UpdateJobState updates an existing job
2858+ // Only acceptable values are
2859+ // JobState_PAUSED - acceptable only from running state
2860+ // JobState_CANCELLED - acceptable only from running/pause state
2861+ // JobState_RUNNING - acceptable only from pause state
2862+ updateJobState : {
2863+ path : '/openstorage.api.OpenStorageJob/UpdateJobState' ,
2864+ requestStream : false ,
2865+ responseStream : false ,
2866+ requestType : api_pb . SdkUpdateJobRequest ,
2867+ responseType : api_pb . SdkUpdateJobResponse ,
2868+ requestSerialize : serialize_openstorage_api_SdkUpdateJobRequest ,
2869+ requestDeserialize : deserialize_openstorage_api_SdkUpdateJobRequest ,
2870+ responseSerialize : serialize_openstorage_api_SdkUpdateJobResponse ,
2871+ responseDeserialize : deserialize_openstorage_api_SdkUpdateJobResponse ,
2872+ } ,
2873+ // GetJobStatus gets the status of a job
2874+ getJobStatus : {
2875+ path : '/openstorage.api.OpenStorageJob/GetJobStatus' ,
2876+ requestStream : false ,
2877+ responseStream : false ,
2878+ requestType : api_pb . SdkGetJobStatusRequest ,
2879+ responseType : api_pb . SdkGetJobStatusResponse ,
2880+ requestSerialize : serialize_openstorage_api_SdkGetJobStatusRequest ,
2881+ requestDeserialize : deserialize_openstorage_api_SdkGetJobStatusRequest ,
2882+ responseSerialize : serialize_openstorage_api_SdkGetJobStatusResponse ,
2883+ responseDeserialize : deserialize_openstorage_api_SdkGetJobStatusResponse ,
2884+ } ,
2885+ // EnumerateJobs returns all the jobs currently known to the system
2886+ enumerateJobs : {
2887+ path : '/openstorage.api.OpenStorageJob/EnumerateJobs' ,
2888+ requestStream : false ,
2889+ responseStream : false ,
2890+ requestType : api_pb . SdkEnumerateJobsRequest ,
2891+ responseType : api_pb . SdkEnumerateJobsResponse ,
2892+ requestSerialize : serialize_openstorage_api_SdkEnumerateJobsRequest ,
2893+ requestDeserialize : deserialize_openstorage_api_SdkEnumerateJobsRequest ,
2894+ responseSerialize : serialize_openstorage_api_SdkEnumerateJobsResponse ,
2895+ responseDeserialize : deserialize_openstorage_api_SdkEnumerateJobsResponse ,
2896+ } ,
2897+ } ;
2898+
2899+ exports . OpenStorageJobClient = grpc . makeGenericClientConstructor ( OpenStorageJobService ) ;
27002900// OpenStorageNode is a service used to manage nodes in the cluster
27012901var OpenStorageNodeService = exports . OpenStorageNodeService = {
27022902 // Inspect returns information about the specified node
@@ -2760,6 +2960,46 @@ volumeUsageByNode: {
27602960 responseSerialize : serialize_openstorage_api_SdkNodeVolumeUsageByNodeResponse ,
27612961 responseDeserialize : deserialize_openstorage_api_SdkNodeVolumeUsageByNodeResponse ,
27622962 } ,
2963+ // DrainAttachments creates a task to drain volume attachments
2964+ // from the provided node in the cluster.
2965+ drainAttachments : {
2966+ path : '/openstorage.api.OpenStorageNode/DrainAttachments' ,
2967+ requestStream : false ,
2968+ responseStream : false ,
2969+ requestType : api_pb . SdkNodeDrainAttachmentsRequest ,
2970+ responseType : api_pb . SdkJobResponse ,
2971+ requestSerialize : serialize_openstorage_api_SdkNodeDrainAttachmentsRequest ,
2972+ requestDeserialize : deserialize_openstorage_api_SdkNodeDrainAttachmentsRequest ,
2973+ responseSerialize : serialize_openstorage_api_SdkJobResponse ,
2974+ responseDeserialize : deserialize_openstorage_api_SdkJobResponse ,
2975+ } ,
2976+ // CordonAttachments disables any new volume attachments
2977+ // from the provided node in the cluster. Existing volume attachments
2978+ // will stay on the node.
2979+ cordonAttachments : {
2980+ path : '/openstorage.api.OpenStorageNode/CordonAttachments' ,
2981+ requestStream : false ,
2982+ responseStream : false ,
2983+ requestType : api_pb . SdkNodeCordonAttachmentsRequest ,
2984+ responseType : api_pb . SdkNodeCordonAttachmentsResponse ,
2985+ requestSerialize : serialize_openstorage_api_SdkNodeCordonAttachmentsRequest ,
2986+ requestDeserialize : deserialize_openstorage_api_SdkNodeCordonAttachmentsRequest ,
2987+ responseSerialize : serialize_openstorage_api_SdkNodeCordonAttachmentsResponse ,
2988+ responseDeserialize : deserialize_openstorage_api_SdkNodeCordonAttachmentsResponse ,
2989+ } ,
2990+ // UncordonAttachments re-enables volume attachments
2991+ // on the provided node in the cluster.
2992+ uncordonAttachments : {
2993+ path : '/openstorage.api.OpenStorageNode/UncordonAttachments' ,
2994+ requestStream : false ,
2995+ responseStream : false ,
2996+ requestType : api_pb . SdkNodeUncordonAttachmentsRequest ,
2997+ responseType : api_pb . SdkNodeUncordonAttachmentsResponse ,
2998+ requestSerialize : serialize_openstorage_api_SdkNodeUncordonAttachmentsRequest ,
2999+ requestDeserialize : deserialize_openstorage_api_SdkNodeUncordonAttachmentsRequest ,
3000+ responseSerialize : serialize_openstorage_api_SdkNodeUncordonAttachmentsResponse ,
3001+ responseDeserialize : deserialize_openstorage_api_SdkNodeUncordonAttachmentsResponse ,
3002+ } ,
27633003} ;
27643004
27653005exports . OpenStorageNodeClient = grpc . makeGenericClientConstructor ( OpenStorageNodeService ) ;
@@ -3267,6 +3507,18 @@ validate: {
32673507 responseSerialize : serialize_openstorage_api_SdkCredentialValidateResponse ,
32683508 responseDeserialize : deserialize_openstorage_api_SdkCredentialValidateResponse ,
32693509 } ,
3510+ // DeleteReferences is used to remove references to credentials
3511+ deleteReferences : {
3512+ path : '/openstorage.api.OpenStorageCredentials/DeleteReferences' ,
3513+ requestStream : false ,
3514+ responseStream : false ,
3515+ requestType : api_pb . SdkCredentialDeleteReferencesRequest ,
3516+ responseType : api_pb . SdkCredentialDeleteReferencesResponse ,
3517+ requestSerialize : serialize_openstorage_api_SdkCredentialDeleteReferencesRequest ,
3518+ requestDeserialize : deserialize_openstorage_api_SdkCredentialDeleteReferencesRequest ,
3519+ responseSerialize : serialize_openstorage_api_SdkCredentialDeleteReferencesResponse ,
3520+ responseDeserialize : deserialize_openstorage_api_SdkCredentialDeleteReferencesResponse ,
3521+ } ,
32703522} ;
32713523
32723524exports . OpenStorageCredentialsClient = grpc . makeGenericClientConstructor ( OpenStorageCredentialsService ) ;
0 commit comments