safelock

package module

Go to main page

Versions in this module

v0

v0.6.0

Sep 13, 2022

Changes in this version

+ type RedisLock struct

+ func NewRedisLock(node uint16, filename string, rdb redis.UniversalClient) *RedisLock

+ func (l *RedisLock) ForceUnlock() error

+ func (l *RedisLock) GetFilename() string

+ func (l *RedisLock) GetLockFilename() string

+ func (l *RedisLock) GetLockState() (LockState, error)

+ func (l *RedisLock) Lock() error

+ func (l *RedisLock) Unlock() error

+ func (l *RedisLock) WaitForLock(timeout time.Duration) error

v0.5.0

Mar 29, 2022

v0.4.1

Mar 29, 2022

v0.4.0

Mar 15, 2022

Changes in this version

type FileLock

+ func (l *FileLock) ForceUnlock() error

type S3ObjectLock

+ func (l *S3ObjectLock) ForceUnlock() error

type SafeLock

+ func (l *SafeLock) ForceUnlock() error

type SafeLockiface

+ ForceUnlock func() error

v0.3.0

Mar 15, 2022

v0.2.0

Mar 14, 2022

Changes in this version

+ type FileLock struct

+ func NewFileLock(node uint16, filename string, fs afero.Fs) *FileLock

+ func (l *FileLock) GetFilename() string

+ func (l *FileLock) GetLockFilename() string

+ func (l *FileLock) GetLockState() (LockState, error)

+ func (l *FileLock) Lock() error

+ func (l *FileLock) Unlock() error

+ func (l *FileLock) WaitForLock() error

+ type LockS3Client interface

+ DeleteObject func(ctx context.Context, params *s3.DeleteObjectInput, optFns ...func(*s3.Options)) (*s3.DeleteObjectOutput, error)

+ GetObject func(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)

+ HeadObject func(ctx context.Context, params *s3.HeadObjectInput, optFns ...func(*s3.Options)) (*s3.HeadObjectOutput, error)

+ PutObject func(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)

+ type LockState string

+ const DefaultSuffix

+ const DefaultTimeout

+ const LockStateLocked

+ const LockStateUnknown

+ const LockStateUnlocked

+ type S3ObjectLock struct

+ func NewS3ObjectLock(node uint16, s3bucket, s3key, s3KMSKeyArn string, svcS3 LockS3Client) *S3ObjectLock

+ func (l *S3ObjectLock) GetLockPath() string

+ func (l *S3ObjectLock) GetLockState() (LockState, error)

+ func (l *S3ObjectLock) GetLockURI() string

+ func (l *S3ObjectLock) GetObjectURI() string

+ func (l *S3ObjectLock) GetS3Bucket() string

+ func (l *S3ObjectLock) GetS3KMSKeyArn() string

+ func (l *S3ObjectLock) GetS3Key() string

+ func (l *S3ObjectLock) Lock() error

+ func (l *S3ObjectLock) Unlock() error

+ func (l *S3ObjectLock) WaitForLock() error

+ type SafeLock struct

+ func NewSafeLock(node uint16) *SafeLock

+ func (l *SafeLock) GetID() uint64

+ func (l *SafeLock) GetIDBytes() []byte

+ func (l *SafeLock) GetLockBody() []byte

+ func (l *SafeLock) GetLockState() (LockState, error)

+ func (l *SafeLock) GetLockSuffix() string

+ func (l *SafeLock) GetLockURI() string

+ func (l *SafeLock) GetNode() int

+ func (l *SafeLock) GetNodeBytes() []byte

+ func (l *SafeLock) GetTimeout() time.Duration

+ func (l *SafeLock) Lock() error

+ func (l *SafeLock) SetID(id uint64)

+ func (l *SafeLock) SetIDBytes(buf []byte) error

+ func (l *SafeLock) SetLockSuffix(lockSuffix string)

+ func (l *SafeLock) SetNode(node uint16)

+ func (l *SafeLock) SetNodeBytes(buf []byte) error

+ func (l *SafeLock) SetTimeout(timeout time.Duration)

+ func (l *SafeLock) Unlock() error

+ func (l *SafeLock) WaitForLock() error

+ type SafeLockiface interface

+ GetID func() uint64

+ GetIDBytes func() []byte

+ GetLockBody func() []byte

+ GetLockState func() (LockState, error)

+ GetLockSuffix func() string

+ GetLockURI func() string

+ GetNode func() uint16

+ GetNodeBytes func() []byte

+ GetTimeout func() time.Duration

+ Lock func() error

+ SetID func(uint64)

+ SetIDBytes func([]byte) error

+ SetLockSuffix func(string)

+ SetNode func(uint16)

+ SetNodeBytes func([]byte) error

+ SetTimeout func(time.Duration)

+ Unlock func() error

+ WaitForLock func() error

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