Skip to content

Commit

Permalink
Skeleton of db.awaitIndex() procedure
Browse files Browse the repository at this point in the history
  • Loading branch information
benbc committed Aug 16, 2016
1 parent 102ae1e commit f2fe64c
Show file tree
Hide file tree
Showing 4 changed files with 46 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
/*
* Copyright (c) 2002-2016 "Neo Technology,"
* Network Engine for Objects in Lund AB [http://neotechnology.com]
*
* This file is part of Neo4j.
*
* Neo4j is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package org.neo4j.kernel.builtinprocs;

import org.neo4j.collection.RawIterator;
import org.neo4j.kernel.api.exceptions.ProcedureException;
import org.neo4j.kernel.api.proc.CallableProcedure;
import org.neo4j.kernel.api.proc.ProcedureSignature;

import static org.neo4j.helpers.collection.Iterators.asRawIterator;
import static org.neo4j.helpers.collection.Iterators.emptyIterator;
import static org.neo4j.kernel.api.proc.ProcedureSignature.procedureSignature;

public class AwaitIndexProcedure extends CallableProcedure.BasicProcedure
{
public AwaitIndexProcedure( ProcedureSignature.ProcedureName name )
{
super( procedureSignature( name ).build() );
}

@Override
public RawIterator<Object[], ProcedureException> apply( Context ctx, Object[] input ) throws ProcedureException
{
return asRawIterator( emptyIterator() );
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,7 @@ public void accept( Procedures procs ) throws ProcedureException
procs.register( new ListPropertyKeysProcedure( procedureName( "db", "propertyKeys" ) ) );
procs.register( new ListRelationshipTypesProcedure( procedureName( "db", "relationshipTypes" ) ) );
procs.register( new ListIndexesProcedure( procedureName( "db", "indexes" ) ) );
procs.register( new AwaitIndexProcedure( procedureName( "db", "awaitIndex" ) ) );
procs.register( new ListConstraintsProcedure( procedureName( "db", "constraints" ) ) );

// These are 'sys'-namespaced procedures, they deal with DBMS-level
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -141,6 +141,7 @@ public void shouldListCorrectBuiltinProcedures() throws Throwable
{
// When/Then
assertThat( call( "dbms.procedures" ), contains(
record( "db.awaitIndex", "db.awaitIndex() :: ()" ),
record( "db.constraints", "db.constraints() :: (description :: STRING?)" ),
record( "db.indexes", "db.indexes() :: (description :: STRING?, state :: STRING?)" ),
record( "db.labels", "db.labels() :: (label :: STRING?)" ),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -104,6 +104,7 @@ public void listProcedures() throws Throwable
assertThat( asList( stream ), containsInAnyOrder(
equalTo( new Object[]{"db.constraints", "db.constraints() :: (description :: STRING?)"} ),
equalTo( new Object[]{"db.indexes", "db.indexes() :: (description :: STRING?, state :: STRING?)"} ),
equalTo( new Object[]{"db.awaitIndex", "db.awaitIndex() :: ()"} ),
equalTo( new Object[]{"db.propertyKeys", "db.propertyKeys() :: (propertyKey :: STRING?)"} ),
equalTo( new Object[]{"db.labels", "db.labels() :: (label :: STRING?)"} ),
equalTo( new Object[]{"db.relationshipTypes", "db.relationshipTypes() :: (relationshipType :: " +
Expand Down

0 comments on commit f2fe64c

Please sign in to comment.