pub type PullResult {
  PullMap(dict.Dict(String, PullResult))
  PullSingle(fact.Value)
  PullMany(List(fact.Value))
  PullNestedMany(List(PullResult))
  PullRawBinary(BitArray)
}

Constructors

• PullMap(dict.Dict(String, PullResult))

• PullSingle(fact.Value)

• PullMany(List(fact.Value))

• PullNestedMany(List(PullResult))

• PullRawBinary(BitArray)

pub type QueryMetadata {
  QueryMetadata(
    tx_id: option.Option(Int),
    valid_time: option.Option(Int),
    execution_time_ms: Int,
    index_hits: Int,
    plan: String,
    shard_id: option.Option(Int),
    aggregates: dict.Dict(String, ast.AggFunc),
  )
}

Constructors

• QueryMetadata(
    tx_id: option.Option(Int),
    valid_time: option.Option(Int),
    execution_time_ms: Int,
    index_hits: Int,
    plan: String,
    shard_id: option.Option(Int),
    aggregates: dict.Dict(String, ast.AggFunc),
  )

pub type QueryResult {
  QueryResult(
    rows: List(dict.Dict(String, fact.Value)),
    metadata: QueryMetadata,
    updated_columnar_store: option.Option(
      dict.Dict(String, List(internal.StorageChunk)),
    ),
  )
}

Constructors

• QueryResult(
    rows: List(dict.Dict(String, fact.Value)),
    metadata: QueryMetadata,
    updated_columnar_store: option.Option(
      dict.Dict(String, List(internal.StorageChunk)),
    ),
  )

pub type ReactiveDelta {
  Initial(QueryResult)
  Delta(added: QueryResult, removed: QueryResult)
}

Constructors

• Initial(QueryResult)

• Delta(added: QueryResult, removed: QueryResult)

pub type ShardMap {
  ShardMap(
    nodes: dict.Dict(Int, process.Pid),
    vnodes: dict.Dict(Int, Int),
    sorted_hashes: List(Int),
  )
}

Constructors

• ShardMap(
    nodes: dict.Dict(Int, process.Pid),
    vnodes: dict.Dict(Int, Int),
    sorted_hashes: List(Int),
  )

pub type ShardedDb(shard_type) {
  ShardedDb(
    shards: dict.Dict(Int, shard_type),
    shard_count: Int,
    cluster_id: String,
    shard_map: ShardMap,
  )
}

Constructors

• ShardedDb(
    shards: dict.Dict(Int, shard_type),
    shard_count: Int,
    cluster_id: String,
    shard_map: ShardMap,
  )

pub type TraversalExpr =
  List(TraversalStep)

pub type TraversalStep {
  Out(attribute: String)
  In(attribute: String)
}

Constructors

• Out(attribute: String)

• In(attribute: String)