Versions in this module Expand all Collapse all v0 v0.24.0 Apr 4, 2020 Changes in this version + const DEBUG_TAG + const ERR_TAG + func GetHTTPTransport() *http.Transport + func GetStdLogger(l *LogHandle, lvl logrus.Level) *glog.Logger + func InitLoggers(logToSyslog bool) + func LogPanic(err *error) + func SetCloudLogLevel(level logrus.Level) + type ADLv1Config struct + Authorizer autorest.Authorizer + Endpoint string + func (config *ADLv1Config) Init() + type ADLv2Config struct + Authorizer autorest.Authorizer + Endpoint string + type AZBlobConfig struct + AccountKey string + AccountName string + Container string + Endpoint string + Prefix string + SasToken SASTokenProvider + TokenRenewBuffer time.Duration + func AzureBlobConfig(endpoint string, location string, storageType string) (config AZBlobConfig, err error) + func (config *AZBlobConfig) Init() + func (config *AZBlobConfig) WithAuthorization() autorest.PrepareDecorator + type AzureAuthorizerConfig struct + Log *LogHandle + TenantId string + func (c AzureAuthorizerConfig) Authorizer() (autorest.Authorizer, error) + type FlagStorage struct + Backend interface{} + Cache []string + Cheap bool + DebugFuse bool + DebugS3 bool + DirMode os.FileMode + Endpoint string + ExplicitDir bool + FileMode os.FileMode + Foreground bool + Gid uint32 + HTTPTimeout time.Duration + MountOptions map[string]string + MountPoint string + MountPointArg string + MountPointCreated string + StatCacheTTL time.Duration + TypeCacheTTL time.Duration + Uid uint32 + UseContentType bool + func (flags *FlagStorage) Cleanup() + func (flags *FlagStorage) GetMimeType(fileName string) (retMime *string) + type FusePanicLogger struct + Fs fuseutil.FileSystem + func (fs FusePanicLogger) CreateFile(ctx context.Context, op *fuseops.CreateFileOp) (err error) + func (fs FusePanicLogger) CreateLink(ctx context.Context, op *fuseops.CreateLinkOp) (err error) + func (fs FusePanicLogger) CreateSymlink(ctx context.Context, op *fuseops.CreateSymlinkOp) (err error) + func (fs FusePanicLogger) Destroy() + func (fs FusePanicLogger) Fallocate(ctx context.Context, op *fuseops.FallocateOp) (err error) + func (fs FusePanicLogger) FlushFile(ctx context.Context, op *fuseops.FlushFileOp) (err error) + func (fs FusePanicLogger) ForgetInode(ctx context.Context, op *fuseops.ForgetInodeOp) (err error) + func (fs FusePanicLogger) GetInodeAttributes(ctx context.Context, op *fuseops.GetInodeAttributesOp) (err error) + func (fs FusePanicLogger) GetXattr(ctx context.Context, op *fuseops.GetXattrOp) (err error) + func (fs FusePanicLogger) ListXattr(ctx context.Context, op *fuseops.ListXattrOp) (err error) + func (fs FusePanicLogger) LookUpInode(ctx context.Context, op *fuseops.LookUpInodeOp) (err error) + func (fs FusePanicLogger) MkDir(ctx context.Context, op *fuseops.MkDirOp) (err error) + func (fs FusePanicLogger) MkNode(ctx context.Context, op *fuseops.MkNodeOp) (err error) + func (fs FusePanicLogger) OpenDir(ctx context.Context, op *fuseops.OpenDirOp) (err error) + func (fs FusePanicLogger) OpenFile(ctx context.Context, op *fuseops.OpenFileOp) (err error) + func (fs FusePanicLogger) ReadDir(ctx context.Context, op *fuseops.ReadDirOp) (err error) + func (fs FusePanicLogger) ReadFile(ctx context.Context, op *fuseops.ReadFileOp) (err error) + func (fs FusePanicLogger) ReadSymlink(ctx context.Context, op *fuseops.ReadSymlinkOp) (err error) + func (fs FusePanicLogger) ReleaseDirHandle(ctx context.Context, op *fuseops.ReleaseDirHandleOp) (err error) + func (fs FusePanicLogger) ReleaseFileHandle(ctx context.Context, op *fuseops.ReleaseFileHandleOp) (err error) + func (fs FusePanicLogger) RemoveXattr(ctx context.Context, op *fuseops.RemoveXattrOp) (err error) + func (fs FusePanicLogger) Rename(ctx context.Context, op *fuseops.RenameOp) (err error) + func (fs FusePanicLogger) RmDir(ctx context.Context, op *fuseops.RmDirOp) (err error) + func (fs FusePanicLogger) SetInodeAttributes(ctx context.Context, op *fuseops.SetInodeAttributesOp) (err error) + func (fs FusePanicLogger) SetXattr(ctx context.Context, op *fuseops.SetXattrOp) (err error) + func (fs FusePanicLogger) StatFS(ctx context.Context, op *fuseops.StatFSOp) (err error) + func (fs FusePanicLogger) SyncFile(ctx context.Context, op *fuseops.SyncFileOp) (err error) + func (fs FusePanicLogger) Unlink(ctx context.Context, op *fuseops.UnlinkOp) (err error) + func (fs FusePanicLogger) WriteFile(ctx context.Context, op *fuseops.WriteFileOp) (err error) + type LogHandle struct + Lvl *logrus.Level + func GetLogger(name string) *LogHandle + func NewLogger(name string) *LogHandle + func (l *LogHandle) Format(e *logrus.Entry) ([]byte, error) + func (l *LogHandle) Log(args ...interface{}) + type RetryHTTPLogger struct + func (logger RetryHTTPLogger) Printf(format string, args ...interface{}) + type S3Config struct + ACL string + AccessKey string + BucketOwner string + Credentials *credentials.Credentials + KMSKeyID string + Profile string + Region string + RegionSet bool + RequesterPays bool + RoleArn string + RoleExternalId string + RoleSessionName string + SecretKey string + Session *session.Session + SseC string + SseCDigest string + StorageClass string + StsEndpoint string + Subdomain bool + UseKMS bool + UseSSE bool + func (c *S3Config) Init() *S3Config + func (c *S3Config) ToAwsConfig(flags *FlagStorage) (*aws.Config, error) + type SASTokenProvider func() (string, error)