suweal_service/query

Types

Query

pub type Query(a, b) {
  Query(
    resource: String,
    operation_type: suweal_service.OperationType,
    query: List(node.Node),
    serializer: serialize.Serializer(a),
    parameters: List(#(String, surreal_ql.SurrealQL)),
    transform: fn(
      Result(option.Option(a), suweal_service.DBExecutionError),
    ) -> Result(b, suweal_service.DBExecutionError),
  )
}

Constructors

Query(
  resource: String,
  operation_type: suweal_service.OperationType,
  query: List(node.Node),
  serializer: serialize.Serializer(a),
  parameters: List(#(String, surreal_ql.SurrealQL)),
  transform: fn(
    Result(option.Option(a), suweal_service.DBExecutionError),
  ) -> Result(b, suweal_service.DBExecutionError),
)

Values

empty_if_none

</>

pub fn empty_if_none(
  query: Query(a, option.Option(List(b))),
) -> Query(a, List(b))

not_empty

</>

pub fn not_empty(
  query: Query(a, option.Option(List(b))),
) -> Query(a, List(b))

optional_single

</>

pub fn optional_single(
  query: Query(a, option.Option(List(b))),
) -> Query(a, option.Option(b))

query

</>

pub fn query(
  resource resource: String,
  operation_type operation_type: suweal_service.OperationType,
  query query: List(node.Node),
  serializer serializer: serialize.Serializer(a),
  parameters parameters: List(#(String, surreal_ql.SurrealQL)),
) -> Query(a, option.Option(a))

run

</>

pub fn run(
  query: Query(a, b),
  in namespace: String,
  service service: process.Name(
    hive.DispatcherMessage(model.DBMessage),
  ),
  response operation_response: suweal_service.DbOperationErrorSet,
) -> Result(b, response.Response(wisp.Body))

single

</>

pub fn single(
  query: Query(a, option.Option(List(b))),
) -> Query(a, b)