You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2017/07/13 17:48:08 UTC
[20/52] [abbrv] tinkerpop git commit: Reorganize Gremlin-DotNet
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Remote/RemoteStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Remote/RemoteStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Remote/RemoteStrategy.cs
new file mode 100644
index 0000000..4826113
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Remote/RemoteStrategy.cs
@@ -0,0 +1,61 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System.Threading.Tasks;
+using Gremlin.Net.Process.Traversal;
+
+namespace Gremlin.Net.Process.Remote
+{
+ /// <summary>
+ /// Reconstructs a <see cref="ITraversal" /> by submitting it to a remote server via an
+ /// <see cref="IRemoteConnection" /> instance.
+ /// </summary>
+ public class RemoteStrategy : ITraversalStrategy
+ {
+ private readonly IRemoteConnection _remoteConnection;
+
+ /// <summary>
+ /// Initializes a new instance of the <see cref="RemoteStrategy" /> class.
+ /// </summary>
+ /// <param name="remoteConnection">The <see cref="IRemoteConnection" /> that should be used.</param>
+ public RemoteStrategy(IRemoteConnection remoteConnection)
+ {
+ _remoteConnection = remoteConnection;
+ }
+
+ /// <inheritdoc />
+ public void Apply(ITraversal traversal)
+ {
+ ApplyAsync(traversal).Wait();
+ }
+
+ /// <inheritdoc />
+ public async Task ApplyAsync(ITraversal traversal)
+ {
+ if (traversal.Traversers != null) return;
+ var remoteTraversal = await _remoteConnection.SubmitAsync(traversal.Bytecode).ConfigureAwait(false);
+ traversal.SideEffects = remoteTraversal.SideEffects;
+ traversal.Traversers = remoteTraversal.Traversers;
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Barrier.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Barrier.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Barrier.cs
new file mode 100644
index 0000000..13d1796
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Barrier.cs
@@ -0,0 +1,30 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public enum Barrier
+ {
+ normSack
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Binding.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Binding.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Binding.cs
new file mode 100644
index 0000000..80c8269
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Binding.cs
@@ -0,0 +1,80 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System;
+
+namespace Gremlin.Net.Process.Traversal
+{
+ /// <summary>
+ /// Associates a variable with a value.
+ /// </summary>
+ public class Binding : IEquatable<Binding>
+ {
+ /// <summary>
+ /// Initializes a new instance of the <see cref="Binding" /> class.
+ /// </summary>
+ /// <param name="key">The key that identifies the <see cref="Binding" />.</param>
+ /// <param name="value">The value of the <see cref="Binding" />.</param>
+ public Binding(string key, object value)
+ {
+ Key = key;
+ Value = value;
+ }
+
+ /// <summary>
+ /// Gets the key that identifies the <see cref="Binding" />.
+ /// </summary>
+ public string Key { get; }
+
+ /// <summary>
+ /// Gets the value of the <see cref="Binding" />.
+ /// </summary>
+ public object Value { get; }
+
+ /// <inheritdoc />
+ public bool Equals(Binding other)
+ {
+ if (other == null)
+ return false;
+ return Key == other.Key && Value.Equals(other.Value);
+ }
+
+ /// <inheritdoc />
+ public override bool Equals(object other)
+ {
+ if (ReferenceEquals(null, other)) return false;
+ if (ReferenceEquals(this, other)) return true;
+ if (other.GetType() != GetType()) return false;
+ return Equals(other as Binding);
+ }
+
+ /// <inheritdoc />
+ public override int GetHashCode()
+ {
+ unchecked
+ {
+ return ((Key?.GetHashCode() ?? 0) * 397) ^ (Value?.GetHashCode() ?? 0);
+ }
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Bindings.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Bindings.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Bindings.cs
new file mode 100644
index 0000000..985369e
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Bindings.cs
@@ -0,0 +1,42 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ /// <summary>
+ /// Bindings are used to associate a variable with a value.
+ /// </summary>
+ public class Bindings
+ {
+ /// <summary>
+ /// Binds the variable to the specified value.
+ /// </summary>
+ /// <param name="variable">The variable to bind.</param>
+ /// <param name="value">The value to which the variable should be bound.</param>
+ /// <returns>The bound value.</returns>
+ public Binding Of(string variable, object value)
+ {
+ return new Binding(variable, value);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Bytecode.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Bytecode.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Bytecode.cs
new file mode 100644
index 0000000..b35e8db
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Bytecode.cs
@@ -0,0 +1,85 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+
+namespace Gremlin.Net.Process.Traversal
+{
+ /// <summary>
+ /// A language agnostic representation of <see cref="ITraversal" /> mutations.
+ /// </summary>
+ /// <remarks>
+ /// Bytecode is simply a list of ordered instructions.
+ /// Bytecode can be serialized between environments and machines by way of a GraphSON representation.
+ /// Thus, Gremlin-CSharp can create bytecode in C# and ship it to Gremlin-Java for evaluation in Java.
+ /// </remarks>
+ public class Bytecode
+ {
+ /// <summary>
+ /// Initializes a new instance of the <see cref="Bytecode" /> class.
+ /// </summary>
+ public Bytecode()
+ {
+ }
+
+ /// <summary>
+ /// Initializes a new instance of the <see cref="Bytecode" /> class.
+ /// </summary>
+ /// <param name="byteCode">Already existing <see cref="Bytecode" /> that should be cloned.</param>
+ public Bytecode(Bytecode byteCode)
+ {
+ SourceInstructions = new List<Instruction>(byteCode.SourceInstructions);
+ StepInstructions = new List<Instruction>(byteCode.StepInstructions);
+ }
+
+ /// <summary>
+ /// Gets the traversal source instructions.
+ /// </summary>
+ public List<Instruction> SourceInstructions { get; } = new List<Instruction>();
+
+ /// <summary>
+ /// Gets the <see cref="ITraversal" /> instructions.
+ /// </summary>
+ public List<Instruction> StepInstructions { get; } = new List<Instruction>();
+
+ /// <summary>
+ /// Add a traversal source instruction to the bytecode.
+ /// </summary>
+ /// <param name="sourceName">The traversal source method name (e.g. withSack()).</param>
+ /// <param name="args">The traversal source method arguments.</param>
+ public void AddSource(string sourceName, params object[] args)
+ {
+ SourceInstructions.Add(new Instruction(sourceName, args));
+ }
+
+ /// <summary>
+ /// Adds a <see cref="ITraversal" /> instruction to the bytecode.
+ /// </summary>
+ /// <param name="stepName">The traversal method name (e.g. out()).</param>
+ /// <param name="args">The traversal method arguments.</param>
+ public void AddStep(string stepName, params object[] args)
+ {
+ StepInstructions.Add(new Instruction(stepName, args));
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Cardinality.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Cardinality.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Cardinality.cs
new file mode 100644
index 0000000..f2365c3
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Cardinality.cs
@@ -0,0 +1,32 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public enum Cardinality
+ {
+ list,
+ set,
+ single
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Column.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Column.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Column.cs
new file mode 100644
index 0000000..ee591da
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Column.cs
@@ -0,0 +1,31 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public enum Column
+ {
+ keys,
+ values
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/DefaultTraversal.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/DefaultTraversal.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/DefaultTraversal.cs
new file mode 100644
index 0000000..86c636c
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/DefaultTraversal.cs
@@ -0,0 +1,195 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace Gremlin.Net.Process.Traversal
+{
+ /// <summary>
+ /// A traversal represents a directed walk over a graph.
+ /// </summary>
+ public abstract class DefaultTraversal : ITraversal
+ {
+ private IEnumerator<Traverser> _traverserEnumerator;
+
+ /// <summary>
+ /// Gets the <see cref="Bytecode" /> representation of this traversal.
+ /// </summary>
+ public Bytecode Bytecode { get; protected set; }
+
+ /// <summary>
+ /// Gets or sets the <see cref="ITraversalSideEffects" /> of this traversal.
+ /// </summary>
+ public ITraversalSideEffects SideEffects { get; set; }
+
+ /// <summary>
+ /// Gets or sets the <see cref="Traverser" />'s of this traversal that hold the results of the traversal.
+ /// </summary>
+ public IEnumerable<Traverser> Traversers { get; set; }
+
+ /// <summary>
+ /// Gets or sets the <see cref="ITraversalStrategy" /> strategies of this traversal.
+ /// </summary>
+ protected ICollection<ITraversalStrategy> TraversalStrategies { get; set; } = new List<ITraversalStrategy>();
+
+ private IEnumerator<Traverser> TraverserEnumerator
+ => _traverserEnumerator ?? (_traverserEnumerator = GetTraverserEnumerator());
+
+ /// <inheritdoc />
+ public void Dispose()
+ {
+ Dispose(true);
+ }
+
+ /// <inheritdoc />
+ public bool MoveNext()
+ {
+ var currentTraverser = TraverserEnumerator.Current;
+ if (currentTraverser?.Bulk > 1)
+ {
+ currentTraverser.Bulk--;
+ return true;
+ }
+ return TraverserEnumerator.MoveNext();
+ }
+
+ /// <summary>
+ /// Reset is not supported.
+ /// </summary>
+ /// <exception cref="NotSupportedException">Thrown always as this operation is not supported.</exception>
+ public void Reset()
+ {
+ throw new NotSupportedException();
+ }
+
+ /// <inheritdoc />
+ public object Current => TraverserEnumerator.Current?.Object;
+
+ private IEnumerator<Traverser> GetTraverserEnumerator()
+ {
+ if (Traversers == null)
+ ApplyStrategies();
+ return Traversers.GetEnumerator();
+ }
+
+ private void ApplyStrategies()
+ {
+ foreach (var strategy in TraversalStrategies)
+ strategy.Apply(this);
+ }
+
+ private async Task ApplyStrategiesAsync()
+ {
+ foreach (var strategy in TraversalStrategies)
+ await strategy.ApplyAsync(this).ConfigureAwait(false);
+ }
+
+ /// <summary>
+ /// Gets the next result from the traversal.
+ /// </summary>
+ /// <returns>The result.</returns>
+ public object Next()
+ {
+ MoveNext();
+ return Current;
+ }
+
+ /// <summary>
+ /// Gets the next n-number of results from the traversal.
+ /// </summary>
+ /// <param name="amount">The number of results to get.</param>
+ /// <returns>The n-results.</returns>
+ public IEnumerable<object> Next(int amount)
+ {
+ for (var i = 0; i < amount; i++)
+ yield return Next();
+ }
+
+ /// <summary>
+ /// Iterates all <see cref="Traverser" /> instances in the traversal.
+ /// </summary>
+ /// <returns>The fully drained traversal.</returns>
+ public ITraversal Iterate()
+ {
+ while (MoveNext())
+ {
+ }
+ return this;
+ }
+
+ /// <summary>
+ /// Gets the next <see cref="Traverser" />.
+ /// </summary>
+ /// <returns>The next <see cref="Traverser" />.</returns>
+ public Traverser NextTraverser()
+ {
+ TraverserEnumerator.MoveNext();
+ return TraverserEnumerator.Current;
+ }
+
+ /// <summary>
+ /// Puts all the results into a <see cref="List{T}" />.
+ /// </summary>
+ /// <returns>The results in a list.</returns>
+ public List<object> ToList()
+ {
+ var objs = new List<object>();
+ while (MoveNext())
+ objs.Add(Current);
+ return objs;
+ }
+
+ /// <summary>
+ /// Puts all the results into a <see cref="HashSet{T}" />.
+ /// </summary>
+ /// <returns>The results in a set.</returns>
+ public HashSet<object> ToSet()
+ {
+ var objs = new HashSet<object>();
+ while (MoveNext())
+ objs.Add(Current);
+ return objs;
+ }
+
+ /// <inheritdoc />
+ protected virtual void Dispose(bool disposing)
+ {
+ if (disposing)
+ SideEffects?.Dispose();
+ }
+
+ /// <summary>
+ /// Starts a promise to execute a function on the current traversal that will be completed in the future.
+ /// </summary>
+ /// <typeparam name="TReturn">The return type of the <paramref name="callback" />.</typeparam>
+ /// <param name="callback">The function to execute on the current traversal.</param>
+ /// <returns>The result of the executed <paramref name="callback" />.</returns>
+ public async Task<TReturn> Promise<TReturn>(Func<ITraversal, TReturn> callback)
+ {
+ await ApplyStrategiesAsync().ConfigureAwait(false);
+ return callback(this);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Direction.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Direction.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Direction.cs
new file mode 100644
index 0000000..413e11f
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Direction.cs
@@ -0,0 +1,32 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public enum Direction
+ {
+ BOTH,
+ IN,
+ OUT
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/GraphTraversal.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/GraphTraversal.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/GraphTraversal.cs
new file mode 100644
index 0000000..88e9261
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/GraphTraversal.cs
@@ -0,0 +1,629 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public class GraphTraversal : DefaultTraversal
+ {
+ public GraphTraversal()
+ : this(new List<ITraversalStrategy>(), new Bytecode())
+ {
+ }
+
+ public GraphTraversal(ICollection<ITraversalStrategy> traversalStrategies, Bytecode bytecode)
+ {
+ TraversalStrategies = traversalStrategies;
+ Bytecode = bytecode;
+ }
+
+ public GraphTraversal V(params object[] args)
+ {
+ Bytecode.AddStep("V", args);
+ return this;
+ }
+
+ public GraphTraversal AddE(params object[] args)
+ {
+ Bytecode.AddStep("addE", args);
+ return this;
+ }
+
+ public GraphTraversal AddInE(params object[] args)
+ {
+ Bytecode.AddStep("addInE", args);
+ return this;
+ }
+
+ public GraphTraversal AddOutE(params object[] args)
+ {
+ Bytecode.AddStep("addOutE", args);
+ return this;
+ }
+
+ public GraphTraversal AddV(params object[] args)
+ {
+ Bytecode.AddStep("addV", args);
+ return this;
+ }
+
+ public GraphTraversal Aggregate(params object[] args)
+ {
+ Bytecode.AddStep("aggregate", args);
+ return this;
+ }
+
+ public GraphTraversal And(params object[] args)
+ {
+ Bytecode.AddStep("and", args);
+ return this;
+ }
+
+ public GraphTraversal As(params object[] args)
+ {
+ Bytecode.AddStep("as", args);
+ return this;
+ }
+
+ public GraphTraversal Barrier(params object[] args)
+ {
+ Bytecode.AddStep("barrier", args);
+ return this;
+ }
+
+ public GraphTraversal Both(params object[] args)
+ {
+ Bytecode.AddStep("both", args);
+ return this;
+ }
+
+ public GraphTraversal BothE(params object[] args)
+ {
+ Bytecode.AddStep("bothE", args);
+ return this;
+ }
+
+ public GraphTraversal BothV(params object[] args)
+ {
+ Bytecode.AddStep("bothV", args);
+ return this;
+ }
+
+ public GraphTraversal Branch(params object[] args)
+ {
+ Bytecode.AddStep("branch", args);
+ return this;
+ }
+
+ public GraphTraversal By(params object[] args)
+ {
+ Bytecode.AddStep("by", args);
+ return this;
+ }
+
+ public GraphTraversal Cap(params object[] args)
+ {
+ Bytecode.AddStep("cap", args);
+ return this;
+ }
+
+ public GraphTraversal Choose(params object[] args)
+ {
+ Bytecode.AddStep("choose", args);
+ return this;
+ }
+
+ public GraphTraversal Coalesce(params object[] args)
+ {
+ Bytecode.AddStep("coalesce", args);
+ return this;
+ }
+
+ public GraphTraversal Coin(params object[] args)
+ {
+ Bytecode.AddStep("coin", args);
+ return this;
+ }
+
+ public GraphTraversal Constant(params object[] args)
+ {
+ Bytecode.AddStep("constant", args);
+ return this;
+ }
+
+ public GraphTraversal Count(params object[] args)
+ {
+ Bytecode.AddStep("count", args);
+ return this;
+ }
+
+ public GraphTraversal CyclicPath(params object[] args)
+ {
+ Bytecode.AddStep("cyclicPath", args);
+ return this;
+ }
+
+ public GraphTraversal Dedup(params object[] args)
+ {
+ Bytecode.AddStep("dedup", args);
+ return this;
+ }
+
+ public GraphTraversal Drop(params object[] args)
+ {
+ Bytecode.AddStep("drop", args);
+ return this;
+ }
+
+ public GraphTraversal Emit(params object[] args)
+ {
+ Bytecode.AddStep("emit", args);
+ return this;
+ }
+
+ public GraphTraversal Filter(params object[] args)
+ {
+ Bytecode.AddStep("filter", args);
+ return this;
+ }
+
+ public GraphTraversal FlatMap(params object[] args)
+ {
+ Bytecode.AddStep("flatMap", args);
+ return this;
+ }
+
+ public GraphTraversal Fold(params object[] args)
+ {
+ Bytecode.AddStep("fold", args);
+ return this;
+ }
+
+ public GraphTraversal From(params object[] args)
+ {
+ Bytecode.AddStep("from", args);
+ return this;
+ }
+
+ public GraphTraversal Group(params object[] args)
+ {
+ Bytecode.AddStep("group", args);
+ return this;
+ }
+
+ public GraphTraversal GroupCount(params object[] args)
+ {
+ Bytecode.AddStep("groupCount", args);
+ return this;
+ }
+
+ public GraphTraversal GroupV3d0(params object[] args)
+ {
+ Bytecode.AddStep("groupV3d0", args);
+ return this;
+ }
+
+ public GraphTraversal Has(params object[] args)
+ {
+ Bytecode.AddStep("has", args);
+ return this;
+ }
+
+ public GraphTraversal HasId(params object[] args)
+ {
+ Bytecode.AddStep("hasId", args);
+ return this;
+ }
+
+ public GraphTraversal HasKey(params object[] args)
+ {
+ Bytecode.AddStep("hasKey", args);
+ return this;
+ }
+
+ public GraphTraversal HasLabel(params object[] args)
+ {
+ Bytecode.AddStep("hasLabel", args);
+ return this;
+ }
+
+ public GraphTraversal HasNot(params object[] args)
+ {
+ Bytecode.AddStep("hasNot", args);
+ return this;
+ }
+
+ public GraphTraversal HasValue(params object[] args)
+ {
+ Bytecode.AddStep("hasValue", args);
+ return this;
+ }
+
+ public GraphTraversal Id(params object[] args)
+ {
+ Bytecode.AddStep("id", args);
+ return this;
+ }
+
+ public GraphTraversal Identity(params object[] args)
+ {
+ Bytecode.AddStep("identity", args);
+ return this;
+ }
+
+ public GraphTraversal In(params object[] args)
+ {
+ Bytecode.AddStep("in", args);
+ return this;
+ }
+
+ public GraphTraversal InE(params object[] args)
+ {
+ Bytecode.AddStep("inE", args);
+ return this;
+ }
+
+ public GraphTraversal InV(params object[] args)
+ {
+ Bytecode.AddStep("inV", args);
+ return this;
+ }
+
+ public GraphTraversal Inject(params object[] args)
+ {
+ Bytecode.AddStep("inject", args);
+ return this;
+ }
+
+ public GraphTraversal Is(params object[] args)
+ {
+ Bytecode.AddStep("is", args);
+ return this;
+ }
+
+ public GraphTraversal Key(params object[] args)
+ {
+ Bytecode.AddStep("key", args);
+ return this;
+ }
+
+ public GraphTraversal Label(params object[] args)
+ {
+ Bytecode.AddStep("label", args);
+ return this;
+ }
+
+ public GraphTraversal Limit(params object[] args)
+ {
+ Bytecode.AddStep("limit", args);
+ return this;
+ }
+
+ public GraphTraversal Local(params object[] args)
+ {
+ Bytecode.AddStep("local", args);
+ return this;
+ }
+
+ public GraphTraversal Loops(params object[] args)
+ {
+ Bytecode.AddStep("loops", args);
+ return this;
+ }
+
+ public GraphTraversal Map(params object[] args)
+ {
+ Bytecode.AddStep("map", args);
+ return this;
+ }
+
+ public GraphTraversal MapKeys(params object[] args)
+ {
+ Bytecode.AddStep("mapKeys", args);
+ return this;
+ }
+
+ public GraphTraversal MapValues(params object[] args)
+ {
+ Bytecode.AddStep("mapValues", args);
+ return this;
+ }
+
+ public GraphTraversal Match(params object[] args)
+ {
+ Bytecode.AddStep("match", args);
+ return this;
+ }
+
+ public GraphTraversal Max(params object[] args)
+ {
+ Bytecode.AddStep("max", args);
+ return this;
+ }
+
+ public GraphTraversal Mean(params object[] args)
+ {
+ Bytecode.AddStep("mean", args);
+ return this;
+ }
+
+ public GraphTraversal Min(params object[] args)
+ {
+ Bytecode.AddStep("min", args);
+ return this;
+ }
+
+ public GraphTraversal Not(params object[] args)
+ {
+ Bytecode.AddStep("not", args);
+ return this;
+ }
+
+ public GraphTraversal Option(params object[] args)
+ {
+ Bytecode.AddStep("option", args);
+ return this;
+ }
+
+ public GraphTraversal Optional(params object[] args)
+ {
+ Bytecode.AddStep("optional", args);
+ return this;
+ }
+
+ public GraphTraversal Or(params object[] args)
+ {
+ Bytecode.AddStep("or", args);
+ return this;
+ }
+
+ public GraphTraversal Order(params object[] args)
+ {
+ Bytecode.AddStep("order", args);
+ return this;
+ }
+
+ public GraphTraversal OtherV(params object[] args)
+ {
+ Bytecode.AddStep("otherV", args);
+ return this;
+ }
+
+ public GraphTraversal Out(params object[] args)
+ {
+ Bytecode.AddStep("out", args);
+ return this;
+ }
+
+ public GraphTraversal OutE(params object[] args)
+ {
+ Bytecode.AddStep("outE", args);
+ return this;
+ }
+
+ public GraphTraversal OutV(params object[] args)
+ {
+ Bytecode.AddStep("outV", args);
+ return this;
+ }
+
+ public GraphTraversal PageRank(params object[] args)
+ {
+ Bytecode.AddStep("pageRank", args);
+ return this;
+ }
+
+ public GraphTraversal Path(params object[] args)
+ {
+ Bytecode.AddStep("path", args);
+ return this;
+ }
+
+ public GraphTraversal PeerPressure(params object[] args)
+ {
+ Bytecode.AddStep("peerPressure", args);
+ return this;
+ }
+
+ public GraphTraversal Profile(params object[] args)
+ {
+ Bytecode.AddStep("profile", args);
+ return this;
+ }
+
+ public GraphTraversal Program(params object[] args)
+ {
+ Bytecode.AddStep("program", args);
+ return this;
+ }
+
+ public GraphTraversal Project(params object[] args)
+ {
+ Bytecode.AddStep("project", args);
+ return this;
+ }
+
+ public GraphTraversal Properties(params object[] args)
+ {
+ Bytecode.AddStep("properties", args);
+ return this;
+ }
+
+ public GraphTraversal Property(params object[] args)
+ {
+ Bytecode.AddStep("property", args);
+ return this;
+ }
+
+ public GraphTraversal PropertyMap(params object[] args)
+ {
+ Bytecode.AddStep("propertyMap", args);
+ return this;
+ }
+
+ public GraphTraversal Range(params object[] args)
+ {
+ Bytecode.AddStep("range", args);
+ return this;
+ }
+
+ public GraphTraversal Repeat(params object[] args)
+ {
+ Bytecode.AddStep("repeat", args);
+ return this;
+ }
+
+ public GraphTraversal Sack(params object[] args)
+ {
+ Bytecode.AddStep("sack", args);
+ return this;
+ }
+
+ public GraphTraversal Sample(params object[] args)
+ {
+ Bytecode.AddStep("sample", args);
+ return this;
+ }
+
+ public GraphTraversal Select(params object[] args)
+ {
+ Bytecode.AddStep("select", args);
+ return this;
+ }
+
+ public GraphTraversal SideEffect(params object[] args)
+ {
+ Bytecode.AddStep("sideEffect", args);
+ return this;
+ }
+
+ public GraphTraversal SimplePath(params object[] args)
+ {
+ Bytecode.AddStep("simplePath", args);
+ return this;
+ }
+
+ public GraphTraversal Store(params object[] args)
+ {
+ Bytecode.AddStep("store", args);
+ return this;
+ }
+
+ public GraphTraversal Subgraph(params object[] args)
+ {
+ Bytecode.AddStep("subgraph", args);
+ return this;
+ }
+
+ public GraphTraversal Sum(params object[] args)
+ {
+ Bytecode.AddStep("sum", args);
+ return this;
+ }
+
+ public GraphTraversal Tail(params object[] args)
+ {
+ Bytecode.AddStep("tail", args);
+ return this;
+ }
+
+ public GraphTraversal TimeLimit(params object[] args)
+ {
+ Bytecode.AddStep("timeLimit", args);
+ return this;
+ }
+
+ public GraphTraversal Times(params object[] args)
+ {
+ Bytecode.AddStep("times", args);
+ return this;
+ }
+
+ public GraphTraversal To(params object[] args)
+ {
+ Bytecode.AddStep("to", args);
+ return this;
+ }
+
+ public GraphTraversal ToE(params object[] args)
+ {
+ Bytecode.AddStep("toE", args);
+ return this;
+ }
+
+ public GraphTraversal ToV(params object[] args)
+ {
+ Bytecode.AddStep("toV", args);
+ return this;
+ }
+
+ public GraphTraversal Tree(params object[] args)
+ {
+ Bytecode.AddStep("tree", args);
+ return this;
+ }
+
+ public GraphTraversal Unfold(params object[] args)
+ {
+ Bytecode.AddStep("unfold", args);
+ return this;
+ }
+
+ public GraphTraversal Union(params object[] args)
+ {
+ Bytecode.AddStep("union", args);
+ return this;
+ }
+
+ public GraphTraversal Until(params object[] args)
+ {
+ Bytecode.AddStep("until", args);
+ return this;
+ }
+
+ public GraphTraversal Value(params object[] args)
+ {
+ Bytecode.AddStep("value", args);
+ return this;
+ }
+
+ public GraphTraversal ValueMap(params object[] args)
+ {
+ Bytecode.AddStep("valueMap", args);
+ return this;
+ }
+
+ public GraphTraversal Values(params object[] args)
+ {
+ Bytecode.AddStep("values", args);
+ return this;
+ }
+
+ public GraphTraversal Where(params object[] args)
+ {
+ Bytecode.AddStep("where", args);
+ return this;
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/GraphTraversalSource.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/GraphTraversalSource.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/GraphTraversalSource.cs
new file mode 100644
index 0000000..6382781
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/GraphTraversalSource.cs
@@ -0,0 +1,142 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+using Gremlin.Net.Process.Remote;
+using Gremlin.Net.Process.Traversal.Strategy.Decoration;
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public class GraphTraversalSource
+ {
+ public ICollection<ITraversalStrategy> TraversalStrategies { get; set; }
+ public Bytecode Bytecode { get; set; }
+
+ public GraphTraversalSource()
+ : this(new List<ITraversalStrategy>(), new Bytecode())
+ {
+ }
+
+ public GraphTraversalSource(ICollection<ITraversalStrategy> traversalStrategies, Bytecode bytecode)
+ {
+ TraversalStrategies = traversalStrategies;
+ Bytecode = bytecode;
+ }
+
+ public GraphTraversalSource WithBulk(params object[] args)
+ {
+ var source = new GraphTraversalSource(new List<ITraversalStrategy>(TraversalStrategies),
+ new Bytecode(Bytecode));
+ source.Bytecode.AddSource("withBulk", args);
+ return source;
+ }
+
+ public GraphTraversalSource WithPath(params object[] args)
+ {
+ var source = new GraphTraversalSource(new List<ITraversalStrategy>(TraversalStrategies),
+ new Bytecode(Bytecode));
+ source.Bytecode.AddSource("withPath", args);
+ return source;
+ }
+
+ public GraphTraversalSource WithSack(params object[] args)
+ {
+ var source = new GraphTraversalSource(new List<ITraversalStrategy>(TraversalStrategies),
+ new Bytecode(Bytecode));
+ source.Bytecode.AddSource("withSack", args);
+ return source;
+ }
+
+ public GraphTraversalSource WithSideEffect(params object[] args)
+ {
+ var source = new GraphTraversalSource(new List<ITraversalStrategy>(TraversalStrategies),
+ new Bytecode(Bytecode));
+ source.Bytecode.AddSource("withSideEffect", args);
+ return source;
+ }
+
+ public GraphTraversalSource WithStrategies(params object[] args)
+ {
+ var source = new GraphTraversalSource(new List<ITraversalStrategy>(TraversalStrategies),
+ new Bytecode(Bytecode));
+ source.Bytecode.AddSource("withStrategies", args);
+ return source;
+ }
+
+ public GraphTraversalSource WithoutStrategies(params object[] args)
+ {
+ var source = new GraphTraversalSource(new List<ITraversalStrategy>(TraversalStrategies),
+ new Bytecode(Bytecode));
+ source.Bytecode.AddSource("withoutStrategies", args);
+ return source;
+ }
+
+ public GraphTraversalSource WithBindings(object bindings)
+ {
+ return this;
+ }
+
+ public GraphTraversalSource WithRemote(IRemoteConnection remoteConnection)
+ {
+ var source = new GraphTraversalSource(new List<ITraversalStrategy>(TraversalStrategies),
+ new Bytecode(Bytecode));
+ source.TraversalStrategies.Add(new RemoteStrategy(remoteConnection));
+ return source;
+ }
+
+ public GraphTraversalSource WithComputer(string graphComputer = null, int? workers = null, string persist = null,
+ string result = null, ITraversal vertices = null, ITraversal edges = null,
+ Dictionary<string, dynamic> configuration = null)
+ {
+ return WithStrategies(new VertexProgramStrategy(graphComputer, workers, persist, result, vertices, edges, configuration));
+ }
+
+ public GraphTraversal E(params object[] args)
+ {
+ var traversal = new GraphTraversal(TraversalStrategies, new Bytecode(Bytecode));
+ traversal.Bytecode.AddStep("E", args);
+ return traversal;
+ }
+
+ public GraphTraversal V(params object[] args)
+ {
+ var traversal = new GraphTraversal(TraversalStrategies, new Bytecode(Bytecode));
+ traversal.Bytecode.AddStep("V", args);
+ return traversal;
+ }
+
+ public GraphTraversal AddV(params object[] args)
+ {
+ var traversal = new GraphTraversal(TraversalStrategies, new Bytecode(Bytecode));
+ traversal.Bytecode.AddStep("addV", args);
+ return traversal;
+ }
+
+ public GraphTraversal Inject(params object[] args)
+ {
+ var traversal = new GraphTraversal(TraversalStrategies, new Bytecode(Bytecode));
+ traversal.Bytecode.AddStep("inject", args);
+ return traversal;
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversal.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversal.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversal.cs
new file mode 100644
index 0000000..cb472b7
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversal.cs
@@ -0,0 +1,96 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace Gremlin.Net.Process.Traversal
+{
+ /// <summary>
+ /// A traversal represents a directed walk over a graph.
+ /// </summary>
+ public interface ITraversal : IDisposable, IEnumerator
+ {
+ /// <summary>
+ /// Gets the <see cref="Bytecode" /> representation of this traversal.
+ /// </summary>
+ Bytecode Bytecode { get; }
+
+ /// <summary>
+ /// Gets or sets the <see cref="ITraversalSideEffects" /> of this traversal.
+ /// </summary>
+ ITraversalSideEffects SideEffects { get; set; }
+
+ /// <summary>
+ /// Gets or sets the <see cref="Traverser" />'s of this traversal that hold the results of the traversal.
+ /// </summary>
+ IEnumerable<Traverser> Traversers { get; set; }
+
+ /// <summary>
+ /// Gets the next result from the traversal.
+ /// </summary>
+ /// <returns>The result.</returns>
+ object Next();
+
+ /// <summary>
+ /// Gets the next n-number of results from the traversal.
+ /// </summary>
+ /// <param name="amount">The number of results to get.</param>
+ /// <returns>The n-results.</returns>
+ IEnumerable<object> Next(int amount);
+
+ /// <summary>
+ /// Iterates all <see cref="Traverser" /> instances in the traversal.
+ /// </summary>
+ /// <returns>The fully drained traversal.</returns>
+ ITraversal Iterate();
+
+ /// <summary>
+ /// Gets the next <see cref="Traverser" />.
+ /// </summary>
+ /// <returns>The next <see cref="Traverser" />.</returns>
+ Traverser NextTraverser();
+
+ /// <summary>
+ /// Puts all the results into a <see cref="List{T}" />.
+ /// </summary>
+ /// <returns>The results in a list.</returns>
+ List<object> ToList();
+
+ /// <summary>
+ /// Puts all the results into a <see cref="HashSet{T}" />.
+ /// </summary>
+ /// <returns>The results in a set.</returns>
+ HashSet<object> ToSet();
+
+ /// <summary>
+ /// Starts a promise to execute a function on the current traversal that will be completed in the future.
+ /// </summary>
+ /// <typeparam name="TReturn">The return type of the <paramref name="callback" />.</typeparam>
+ /// <param name="callback">The function to execute on the current traversal.</param>
+ /// <returns>The result of the executed <paramref name="callback" />.</returns>
+ Task<TReturn> Promise<TReturn>(Func<ITraversal, TReturn> callback);
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversalSideEffects.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversalSideEffects.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversalSideEffects.cs
new file mode 100644
index 0000000..7e7b450
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversalSideEffects.cs
@@ -0,0 +1,52 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System;
+using System.Collections.Generic;
+
+namespace Gremlin.Net.Process.Traversal
+{
+ /// <summary>
+ /// A <see cref="ITraversal" /> can maintain global sideEffects.
+ /// </summary>
+ public interface ITraversalSideEffects : IDisposable
+ {
+ /// <summary>
+ /// Retrieves the keys of the side-effect that can be supplied to <see cref="Get(string)" />.
+ /// </summary>
+ /// <returns>The keys of the side-effect.</returns>
+ IReadOnlyCollection<string> Keys();
+
+ /// <summary>
+ /// Gets the side-effect associated with the provided key.
+ /// </summary>
+ /// <param name="key">The key to get the value for.</param>
+ /// <returns>The value associated with key.</returns>
+ object Get(string key);
+
+ /// <summary>
+ /// Invalidates the side effect cache for traversal.
+ /// </summary>
+ void Close();
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversalStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversalStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversalStrategy.cs
new file mode 100644
index 0000000..991a807
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/ITraversalStrategy.cs
@@ -0,0 +1,46 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System.Threading.Tasks;
+
+namespace Gremlin.Net.Process.Traversal
+{
+ /// <summary>
+ /// A <see cref="ITraversalStrategy" /> defines a particular atomic operation for mutating a
+ /// <see cref="ITraversal" /> prior to its evaluation.
+ /// </summary>
+ public interface ITraversalStrategy
+ {
+ /// <summary>
+ /// Applies the strategy to the given <see cref="ITraversal" />.
+ /// </summary>
+ /// <param name="traversal">The <see cref="ITraversal" /> the strategy should be applied to.</param>
+ void Apply(ITraversal traversal);
+
+ /// <summary>
+ /// Applies the strategy to the given <see cref="ITraversal" /> asynchronously.
+ /// </summary>
+ /// <param name="traversal">The <see cref="ITraversal" /> the strategy should be applied to.</param>
+ Task ApplyAsync(ITraversal traversal);
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Instruction.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Instruction.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Instruction.cs
new file mode 100644
index 0000000..195b7bf
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Instruction.cs
@@ -0,0 +1,52 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ /// <summary>
+ /// Represents a <see cref="Bytecode" /> instruction by an operator name and its arguments.
+ /// </summary>
+ public class Instruction
+ {
+ /// <summary>
+ /// Initializes a new instance of the <see cref="Instruction" /> class.
+ /// </summary>
+ /// <param name="operatorName">The name of the operator.</param>
+ /// <param name="arguments">The arguments.</param>
+ public Instruction(string operatorName, params dynamic[] arguments)
+ {
+ OperatorName = operatorName;
+ Arguments = arguments;
+ }
+
+ /// <summary>
+ /// Gets the name of the operator.
+ /// </summary>
+ public string OperatorName { get; }
+
+ /// <summary>
+ /// Gets the arguments.
+ /// </summary>
+ public dynamic[] Arguments { get; }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Operator.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Operator.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Operator.cs
new file mode 100644
index 0000000..563f091
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Operator.cs
@@ -0,0 +1,40 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public enum Operator
+ {
+ addAll,
+ and,
+ assign,
+ div,
+ max,
+ min,
+ minus,
+ mult,
+ or,
+ sum,
+ sumLong
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Order.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Order.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Order.cs
new file mode 100644
index 0000000..bbd0eab
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Order.cs
@@ -0,0 +1,36 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public enum Order
+ {
+ decr,
+ incr,
+ keyDecr,
+ keyIncr,
+ shuffle,
+ valueDecr,
+ valueIncr
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/P.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/P.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/P.cs
new file mode 100644
index 0000000..0ecdccd
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/P.cs
@@ -0,0 +1,107 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public class P
+ {
+ public static TraversalPredicate Between(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("between", value);
+ }
+
+ public static TraversalPredicate Eq(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("eq", value);
+ }
+
+ public static TraversalPredicate Gt(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("gt", value);
+ }
+
+ public static TraversalPredicate Gte(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("gte", value);
+ }
+
+ public static TraversalPredicate Inside(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("inside", value);
+ }
+
+ public static TraversalPredicate Lt(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("lt", value);
+ }
+
+ public static TraversalPredicate Lte(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("lte", value);
+ }
+
+ public static TraversalPredicate Neq(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("neq", value);
+ }
+
+ public static TraversalPredicate Not(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("not", value);
+ }
+
+ public static TraversalPredicate Outside(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("outside", value);
+ }
+
+ public static TraversalPredicate Test(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("test", value);
+ }
+
+ public static TraversalPredicate Within(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("within", value);
+ }
+
+ public static TraversalPredicate Without(params object[] args)
+ {
+ var value = args.Length == 1 ? args[0] : args;
+ return new TraversalPredicate("without", value);
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Pick.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Pick.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Pick.cs
new file mode 100644
index 0000000..f16aa20
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Pick.cs
@@ -0,0 +1,31 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public enum Pick
+ {
+ any,
+ none
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Pop.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Pop.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Pop.cs
new file mode 100644
index 0000000..e0cf62e
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Pop.cs
@@ -0,0 +1,32 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public enum Pop
+ {
+ all,
+ first,
+ last
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Scope.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Scope.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Scope.cs
new file mode 100644
index 0000000..c4af316
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Scope.cs
@@ -0,0 +1,31 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal
+{
+ public enum Scope
+ {
+ global,
+ local
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/AbstractTraversalStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/AbstractTraversalStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/AbstractTraversalStrategy.cs
new file mode 100644
index 0000000..8c9666c
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/AbstractTraversalStrategy.cs
@@ -0,0 +1,86 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace Gremlin.Net.Process.Traversal.Strategy
+{
+ /// <summary>
+ /// Provides a common base class for strategies that are only included in <see cref="Bytecode" />
+ /// to be applied remotely.
+ /// </summary>
+ public abstract class AbstractTraversalStrategy : ITraversalStrategy, IEquatable<AbstractTraversalStrategy>
+ {
+ /// <summary>
+ /// Gets the name of the strategy.
+ /// </summary>
+ public string StrategyName => GetType().Name;
+
+ /// <summary>
+ /// Gets the configuration of the strategy.
+ /// </summary>
+ public Dictionary<string, dynamic> Configuration { get; } = new Dictionary<string, dynamic>();
+
+ /// <inheritdoc />
+ public bool Equals(AbstractTraversalStrategy other)
+ {
+ if (ReferenceEquals(null, other)) return false;
+ if (ReferenceEquals(this, other)) return true;
+ return StrategyName == other.StrategyName;
+ }
+
+ /// <inheritdoc />
+ public virtual void Apply(ITraversal traversal)
+ {
+ }
+
+ /// <inheritdoc />
+ public virtual Task ApplyAsync(ITraversal traversal)
+ {
+ return Task.CompletedTask;
+ }
+
+ /// <inheritdoc />
+ public override bool Equals(object obj)
+ {
+ if (ReferenceEquals(null, obj)) return false;
+ if (ReferenceEquals(this, obj)) return true;
+ if (obj.GetType() != GetType()) return false;
+ return Equals((AbstractTraversalStrategy) obj);
+ }
+
+ /// <inheritdoc />
+ public override int GetHashCode()
+ {
+ return StrategyName.GetHashCode();
+ }
+
+ /// <inheritdoc />
+ public override string ToString()
+ {
+ return StrategyName;
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/ConnectiveStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/ConnectiveStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/ConnectiveStrategy.cs
new file mode 100644
index 0000000..2bca7c2
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/ConnectiveStrategy.cs
@@ -0,0 +1,33 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal.Strategy.Decoration
+{
+ /// <summary>
+ /// ConnectiveStrategy rewrites the binary conjunction form of <c>a.and().b</c> into an AndStep of
+ /// <c>and(a, b)</c> (likewise for OrStep).
+ /// </summary>
+ public class ConnectiveStrategy : AbstractTraversalStrategy
+ {
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/ElementIdStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/ElementIdStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/ElementIdStrategy.cs
new file mode 100644
index 0000000..6079f58
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/ElementIdStrategy.cs
@@ -0,0 +1,32 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal.Strategy.Decoration
+{
+ /// <summary>
+ /// Provides a degree of control over element identifier assignment as some graphs don't provide that feature.
+ /// </summary>
+ public class ElementIdStrategy : AbstractTraversalStrategy
+ {
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/HaltedTraverserStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/HaltedTraverserStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/HaltedTraverserStrategy.cs
new file mode 100644
index 0000000..98f949c
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/HaltedTraverserStrategy.cs
@@ -0,0 +1,34 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal.Strategy.Decoration
+{
+ public class HaltedTraverserStrategy : AbstractTraversalStrategy
+ {
+ public HaltedTraverserStrategy(string haltedTraverserFactoryName = null)
+ {
+ if (haltedTraverserFactoryName != null)
+ Configuration["haltedTraverserFactory"] = haltedTraverserFactoryName;
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/PartitionStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/PartitionStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/PartitionStrategy.cs
new file mode 100644
index 0000000..f89037b
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/PartitionStrategy.cs
@@ -0,0 +1,56 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+
+namespace Gremlin.Net.Process.Traversal.Strategy.Decoration
+{
+ /// <summary>
+ /// Partitions the vertices, edges and vertex properties of a graph into String named partitions.
+ /// </summary>
+ public class PartitionStrategy : AbstractTraversalStrategy
+ {
+ /// <summary>
+ /// Initializes a new instance of the <see cref="PartitionStrategy" /> class.
+ /// </summary>
+ /// <param name="partitionKey">Specifies the partition key name.</param>
+ /// <param name="writePartition">
+ /// Specifies the name of the partition to write when adding vertices, edges and vertex
+ /// properties.
+ /// </param>
+ /// <param name="readPartitions">Specifies the partition of the graph to read from.</param>
+ /// <param name="includeMetaProperties">Set to true if vertex properties should get assigned to partitions.</param>
+ public PartitionStrategy(string partitionKey = null, string writePartition = null,
+ IEnumerable<string> readPartitions = null, bool? includeMetaProperties = null)
+ {
+ if (partitionKey != null)
+ Configuration["partitionKey"] = partitionKey;
+ if (writePartition != null)
+ Configuration["writePartition"] = writePartition;
+ if (readPartitions != null)
+ Configuration["readPartitions"] = readPartitions;
+ if (includeMetaProperties != null)
+ Configuration["includeMetaProperties"] = includeMetaProperties.Value;
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/SubgraphStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/SubgraphStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/SubgraphStrategy.cs
new file mode 100644
index 0000000..2f0d23e
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/SubgraphStrategy.cs
@@ -0,0 +1,48 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal.Strategy.Decoration
+{
+ /// <summary>
+ /// Provides a way to limit the view of a <see cref="ITraversal" />.
+ /// </summary>
+ public class SubgraphStrategy : AbstractTraversalStrategy
+ {
+ /// <summary>
+ /// Initializes a new instance of the <see cref="SubgraphStrategy" /> class.
+ /// </summary>
+ /// <param name="vertexCriterion">Constrains vertices for the <see cref="ITraversal" />.</param>
+ /// <param name="edgeCriterion">Constrains edges for the <see cref="ITraversal" />.</param>
+ /// <param name="vertexPropertyCriterion">Constrains vertex properties for the <see cref="ITraversal" />.</param>
+ public SubgraphStrategy(ITraversal vertexCriterion = null, ITraversal edgeCriterion = null,
+ ITraversal vertexPropertyCriterion = null)
+ {
+ if (vertexCriterion != null)
+ Configuration["vertices"] = vertexCriterion;
+ if (edgeCriterion != null)
+ Configuration["edges"] = edgeCriterion;
+ if (vertexPropertyCriterion != null)
+ Configuration["vertexProperties"] = vertexPropertyCriterion;
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/VertexProgramStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/VertexProgramStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/VertexProgramStrategy.cs
new file mode 100644
index 0000000..1c5b5f2
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Decoration/VertexProgramStrategy.cs
@@ -0,0 +1,50 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+using System.Linq;
+
+namespace Gremlin.Net.Process.Traversal.Strategy.Decoration
+{
+ public class VertexProgramStrategy : AbstractTraversalStrategy
+ {
+ public VertexProgramStrategy(string graphComputer = null, int? workers = null, string persist = null,
+ string result = null, ITraversal vertices = null, ITraversal edges = null,
+ Dictionary<string, dynamic> configuration = null)
+ {
+ if (graphComputer != null)
+ Configuration["graphComputer"] = graphComputer;
+ if (workers != null)
+ Configuration["workers"] = workers;
+ if (persist != null)
+ Configuration["persist"] = persist;
+ if (result != null)
+ Configuration["result"] = result;
+ if (vertices != null)
+ Configuration["vertices"] = vertices;
+ if (edges != null)
+ Configuration["edges"] = edges;
+ configuration?.ToList().ForEach(x => Configuration[x.Key] = x.Value);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fec3ca5c/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Finalization/MatchAlgorithmStrategy.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Finalization/MatchAlgorithmStrategy.cs b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Finalization/MatchAlgorithmStrategy.cs
new file mode 100644
index 0000000..11a9e2c
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Process/Traversal/Strategy/Finalization/MatchAlgorithmStrategy.cs
@@ -0,0 +1,34 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Process.Traversal.Strategy.Finalization
+{
+ public class MatchAlgorithmStrategy : AbstractTraversalStrategy
+ {
+ public MatchAlgorithmStrategy(string matchAlgorithm = null)
+ {
+ if (matchAlgorithm != null)
+ Configuration["matchAlgorithm"] = matchAlgorithm;
+ }
+ }
+}
\ No newline at end of file