Method putTailLockFile

db/journal/queue.go:181–183

(ctx context.Context)

}

func (q *Queue) putTailLockFile(ctx context.Context) error {
	return q.engine.PutIfNotExists(ctx, q.tailLockPath, nil)
}

func (q *Queue) deleteTailLockFile() error {
	return q.engine.Delete(context.Background(), q.tailLockPath)