dlock

Dec 29, 2020

Changes in this version

+ type SpindleLock struct

+ func NewSpindleLock(opts *SpindleLockOptions) *SpindleLock

+ func (l *SpindleLock) Lock(ctx context.Context) error

+ func (l *SpindleLock) Unlock() error

+ type SpindleLockOptions struct

+ Client *spanner.Client

+ Duration int64

+ Id string

+ Logger *log.Logger

+ Name string

+ Table string

Oct 16, 2020

Changes in this version

type K8sLock

+ func (l *K8sLock) IsLeader() bool

Jul 9, 2020

Changes in this version

type RedisLockOption

+ func WithRedsyncOptions(v []redsync.Option) RedisLockOption

Jul 8, 2020

Changes in this version

+ func NewRedisLock(name string, mopts []redsync.Option, opts ...RedisLockOption) *rlock

+ func NewRedisPool(host string, opts ...RedisPoolOption) *redis.Pool

+ type K8sLock struct

+ func NewK8sLock(id, name string, opts ...K8sLockOption) *K8sLock

+ func (l *K8sLock) Lock(ctx context.Context) error

+ func (l *K8sLock) Unlock() error

+ type K8sLockOption interface

+ Apply func(*K8sLock)

+ func WithK8sClient(c *kubernetes.Clientset) K8sLockOption

+ func WithLeaseDuration(v time.Duration) K8sLockOption

+ func WithNamespace(v string) K8sLockOption

+ func WithNewLeaderCallback(v func(string)) K8sLockOption

+ func WithRenewDeadline(v time.Duration) K8sLockOption

+ func WithRetryPeriod(v time.Duration) K8sLockOption

+ func WithStartCallback(v func(context.Context)) K8sLockOption

+ type Locker interface

+ Lock func(ctx context.Context) error

+ Unlock func() error

+ type RedisLockOption interface

+ Apply func(*rlock)

+ func WithExtendAfter(v time.Duration) RedisLockOption

+ func WithHost(v string) RedisLockOption

+ func WithHosts(v []string) RedisLockOption

+ func WithPools(v []*redis.Pool) RedisLockOption

+ type RedisPoolOption interface

+ Apply func(*rpool)

+ func WithPassword(v string) RedisPoolOption

+ func WithTimeout(v time.Duration) RedisPoolOption