Generated 5.1.x BP SDK from commit 1664144 (#95)

Author: RachelTucker

ds3/ds3Gets.go

@@ -4118,6 +4118,7 @@ func (client *Client) GetS3TargetsSpectraS3(request *models.GetS3TargetsSpectraS
         WithOptionalQueryParam("https", networking.BoolPtrToStrPtr(request.Https)).
         WithOptionalVoidQueryParam("last_page", request.LastPage).
         WithOptionalQueryParam("name", request.Name).
+        WithOptionalQueryParam("naming_mode", networking.InterfaceToStrPtr(request.NamingMode)).
         WithOptionalQueryParam("page_length", networking.IntPtrToStrPtr(request.PageLength)).
         WithOptionalQueryParam("page_offset", networking.IntPtrToStrPtr(request.PageOffset)).
         WithOptionalQueryParam("page_start_marker", request.PageStartMarker).

ds3/ds3Posts.go

@@ -18,6 +18,31 @@ import (
     "github.com/SpectraLogic/ds3_go_sdk/ds3/networking"
 )
 
+func (client *Client) CompleteBlob(request *models.CompleteBlobRequest) (*models.CompleteBlobResponse, error) {
+    // Build the http request
+    httpRequest, err := networking.NewHttpRequestBuilder().
+        WithHttpVerb(HTTP_VERB_POST).
+        WithPath("/" + request.BucketName + "/" + request.ObjectName).
+        WithQueryParam("blob", request.Blob).
+        WithQueryParam("job", request.Job).
+        Build(client.connectionInfo)
+
+    if err != nil {
+        return nil, err
+    }
+
+    networkRetryDecorator := networking.NewNetworkRetryDecorator(client.sendNetwork, client.clientPolicy.maxRetries)
+
+    // Invoke the HTTP request.
+    response, requestErr := networkRetryDecorator.Invoke(httpRequest)
+    if requestErr != nil {
+        return nil, requestErr
+    }
+
+    // Create a response object based on the result.
+    return models.NewCompleteBlobResponse(response)
+}
+
 func (client *Client) CompleteMultiPartUpload(request *models.CompleteMultiPartUploadRequest) (*models.CompleteMultiPartUploadResponse, error) {
     // Build the http request
     httpRequest, err := networking.NewHttpRequestBuilder().
@@ -1276,6 +1301,7 @@ func (client *Client) RegisterS3TargetSpectraS3(request *models.RegisterS3Target
         WithOptionalQueryParam("data_path_end_point", request.DataPathEndPoint).
         WithOptionalQueryParam("default_read_preference", networking.InterfaceToStrPtr(request.DefaultReadPreference)).
         WithOptionalQueryParam("https", networking.BoolPtrToStrPtr(request.Https)).
+        WithOptionalQueryParam("naming_mode", networking.InterfaceToStrPtr(request.NamingMode)).
         WithOptionalQueryParam("offline_data_staging_window_in_tb", networking.IntPtrToStrPtr(request.OfflineDataStagingWindowInTb)).
         WithOptionalQueryParam("permit_going_out_of_sync", networking.BoolPtrToStrPtr(request.PermitGoingOutOfSync)).
         WithOptionalQueryParam("proxy_domain", request.ProxyDomain).
@@ -1309,6 +1335,7 @@ func (client *Client) DelegateCreateUserSpectraS3(request *models.DelegateCreate
         WithHttpVerb(HTTP_VERB_POST).
         WithPath("/_rest_/user").
         WithQueryParam("name", request.Name).
+        WithOptionalQueryParam("default_data_policy_id", request.DefaultDataPolicyId).
         WithOptionalQueryParam("id", request.Id).
         WithOptionalQueryParam("max_buckets", networking.IntPtrToStrPtr(request.MaxBuckets)).
         WithOptionalQueryParam("secret_key", request.SecretKey).

ds3/ds3Puts.go

@@ -613,6 +613,7 @@ func (client *Client) PutBulkJobSpectraS3(request *models.PutBulkJobSpectraS3Req
         WithOptionalQueryParam("max_upload_size", networking.Int64PtrToStrPtr(request.MaxUploadSize)).
         WithOptionalQueryParam("minimize_spanning_across_media", networking.BoolPtrToStrPtr(request.MinimizeSpanningAcrossMedia)).
         WithOptionalQueryParam("name", request.Name).
+        WithOptionalVoidQueryParam("pre_allocate_job_space", request.PreAllocateJobSpace).
         WithOptionalQueryParam("priority", networking.InterfaceToStrPtr(request.Priority)).
         WithOptionalQueryParam("verify_after_write", networking.BoolPtrToStrPtr(request.VerifyAfterWrite)).
         WithQueryParam("operation", "start_bulk_put").
@@ -2584,6 +2585,7 @@ func (client *Client) ModifyS3TargetSpectraS3(request *models.ModifyS3TargetSpec
         WithOptionalQueryParam("default_read_preference", networking.InterfaceToStrPtr(request.DefaultReadPreference)).
         WithOptionalQueryParam("https", networking.BoolPtrToStrPtr(request.Https)).
         WithOptionalQueryParam("name", request.Name).
+        WithOptionalQueryParam("naming_mode", networking.InterfaceToStrPtr(request.NamingMode)).
         WithOptionalQueryParam("offline_data_staging_window_in_tb", networking.IntPtrToStrPtr(request.OfflineDataStagingWindowInTb)).
         WithOptionalQueryParam("permit_going_out_of_sync", networking.BoolPtrToStrPtr(request.PermitGoingOutOfSync)).
         WithOptionalQueryParam("proxy_domain", request.ProxyDomain).

ds3/models/requests.go

@@ -32,6 +32,22 @@ func NewAbortMultiPartUploadRequest(bucketName string, objectName string, upload
     }
 }
 
+type CompleteBlobRequest struct {
+    BucketName string
+    ObjectName string
+    Blob string
+    Job string
+}
+
+func NewCompleteBlobRequest(bucketName string, objectName string, blob string, job string) *CompleteBlobRequest {
+    return &CompleteBlobRequest{
+        BucketName: bucketName,
+        ObjectName: objectName,
+        Blob: blob,
+        Job: job,
+    }
+}
+
 type CompleteMultiPartUploadRequest struct {
     BucketName string
     ObjectName string
@@ -3054,6 +3070,7 @@ type PutBulkJobSpectraS3Request struct {
     MinimizeSpanningAcrossMedia *bool
     Name *string
     Objects []Ds3PutObject
+    PreAllocateJobSpace bool
     Priority Priority
     VerifyAfterWrite *bool
 }
@@ -3100,6 +3117,11 @@ func (putBulkJobSpectraS3Request *PutBulkJobSpectraS3Request) WithName(name stri
     return putBulkJobSpectraS3Request
 }
 
+func (putBulkJobSpectraS3Request *PutBulkJobSpectraS3Request) WithPreAllocateJobSpace() *PutBulkJobSpectraS3Request {
+    putBulkJobSpectraS3Request.PreAllocateJobSpace = true
+    return putBulkJobSpectraS3Request
+}
+
 func (putBulkJobSpectraS3Request *PutBulkJobSpectraS3Request) WithPriority(priority Priority) *PutBulkJobSpectraS3Request {
     putBulkJobSpectraS3Request.Priority = priority
     return putBulkJobSpectraS3Request
@@ -9013,6 +9035,7 @@ type GetS3TargetsSpectraS3Request struct {
     Https *bool
     LastPage bool
     Name *string
+    NamingMode CloudNamingMode
     PageLength *int
     PageOffset *int
     PageStartMarker *string
@@ -9057,6 +9080,11 @@ func (getS3TargetsSpectraS3Request *GetS3TargetsSpectraS3Request) WithName(name
     return getS3TargetsSpectraS3Request
 }
 
+func (getS3TargetsSpectraS3Request *GetS3TargetsSpectraS3Request) WithNamingMode(namingMode CloudNamingMode) *GetS3TargetsSpectraS3Request {
+    getS3TargetsSpectraS3Request.NamingMode = namingMode
+    return getS3TargetsSpectraS3Request
+}
+
 func (getS3TargetsSpectraS3Request *GetS3TargetsSpectraS3Request) WithPageLength(pageLength int) *GetS3TargetsSpectraS3Request {
     getS3TargetsSpectraS3Request.PageLength = &pageLength
     return getS3TargetsSpectraS3Request
@@ -9141,6 +9169,7 @@ type ModifyS3TargetSpectraS3Request struct {
     DefaultReadPreference TargetReadPreferenceType
     Https *bool
     Name *string
+    NamingMode CloudNamingMode
     OfflineDataStagingWindowInTb *int
     PermitGoingOutOfSync *bool
     ProxyDomain *string
@@ -9201,6 +9230,11 @@ func (modifyS3TargetSpectraS3Request *ModifyS3TargetSpectraS3Request) WithName(n
     return modifyS3TargetSpectraS3Request
 }
 
+func (modifyS3TargetSpectraS3Request *ModifyS3TargetSpectraS3Request) WithNamingMode(namingMode CloudNamingMode) *ModifyS3TargetSpectraS3Request {
+    modifyS3TargetSpectraS3Request.NamingMode = namingMode
+    return modifyS3TargetSpectraS3Request
+}
+
 func (modifyS3TargetSpectraS3Request *ModifyS3TargetSpectraS3Request) WithOfflineDataStagingWindowInTb(offlineDataStagingWindowInTb int) *ModifyS3TargetSpectraS3Request {
     modifyS3TargetSpectraS3Request.OfflineDataStagingWindowInTb = &offlineDataStagingWindowInTb
     return modifyS3TargetSpectraS3Request
@@ -9265,6 +9299,7 @@ type RegisterS3TargetSpectraS3Request struct {
     DefaultReadPreference TargetReadPreferenceType
     Https *bool
     Name string
+    NamingMode CloudNamingMode
     OfflineDataStagingWindowInTb *int
     PermitGoingOutOfSync *bool
     ProxyDomain *string
@@ -9315,6 +9350,11 @@ func (registerS3TargetSpectraS3Request *RegisterS3TargetSpectraS3Request) WithHt
     return registerS3TargetSpectraS3Request
 }
 
+func (registerS3TargetSpectraS3Request *RegisterS3TargetSpectraS3Request) WithNamingMode(namingMode CloudNamingMode) *RegisterS3TargetSpectraS3Request {
+    registerS3TargetSpectraS3Request.NamingMode = namingMode
+    return registerS3TargetSpectraS3Request
+}
+
 func (registerS3TargetSpectraS3Request *RegisterS3TargetSpectraS3Request) WithOfflineDataStagingWindowInTb(offlineDataStagingWindowInTb int) *RegisterS3TargetSpectraS3Request {
     registerS3TargetSpectraS3Request.OfflineDataStagingWindowInTb = &offlineDataStagingWindowInTb
     return registerS3TargetSpectraS3Request
@@ -9377,6 +9417,7 @@ func (verifyS3TargetSpectraS3Request *VerifyS3TargetSpectraS3Request) WithFullDe
 }
 
 type DelegateCreateUserSpectraS3Request struct {
+    DefaultDataPolicyId *string
     Id *string
     MaxBuckets *int
     Name string
@@ -9389,6 +9430,11 @@ func NewDelegateCreateUserSpectraS3Request(name string) *DelegateCreateUserSpect
     }
 }
 
+func (delegateCreateUserSpectraS3Request *DelegateCreateUserSpectraS3Request) WithDefaultDataPolicyId(defaultDataPolicyId string) *DelegateCreateUserSpectraS3Request {
+    delegateCreateUserSpectraS3Request.DefaultDataPolicyId = &defaultDataPolicyId
+    return delegateCreateUserSpectraS3Request
+}
+
 func (delegateCreateUserSpectraS3Request *DelegateCreateUserSpectraS3Request) WithId(id string) *DelegateCreateUserSpectraS3Request {
     delegateCreateUserSpectraS3Request.Id = &id
     return delegateCreateUserSpectraS3Request

ds3/models/responseModels.go

@@ -436,6 +436,53 @@ func (capacitySummaryContainer *CapacitySummaryContainer) parse(xmlNode *XmlNode
     }
 }
 
+type CloudNamingMode Enum
+
+const (
+    CLOUD_NAMING_MODE_BLACK_PEARL CloudNamingMode = 1 + iota
+    CLOUD_NAMING_MODE_AWS_S3 CloudNamingMode = 1 + iota
+)
+
+func (cloudNamingMode *CloudNamingMode) UnmarshalText(text []byte) error {
+    var str string = string(bytes.ToUpper(text))
+    switch str {
+        case "": *cloudNamingMode = UNDEFINED
+        case "BLACK_PEARL": *cloudNamingMode = CLOUD_NAMING_MODE_BLACK_PEARL
+        case "AWS_S3": *cloudNamingMode = CLOUD_NAMING_MODE_AWS_S3
+        default:
+            *cloudNamingMode = UNDEFINED
+            return errors.New(fmt.Sprintf("Cannot marshal '%s' into CloudNamingMode", str))
+    }
+    return nil
+}
+
+func (cloudNamingMode CloudNamingMode) String() string {
+    switch cloudNamingMode {
+        case CLOUD_NAMING_MODE_BLACK_PEARL: return "BLACK_PEARL"
+        case CLOUD_NAMING_MODE_AWS_S3: return "AWS_S3"
+        default:
+            log.Printf("Error: invalid CloudNamingMode represented by '%d'", cloudNamingMode)
+            return ""
+    }
+}
+
+func (cloudNamingMode CloudNamingMode) StringPtr() *string {
+    if cloudNamingMode == UNDEFINED {
+        return nil
+    }
+    result := cloudNamingMode.String()
+    return &result
+}
+
+func newCloudNamingModeFromContent(content []byte, aggErr *AggregateError) *CloudNamingMode {
+    if len(content) == 0 {
+        // no value
+        return nil
+    }
+    result := new(CloudNamingMode)
+    parseEnum(content, result, aggErr)
+    return result
+}
 type CompletedJob struct {
     BucketId string
     CachedSizeInBytes int64
@@ -1659,9 +1706,11 @@ type S3Region Enum
 const (
     S3_REGION_GOV_CLOUD S3Region = 1 + iota
     S3_REGION_US_EAST_1 S3Region = 1 + iota
+    S3_REGION_US_EAST_2 S3Region = 1 + iota
     S3_REGION_US_WEST_1 S3Region = 1 + iota
     S3_REGION_US_WEST_2 S3Region = 1 + iota
     S3_REGION_EU_WEST_1 S3Region = 1 + iota
+    S3_REGION_EU_WEST_2 S3Region = 1 + iota
     S3_REGION_EU_CENTRAL_1 S3Region = 1 + iota
     S3_REGION_AP_SOUTH_1 S3Region = 1 + iota
     S3_REGION_AP_SOUTHEAST_1 S3Region = 1 + iota
@@ -1670,6 +1719,7 @@ const (
     S3_REGION_AP_NORTHEAST_2 S3Region = 1 + iota
     S3_REGION_SA_EAST_1 S3Region = 1 + iota
     S3_REGION_CN_NORTH_1 S3Region = 1 + iota
+    S3_REGION_CA_CENTRAL_1 S3Region = 1 + iota
 )
 
 func (s3Region *S3Region) UnmarshalText(text []byte) error {
@@ -1678,9 +1728,11 @@ func (s3Region *S3Region) UnmarshalText(text []byte) error {
         case "": *s3Region = UNDEFINED
         case "GOV_CLOUD": *s3Region = S3_REGION_GOV_CLOUD
         case "US_EAST_1": *s3Region = S3_REGION_US_EAST_1
+        case "US_EAST_2": *s3Region = S3_REGION_US_EAST_2
         case "US_WEST_1": *s3Region = S3_REGION_US_WEST_1
         case "US_WEST_2": *s3Region = S3_REGION_US_WEST_2
         case "EU_WEST_1": *s3Region = S3_REGION_EU_WEST_1
+        case "EU_WEST_2": *s3Region = S3_REGION_EU_WEST_2
         case "EU_CENTRAL_1": *s3Region = S3_REGION_EU_CENTRAL_1
         case "AP_SOUTH_1": *s3Region = S3_REGION_AP_SOUTH_1
         case "AP_SOUTHEAST_1": *s3Region = S3_REGION_AP_SOUTHEAST_1
@@ -1689,6 +1741,7 @@ func (s3Region *S3Region) UnmarshalText(text []byte) error {
         case "AP_NORTHEAST_2": *s3Region = S3_REGION_AP_NORTHEAST_2
         case "SA_EAST_1": *s3Region = S3_REGION_SA_EAST_1
         case "CN_NORTH_1": *s3Region = S3_REGION_CN_NORTH_1
+        case "CA_CENTRAL_1": *s3Region = S3_REGION_CA_CENTRAL_1
         default:
             *s3Region = UNDEFINED
             return errors.New(fmt.Sprintf("Cannot marshal '%s' into S3Region", str))
@@ -1700,9 +1753,11 @@ func (s3Region S3Region) String() string {
     switch s3Region {
         case S3_REGION_GOV_CLOUD: return "GOV_CLOUD"
         case S3_REGION_US_EAST_1: return "US_EAST_1"
+        case S3_REGION_US_EAST_2: return "US_EAST_2"
         case S3_REGION_US_WEST_1: return "US_WEST_1"
         case S3_REGION_US_WEST_2: return "US_WEST_2"
         case S3_REGION_EU_WEST_1: return "EU_WEST_1"
+        case S3_REGION_EU_WEST_2: return "EU_WEST_2"
         case S3_REGION_EU_CENTRAL_1: return "EU_CENTRAL_1"
         case S3_REGION_AP_SOUTH_1: return "AP_SOUTH_1"
         case S3_REGION_AP_SOUTHEAST_1: return "AP_SOUTHEAST_1"
@@ -1711,6 +1766,7 @@ func (s3Region S3Region) String() string {
         case S3_REGION_AP_NORTHEAST_2: return "AP_NORTHEAST_2"
         case S3_REGION_SA_EAST_1: return "SA_EAST_1"
         case S3_REGION_CN_NORTH_1: return "CN_NORTH_1"
+        case S3_REGION_CA_CENTRAL_1: return "CA_CENTRAL_1"
         default:
             log.Printf("Error: invalid S3Region represented by '%d'", s3Region)
             return ""
@@ -3828,6 +3884,7 @@ const (
     TAPE_DRIVE_TYPE_TS1140 TapeDriveType = 1 + iota
     TAPE_DRIVE_TYPE_TS1150 TapeDriveType = 1 + iota
     TAPE_DRIVE_TYPE_TS1155 TapeDriveType = 1 + iota
+    TAPE_DRIVE_TYPE_TS1160 TapeDriveType = 1 + iota
 )
 
 func (tapeDriveType *TapeDriveType) UnmarshalText(text []byte) error {
@@ -3842,6 +3899,7 @@ func (tapeDriveType *TapeDriveType) UnmarshalText(text []byte) error {
         case "TS1140": *tapeDriveType = TAPE_DRIVE_TYPE_TS1140
         case "TS1150": *tapeDriveType = TAPE_DRIVE_TYPE_TS1150
         case "TS1155": *tapeDriveType = TAPE_DRIVE_TYPE_TS1155
+        case "TS1160": *tapeDriveType = TAPE_DRIVE_TYPE_TS1160
         default:
             *tapeDriveType = UNDEFINED
             return errors.New(fmt.Sprintf("Cannot marshal '%s' into TapeDriveType", str))
@@ -3859,6 +3917,7 @@ func (tapeDriveType TapeDriveType) String() string {
         case TAPE_DRIVE_TYPE_TS1140: return "TS1140"
         case TAPE_DRIVE_TYPE_TS1150: return "TS1150"
         case TAPE_DRIVE_TYPE_TS1155: return "TS1155"
+        case TAPE_DRIVE_TYPE_TS1160: return "TS1160"
         default:
             log.Printf("Error: invalid TapeDriveType represented by '%d'", tapeDriveType)
             return ""
@@ -4395,6 +4454,7 @@ type AzureTarget struct {
     Id string
     LastFullyVerified *string
     Name *string
+    NamingMode CloudNamingMode
     PermitGoingOutOfSync bool
     Quiesced Quiesced
     State TargetState
@@ -4425,6 +4485,8 @@ func (azureTarget *AzureTarget) parse(xmlNode *XmlNode, aggErr *AggregateError)
             azureTarget.LastFullyVerified = parseNullableString(child.Content)
         case "Name":
             azureTarget.Name = parseNullableString(child.Content)
+        case "NamingMode":
+            parseEnum(child.Content, &azureTarget.NamingMode, aggErr)
         case "PermitGoingOutOfSync":
             azureTarget.PermitGoingOutOfSync = parseBool(child.Content, aggErr)
         case "Quiesced":
@@ -4720,6 +4782,7 @@ type S3Target struct {
     Id string
     LastFullyVerified *string
     Name *string
+    NamingMode CloudNamingMode
     OfflineDataStagingWindowInTb int
     PermitGoingOutOfSync bool
     ProxyDomain *string
@@ -4759,6 +4822,8 @@ func (s3Target *S3Target) parse(xmlNode *XmlNode, aggErr *AggregateError) {
             s3Target.LastFullyVerified = parseNullableString(child.Content)
         case "Name":
             s3Target.Name = parseNullableString(child.Content)
+        case "NamingMode":
+            parseEnum(child.Content, &s3Target.NamingMode, aggErr)
         case "OfflineDataStagingWindowInTb":
             s3Target.OfflineDataStagingWindowInTb = parseInt(child.Content, aggErr)
         case "PermitGoingOutOfSync":

ds3/models/responses.go

@@ -37,6 +37,25 @@ func NewAbortMultiPartUploadResponse(webResponse WebResponse) (*AbortMultiPartUp
     }
 }
 
+type CompleteBlobResponse struct {
+    
+    Headers *http.Header
+}
+
+
+
+func NewCompleteBlobResponse(webResponse WebResponse) (*CompleteBlobResponse, error) {
+    defer webResponse.Body().Close()
+    expectedStatusCodes := []int { 200 }
+
+    switch code := webResponse.StatusCode(); code {
+    case 200:
+        return &CompleteBlobResponse{Headers: webResponse.Header()}, nil
+    default:
+        return nil, buildBadStatusCodeError(webResponse, expectedStatusCodes)
+    }
+}
+
 type CompleteMultiPartUploadResponse struct {
     CompleteMultipartUploadResult CompleteMultipartUploadResult
     Headers *http.Header