locks

type Lock struct {
	ID           string     `json:"id"`
	Resource     string     `json:"resource"`
	Owner        string     `json:"owner"`
	AcquiredTime *time.Time `json:"acquiredTime"`
	UpdatedAt    *time.Time `json:"updatedAt"`
	Expiry       *time.Time `json:"expiry"`
}

type LockOption interface {
	Apply(options *LockOptions)
}

type LockOptions struct {
	Owner       string
	Expiry      *time.Duration
	RenewExpiry *time.Duration
	RetryOption WithRetry
}

type Locker interface {
	Lock(ctx context.Context, resource string, options ...LockOption) (*Lock, error)
	Unlock(ctx context.Context, lock *Lock) error
	Renew(ctx context.Context, lock *Lock) error
}

type MockedLocker struct {
	mock.Mock
}

type MongoDBLocker struct {
	// contains filtered or unexported fields
}

type RetryInterval func(retries int, lastError error) (bool, time.Duration)

type WithExpiry time.Duration

type WithOwner string

type WithRenewExpiry time.Duration

type WithRetry RetryInterval