lock

type Lock interface {
	// Lock acquires a lock on the key. If the lock is already held, it will block until the lock is acquired or
	// the context fails.
	// Lock returns an error if the context expires or an unrecoverable error occurs when trying to acquire the lock.
	Lock(ctx context.Context) (expired <-chan struct{}, err error)
	// TryLock tries to acquire the lock on the key and reports whether it succeeded.
	// It blocks until at least one attempt was made to acquired the lock, and returns acquired=false and no error
	// if the lock is known to be held by someone else
	TryLock(ctx context.Context) (acquired bool, expired <-chan struct{}, err error)
	// Unlock releases the lock on the key in a non-blocking fashion.
	// It spawns a goroutine that will perform the unlock mechanism until it succeeds or the the lock is
	// expired by the server.
	// It immediately signals to the lock's original expired channel that the lock is released.
	Unlock() error
}

type LockManager interface {
	// Checks the health of the LockManager backend, conditions are a list of opaque
	// issues that may be present in the backend.
	Health(ctx context.Context) (conditions []string, err error)

	// Instantiates a new Lock instance for the given key, with the given options.
	//
	// Defaults to lock.DefaultOptions if no options are provided.
	NewLock(key string, opts ...LockOption) Lock
}

type LockOption func(o *LockOptions)

type LockOptions struct {
	Tracer trace.Tracer
}

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

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