package domain
Contains case classes that can be used independently.
- Alphabetic
- By Inheritance
- domain
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class GremlinVersion(version: String) extends Product with Serializable
Contains information about the Gremlin query language available on your cluster.
Contains information about the Gremlin query language available on your cluster. Specifically, it contains a version field that specifies the current TinkerPop version being used by the engine.
- version
Gremlin version number.
- final case class InitiateResetResponse(status: String, payload: TokenPayload) extends Product with Serializable
The response from Neptune after initiating a database reset.
The response from Neptune after initiating a database reset.
- status
the status of the system.
- payload
the token used to perform the database reset.
- final case class InstanceStatusResponse(status: String, startTime: String, dbEngineVersion: String, role: String, gremlin: GremlinVersion) extends Product with Serializable
The response from Neptune when requesting the system status.
The response from Neptune when requesting the system status.
- status
the status of the system.
- startTime
set to the UTC time at which the current server process started.
- dbEngineVersion
set to the Neptune engine version running on your DB cluster.
- role
set to "reader" if the instance is a read-replica, or to "writer" if the instance is the primary instance.
- gremlin
contains information about the Gremlin query language available on your cluster. Specifically, it contains a version field that specifies the current TinkerPop version being used by the engine.
- final case class PerformResetResponse(status: String) extends Product with Serializable
The response from Neptune after performing a database reset.
The response from Neptune after performing a database reset.
- status
the status of the system.
- final case class SerialPathElement(nodeId: Long, visible: Boolean = true, resolved: Boolean = true, outEdgeLabel: String = "") extends Product with Serializable
A serializable version of the SerialPathElement.
A serializable version of the SerialPathElement.
- nodeId
the ID of the node this path element represents.
- visible
whether this path element should be shown in the flow.
- resolved
whether we have resolved the method call this argument belongs to.
- outEdgeLabel
label of the outgoing DDG edge.
- final case class SerialReachableByResult(path: Vector[SerialPathElement], callSite: Option[Long], callDepth: Int = 0, partial: Boolean = false) extends Product with Serializable
A serializable version of ReachableByResult.
A serializable version of ReachableByResult.
- path
a path of nodes represented by SerialReachableByResults.
- callSite
the call site that was expanded to kick off the task. We require this to match call sites to exclude non-realizable paths through other callers
- callDepth
the call depth of this result.
- partial
indicate whether this result stands on its own or requires further analysis, e.g., by expanding output arguments backwards into method output parameters.
- final case class SerializableTable(table: ConcurrentHashMap[Long, Vector[SerialReachableByResult]]) extends Product with Serializable
- final case class TigerGraphResponse(version: TigerGraphVersionInfo, error: Boolean, message: String, results: Seq[Json]) extends Product with Serializable
The response specification for REST++ responses.
- final case class TigerGraphVersionInfo(edition: String, api: String, schema: Int) extends Product with Serializable
The version information response object.
- final case class TokenPayload(token: String) extends Product with Serializable
The Neptune token used to correlate database operations.
The Neptune token used to correlate database operations.
- token
a string token used for database operations.
Value Members
- def deserializeCache(p: Path, decompress: Boolean): ConcurrentHashMap[Long, Vector[SerialReachableByResult]]
Given a path, will deserialize the file at the given path.
Given a path, will deserialize the file at the given path.
- p
path to read deserialized data from.
- decompress
true if the cache needs to be decompressed.
- returns
the deserialized object.
- def deserializeResultTable(serTab: Option[ConcurrentHashMap[Long, Vector[SerialReachableByResult]]], cpg: Cpg): Option[ResultTable]
Converts serialized path results to deserialized ReachableByResults.
Converts serialized path results to deserialized ReachableByResults. This is assumed to be called before any nodes are removed from the graph since these results were serialized.
- serTab
serialized raw results.
- returns
deserialized ReachableByResults table.
- def serializeCache(o: ConcurrentHashMap[Long, Vector[SerialReachableByResult]], p: Path, compress: Boolean): Unit
Given an object and a path, will serialize the object to the given path.
Given an object and a path, will serialize the object to the given path.
- o
object to serialize.
- p
path to write serialized data to.
- compress
true to compress the cache.
- object SerialPathElement extends Serializable
A serializable version of the SerialPathElement.
- object SerialReachableByResult extends Serializable
A serializable version of ReachableByResult.