From 1095a990f1cc5923d3a52b38993279ee3a6be311 Mon Sep 17 00:00:00 2001 From: Azure SDK for Python bot Date: Wed, 14 Nov 2018 18:42:43 +0000 Subject: [PATCH] Generated from e2352b510b4d4bcc89aed634b99985388b785ba3 Add maximum chunk size to data lake store docs. --- .../2017-03-09/network/mgmt/network/models.go | 7 --- .../latest/network/mgmt/network/models.go | 7 --- .../preview/network/mgmt/network/models.go | 7 --- .../preview/network/mgmt/network/models.go | 7 --- .../store/2016-11-01/filesystem/filesystem.go | 9 ++-- .../filesystem/filesystemapi/interfaces.go | 54 +++++++++++++++++++ .../filesystem/filesystem.go | 9 ++-- .../filesystem/filesystemapi/interfaces.go | 54 +++++++++++++++++++ 8 files changed, 120 insertions(+), 34 deletions(-) create mode 100644 services/datalake/store/2016-11-01/filesystem/filesystemapi/interfaces.go create mode 100644 services/preview/datalake/store/2015-10-01-preview/filesystem/filesystemapi/interfaces.go diff --git a/profiles/2017-03-09/network/mgmt/network/models.go b/profiles/2017-03-09/network/mgmt/network/models.go index 896f18980ee8..e0088ddbb392 100644 --- a/profiles/2017-03-09/network/mgmt/network/models.go +++ b/profiles/2017-03-09/network/mgmt/network/models.go @@ -32,7 +32,6 @@ type ExpressRouteCircuitAuthorizationsClient = original.ExpressRouteCircuitAutho type ExpressRouteCircuitPeeringsClient = original.ExpressRouteCircuitPeeringsClient type ExpressRouteCircuitsClient = original.ExpressRouteCircuitsClient type ExpressRouteServiceProvidersClient = original.ExpressRouteServiceProvidersClient -type InterfacesClient = original.InterfacesClient type LoadBalancersClient = original.LoadBalancersClient type LocalNetworkGatewaysClient = original.LocalNetworkGatewaysClient type ApplicationGatewayCookieBasedAffinity = original.ApplicationGatewayCookieBasedAffinity @@ -513,12 +512,6 @@ func NewExpressRouteServiceProvidersClient(subscriptionID string) ExpressRouteSe func NewExpressRouteServiceProvidersClientWithBaseURI(baseURI string, subscriptionID string) ExpressRouteServiceProvidersClient { return original.NewExpressRouteServiceProvidersClientWithBaseURI(baseURI, subscriptionID) } -func NewInterfacesClient(subscriptionID string) InterfacesClient { - return original.NewInterfacesClient(subscriptionID) -} -func NewInterfacesClientWithBaseURI(baseURI string, subscriptionID string) InterfacesClient { - return original.NewInterfacesClientWithBaseURI(baseURI, subscriptionID) -} func NewLoadBalancersClient(subscriptionID string) LoadBalancersClient { return original.NewLoadBalancersClient(subscriptionID) } diff --git a/profiles/latest/network/mgmt/network/models.go b/profiles/latest/network/mgmt/network/models.go index 482345fc8e18..6762f83b585e 100644 --- a/profiles/latest/network/mgmt/network/models.go +++ b/profiles/latest/network/mgmt/network/models.go @@ -40,7 +40,6 @@ type ExpressRouteServiceProvidersClient = original.ExpressRouteServiceProvidersC type InboundNatRulesClient = original.InboundNatRulesClient type InterfaceIPConfigurationsClient = original.InterfaceIPConfigurationsClient type InterfaceLoadBalancersClient = original.InterfaceLoadBalancersClient -type InterfacesClient = original.InterfacesClient type LoadBalancerBackendAddressPoolsClient = original.LoadBalancerBackendAddressPoolsClient type LoadBalancerFrontendIPConfigurationsClient = original.LoadBalancerFrontendIPConfigurationsClient type LoadBalancerLoadBalancingRulesClient = original.LoadBalancerLoadBalancingRulesClient @@ -1180,12 +1179,6 @@ func NewInterfaceLoadBalancersClient(subscriptionID string) InterfaceLoadBalance func NewInterfaceLoadBalancersClientWithBaseURI(baseURI string, subscriptionID string) InterfaceLoadBalancersClient { return original.NewInterfaceLoadBalancersClientWithBaseURI(baseURI, subscriptionID) } -func NewInterfacesClient(subscriptionID string) InterfacesClient { - return original.NewInterfacesClient(subscriptionID) -} -func NewInterfacesClientWithBaseURI(baseURI string, subscriptionID string) InterfacesClient { - return original.NewInterfacesClientWithBaseURI(baseURI, subscriptionID) -} func NewLoadBalancerBackendAddressPoolsClient(subscriptionID string) LoadBalancerBackendAddressPoolsClient { return original.NewLoadBalancerBackendAddressPoolsClient(subscriptionID) } diff --git a/profiles/preview/network/mgmt/network/models.go b/profiles/preview/network/mgmt/network/models.go index f0a8c69de982..9e8622d8222e 100644 --- a/profiles/preview/network/mgmt/network/models.go +++ b/profiles/preview/network/mgmt/network/models.go @@ -55,7 +55,6 @@ type InboundNatRulesClient = original.InboundNatRulesClient type InterfaceEndpointsClient = original.InterfaceEndpointsClient type InterfaceIPConfigurationsClient = original.InterfaceIPConfigurationsClient type InterfaceLoadBalancersClient = original.InterfaceLoadBalancersClient -type InterfacesClient = original.InterfacesClient type InterfaceTapConfigurationsClient = original.InterfaceTapConfigurationsClient type LoadBalancerBackendAddressPoolsClient = original.LoadBalancerBackendAddressPoolsClient type LoadBalancerFrontendIPConfigurationsClient = original.LoadBalancerFrontendIPConfigurationsClient @@ -1765,12 +1764,6 @@ func NewInterfaceLoadBalancersClient(subscriptionID string) InterfaceLoadBalance func NewInterfaceLoadBalancersClientWithBaseURI(baseURI string, subscriptionID string) InterfaceLoadBalancersClient { return original.NewInterfaceLoadBalancersClientWithBaseURI(baseURI, subscriptionID) } -func NewInterfacesClient(subscriptionID string) InterfacesClient { - return original.NewInterfacesClient(subscriptionID) -} -func NewInterfacesClientWithBaseURI(baseURI string, subscriptionID string) InterfacesClient { - return original.NewInterfacesClientWithBaseURI(baseURI, subscriptionID) -} func NewInterfaceTapConfigurationsClient(subscriptionID string) InterfaceTapConfigurationsClient { return original.NewInterfaceTapConfigurationsClient(subscriptionID) } diff --git a/profiles/preview/preview/network/mgmt/network/models.go b/profiles/preview/preview/network/mgmt/network/models.go index a3ecb2be065b..53406eeb1fc5 100644 --- a/profiles/preview/preview/network/mgmt/network/models.go +++ b/profiles/preview/preview/network/mgmt/network/models.go @@ -32,7 +32,6 @@ type ExpressRouteCircuitAuthorizationsClient = original.ExpressRouteCircuitAutho type ExpressRouteCircuitPeeringsClient = original.ExpressRouteCircuitPeeringsClient type ExpressRouteCircuitsClient = original.ExpressRouteCircuitsClient type ExpressRouteServiceProvidersClient = original.ExpressRouteServiceProvidersClient -type InterfacesClient = original.InterfacesClient type LoadBalancersClient = original.LoadBalancersClient type LocalNetworkGatewaysClient = original.LocalNetworkGatewaysClient type ApplicationGatewayCookieBasedAffinity = original.ApplicationGatewayCookieBasedAffinity @@ -471,12 +470,6 @@ func NewExpressRouteServiceProvidersClient(subscriptionID string) ExpressRouteSe func NewExpressRouteServiceProvidersClientWithBaseURI(baseURI string, subscriptionID string) ExpressRouteServiceProvidersClient { return original.NewExpressRouteServiceProvidersClientWithBaseURI(baseURI, subscriptionID) } -func NewInterfacesClient(subscriptionID string) InterfacesClient { - return original.NewInterfacesClient(subscriptionID) -} -func NewInterfacesClientWithBaseURI(baseURI string, subscriptionID string) InterfacesClient { - return original.NewInterfacesClientWithBaseURI(baseURI, subscriptionID) -} func NewLoadBalancersClient(subscriptionID string) LoadBalancersClient { return original.NewLoadBalancersClient(subscriptionID) } diff --git a/services/datalake/store/2016-11-01/filesystem/filesystem.go b/services/datalake/store/2016-11-01/filesystem/filesystem.go index 12d6a5d091f4..a70017566bf5 100644 --- a/services/datalake/store/2016-11-01/filesystem/filesystem.go +++ b/services/datalake/store/2016-11-01/filesystem/filesystem.go @@ -44,7 +44,8 @@ func NewClient() Client { // Parameters: // accountName - the Azure Data Lake Store account to execute filesystem operations on. // pathParameter - the Data Lake Store path (starting with '/') of the file to which to append. -// streamContents - the file contents to include when appending to the file. +// streamContents - the file contents to include when appending to the file. The maximum content size is 4MB. +// For content larger than 4MB you must append the content in 4MB chunks. // offset - the optional offset in the stream to begin the append operation. Default is to append at the end of // the stream. // syncFlag - optionally indicates what to do after completion of the concurrent append. DATA indicates that @@ -333,7 +334,8 @@ func (client Client) ConcatResponder(resp *http.Response) (result autorest.Respo // accountName - the Azure Data Lake Store account to execute filesystem operations on. // pathParameter - the Data Lake Store path (starting with '/') of the file to which to append using concurrent // append. -// streamContents - the file contents to include when appending to the file. +// streamContents - the file contents to include when appending to the file. The maximum content size is 4MB. +// For content larger than 4MB you must append the content in 4MB chunks. // appendMode - indicates the concurrent append call should create the file if it doesn't exist or just open // the existing file for append // syncFlag - optionally indicates what to do after completion of the concurrent append. DATA indicates that @@ -435,7 +437,8 @@ func (client Client) ConcurrentAppendResponder(resp *http.Response) (result auto // accountName - the Azure Data Lake Store account to execute filesystem operations on. // pathParameter - the Data Lake Store path (starting with '/') of the file to create. // streamContents - the file contents to include when creating the file. This parameter is optional, resulting -// in an empty file if not specified. +// in an empty file if not specified. The maximum content size is 4MB. For content larger than 4MB you must +// append the content in 4MB chunks. // overwrite - the indication of if the file should be overwritten. // syncFlag - optionally indicates what to do after completion of the create. DATA indicates that more data // will be sent immediately by the client, the file handle should remain open/locked, and file metadata diff --git a/services/datalake/store/2016-11-01/filesystem/filesystemapi/interfaces.go b/services/datalake/store/2016-11-01/filesystem/filesystemapi/interfaces.go new file mode 100644 index 000000000000..f49abc69a524 --- /dev/null +++ b/services/datalake/store/2016-11-01/filesystem/filesystemapi/interfaces.go @@ -0,0 +1,54 @@ +package filesystemapi + +// Copyright (c) Microsoft and contributors. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// +// See the License for the specific language governing permissions and +// limitations under the License. +// +// Code generated by Microsoft (R) AutoRest Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "context" + "github.com/Azure/azure-sdk-for-go/services/datalake/store/2016-11-01/filesystem" + "github.com/Azure/go-autorest/autorest" + "github.com/satori/go.uuid" + "io" +) + +// ClientAPI contains the set of methods on the Client type. +type ClientAPI interface { + Append(ctx context.Context, accountName string, pathParameter string, streamContents io.ReadCloser, offset *int64, syncFlag SyncFlag, leaseID *uuid.UUID, fileSessionID *uuid.UUID) (result autorest.Response, err error) + CheckAccess(ctx context.Context, accountName string, pathParameter string, fsaction string) (result autorest.Response, err error) + Concat(ctx context.Context, accountName string, pathParameter string, sources []string) (result autorest.Response, err error) + ConcurrentAppend(ctx context.Context, accountName string, pathParameter string, streamContents io.ReadCloser, appendMode AppendModeType, syncFlag SyncFlag) (result autorest.Response, err error) + Create(ctx context.Context, accountName string, pathParameter string, streamContents io.ReadCloser, overwrite *bool, syncFlag SyncFlag, leaseID *uuid.UUID, permission *int32) (result autorest.Response, err error) + Delete(ctx context.Context, accountName string, pathParameter string, recursive *bool) (result filesystem.FileOperationResult, err error) + GetACLStatus(ctx context.Context, accountName string, pathParameter string, tooID *bool) (result filesystem.ACLStatusResult, err error) + GetContentSummary(ctx context.Context, accountName string, pathParameter string) (result filesystem.ContentSummaryResult, err error) + GetFileStatus(ctx context.Context, accountName string, pathParameter string, tooID *bool) (result filesystem.FileStatusResult, err error) + ListFileStatus(ctx context.Context, accountName string, pathParameter string, listSize *int32, listAfter string, listBefore string, tooID *bool) (result filesystem.FileStatusesResult, err error) + Mkdirs(ctx context.Context, accountName string, pathParameter string, permission *int32) (result filesystem.FileOperationResult, err error) + ModifyACLEntries(ctx context.Context, accountName string, pathParameter string, aclspec string) (result autorest.Response, err error) + MsConcat(ctx context.Context, accountName string, pathParameter string, streamContents io.ReadCloser, deleteSourceDirectory *bool) (result autorest.Response, err error) + Open(ctx context.Context, accountName string, pathParameter string, length *int64, offset *int64, fileSessionID *uuid.UUID) (result filesystem.ReadCloser, err error) + RemoveACL(ctx context.Context, accountName string, pathParameter string) (result autorest.Response, err error) + RemoveACLEntries(ctx context.Context, accountName string, pathParameter string, aclspec string) (result autorest.Response, err error) + RemoveDefaultACL(ctx context.Context, accountName string, pathParameter string) (result autorest.Response, err error) + Rename(ctx context.Context, accountName string, pathParameter string, destination string) (result filesystem.FileOperationResult, err error) + SetACL(ctx context.Context, accountName string, pathParameter string, aclspec string) (result autorest.Response, err error) + SetFileExpiry(ctx context.Context, accountName string, pathParameter string, expiryOption ExpiryOptionType, expireTime *int64) (result autorest.Response, err error) + SetOwner(ctx context.Context, accountName string, pathParameter string, owner string, group string) (result autorest.Response, err error) + SetPermission(ctx context.Context, accountName string, pathParameter string, permission string) (result autorest.Response, err error) +} + +var _ ClientAPI = (*filesystem.Client)(nil) diff --git a/services/preview/datalake/store/2015-10-01-preview/filesystem/filesystem.go b/services/preview/datalake/store/2015-10-01-preview/filesystem/filesystem.go index 589d149e5345..2a25732ead9f 100644 --- a/services/preview/datalake/store/2015-10-01-preview/filesystem/filesystem.go +++ b/services/preview/datalake/store/2015-10-01-preview/filesystem/filesystem.go @@ -44,7 +44,8 @@ func NewClient() Client { // Parameters: // accountName - the Azure Data Lake Store account to execute filesystem operations on. // directFilePath - the Data Lake Store path (starting with '/') of the file to which to append. -// streamContents - the file contents to include when appending to the file. +// streamContents - the file contents to include when appending to the file. The maximum content size is 4MB. +// For content larger than 4MB you must append the content in 4MB chunks. // offset - the optional offset in the stream to begin the append operation. Default is to append at the end of // the stream. func (client Client) Append(ctx context.Context, accountName string, directFilePath string, streamContents io.ReadCloser, offset *int64) (result autorest.Response, err error) { @@ -313,7 +314,8 @@ func (client Client) ConcatResponder(resp *http.Response) (result autorest.Respo // accountName - the Azure Data Lake Store account to execute filesystem operations on. // filePath - the Data Lake Store path (starting with '/') of the file to which to append using concurrent // append. -// streamContents - the file contents to include when appending to the file. +// streamContents - the file contents to include when appending to the file. The maximum content size is 4MB. +// For content larger than 4MB you must append the content in 4MB chunks. // appendMode - indicates the concurrent append call should create the file if it doesn't exist or just open // the existing file for append func (client Client) ConcurrentAppend(ctx context.Context, accountName string, filePath string, streamContents io.ReadCloser, appendMode AppendModeType) (result autorest.Response, err error) { @@ -403,7 +405,8 @@ func (client Client) ConcurrentAppendResponder(resp *http.Response) (result auto // accountName - the Azure Data Lake Store account to execute filesystem operations on. // directFilePath - the Data Lake Store path (starting with '/') of the file to create. // streamContents - the file contents to include when creating the file. This parameter is optional, resulting -// in an empty file if not specified. +// in an empty file if not specified. The maximum content size is 4MB. For content larger than 4MB you must +// append the content in 4MB chunks. // overwrite - the indication of if the file should be overwritten. func (client Client) Create(ctx context.Context, accountName string, directFilePath string, streamContents io.ReadCloser, overwrite *bool) (result autorest.Response, err error) { if tracing.IsEnabled() { diff --git a/services/preview/datalake/store/2015-10-01-preview/filesystem/filesystemapi/interfaces.go b/services/preview/datalake/store/2015-10-01-preview/filesystem/filesystemapi/interfaces.go new file mode 100644 index 000000000000..7a18fb835186 --- /dev/null +++ b/services/preview/datalake/store/2015-10-01-preview/filesystem/filesystemapi/interfaces.go @@ -0,0 +1,54 @@ +package filesystemapi + +// Copyright (c) Microsoft and contributors. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// +// See the License for the specific language governing permissions and +// limitations under the License. +// +// Code generated by Microsoft (R) AutoRest Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "context" + "github.com/Azure/azure-sdk-for-go/services/preview/datalake/store/2015-10-01-preview/filesystem" + "github.com/Azure/go-autorest/autorest" + "io" +) + +// ClientAPI contains the set of methods on the Client type. +type ClientAPI interface { + Append(ctx context.Context, accountName string, directFilePath string, streamContents io.ReadCloser, offset *int64) (result autorest.Response, err error) + CheckAccess(ctx context.Context, accountName string, pathParameter string, fsaction string) (result autorest.Response, err error) + Concat(ctx context.Context, accountName string, destinationPath string, sources []string) (result autorest.Response, err error) + ConcurrentAppend(ctx context.Context, accountName string, filePath string, streamContents io.ReadCloser, appendMode AppendModeType) (result autorest.Response, err error) + Create(ctx context.Context, accountName string, directFilePath string, streamContents io.ReadCloser, overwrite *bool) (result autorest.Response, err error) + Delete(ctx context.Context, accountName string, filePath string, recursive *bool) (result filesystem.FileOperationResult, err error) + Flush(ctx context.Context, accountName string, flushFilePath string) (result autorest.Response, err error) + GetACLStatus(ctx context.Context, accountName string, ACLFilePath string) (result filesystem.ACLStatusResult, err error) + GetContentSummary(ctx context.Context, accountName string, getContentSummaryFilePath string) (result filesystem.ContentSummaryResult, err error) + GetFileStatus(ctx context.Context, accountName string, getFilePath string) (result filesystem.FileStatusResult, err error) + ListFileStatus(ctx context.Context, accountName string, listFilePath string, listSize *int32, listAfter string, listBefore string) (result filesystem.FileStatusesResult, err error) + Mkdirs(ctx context.Context, accountName string, pathParameter string) (result filesystem.FileOperationResult, err error) + ModifyACLEntries(ctx context.Context, accountName string, modifyACLFilePath string, aclspec string) (result autorest.Response, err error) + MsConcat(ctx context.Context, accountName string, msConcatDestinationPath string, streamContents io.ReadCloser, deleteSourceDirectory *bool) (result autorest.Response, err error) + Open(ctx context.Context, accountName string, directFilePath string, length *int64, offset *int64) (result filesystem.ReadCloser, err error) + RemoveACL(ctx context.Context, accountName string, ACLFilePath string) (result autorest.Response, err error) + RemoveACLEntries(ctx context.Context, accountName string, removeACLFilePath string, aclspec string) (result autorest.Response, err error) + RemoveDefaultACL(ctx context.Context, accountName string, defaultACLFilePath string) (result autorest.Response, err error) + Rename(ctx context.Context, accountName string, renameFilePath string, destination string) (result filesystem.FileOperationResult, err error) + SetACL(ctx context.Context, accountName string, setACLFilePath string, aclspec string) (result autorest.Response, err error) + SetFileExpiry(ctx context.Context, accountName string, filePath string, expiryOption ExpiryOptionType, expireTime *int64) (result autorest.Response, err error) + SetOwner(ctx context.Context, accountName string, setOwnerFilePath string, owner string, group string) (result autorest.Response, err error) + SetPermission(ctx context.Context, accountName string, setPermissionFilePath string, permission string) (result autorest.Response, err error) +} + +var _ ClientAPI = (*filesystem.Client)(nil)