lock

Documentation

Index

• func BucketKey(storage, bucket string) key
• func MigrationCostsKey(fromStorage, toStorage string) key
• func MigrationKey(fromStorage, toStorage, user string) key
• func ObjKey(storage string, o dom.Object) key
• func UpdateOverlap(m time.Duration)
• func UserKey(user string) key
• func WithRefresh(ctx context.Context, work func() error, refresh func(time.Duration) error, ...) error
• type Opt
  • func WithDuration(d time.Duration) Opt
  • func WithRetry(retry bool) Opt
• type Service
  • func New(redisClient redis.UniversalClient) Service

Functions

func BucketKey

func BucketKey(storage, bucket string) key

func MigrationCostsKey

func MigrationCostsKey(fromStorage, toStorage string) key

func MigrationKey

func MigrationKey(fromStorage, toStorage, user string) key

func ObjKey

func ObjKey(storage string, o dom.Object) key

func UpdateOverlap

func UpdateOverlap(m time.Duration)

func UserKey

func UserKey(user string) key

func WithRefresh

func WithRefresh(ctx context.Context, work func() error, refresh func(time.Duration) error, period time.Duration) error

Types

type Opt

type Opt interface {
	// contains filtered or unexported methods
}

func WithDuration

func WithDuration(d time.Duration) Opt

func WithRetry

func WithRetry(retry bool) Opt

type Service

type Service interface {
	Lock(ctx context.Context, key key, opts ...Opt) (release func(), refresh func(time.Duration) error, err error)
}

func New

func New(redisClient redis.UniversalClient) Service