common

package

Go to main page

Versions in this module

v0

v0.24.2

Jan 16, 2022

Changes in this version

+ type GCSConfig struct

+ ChunkSize int

+ Credentials *google.Credentials

+ func NewGCSConfig() *GCSConfig

v0.24.0

Apr 4, 2020

Changes in this version

type FusePanicLogger

+ func (fs FusePanicLogger) Fallocate(ctx context.Context, op *fuseops.FallocateOp) (err error)

type S3Config

+ BucketOwner string

v0.23.1

Nov 17, 2019

v0.23.0

Nov 13, 2019

v0.22.0

Nov 2, 2019

Changes in this version

+ func GetHTTPTransport() *http.Transport

v0.21.0

Aug 21, 2019

Changes in this version

+ const DEBUG_TAG

+ const ERR_TAG

+ 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) 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

+ 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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL