common

package
v0.24.3 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2024 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

View Source 
const DEBUG_TAG = "[DEBUG]"
View Source 
const ERR_TAG = "[ERR]"

Variables

This section is empty.

Functions

func GetHTTPTransport added in v0.22.0 

func GetHTTPTransport() *http.Transport

func GetStdLogger 

func GetStdLogger(l *LogHandle, lvl logrus.Level) *glog.Logger

func InitLoggers 

func InitLoggers(logToSyslog bool)

func LogPanic 

func LogPanic(err *error)

func SetCloudLogLevel 

func SetCloudLogLevel(level logrus.Level)

Types

type ADLv1Config 

type ADLv1Config struct {
	Endpoint   string
	Authorizer autorest.Authorizer
}

func (*ADLv1Config) Init 

func (config *ADLv1Config) Init()

type ADLv2Config 

type ADLv2Config struct {
	Endpoint   string
	Authorizer autorest.Authorizer
}

type AZBlobConfig 

type AZBlobConfig struct {
	Endpoint         string
	AccountName      string
	AccountKey       string
	SasToken         SASTokenProvider
	TokenRenewBuffer time.Duration

	Container string
	Prefix    string
}

func AzureBlobConfig 

func AzureBlobConfig(endpoint string, location string, storageType string) (config AZBlobConfig, err error)

func (*AZBlobConfig) Init 

func (config *AZBlobConfig) Init()

func (*AZBlobConfig) WithAuthorization 

func (config *AZBlobConfig) WithAuthorization() autorest.PrepareDecorator

hijack the SharedKeyCredentials signing code from azure-storage-blob-go https://github.com/Azure/go-autorest/issues/456

type AzureAuthorizerConfig 

type AzureAuthorizerConfig struct {
	Log      *LogHandle
	TenantId string
}

func (AzureAuthorizerConfig) Authorizer 

func (c AzureAuthorizerConfig) Authorizer() (autorest.Authorizer, error)

type FlagStorage 

type FlagStorage struct {
	PidFile string

	// File system
	MountOptions      map[string]string
	MountPoint        string
	MountPointArg     string
	MountPointCreated string

	Cache    []string
	DirMode  os.FileMode
	FileMode os.FileMode
	Uid      uint32
	Gid      uint32

	// Common Backend Config
	UseContentType bool
	Endpoint       string

	Backend interface{}

	// Tuning
	Cheap        bool
	ExplicitDir  bool
	StatCacheTTL time.Duration
	TypeCacheTTL time.Duration
	HTTPTimeout  time.Duration

	// Debugging
	DebugFuse  bool
	DebugS3    bool
	Foreground bool
}

func (*FlagStorage) Cleanup 

func (flags *FlagStorage) Cleanup()

func (*FlagStorage) GetMimeType 

func (flags *FlagStorage) GetMimeType(fileName string) (retMime *string)

type FusePanicLogger 

type FusePanicLogger struct {
	Fs fuseutil.FileSystem
}

func (FusePanicLogger) BatchForget added in v0.24.1 

func (fs FusePanicLogger) BatchForget(ctx context.Context, op *fuseops.BatchForgetOp) (err error)

func (FusePanicLogger) CreateFile 

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 (FusePanicLogger) Destroy 

func (fs FusePanicLogger) Destroy()

func (FusePanicLogger) Fallocate added in v0.24.0 

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

func (FusePanicLogger) FlushFile 

func (fs FusePanicLogger) FlushFile(ctx context.Context, op *fuseops.FlushFileOp) (err error)

func (FusePanicLogger) ForgetInode 

func (fs FusePanicLogger) ForgetInode(ctx context.Context, op *fuseops.ForgetInodeOp) (err error)

func (FusePanicLogger) GetInodeAttributes 

func (fs FusePanicLogger) GetInodeAttributes(ctx context.Context, op *fuseops.GetInodeAttributesOp) (err error)

func (FusePanicLogger) GetXattr 

func (fs FusePanicLogger) GetXattr(ctx context.Context, op *fuseops.GetXattrOp) (err error)

func (FusePanicLogger) ListXattr 

func (fs FusePanicLogger) ListXattr(ctx context.Context, op *fuseops.ListXattrOp) (err error)

func (FusePanicLogger) LookUpInode 

func (fs FusePanicLogger) LookUpInode(ctx context.Context, op *fuseops.LookUpInodeOp) (err error)

func (FusePanicLogger) MkDir 

func (fs FusePanicLogger) MkDir(ctx context.Context, op *fuseops.MkDirOp) (err error)

func (FusePanicLogger) MkNode 

func (fs FusePanicLogger) MkNode(ctx context.Context, op *fuseops.MkNodeOp) (err error)

func (FusePanicLogger) OpenDir 

func (fs FusePanicLogger) OpenDir(ctx context.Context, op *fuseops.OpenDirOp) (err error)

func (FusePanicLogger) OpenFile 

func (fs FusePanicLogger) OpenFile(ctx context.Context, op *fuseops.OpenFileOp) (err error)

func (FusePanicLogger) ReadDir 

func (fs FusePanicLogger) ReadDir(ctx context.Context, op *fuseops.ReadDirOp) (err error)

func (FusePanicLogger) ReadFile 

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 (FusePanicLogger) ReleaseDirHandle 

func (fs FusePanicLogger) ReleaseDirHandle(ctx context.Context, op *fuseops.ReleaseDirHandleOp) (err error)

func (FusePanicLogger) ReleaseFileHandle 

func (fs FusePanicLogger) ReleaseFileHandle(ctx context.Context, op *fuseops.ReleaseFileHandleOp) (err error)

func (FusePanicLogger) RemoveXattr 

func (fs FusePanicLogger) RemoveXattr(ctx context.Context, op *fuseops.RemoveXattrOp) (err error)

func (FusePanicLogger) Rename 

func (fs FusePanicLogger) Rename(ctx context.Context, op *fuseops.RenameOp) (err error)

func (FusePanicLogger) RmDir 

func (fs FusePanicLogger) RmDir(ctx context.Context, op *fuseops.RmDirOp) (err error)

func (FusePanicLogger) SetInodeAttributes 

func (fs FusePanicLogger) SetInodeAttributes(ctx context.Context, op *fuseops.SetInodeAttributesOp) (err error)

func (FusePanicLogger) SetXattr 

func (fs FusePanicLogger) SetXattr(ctx context.Context, op *fuseops.SetXattrOp) (err error)

func (FusePanicLogger) StatFS 

func (fs FusePanicLogger) StatFS(ctx context.Context, op *fuseops.StatFSOp) (err error)

func (FusePanicLogger) SyncFile 

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 (FusePanicLogger) WriteFile 

func (fs FusePanicLogger) WriteFile(ctx context.Context, op *fuseops.WriteFileOp) (err error)

type GCSConfig added in v0.24.1 

type GCSConfig struct {
	Credentials *google.Credentials
	ChunkSize   int // determine the size of chunks when uploading a file to GCS
}

func NewGCSConfig added in v0.24.1 

func NewGCSConfig() *GCSConfig

NewGCSConfig returns a GCS Config.

type LogHandle 

type LogHandle struct {
	logrus.Logger

	Lvl *logrus.Level
	// contains filtered or unexported fields
}

func GetLogger 

func GetLogger(name string) *LogHandle

func NewLogger 

func NewLogger(name string) *LogHandle

func (*LogHandle) Format 

func (l *LogHandle) Format(e *logrus.Entry) ([]byte, error)

func (*LogHandle) Log 

func (l *LogHandle) Log(args ...interface{})

for aws.Logger

type RetryHTTPLogger 

type RetryHTTPLogger struct {
	*LogHandle
}

func (RetryHTTPLogger) Printf 

func (logger RetryHTTPLogger) Printf(format string, args ...interface{})

type S3Config 

type S3Config struct {
	Profile         string
	AccessKey       string
	SecretKey       string
	RoleArn         string
	RoleExternalId  string
	RoleSessionName string
	StsEndpoint     string

	RequesterPays bool
	Region        string
	RegionSet     bool

	StorageClass string

	UseSSE     bool
	UseKMS     bool
	KMSKeyID   string
	SseC       string
	SseCDigest string
	ACL        string

	Subdomain bool

	Credentials *credentials.Credentials
	Session     *session.Session

	BucketOwner string
}

func (*S3Config) Init 

func (c *S3Config) Init() *S3Config

func (*S3Config) ToAwsConfig 

func (c *S3Config) ToAwsConfig(flags *FlagStorage) (*aws.Config, error)

type SASTokenProvider 

type SASTokenProvider func() (string, error)

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.