filesystem

package
v11.2.1-beta+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 7, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package filesystem implements the Azure ARM Filesystem service API version 2015-10-01-preview.

Creates an Azure Data Lake Store filesystem client.

Index

Constants

View Source 
const (
	// DefaultAdlsFileSystemDNSSuffix is the default value for adls file system dns suffix
	DefaultAdlsFileSystemDNSSuffix = "azuredatalakestore.net"
)

Variables

This section is empty.

Functions

func UserAgent 

func UserAgent() string

UserAgent returns the UserAgent string to use when sending http.Requests.

func Version 

func Version() string

Version returns the semantic version (see http://semver.org) of the client.

Types

type ACLStatus 

type ACLStatus struct {
	Entries    *[]string `json:"entries,omitempty"`
	Group      *string   `json:"group,omitempty"`
	Owner      *string   `json:"owner,omitempty"`
	Permission *int32    `json:"permission,omitempty"`
	StickyBit  *bool     `json:"stickyBit,omitempty"`
}

ACLStatus is data Lake Store file or directory Access Control List information.

type ACLStatusResult 

type ACLStatusResult struct {
	autorest.Response `json:"-"`
	ACLStatus         *ACLStatus `json:"AclStatus,omitempty"`
}

ACLStatusResult is data Lake Store file or directory Access Control List information.

type AdlsAccessControlException 

type AdlsAccessControlException struct {
	JavaClassName *string   `json:"javaClassName,omitempty"`
	Message       *string   `json:"message,omitempty"`
	Exception     Exception `json:"exception,omitempty"`
}

AdlsAccessControlException is a WebHDFS exception thrown indicating that access is denied due to insufficient permissions. Thrown when a 403 error response code is returned (forbidden).

func (AdlsAccessControlException) AsAdlsAccessControlException 

func (aace AdlsAccessControlException) AsAdlsAccessControlException() (*AdlsAccessControlException, bool)

AsAdlsAccessControlException is the AdlsRemoteException implementation for AdlsAccessControlException.

func (AdlsAccessControlException) AsAdlsBadOffsetException 

func (aace AdlsAccessControlException) AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)

AsAdlsBadOffsetException is the AdlsRemoteException implementation for AdlsAccessControlException.

func (AdlsAccessControlException) AsAdlsFileAlreadyExistsException 

func (aace AdlsAccessControlException) AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)

AsAdlsFileAlreadyExistsException is the AdlsRemoteException implementation for AdlsAccessControlException.

func (AdlsAccessControlException) AsAdlsFileNotFoundException 

func (aace AdlsAccessControlException) AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)

AsAdlsFileNotFoundException is the AdlsRemoteException implementation for AdlsAccessControlException.

func (AdlsAccessControlException) AsAdlsIOException 

func (aace AdlsAccessControlException) AsAdlsIOException() (*AdlsIOException, bool)

AsAdlsIOException is the AdlsRemoteException implementation for AdlsAccessControlException.

func (AdlsAccessControlException) AsAdlsIllegalArgumentException 

func (aace AdlsAccessControlException) AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)

AsAdlsIllegalArgumentException is the AdlsRemoteException implementation for AdlsAccessControlException.

func (AdlsAccessControlException) AsAdlsRuntimeException 

func (aace AdlsAccessControlException) AsAdlsRuntimeException() (*AdlsRuntimeException, bool)

AsAdlsRuntimeException is the AdlsRemoteException implementation for AdlsAccessControlException.

func (AdlsAccessControlException) AsAdlsSecurityException 

func (aace AdlsAccessControlException) AsAdlsSecurityException() (*AdlsSecurityException, bool)

AsAdlsSecurityException is the AdlsRemoteException implementation for AdlsAccessControlException.

func (AdlsAccessControlException) AsAdlsUnsupportedOperationException 

func (aace AdlsAccessControlException) AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)

AsAdlsUnsupportedOperationException is the AdlsRemoteException implementation for AdlsAccessControlException.

func (AdlsAccessControlException) MarshalJSON 

func (aace AdlsAccessControlException) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AdlsAccessControlException.

type AdlsBadOffsetException 

type AdlsBadOffsetException struct {
	JavaClassName *string   `json:"javaClassName,omitempty"`
	Message       *string   `json:"message,omitempty"`
	Exception     Exception `json:"exception,omitempty"`
}

AdlsBadOffsetException is a WebHDFS exception thrown indicating the append or read is from a bad offset. Thrown when a 400 error response code is returned for append and open operations (Bad request).

func (AdlsBadOffsetException) AsAdlsAccessControlException 

func (aboe AdlsBadOffsetException) AsAdlsAccessControlException() (*AdlsAccessControlException, bool)

AsAdlsAccessControlException is the AdlsRemoteException implementation for AdlsBadOffsetException.

func (AdlsBadOffsetException) AsAdlsBadOffsetException 

func (aboe AdlsBadOffsetException) AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)

AsAdlsBadOffsetException is the AdlsRemoteException implementation for AdlsBadOffsetException.

func (AdlsBadOffsetException) AsAdlsFileAlreadyExistsException 

func (aboe AdlsBadOffsetException) AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)

AsAdlsFileAlreadyExistsException is the AdlsRemoteException implementation for AdlsBadOffsetException.

func (AdlsBadOffsetException) AsAdlsFileNotFoundException 

func (aboe AdlsBadOffsetException) AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)

AsAdlsFileNotFoundException is the AdlsRemoteException implementation for AdlsBadOffsetException.

func (AdlsBadOffsetException) AsAdlsIOException 

func (aboe AdlsBadOffsetException) AsAdlsIOException() (*AdlsIOException, bool)

AsAdlsIOException is the AdlsRemoteException implementation for AdlsBadOffsetException.

func (AdlsBadOffsetException) AsAdlsIllegalArgumentException 

func (aboe AdlsBadOffsetException) AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)

AsAdlsIllegalArgumentException is the AdlsRemoteException implementation for AdlsBadOffsetException.

func (AdlsBadOffsetException) AsAdlsRuntimeException 

func (aboe AdlsBadOffsetException) AsAdlsRuntimeException() (*AdlsRuntimeException, bool)

AsAdlsRuntimeException is the AdlsRemoteException implementation for AdlsBadOffsetException.

func (AdlsBadOffsetException) AsAdlsSecurityException 

func (aboe AdlsBadOffsetException) AsAdlsSecurityException() (*AdlsSecurityException, bool)

AsAdlsSecurityException is the AdlsRemoteException implementation for AdlsBadOffsetException.

func (AdlsBadOffsetException) AsAdlsUnsupportedOperationException 

func (aboe AdlsBadOffsetException) AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)

AsAdlsUnsupportedOperationException is the AdlsRemoteException implementation for AdlsBadOffsetException.

func (AdlsBadOffsetException) MarshalJSON 

func (aboe AdlsBadOffsetException) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AdlsBadOffsetException.

type AdlsError 

type AdlsError struct {
	RemoteException AdlsRemoteException `json:"RemoteException,omitempty"`
}

AdlsError is data Lake Store filesystem error containing a specific WebHDFS exception.

func (*AdlsError) UnmarshalJSON 

func (ae *AdlsError) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AdlsError struct.

type AdlsFileAlreadyExistsException 

type AdlsFileAlreadyExistsException struct {
	JavaClassName *string   `json:"javaClassName,omitempty"`
	Message       *string   `json:"message,omitempty"`
	Exception     Exception `json:"exception,omitempty"`
}

AdlsFileAlreadyExistsException is a WebHDFS exception thrown indicating the file or folder already exists. Thrown when a 403 error response code is returned (forbidden).

func (AdlsFileAlreadyExistsException) AsAdlsAccessControlException 

func (afaee AdlsFileAlreadyExistsException) AsAdlsAccessControlException() (*AdlsAccessControlException, bool)

AsAdlsAccessControlException is the AdlsRemoteException implementation for AdlsFileAlreadyExistsException.

func (AdlsFileAlreadyExistsException) AsAdlsBadOffsetException 

func (afaee AdlsFileAlreadyExistsException) AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)

AsAdlsBadOffsetException is the AdlsRemoteException implementation for AdlsFileAlreadyExistsException.

func (AdlsFileAlreadyExistsException) AsAdlsFileAlreadyExistsException 

func (afaee AdlsFileAlreadyExistsException) AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)

AsAdlsFileAlreadyExistsException is the AdlsRemoteException implementation for AdlsFileAlreadyExistsException.

func (AdlsFileAlreadyExistsException) AsAdlsFileNotFoundException 

func (afaee AdlsFileAlreadyExistsException) AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)

AsAdlsFileNotFoundException is the AdlsRemoteException implementation for AdlsFileAlreadyExistsException.

func (AdlsFileAlreadyExistsException) AsAdlsIOException 

func (afaee AdlsFileAlreadyExistsException) AsAdlsIOException() (*AdlsIOException, bool)

AsAdlsIOException is the AdlsRemoteException implementation for AdlsFileAlreadyExistsException.

func (AdlsFileAlreadyExistsException) AsAdlsIllegalArgumentException 

func (afaee AdlsFileAlreadyExistsException) AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)

AsAdlsIllegalArgumentException is the AdlsRemoteException implementation for AdlsFileAlreadyExistsException.

func (AdlsFileAlreadyExistsException) AsAdlsRuntimeException 

func (afaee AdlsFileAlreadyExistsException) AsAdlsRuntimeException() (*AdlsRuntimeException, bool)

AsAdlsRuntimeException is the AdlsRemoteException implementation for AdlsFileAlreadyExistsException.

func (AdlsFileAlreadyExistsException) AsAdlsSecurityException 

func (afaee AdlsFileAlreadyExistsException) AsAdlsSecurityException() (*AdlsSecurityException, bool)

AsAdlsSecurityException is the AdlsRemoteException implementation for AdlsFileAlreadyExistsException.

func (AdlsFileAlreadyExistsException) AsAdlsUnsupportedOperationException 

func (afaee AdlsFileAlreadyExistsException) AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)

AsAdlsUnsupportedOperationException is the AdlsRemoteException implementation for AdlsFileAlreadyExistsException.

func (AdlsFileAlreadyExistsException) MarshalJSON 

func (afaee AdlsFileAlreadyExistsException) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AdlsFileAlreadyExistsException.

type AdlsFileNotFoundException 

type AdlsFileNotFoundException struct {
	JavaClassName *string   `json:"javaClassName,omitempty"`
	Message       *string   `json:"message,omitempty"`
	Exception     Exception `json:"exception,omitempty"`
}

AdlsFileNotFoundException is a WebHDFS exception thrown indicating the file or folder could not be found. Thrown when a 404 error response code is returned (not found).

func (AdlsFileNotFoundException) AsAdlsAccessControlException 

func (afnfe AdlsFileNotFoundException) AsAdlsAccessControlException() (*AdlsAccessControlException, bool)

AsAdlsAccessControlException is the AdlsRemoteException implementation for AdlsFileNotFoundException.

func (AdlsFileNotFoundException) AsAdlsBadOffsetException 

func (afnfe AdlsFileNotFoundException) AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)

AsAdlsBadOffsetException is the AdlsRemoteException implementation for AdlsFileNotFoundException.

func (AdlsFileNotFoundException) AsAdlsFileAlreadyExistsException 

func (afnfe AdlsFileNotFoundException) AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)

AsAdlsFileAlreadyExistsException is the AdlsRemoteException implementation for AdlsFileNotFoundException.

func (AdlsFileNotFoundException) AsAdlsFileNotFoundException 

func (afnfe AdlsFileNotFoundException) AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)

AsAdlsFileNotFoundException is the AdlsRemoteException implementation for AdlsFileNotFoundException.

func (AdlsFileNotFoundException) AsAdlsIOException 

func (afnfe AdlsFileNotFoundException) AsAdlsIOException() (*AdlsIOException, bool)

AsAdlsIOException is the AdlsRemoteException implementation for AdlsFileNotFoundException.

func (AdlsFileNotFoundException) AsAdlsIllegalArgumentException 

func (afnfe AdlsFileNotFoundException) AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)

AsAdlsIllegalArgumentException is the AdlsRemoteException implementation for AdlsFileNotFoundException.

func (AdlsFileNotFoundException) AsAdlsRuntimeException 

func (afnfe AdlsFileNotFoundException) AsAdlsRuntimeException() (*AdlsRuntimeException, bool)

AsAdlsRuntimeException is the AdlsRemoteException implementation for AdlsFileNotFoundException.

func (AdlsFileNotFoundException) AsAdlsSecurityException 

func (afnfe AdlsFileNotFoundException) AsAdlsSecurityException() (*AdlsSecurityException, bool)

AsAdlsSecurityException is the AdlsRemoteException implementation for AdlsFileNotFoundException.

func (AdlsFileNotFoundException) AsAdlsUnsupportedOperationException 

func (afnfe AdlsFileNotFoundException) AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)

AsAdlsUnsupportedOperationException is the AdlsRemoteException implementation for AdlsFileNotFoundException.

func (AdlsFileNotFoundException) MarshalJSON 

func (afnfe AdlsFileNotFoundException) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AdlsFileNotFoundException.

type AdlsIOException 

type AdlsIOException struct {
	JavaClassName *string   `json:"javaClassName,omitempty"`
	Message       *string   `json:"message,omitempty"`
	Exception     Exception `json:"exception,omitempty"`
}

AdlsIOException is a WebHDFS exception thrown indicating there was an IO (read or write) error. Thrown when a 403 error response code is returned (forbidden).

func (AdlsIOException) AsAdlsAccessControlException 

func (aie AdlsIOException) AsAdlsAccessControlException() (*AdlsAccessControlException, bool)

AsAdlsAccessControlException is the AdlsRemoteException implementation for AdlsIOException.

func (AdlsIOException) AsAdlsBadOffsetException 

func (aie AdlsIOException) AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)

AsAdlsBadOffsetException is the AdlsRemoteException implementation for AdlsIOException.

func (AdlsIOException) AsAdlsFileAlreadyExistsException 

func (aie AdlsIOException) AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)

AsAdlsFileAlreadyExistsException is the AdlsRemoteException implementation for AdlsIOException.

func (AdlsIOException) AsAdlsFileNotFoundException 

func (aie AdlsIOException) AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)

AsAdlsFileNotFoundException is the AdlsRemoteException implementation for AdlsIOException.

func (AdlsIOException) AsAdlsIOException 

func (aie AdlsIOException) AsAdlsIOException() (*AdlsIOException, bool)

AsAdlsIOException is the AdlsRemoteException implementation for AdlsIOException.

func (AdlsIOException) AsAdlsIllegalArgumentException 

func (aie AdlsIOException) AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)

AsAdlsIllegalArgumentException is the AdlsRemoteException implementation for AdlsIOException.

func (AdlsIOException) AsAdlsRuntimeException 

func (aie AdlsIOException) AsAdlsRuntimeException() (*AdlsRuntimeException, bool)

AsAdlsRuntimeException is the AdlsRemoteException implementation for AdlsIOException.

func (AdlsIOException) AsAdlsSecurityException 

func (aie AdlsIOException) AsAdlsSecurityException() (*AdlsSecurityException, bool)

AsAdlsSecurityException is the AdlsRemoteException implementation for AdlsIOException.

func (AdlsIOException) AsAdlsUnsupportedOperationException 

func (aie AdlsIOException) AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)

AsAdlsUnsupportedOperationException is the AdlsRemoteException implementation for AdlsIOException.

func (AdlsIOException) MarshalJSON 

func (aie AdlsIOException) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AdlsIOException.

type AdlsIllegalArgumentException 

type AdlsIllegalArgumentException struct {
	JavaClassName *string   `json:"javaClassName,omitempty"`
	Message       *string   `json:"message,omitempty"`
	Exception     Exception `json:"exception,omitempty"`
}

AdlsIllegalArgumentException is a WebHDFS exception thrown indicating that one more arguments is incorrect. Thrown when a 400 error response code is returned (bad request).

func (AdlsIllegalArgumentException) AsAdlsAccessControlException 

func (aiae AdlsIllegalArgumentException) AsAdlsAccessControlException() (*AdlsAccessControlException, bool)

AsAdlsAccessControlException is the AdlsRemoteException implementation for AdlsIllegalArgumentException.

func (AdlsIllegalArgumentException) AsAdlsBadOffsetException 

func (aiae AdlsIllegalArgumentException) AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)

AsAdlsBadOffsetException is the AdlsRemoteException implementation for AdlsIllegalArgumentException.

func (AdlsIllegalArgumentException) AsAdlsFileAlreadyExistsException 

func (aiae AdlsIllegalArgumentException) AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)

AsAdlsFileAlreadyExistsException is the AdlsRemoteException implementation for AdlsIllegalArgumentException.

func (AdlsIllegalArgumentException) AsAdlsFileNotFoundException 

func (aiae AdlsIllegalArgumentException) AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)

AsAdlsFileNotFoundException is the AdlsRemoteException implementation for AdlsIllegalArgumentException.

func (AdlsIllegalArgumentException) AsAdlsIOException 

func (aiae AdlsIllegalArgumentException) AsAdlsIOException() (*AdlsIOException, bool)

AsAdlsIOException is the AdlsRemoteException implementation for AdlsIllegalArgumentException.

func (AdlsIllegalArgumentException) AsAdlsIllegalArgumentException 

func (aiae AdlsIllegalArgumentException) AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)

AsAdlsIllegalArgumentException is the AdlsRemoteException implementation for AdlsIllegalArgumentException.

func (AdlsIllegalArgumentException) AsAdlsRuntimeException 

func (aiae AdlsIllegalArgumentException) AsAdlsRuntimeException() (*AdlsRuntimeException, bool)

AsAdlsRuntimeException is the AdlsRemoteException implementation for AdlsIllegalArgumentException.

func (AdlsIllegalArgumentException) AsAdlsSecurityException 

func (aiae AdlsIllegalArgumentException) AsAdlsSecurityException() (*AdlsSecurityException, bool)

AsAdlsSecurityException is the AdlsRemoteException implementation for AdlsIllegalArgumentException.

func (AdlsIllegalArgumentException) AsAdlsUnsupportedOperationException 

func (aiae AdlsIllegalArgumentException) AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)

AsAdlsUnsupportedOperationException is the AdlsRemoteException implementation for AdlsIllegalArgumentException.

func (AdlsIllegalArgumentException) MarshalJSON 

func (aiae AdlsIllegalArgumentException) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AdlsIllegalArgumentException.

type AdlsRemoteException 

type AdlsRemoteException interface {
	AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)
	AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)
	AsAdlsSecurityException() (*AdlsSecurityException, bool)
	AsAdlsIOException() (*AdlsIOException, bool)
	AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)
	AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)
	AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)
	AsAdlsRuntimeException() (*AdlsRuntimeException, bool)
	AsAdlsAccessControlException() (*AdlsAccessControlException, bool)
}

AdlsRemoteException is data Lake Store filesystem exception based on the WebHDFS definition for RemoteExceptions.

type AdlsRuntimeException 

type AdlsRuntimeException struct {
	JavaClassName *string   `json:"javaClassName,omitempty"`
	Message       *string   `json:"message,omitempty"`
	Exception     Exception `json:"exception,omitempty"`
}

AdlsRuntimeException is a WebHDFS exception thrown when an unexpected error occurs during an operation. Thrown when a 500 error response code is returned (Internal server error).

func (AdlsRuntimeException) AsAdlsAccessControlException 

func (are AdlsRuntimeException) AsAdlsAccessControlException() (*AdlsAccessControlException, bool)

AsAdlsAccessControlException is the AdlsRemoteException implementation for AdlsRuntimeException.

func (AdlsRuntimeException) AsAdlsBadOffsetException 

func (are AdlsRuntimeException) AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)

AsAdlsBadOffsetException is the AdlsRemoteException implementation for AdlsRuntimeException.

func (AdlsRuntimeException) AsAdlsFileAlreadyExistsException 

func (are AdlsRuntimeException) AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)

AsAdlsFileAlreadyExistsException is the AdlsRemoteException implementation for AdlsRuntimeException.

func (AdlsRuntimeException) AsAdlsFileNotFoundException 

func (are AdlsRuntimeException) AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)

AsAdlsFileNotFoundException is the AdlsRemoteException implementation for AdlsRuntimeException.

func (AdlsRuntimeException) AsAdlsIOException 

func (are AdlsRuntimeException) AsAdlsIOException() (*AdlsIOException, bool)

AsAdlsIOException is the AdlsRemoteException implementation for AdlsRuntimeException.

func (AdlsRuntimeException) AsAdlsIllegalArgumentException 

func (are AdlsRuntimeException) AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)

AsAdlsIllegalArgumentException is the AdlsRemoteException implementation for AdlsRuntimeException.

func (AdlsRuntimeException) AsAdlsRuntimeException 

func (are AdlsRuntimeException) AsAdlsRuntimeException() (*AdlsRuntimeException, bool)

AsAdlsRuntimeException is the AdlsRemoteException implementation for AdlsRuntimeException.

func (AdlsRuntimeException) AsAdlsSecurityException 

func (are AdlsRuntimeException) AsAdlsSecurityException() (*AdlsSecurityException, bool)

AsAdlsSecurityException is the AdlsRemoteException implementation for AdlsRuntimeException.

func (AdlsRuntimeException) AsAdlsUnsupportedOperationException 

func (are AdlsRuntimeException) AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)

AsAdlsUnsupportedOperationException is the AdlsRemoteException implementation for AdlsRuntimeException.

func (AdlsRuntimeException) MarshalJSON 

func (are AdlsRuntimeException) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AdlsRuntimeException.

type AdlsSecurityException 

type AdlsSecurityException struct {
	JavaClassName *string   `json:"javaClassName,omitempty"`
	Message       *string   `json:"message,omitempty"`
	Exception     Exception `json:"exception,omitempty"`
}

AdlsSecurityException is a WebHDFS exception thrown indicating that access is denied. Thrown when a 401 error response code is returned (Unauthorized).

func (AdlsSecurityException) AsAdlsAccessControlException 

func (ase AdlsSecurityException) AsAdlsAccessControlException() (*AdlsAccessControlException, bool)

AsAdlsAccessControlException is the AdlsRemoteException implementation for AdlsSecurityException.

func (AdlsSecurityException) AsAdlsBadOffsetException 

func (ase AdlsSecurityException) AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)

AsAdlsBadOffsetException is the AdlsRemoteException implementation for AdlsSecurityException.

func (AdlsSecurityException) AsAdlsFileAlreadyExistsException 

func (ase AdlsSecurityException) AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)

AsAdlsFileAlreadyExistsException is the AdlsRemoteException implementation for AdlsSecurityException.

func (AdlsSecurityException) AsAdlsFileNotFoundException 

func (ase AdlsSecurityException) AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)

AsAdlsFileNotFoundException is the AdlsRemoteException implementation for AdlsSecurityException.

func (AdlsSecurityException) AsAdlsIOException 

func (ase AdlsSecurityException) AsAdlsIOException() (*AdlsIOException, bool)

AsAdlsIOException is the AdlsRemoteException implementation for AdlsSecurityException.

func (AdlsSecurityException) AsAdlsIllegalArgumentException 

func (ase AdlsSecurityException) AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)

AsAdlsIllegalArgumentException is the AdlsRemoteException implementation for AdlsSecurityException.

func (AdlsSecurityException) AsAdlsRuntimeException 

func (ase AdlsSecurityException) AsAdlsRuntimeException() (*AdlsRuntimeException, bool)

AsAdlsRuntimeException is the AdlsRemoteException implementation for AdlsSecurityException.

func (AdlsSecurityException) AsAdlsSecurityException 

func (ase AdlsSecurityException) AsAdlsSecurityException() (*AdlsSecurityException, bool)

AsAdlsSecurityException is the AdlsRemoteException implementation for AdlsSecurityException.

func (AdlsSecurityException) AsAdlsUnsupportedOperationException 

func (ase AdlsSecurityException) AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)

AsAdlsUnsupportedOperationException is the AdlsRemoteException implementation for AdlsSecurityException.

func (AdlsSecurityException) MarshalJSON 

func (ase AdlsSecurityException) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AdlsSecurityException.

type AdlsUnsupportedOperationException 

type AdlsUnsupportedOperationException struct {
	JavaClassName *string   `json:"javaClassName,omitempty"`
	Message       *string   `json:"message,omitempty"`
	Exception     Exception `json:"exception,omitempty"`
}

AdlsUnsupportedOperationException is a WebHDFS exception thrown indicating that the requested operation is not supported. Thrown when a 400 error response code is returned (bad request).

func (AdlsUnsupportedOperationException) AsAdlsAccessControlException 

func (auoe AdlsUnsupportedOperationException) AsAdlsAccessControlException() (*AdlsAccessControlException, bool)

AsAdlsAccessControlException is the AdlsRemoteException implementation for AdlsUnsupportedOperationException.

func (AdlsUnsupportedOperationException) AsAdlsBadOffsetException 

func (auoe AdlsUnsupportedOperationException) AsAdlsBadOffsetException() (*AdlsBadOffsetException, bool)

AsAdlsBadOffsetException is the AdlsRemoteException implementation for AdlsUnsupportedOperationException.

func (AdlsUnsupportedOperationException) AsAdlsFileAlreadyExistsException 

func (auoe AdlsUnsupportedOperationException) AsAdlsFileAlreadyExistsException() (*AdlsFileAlreadyExistsException, bool)

AsAdlsFileAlreadyExistsException is the AdlsRemoteException implementation for AdlsUnsupportedOperationException.

func (AdlsUnsupportedOperationException) AsAdlsFileNotFoundException 

func (auoe AdlsUnsupportedOperationException) AsAdlsFileNotFoundException() (*AdlsFileNotFoundException, bool)

AsAdlsFileNotFoundException is the AdlsRemoteException implementation for AdlsUnsupportedOperationException.

func (AdlsUnsupportedOperationException) AsAdlsIOException 

func (auoe AdlsUnsupportedOperationException) AsAdlsIOException() (*AdlsIOException, bool)

AsAdlsIOException is the AdlsRemoteException implementation for AdlsUnsupportedOperationException.

func (AdlsUnsupportedOperationException) AsAdlsIllegalArgumentException 

func (auoe AdlsUnsupportedOperationException) AsAdlsIllegalArgumentException() (*AdlsIllegalArgumentException, bool)

AsAdlsIllegalArgumentException is the AdlsRemoteException implementation for AdlsUnsupportedOperationException.

func (AdlsUnsupportedOperationException) AsAdlsRuntimeException 

func (auoe AdlsUnsupportedOperationException) AsAdlsRuntimeException() (*AdlsRuntimeException, bool)

AsAdlsRuntimeException is the AdlsRemoteException implementation for AdlsUnsupportedOperationException.

func (AdlsUnsupportedOperationException) AsAdlsSecurityException 

func (auoe AdlsUnsupportedOperationException) AsAdlsSecurityException() (*AdlsSecurityException, bool)

AsAdlsSecurityException is the AdlsRemoteException implementation for AdlsUnsupportedOperationException.

func (AdlsUnsupportedOperationException) AsAdlsUnsupportedOperationException 

func (auoe AdlsUnsupportedOperationException) AsAdlsUnsupportedOperationException() (*AdlsUnsupportedOperationException, bool)

AsAdlsUnsupportedOperationException is the AdlsRemoteException implementation for AdlsUnsupportedOperationException.

func (AdlsUnsupportedOperationException) MarshalJSON 

func (auoe AdlsUnsupportedOperationException) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AdlsUnsupportedOperationException.

type AppendModeType 

type AppendModeType string

AppendModeType enumerates the values for append mode type. 

const (
	// Autocreate specifies the autocreate state for append mode type.
	Autocreate AppendModeType = "autocreate"
)

type ContentSummary 

type ContentSummary struct {
	DirectoryCount *int64 `json:"directoryCount,omitempty"`
	FileCount      *int64 `json:"fileCount,omitempty"`
	Length         *int64 `json:"length,omitempty"`
	SpaceConsumed  *int64 `json:"spaceConsumed,omitempty"`
}

ContentSummary is data Lake Store content summary information

type ContentSummaryResult 

type ContentSummaryResult struct {
	autorest.Response `json:"-"`
	ContentSummary    *ContentSummary `json:"ContentSummary,omitempty"`
}

ContentSummaryResult is data Lake Store filesystem content summary information response.

type Exception 

type Exception string

Exception enumerates the values for exception. 

const (
	// ExceptionAccessControlException specifies the exception access control exception state for exception.
	ExceptionAccessControlException Exception = "AccessControlException"
	// ExceptionBadOffsetException specifies the exception bad offset exception state for exception.
	ExceptionBadOffsetException Exception = "BadOffsetException"
	// ExceptionFileAlreadyExistsException specifies the exception file already exists exception state for exception.
	ExceptionFileAlreadyExistsException Exception = "FileAlreadyExistsException"
	// ExceptionFileNotFoundException specifies the exception file not found exception state for exception.
	ExceptionFileNotFoundException Exception = "FileNotFoundException"
	// ExceptionIllegalArgumentException specifies the exception illegal argument exception state for exception.
	ExceptionIllegalArgumentException Exception = "IllegalArgumentException"
	// ExceptionIOException specifies the exception io exception state for exception.
	ExceptionIOException Exception = "IOException"
	// ExceptionRuntimeException specifies the exception runtime exception state for exception.
	ExceptionRuntimeException Exception = "RuntimeException"
	// ExceptionSecurityException specifies the exception security exception state for exception.
	ExceptionSecurityException Exception = "SecurityException"
	// ExceptionUnsupportedOperationException specifies the exception unsupported operation exception state for exception.
	ExceptionUnsupportedOperationException Exception = "UnsupportedOperationException"
)

type ExpiryOptionType 

type ExpiryOptionType string

ExpiryOptionType enumerates the values for expiry option type. 

const (
	// Absolute specifies the absolute state for expiry option type.
	Absolute ExpiryOptionType = "Absolute"
	// NeverExpire specifies the never expire state for expiry option type.
	NeverExpire ExpiryOptionType = "NeverExpire"
	// RelativeToCreationDate specifies the relative to creation date state for expiry option type.
	RelativeToCreationDate ExpiryOptionType = "RelativeToCreationDate"
	// RelativeToNow specifies the relative to now state for expiry option type.
	RelativeToNow ExpiryOptionType = "RelativeToNow"
)

type FileOperationResult 

type FileOperationResult struct {
	autorest.Response `json:"-"`
	OperationResult   *bool `json:"boolean,omitempty"`
}

FileOperationResult is the result of the request or operation.

type FileStatusProperties 

type FileStatusProperties struct {
	AccessTime       *int64   `json:"accessTime,omitempty"`
	BlockSize        *int64   `json:"blockSize,omitempty"`
	ChildrenNum      *int64   `json:"childrenNum,omitempty"`
	ExpirationTime   *int64   `json:"expirationTime,omitempty"`
	Group            *string  `json:"group,omitempty"`
	Length           *int64   `json:"length,omitempty"`
	ModificationTime *int64   `json:"modificationTime,omitempty"`
	Owner            *string  `json:"owner,omitempty"`
	PathSuffix       *string  `json:"pathSuffix,omitempty"`
	Permission       *string  `json:"permission,omitempty"`
	Type             FileType `json:"type,omitempty"`
}

FileStatusProperties is data Lake Store file or directory information.

type FileStatusResult 

type FileStatusResult struct {
	autorest.Response `json:"-"`
	FileStatus        *FileStatusProperties `json:"FileStatus,omitempty"`
}

FileStatusResult is data Lake Store filesystem file status information response.

type FileStatuses 

type FileStatuses struct {
	FileStatus *[]FileStatusProperties `json:"FileStatus,omitempty"`
}

FileStatuses is data Lake Store file status list information.

type FileStatusesResult 

type FileStatusesResult struct {
	autorest.Response `json:"-"`
	FileStatuses      *FileStatuses `json:"FileStatuses,omitempty"`
}

FileStatusesResult is data Lake Store filesystem file status list information response.

type FileType 

type FileType string

FileType enumerates the values for file type. 

const (
	// DIRECTORY specifies the directory state for file type.
	DIRECTORY FileType = "DIRECTORY"
	// FILE specifies the file state for file type.
	FILE FileType = "FILE"
)

type GroupClient 

type GroupClient struct {
	ManagementClient
}

GroupClient is the creates an Azure Data Lake Store filesystem client.

func NewGroupClient 

func NewGroupClient() GroupClient

NewGroupClient creates an instance of the GroupClient client.

func (GroupClient) Append 

func (client GroupClient) Append(accountName string, directFilePath string, streamContents io.ReadCloser, op string, appendParameter string, offset *int64) (result autorest.Response, err error)

Append appends to the specified file. This method does not support multiple concurrent appends to the file. NOTE: Concurrent append and normal (serial) append CANNOT be used interchangeably. Once a file has been appended to using either append option, it can only be appended to using that append option. Use the ConcurrentAppend option if you would like support for concurrent appends.

accountName is the Azure Data Lake Store account to execute filesystem operations on. directFilePath is the Data Lake Store path (starting with '/') of the file to which to append. streamContents is the file contents to include when appending to the file. streamContents will be closed upon successful return. Callers should ensure closure when receiving an error.op is the constant value for the operation. appendParameter is the constant value for the operation. offset is the optional offset in the stream to begin the append operation. Default is to append at the end of the stream.

func (GroupClient) AppendPreparer 

func (client GroupClient) AppendPreparer(accountName string, directFilePath string, streamContents io.ReadCloser, op string, appendParameter string, offset *int64) (*http.Request, error)

AppendPreparer prepares the Append request.

func (GroupClient) AppendResponder 

func (client GroupClient) AppendResponder(resp *http.Response) (result autorest.Response, err error)

AppendResponder handles the response to the Append request. The method always closes the http.Response Body.

func (GroupClient) AppendSender 

func (client GroupClient) AppendSender(req *http.Request) (*http.Response, error)

AppendSender sends the Append request. The method will close the http.Response Body if it receives an error.

func (GroupClient) CheckAccess 

func (client GroupClient) CheckAccess(accountName string, pathParameter string, op string, fsaction string) (result autorest.Response, err error)

CheckAccess checks if the specified access is available at the given path.

accountName is the Azure Data Lake Store account to execute filesystem operations on. pathParameter is the Data Lake Store path (starting with '/') of the file or directory for which to check access. op is the constant value for the operation. fsaction is file system operation read/write/execute in string form, matching regex pattern '[rwx-]{3}'

func (GroupClient) CheckAccessPreparer 

func (client GroupClient) CheckAccessPreparer(accountName string, pathParameter string, op string, fsaction string) (*http.Request, error)

CheckAccessPreparer prepares the CheckAccess request.

func (GroupClient) CheckAccessResponder 

func (client GroupClient) CheckAccessResponder(resp *http.Response) (result autorest.Response, err error)

CheckAccessResponder handles the response to the CheckAccess request. The method always closes the http.Response Body.

func (GroupClient) CheckAccessSender 

func (client GroupClient) CheckAccessSender(req *http.Request) (*http.Response, error)

CheckAccessSender sends the CheckAccess request. The method will close the http.Response Body if it receives an error.

func (GroupClient) Concat 

func (client GroupClient) Concat(accountName string, destinationPath string, sources []string, op string) (result autorest.Response, err error)

Concat concatenates the list of source files into the destination file, removing all source files upon success.

accountName is the Azure Data Lake Store account to execute filesystem operations on. destinationPath is the Data Lake Store path (starting with '/') of the destination file resulting from the concatenation. sources is a list of comma seperated Data Lake Store paths (starting with '/') of the files to concatenate, in the order in which they should be concatenated. op is the constant value for the operation.

func (GroupClient) ConcatPreparer 

func (client GroupClient) ConcatPreparer(accountName string, destinationPath string, sources []string, op string) (*http.Request, error)

ConcatPreparer prepares the Concat request.

func (GroupClient) ConcatResponder 

func (client GroupClient) ConcatResponder(resp *http.Response) (result autorest.Response, err error)

ConcatResponder handles the response to the Concat request. The method always closes the http.Response Body.

func (GroupClient) ConcatSender 

func (client GroupClient) ConcatSender(req *http.Request) (*http.Response, error)

ConcatSender sends the Concat request. The method will close the http.Response Body if it receives an error.

func (GroupClient) ConcurrentAppend 

func (client GroupClient) ConcurrentAppend(accountName string, filePath string, streamContents io.ReadCloser, op string, transferEncoding string, appendMode AppendModeType) (result autorest.Response, err error)

ConcurrentAppend appends to the specified file. This method supports multiple concurrent appends to the file. NOTE: ConcurrentAppend and normal (serial) Append CANNOT be used interchangeably; once a file has been appended to using either of these append options, it can only be appended to using that append option. ConcurrentAppend DOES NOT guarantee order and can result in duplicated data landing in the target file. In order to close a file after using ConcurrentAppend, call the Flush method.

accountName is the Azure Data Lake Store account to execute filesystem operations on. filePath is the Data Lake Store path (starting with '/') of the file to which to append using concurrent append. streamContents is the file contents to include when appending to the file. streamContents will be closed upon successful return. Callers should ensure closure when receiving an error.op is the constant value for the operation. transferEncoding is indicates the data being sent to the server is being streamed in chunks. appendMode is indicates the concurrent append call should create the file if it doesn't exist or just open the existing file for append

func (GroupClient) ConcurrentAppendPreparer 

func (client GroupClient) ConcurrentAppendPreparer(accountName string, filePath string, streamContents io.ReadCloser, op string, transferEncoding string, appendMode AppendModeType) (*http.Request, error)

ConcurrentAppendPreparer prepares the ConcurrentAppend request.

func (GroupClient) ConcurrentAppendResponder 

func (client GroupClient) ConcurrentAppendResponder(resp *http.Response) (result autorest.Response, err error)

ConcurrentAppendResponder handles the response to the ConcurrentAppend request. The method always closes the http.Response Body.

func (GroupClient) ConcurrentAppendSender 

func (client GroupClient) ConcurrentAppendSender(req *http.Request) (*http.Response, error)

ConcurrentAppendSender sends the ConcurrentAppend request. The method will close the http.Response Body if it receives an error.

func (GroupClient) Create 

func (client GroupClient) Create(accountName string, directFilePath string, op string, write string, streamContents io.ReadCloser, overwrite *bool) (result autorest.Response, err error)

Create creates a file with optionally specified content.

accountName is the Azure Data Lake Store account to execute filesystem operations on. directFilePath is the Data Lake Store path (starting with '/') of the file to create. op is the constant value for the operation. write is the constant value for the operation. streamContents is the file contents to include when creating the file. This parameter is optional, resulting in an empty file if not specified. streamContents will be closed upon successful return. Callers should ensure closure when receiving an error.overwrite is the indication of if the file should be overwritten.

func (GroupClient) CreatePreparer 

func (client GroupClient) CreatePreparer(accountName string, directFilePath string, op string, write string, streamContents io.ReadCloser, overwrite *bool) (*http.Request, error)

CreatePreparer prepares the Create request.

func (GroupClient) CreateResponder 

func (client GroupClient) CreateResponder(resp *http.Response) (result autorest.Response, err error)

CreateResponder handles the response to the Create request. The method always closes the http.Response Body.

func (GroupClient) CreateSender 

func (client GroupClient) CreateSender(req *http.Request) (*http.Response, error)

CreateSender sends the Create request. The method will close the http.Response Body if it receives an error.

func (GroupClient) Delete 

func (client GroupClient) Delete(accountName string, filePath string, op string, recursive *bool) (result FileOperationResult, err error)

Delete deletes the requested file or directory, optionally recursively.

accountName is the Azure Data Lake Store account to execute filesystem operations on. filePath is the Data Lake Store path (starting with '/') of the file or directory to delete. op is the constant value for the operation. recursive is the optional switch indicating if the delete should be recursive

func (GroupClient) DeletePreparer 

func (client GroupClient) DeletePreparer(accountName string, filePath string, op string, recursive *bool) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (GroupClient) DeleteResponder 

func (client GroupClient) DeleteResponder(resp *http.Response) (result FileOperationResult, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (GroupClient) DeleteSender 

func (client GroupClient) DeleteSender(req *http.Request) (*http.Response, error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (GroupClient) Flush 

func (client GroupClient) Flush(accountName string, flushFilePath string, op string, appendParameter string, flush string) (result autorest.Response, err error)

Flush flushes the specified file to the store. This forces an update to the metadata of the file (returned from GetFileStatus), and is required by ConcurrentAppend once the file is done to populate finalized metadata.

accountName is the Azure Data Lake Store account to execute filesystem operations on. flushFilePath is the Data Lake Store path (starting with '/') of the file to which to flush. op is the constant value for the operation. appendParameter is the constant value that avoids redirects. flush is the constant value initiating the flush.

func (GroupClient) FlushPreparer 

func (client GroupClient) FlushPreparer(accountName string, flushFilePath string, op string, appendParameter string, flush string) (*http.Request, error)

FlushPreparer prepares the Flush request.

func (GroupClient) FlushResponder 

func (client GroupClient) FlushResponder(resp *http.Response) (result autorest.Response, err error)

FlushResponder handles the response to the Flush request. The method always closes the http.Response Body.

func (GroupClient) FlushSender 

func (client GroupClient) FlushSender(req *http.Request) (*http.Response, error)

FlushSender sends the Flush request. The method will close the http.Response Body if it receives an error.

func (GroupClient) GetACLStatus 

func (client GroupClient) GetACLStatus(accountName string, ACLFilePath string, op string) (result ACLStatusResult, err error)

GetACLStatus gets Access Control List (ACL) entries for the specified file or directory.

accountName is the Azure Data Lake Store account to execute filesystem operations on. ACLFilePath is the Data Lake Store path (starting with '/') of the file or directory for which to get the ACL. op is the constant value for the operation.

func (GroupClient) GetACLStatusPreparer 

func (client GroupClient) GetACLStatusPreparer(accountName string, ACLFilePath string, op string) (*http.Request, error)

GetACLStatusPreparer prepares the GetACLStatus request.

func (GroupClient) GetACLStatusResponder 

func (client GroupClient) GetACLStatusResponder(resp *http.Response) (result ACLStatusResult, err error)

GetACLStatusResponder handles the response to the GetACLStatus request. The method always closes the http.Response Body.

func (GroupClient) GetACLStatusSender 

func (client GroupClient) GetACLStatusSender(req *http.Request) (*http.Response, error)

GetACLStatusSender sends the GetACLStatus request. The method will close the http.Response Body if it receives an error.

func (GroupClient) GetContentSummary 

func (client GroupClient) GetContentSummary(accountName string, getContentSummaryFilePath string, op string) (result ContentSummaryResult, err error)

GetContentSummary gets the file content summary object specified by the file path.

accountName is the Azure Data Lake Store account to execute filesystem operations on. getContentSummaryFilePath is the Data Lake Store path (starting with '/') of the file for which to retrieve the summary. op is the constant value for the operation.

func (GroupClient) GetContentSummaryPreparer 

func (client GroupClient) GetContentSummaryPreparer(accountName string, getContentSummaryFilePath string, op string) (*http.Request, error)

GetContentSummaryPreparer prepares the GetContentSummary request.

func (GroupClient) GetContentSummaryResponder 

func (client GroupClient) GetContentSummaryResponder(resp *http.Response) (result ContentSummaryResult, err error)

GetContentSummaryResponder handles the response to the GetContentSummary request. The method always closes the http.Response Body.

func (GroupClient) GetContentSummarySender 

func (client GroupClient) GetContentSummarySender(req *http.Request) (*http.Response, error)

GetContentSummarySender sends the GetContentSummary request. The method will close the http.Response Body if it receives an error.

func (GroupClient) GetFileStatus 

func (client GroupClient) GetFileStatus(accountName string, getFilePath string, op string) (result FileStatusResult, err error)

GetFileStatus get the file status object specified by the file path.

accountName is the Azure Data Lake Store account to execute filesystem operations on. getFilePath is the Data Lake Store path (starting with '/') of the file or directory for which to retrieve the status. op is the constant value for the operation.

func (GroupClient) GetFileStatusPreparer 

func (client GroupClient) GetFileStatusPreparer(accountName string, getFilePath string, op string) (*http.Request, error)

GetFileStatusPreparer prepares the GetFileStatus request.

func (GroupClient) GetFileStatusResponder 

func (client GroupClient) GetFileStatusResponder(resp *http.Response) (result FileStatusResult, err error)

GetFileStatusResponder handles the response to the GetFileStatus request. The method always closes the http.Response Body.

func (GroupClient) GetFileStatusSender 

func (client GroupClient) GetFileStatusSender(req *http.Request) (*http.Response, error)

GetFileStatusSender sends the GetFileStatus request. The method will close the http.Response Body if it receives an error.

func (GroupClient) ListFileStatus 

func (client GroupClient) ListFileStatus(accountName string, listFilePath string, op string, listSize *int32, listAfter string, listBefore string) (result FileStatusesResult, err error)

ListFileStatus get the list of file status objects specified by the file path, with optional pagination parameters

accountName is the Azure Data Lake Store account to execute filesystem operations on. listFilePath is the Data Lake Store path (starting with '/') of the directory to list. op is the constant value for the operation. listSize is gets or sets the number of items to return. Optional. listAfter is gets or sets the item or lexographical index after which to begin returning results. For example, a file list of 'a','b','d' and listAfter='b' will return 'd', and a listAfter='c' will also return 'd'. Optional. listBefore is gets or sets the item or lexographical index before which to begin returning results. For example, a file list of 'a','b','d' and listBefore='d' will return 'a','b', and a listBefore='c' will also return 'a','b'. Optional.

func (GroupClient) ListFileStatusPreparer 

func (client GroupClient) ListFileStatusPreparer(accountName string, listFilePath string, op string, listSize *int32, listAfter string, listBefore string) (*http.Request, error)

ListFileStatusPreparer prepares the ListFileStatus request.

func (GroupClient) ListFileStatusResponder 

func (client GroupClient) ListFileStatusResponder(resp *http.Response) (result FileStatusesResult, err error)

ListFileStatusResponder handles the response to the ListFileStatus request. The method always closes the http.Response Body.

func (GroupClient) ListFileStatusSender 

func (client GroupClient) ListFileStatusSender(req *http.Request) (*http.Response, error)

ListFileStatusSender sends the ListFileStatus request. The method will close the http.Response Body if it receives an error.

func (GroupClient) Mkdirs 

func (client GroupClient) Mkdirs(accountName string, pathParameter string, op string) (result FileOperationResult, err error)

Mkdirs creates a directory.

accountName is the Azure Data Lake Store account to execute filesystem operations on. pathParameter is the Data Lake Store path (starting with '/') of the directory to create. op is the constant value for the operation.

func (GroupClient) MkdirsPreparer 

func (client GroupClient) MkdirsPreparer(accountName string, pathParameter string, op string) (*http.Request, error)

MkdirsPreparer prepares the Mkdirs request.

func (GroupClient) MkdirsResponder 

func (client GroupClient) MkdirsResponder(resp *http.Response) (result FileOperationResult, err error)

MkdirsResponder handles the response to the Mkdirs request. The method always closes the http.Response Body.

func (GroupClient) MkdirsSender 

func (client GroupClient) MkdirsSender(req *http.Request) (*http.Response, error)

MkdirsSender sends the Mkdirs request. The method will close the http.Response Body if it receives an error.

func (GroupClient) ModifyACLEntries 

func (client GroupClient) ModifyACLEntries(accountName string, modifyACLFilePath string, aclspec string, op string) (result autorest.Response, err error)

ModifyACLEntries modifies existing Access Control List (ACL) entries on a file or folder.

accountName is the Azure Data Lake Store account to execute filesystem operations on. modifyACLFilePath is the Data Lake Store path (starting with '/') of the file or directory with the ACL being modified. aclspec is the ACL specification included in ACL modification operations in the format '[default:]user|group|other::r|-w|-x|-' op is the constant value for the operation.

func (GroupClient) ModifyACLEntriesPreparer 

func (client GroupClient) ModifyACLEntriesPreparer(accountName string, modifyACLFilePath string, aclspec string, op string) (*http.Request, error)

ModifyACLEntriesPreparer prepares the ModifyACLEntries request.

func (GroupClient) ModifyACLEntriesResponder 

func (client GroupClient) ModifyACLEntriesResponder(resp *http.Response) (result autorest.Response, err error)

ModifyACLEntriesResponder handles the response to the ModifyACLEntries request. The method always closes the http.Response Body.

func (GroupClient) ModifyACLEntriesSender 

func (client GroupClient) ModifyACLEntriesSender(req *http.Request) (*http.Response, error)

ModifyACLEntriesSender sends the ModifyACLEntries request. The method will close the http.Response Body if it receives an error.

func (GroupClient) MsConcat 

func (client GroupClient) MsConcat(accountName string, msConcatDestinationPath string, streamContents io.ReadCloser, op string, deleteSourceDirectory *bool) (result autorest.Response, err error)

MsConcat concatenates the list of source files into the destination file, deleting all source files upon success. This method accepts more source file paths than the Concat method. This method and the parameters it accepts are subject to change for usability in an upcoming version.

accountName is the Azure Data Lake Store account to execute filesystem operations on. msConcatDestinationPath is the Data Lake Store path (starting with '/') of the destination file resulting from the concatenation. streamContents is a list of Data Lake Store paths (starting with '/') of the source files. Must be in the format: sources=<comma separated list> streamContents will be closed upon successful return. Callers should ensure closure when receiving an error.op is the constant value for the operation. deleteSourceDirectory is indicates that as an optimization instead of deleting each individual source stream, delete the source stream folder if all streams are in the same folder instead. This results in a substantial performance improvement when the only streams in the folder are part of the concatenation operation. WARNING: This includes the deletion of any other files that are not source files. Only set this to true when source files are the only files in the source directory.

func (GroupClient) MsConcatPreparer 

func (client GroupClient) MsConcatPreparer(accountName string, msConcatDestinationPath string, streamContents io.ReadCloser, op string, deleteSourceDirectory *bool) (*http.Request, error)

MsConcatPreparer prepares the MsConcat request.

func (GroupClient) MsConcatResponder 

func (client GroupClient) MsConcatResponder(resp *http.Response) (result autorest.Response, err error)

MsConcatResponder handles the response to the MsConcat request. The method always closes the http.Response Body.

func (GroupClient) MsConcatSender 

func (client GroupClient) MsConcatSender(req *http.Request) (*http.Response, error)

MsConcatSender sends the MsConcat request. The method will close the http.Response Body if it receives an error.

func (GroupClient) Open 

func (client GroupClient) Open(accountName string, directFilePath string, op string, read string, length *int64, offset *int64) (result ReadCloser, err error)

Open opens and reads from the specified file.

accountName is the Azure Data Lake Store account to execute filesystem operations on. directFilePath is the Data Lake Store path (starting with '/') of the file to open. op is the constant value for the operation. read is the constant value for the operation.

func (GroupClient) OpenPreparer 

func (client GroupClient) OpenPreparer(accountName string, directFilePath string, op string, read string, length *int64, offset *int64) (*http.Request, error)

OpenPreparer prepares the Open request.

func (GroupClient) OpenResponder 

func (client GroupClient) OpenResponder(resp *http.Response) (result ReadCloser, err error)

OpenResponder handles the response to the Open request. The method always closes the http.Response Body.

func (GroupClient) OpenSender 

func (client GroupClient) OpenSender(req *http.Request) (*http.Response, error)

OpenSender sends the Open request. The method will close the http.Response Body if it receives an error.

func (GroupClient) RemoveACL 

func (client GroupClient) RemoveACL(accountName string, ACLFilePath string, op string) (result autorest.Response, err error)

RemoveACL removes the existing Access Control List (ACL) of the specified file or directory.

accountName is the Azure Data Lake Store account to execute filesystem operations on. ACLFilePath is the Data Lake Store path (starting with '/') of the file or directory with the ACL being removed. op is the constant value for the operation.

func (GroupClient) RemoveACLEntries 

func (client GroupClient) RemoveACLEntries(accountName string, removeACLFilePath string, aclspec string, op string) (result autorest.Response, err error)

RemoveACLEntries removes existing Access Control List (ACL) entries for a file or folder.

accountName is the Azure Data Lake Store account to execute filesystem operations on. removeACLFilePath is the Data Lake Store path (starting with '/') of the file or directory with the ACL being removed. aclspec is the ACL spec included in ACL removal operations in the format '[default:]user|group|other' op is the constant value for the operation.

func (GroupClient) RemoveACLEntriesPreparer 

func (client GroupClient) RemoveACLEntriesPreparer(accountName string, removeACLFilePath string, aclspec string, op string) (*http.Request, error)

RemoveACLEntriesPreparer prepares the RemoveACLEntries request.

func (GroupClient) RemoveACLEntriesResponder 

func (client GroupClient) RemoveACLEntriesResponder(resp *http.Response) (result autorest.Response, err error)

RemoveACLEntriesResponder handles the response to the RemoveACLEntries request. The method always closes the http.Response Body.

func (GroupClient) RemoveACLEntriesSender 

func (client GroupClient) RemoveACLEntriesSender(req *http.Request) (*http.Response, error)

RemoveACLEntriesSender sends the RemoveACLEntries request. The method will close the http.Response Body if it receives an error.

func (GroupClient) RemoveACLPreparer 

func (client GroupClient) RemoveACLPreparer(accountName string, ACLFilePath string, op string) (*http.Request, error)

RemoveACLPreparer prepares the RemoveACL request.

func (GroupClient) RemoveACLResponder 

func (client GroupClient) RemoveACLResponder(resp *http.Response) (result autorest.Response, err error)

RemoveACLResponder handles the response to the RemoveACL request. The method always closes the http.Response Body.

func (GroupClient) RemoveACLSender 

func (client GroupClient) RemoveACLSender(req *http.Request) (*http.Response, error)

RemoveACLSender sends the RemoveACL request. The method will close the http.Response Body if it receives an error.

func (GroupClient) RemoveDefaultACL 

func (client GroupClient) RemoveDefaultACL(accountName string, defaultACLFilePath string, op string) (result autorest.Response, err error)

RemoveDefaultACL removes the existing Default Access Control List (ACL) of the specified directory.

accountName is the Azure Data Lake Store account to execute filesystem operations on. defaultACLFilePath is the Data Lake Store path (starting with '/') of the directory with the default ACL being removed. op is the constant value for the operation.

func (GroupClient) RemoveDefaultACLPreparer 

func (client GroupClient) RemoveDefaultACLPreparer(accountName string, defaultACLFilePath string, op string) (*http.Request, error)

RemoveDefaultACLPreparer prepares the RemoveDefaultACL request.

func (GroupClient) RemoveDefaultACLResponder 

func (client GroupClient) RemoveDefaultACLResponder(resp *http.Response) (result autorest.Response, err error)

RemoveDefaultACLResponder handles the response to the RemoveDefaultACL request. The method always closes the http.Response Body.

func (GroupClient) RemoveDefaultACLSender 

func (client GroupClient) RemoveDefaultACLSender(req *http.Request) (*http.Response, error)

RemoveDefaultACLSender sends the RemoveDefaultACL request. The method will close the http.Response Body if it receives an error.

func (GroupClient) Rename 

func (client GroupClient) Rename(accountName string, renameFilePath string, destination string, op string) (result FileOperationResult, err error)

Rename rename a file or directory.

accountName is the Azure Data Lake Store account to execute filesystem operations on. renameFilePath is the Data Lake Store path (starting with '/') of the file or directory to move/rename. destination is the path to move/rename the file or folder to op is the constant value for the operation.

func (GroupClient) RenamePreparer 

func (client GroupClient) RenamePreparer(accountName string, renameFilePath string, destination string, op string) (*http.Request, error)

RenamePreparer prepares the Rename request.

func (GroupClient) RenameResponder 

func (client GroupClient) RenameResponder(resp *http.Response) (result FileOperationResult, err error)

RenameResponder handles the response to the Rename request. The method always closes the http.Response Body.

func (GroupClient) RenameSender 

func (client GroupClient) RenameSender(req *http.Request) (*http.Response, error)

RenameSender sends the Rename request. The method will close the http.Response Body if it receives an error.

func (GroupClient) SetACL 

func (client GroupClient) SetACL(accountName string, setACLFilePath string, aclspec string, op string) (result autorest.Response, err error)

SetACL sets the Access Control List (ACL) for a file or folder.

accountName is the Azure Data Lake Store account to execute filesystem operations on. setACLFilePath is the Data Lake Store path (starting with '/') of the file or directory on which to set the ACL. aclspec is the ACL spec included in ACL creation operations in the format '[default:]user|group|other::r|-w|-x|-' op is the constant value for the operation.

func (GroupClient) SetACLPreparer 

func (client GroupClient) SetACLPreparer(accountName string, setACLFilePath string, aclspec string, op string) (*http.Request, error)

SetACLPreparer prepares the SetACL request.

func (GroupClient) SetACLResponder 

func (client GroupClient) SetACLResponder(resp *http.Response) (result autorest.Response, err error)

SetACLResponder handles the response to the SetACL request. The method always closes the http.Response Body.

func (GroupClient) SetACLSender 

func (client GroupClient) SetACLSender(req *http.Request) (*http.Response, error)

SetACLSender sends the SetACL request. The method will close the http.Response Body if it receives an error.

func (GroupClient) SetFileExpiry 

func (client GroupClient) SetFileExpiry(accountName string, filePath string, expiryOption ExpiryOptionType, op string, expireTime *int64) (result autorest.Response, err error)

SetFileExpiry sets or removes the expiration time on the specified file. This operation can only be executed against files. Folders are not supported.

accountName is the Azure Data Lake Store account to execute filesystem operations on. filePath is the Data Lake Store path (starting with '/') of the file on which to set or remove the expiration time. expiryOption is indicates the type of expiration to use for the file: 1. NeverExpire: ExpireTime is ignored. 2. RelativeToNow: ExpireTime is an integer in milliseconds representing the expiration date relative to when file expiration is updated. 3. RelativeToCreationDate: ExpireTime is an integer in milliseconds representing the expiration date relative to file creation. 4. Absolute: ExpireTime is an integer in milliseconds, as a Unix timestamp relative to 1/1/1970 00:00:00. op is the constant value for the operation. expireTime is the time that the file will expire, corresponding to the ExpiryOption that was set.

func (GroupClient) SetFileExpiryPreparer 

func (client GroupClient) SetFileExpiryPreparer(accountName string, filePath string, expiryOption ExpiryOptionType, op string, expireTime *int64) (*http.Request, error)

SetFileExpiryPreparer prepares the SetFileExpiry request.

func (GroupClient) SetFileExpiryResponder 

func (client GroupClient) SetFileExpiryResponder(resp *http.Response) (result autorest.Response, err error)

SetFileExpiryResponder handles the response to the SetFileExpiry request. The method always closes the http.Response Body.

func (GroupClient) SetFileExpirySender 

func (client GroupClient) SetFileExpirySender(req *http.Request) (*http.Response, error)

SetFileExpirySender sends the SetFileExpiry request. The method will close the http.Response Body if it receives an error.

func (GroupClient) SetOwner 

func (client GroupClient) SetOwner(accountName string, setOwnerFilePath string, op string, owner string, group string) (result autorest.Response, err error)

SetOwner sets the owner of a file or directory.

accountName is the Azure Data Lake Store account to execute filesystem operations on. setOwnerFilePath is the Data Lake Store path (starting with '/') of the file or directory for which to set the owner. op is the constant value for the operation. owner is the AAD Object ID of the user owner of the file or directory. If empty, the property will remain unchanged. group is the AAD Object ID of the group owner of the file or directory. If empty, the property will remain unchanged.

func (GroupClient) SetOwnerPreparer 

func (client GroupClient) SetOwnerPreparer(accountName string, setOwnerFilePath string, op string, owner string, group string) (*http.Request, error)

SetOwnerPreparer prepares the SetOwner request.

func (GroupClient) SetOwnerResponder 

func (client GroupClient) SetOwnerResponder(resp *http.Response) (result autorest.Response, err error)

SetOwnerResponder handles the response to the SetOwner request. The method always closes the http.Response Body.

func (GroupClient) SetOwnerSender 

func (client GroupClient) SetOwnerSender(req *http.Request) (*http.Response, error)

SetOwnerSender sends the SetOwner request. The method will close the http.Response Body if it receives an error.

func (GroupClient) SetPermission 

func (client GroupClient) SetPermission(accountName string, setPermissionFilePath string, op string, permission string) (result autorest.Response, err error)

SetPermission sets the permission of the file or folder.

accountName is the Azure Data Lake Store account to execute filesystem operations on. setPermissionFilePath is the Data Lake Store path (starting with '/') of the file or directory for which to set the permission. op is the constant value for the operation. permission is a string representation of the permission (i.e 'rwx'). If empty, this property remains unchanged.

func (GroupClient) SetPermissionPreparer 

func (client GroupClient) SetPermissionPreparer(accountName string, setPermissionFilePath string, op string, permission string) (*http.Request, error)

SetPermissionPreparer prepares the SetPermission request.

func (GroupClient) SetPermissionResponder 

func (client GroupClient) SetPermissionResponder(resp *http.Response) (result autorest.Response, err error)

SetPermissionResponder handles the response to the SetPermission request. The method always closes the http.Response Body.

func (GroupClient) SetPermissionSender 

func (client GroupClient) SetPermissionSender(req *http.Request) (*http.Response, error)

SetPermissionSender sends the SetPermission request. The method will close the http.Response Body if it receives an error.

type ManagementClient 

type ManagementClient struct {
	autorest.Client
	AdlsFileSystemDNSSuffix string
}

ManagementClient is the base client for Filesystem.

func New 

func New() ManagementClient

New creates an instance of the ManagementClient client.

func NewWithoutDefaults 

func NewWithoutDefaults(adlsFileSystemDNSSuffix string) ManagementClient

NewWithoutDefaults creates an instance of the ManagementClient client.

type ReadCloser 

type ReadCloser struct {
	autorest.Response `json:"-"`
	Value             *io.ReadCloser `json:"value,omitempty"`
}

ReadCloser is

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.