Database.ElasticSearch

type Error = { index :: String, index_uuid :: String, reason :: String, type :: String }

type BulkUpdateParams = { _id :: String, _index :: Optional String, require_alias :: Optional Boolean }

type BulkResult = (errors :: Boolean, items :: Array ActionResult, took :: Int)

type BulkParams = (_source :: Optional (Array String), _sourceExcludes :: Optional (Array String), _sourceIncludes :: Optional (Array String), body :: BulkBody, index :: String, pipeline :: Optional String, refresh :: Optional Refresh, requireAlias :: Optional Boolean, routing :: Optional String, timeout :: Optional String, waitForActiveShards :: Optional String)

type BulkIndexParams = { _id :: Optional String, _index :: Optional String, dynamic_templates :: Optional (Object Json), require_alias :: Optional Boolean }

type BulkDeleteParams = { _id :: String, _index :: Optional String, require_alias :: Optional Boolean }

type BulkCreateParams = BulkIndexParams

type BulkBody = Array Action

type ActionResult = { _id :: String, _index :: String, _primary_term :: Int, _seq_no :: Int, _shards :: { failed :: Int, successful :: Int, total :: Int }, _type :: String, _version :: Int, error :: Optional Error, result :: String, status :: Int }

type Action = { create :: BulkCreateParams } |+| { delete :: BulkDeleteParams } |+| { index :: BulkIndexParams } |+| { update :: BulkUpdateParams } |+| { doc :: Object Json } |+| (Object Json)

bulkUpdate :: forall a b. Castable a BulkUpdateParams => EncodeJson (Record b) => a -> Record b -> BulkBody

bulkIndex :: forall a b. Castable a BulkIndexParams => EncodeJson (Record b) => a -> Record b -> BulkBody

bulkDelete :: forall a. Castable a BulkDeleteParams => a -> BulkBody

bulkCreate :: forall a b. Castable a BulkCreateParams => EncodeJson (Record b) => a -> Record b -> BulkBody

bulk :: Api BulkParams BulkResult

data Client :: Type

type Auth = { password :: String, username :: String } |+| { apiKey :: ApiKey }

type ApiKey = String |+| { api_key :: String, id :: String }

cloudClient :: { auth :: Auth, cloud :: { id :: String } } -> Effect Client

client :: forall a. Castable (Record a) { auth :: UndefinedOr Auth, node :: String } => Record a -> Effect Client

apiKey :: forall a. Castable a ApiKey => a -> Auth

type Response a = { body :: Record a, headers :: Object Json, meta :: Object Json, statusCode :: Int, warnings :: Optional (Array String) }

type RequestParams = { ignore :: Optional (Array Number), maxRetries :: Optional Number }

type Optional a = UndefinedOr a

type DataType = (StringLit "boolean") |+| (StringLit "date") |+| (StringLit "double") |+| (StringLit "geo_point") |+| (StringLit "ip") |+| (StringLit "keyword") |+| (StringLit "long")

type CommonParams a = { error_trace :: Optional Boolean, filter_path :: Optional (Array Json), human :: Optional Boolean, pretty :: Optional Boolean, source :: Optional String | a }

type Api a b = forall c d. Castable (Record c) (CommonParams a) => Castable (Record d) RequestParams => Client -> Record c -> Record d -> Aff (Response b)

toObject :: forall a. EncodeJson (Record a) => Record a -> Object Json

long :: DataType

keyword :: DataType

ip :: DataType

geo_point :: DataType

double :: DataType

date :: DataType

boolean :: DataType

type CreateParams = (body :: Object Json, id :: Optional String, index :: String, pipeline :: Optional String, refresh :: Optional Refresh, routing :: Optional String, timeout :: Optional String, version :: Optional Number, versionType :: Optional VersionType, waitForActiveShards :: Optional String)

create :: Api CreateParams IndexResult

type DeleteParams = (id :: String, ifPrimaryTerm :: Optional Number, ifSeqNo :: Optional Number, index :: String, refresh :: Optional Refresh, routing :: Optional String, timeout :: Optional String, version :: Optional Number, versionType :: Optional VersionType, waitForActiveShards :: Optional String)

delete :: Api DeleteParams IndexResult

type GetResult = (_fields :: Optional (Object Json), _id :: String, _index :: String, _primary_term :: Int, _routing :: Optional String, _seq_no :: Int, _source :: Optional (Object Json), _type :: String, _version :: Int, found :: Boolean)

type GetParams = (_source :: Optional (Array String), _source_excludes :: Optional (Array String), _source_includes :: Optional (Array String), id :: String, index :: String, preference :: Optional String, realtime :: Optional Boolean, refresh :: Optional Boolean, routing :: Optional String, stored_fields :: Optional (Array String), version :: Optional Number, version_type :: Optional VersionType)

get :: Api GetParams GetResult

type VersionType = (StringLit "internal") |+| (StringLit "external") |+| (StringLit "external_gte")

type Refresh = (StringLit "true") |+| (StringLit "false") |+| (StringLit "wait_for")

type OpType = (StringLit "index") |+| (StringLit "create")

type IndexResult = (_id :: String, _index :: String, _primary_term :: Int, _seq_no :: Int, _shards :: { failed :: Int, successful :: Int, total :: Int }, _type :: String, _version :: Int, result :: String)

type IndexParams = (body :: Object Json, id :: Optional String, ifPrimaryTerm :: Optional Number, ifSeqNo :: Optional Number, index :: String, opType :: Optional OpType, pipeline :: Optional String, refresh :: Optional Refresh, requireAlias :: Optional Boolean, routing :: Optional String, timeout :: Optional String, type :: Optional String, version :: Optional Number, versionType :: Optional VersionType, waitForActiveShards :: Optional String)

waitFor :: Refresh

refreshTrue :: Refresh

refreshFalse :: Refresh

internal :: VersionType

indexOp :: OpType

index :: Api IndexParams IndexResult

externalGte :: VersionType

external :: VersionType

createOp :: OpType

type Settings = { number_of_replicas :: Optional Int, number_of_shards :: Optional Int }

type Mapping = { index :: Optional Boolean, type :: DataType }

type CreateIndexParams = (body :: Optional CreateIndexBody, include_type_name :: Optional Boolean, index :: String, master_timeout :: Optional String, timeout :: Optional String, wait_for_active_shards :: Optional String)

type CreateIndexBody = { aliases :: Optional (Object Alias), mappings :: Optional { properties :: Object Mapping }, settings :: Optional Settings }

type Alias = { index_routing :: Optional String, is_hidden :: Optional Boolean, is_write_index :: Optional Boolean, routing :: Optional String, search_routing :: Optional String }

settings :: Cast Settings

mappings :: forall a. Homogeneous a Mapping => Record a -> { properties :: Object Mapping }

mapping :: Cast Mapping

createIndexBody :: Cast CreateIndexBody

createIndex :: Api CreateIndexParams (acknowledged :: Boolean)

aliases :: forall a. Homogeneous a Alias => Record a -> Object Alias

alias :: Cast Alias

type DeleteIndexParams = (allow_no_indices :: Optional Boolean, expand_wildcards :: Optional ExpandWildcards, ignore_unavailable :: Optional Boolean, index :: Array String, master_timeout :: Optional String, timeout :: Optional String)

deleteIndex :: Api DeleteIndexParams (acknowledged :: Boolean)

type ZeroTermsQuery = (StringLit "all") |+| (StringLit "none")

type Term = { boost :: Optional Number, case_insensitive :: Optional Boolean, value :: String }

type Relation = (StringLit "INTERSECTS") |+| (StringLit "CONTAINS") |+| (StringLit "WITHIN")

type Range = { boost :: Optional Number, format :: Optional String, gt :: Optional (String |+| Number), gte :: Optional (String |+| Number), lt :: Optional (String |+| Number), lte :: Optional (String |+| Number), relation :: Optional Relation, time_zone :: Optional String }

newtype Query

Constructors

• Query ({ match :: Object Match } |+| { term :: Object Term } |+| { range :: Range } |+| { bool :: Bool } |+| { boosting :: Boosting } |+| { dis_max :: DisMax })

type Operator = (StringLit "AND") |+| (StringLit "OR")

type Match = { analyzer :: Optional String, auto_generate_synonyms_phrase_query :: Optional Boolean, fuzziness :: Optional String, fuzzy_rewrite :: Optional String, fuzzy_transpositions :: Optional Boolean, lenient :: Optional Boolean, max_expansions :: Optional Int, minimum_should_match :: Optional String, operator :: Optional Operator, prefix_length :: Optional Int, query :: String |+| Number |+| Boolean, zero_terms_query :: Optional ZeroTermsQuery }

type DisMax = { queries :: Array Query, tie_breaker :: Optional Number }

type Boosting = { negative :: Query, negative_boost :: Number, positive :: Query }

type Bool = { boost :: Optional Number, filter :: Optional (Array Query), minimum_should_match :: Optional Int, must :: Optional (Array Query), must_not :: Optional (Array Query), should :: Optional (Array Query) }

within :: Relation

terms :: forall a. Homogeneous a Term => Record a -> Query

term :: Cast Term

returnNone :: ZeroTermsQuery

returnAll :: ZeroTermsQuery

range :: forall a. Castable a Range => a -> Query

or :: Operator

matches :: forall a. Homogeneous a Match => Record a -> Query

match :: Cast Match

intersects :: Relation

disMax :: forall a. Castable a DisMax => a -> Query

contains :: Relation

boosting :: forall a. Castable a Boosting => a -> Query

bool :: forall a. Castable a Bool => a -> Query

and :: Operator

type SuggestMode = (StringLit "missing") |+| (StringLit "popular") |+| (StringLit "always")

type SearchType = (StringLit "query_then_fetch") |+| (StringLit "dfs_query_then_fetch")

type SearchSource = Boolean |+| (Array String) |+| { excludes :: Array String, includes :: Array String }

type SearchResult = (_scroll_id :: Optional String, _shards :: { failed :: Int, skipped :: Int, successful :: Int, total :: Int }, hits :: { hits :: Array { _id :: String, _index :: String, _score :: Int, _source :: Optional (Object Json), _type :: String, fields :: Optional (Object Json) }, max_score :: Optional Number, total :: { relation :: String, value :: Int } }, timed_out :: Boolean, took :: Int)

type SearchParamsOpt = (_source :: Optional (Array String), _source_excludes :: Optional (Array String), _source_includes :: Optional (Array String), allow_no_indices :: Optional Boolean, allow_partial_search_results :: Optional Boolean, analyze_wildcard :: Optional Boolean, analyzer :: Optional String, batched_reduce_size :: Optional Number, body :: Optional SearchBody, ccs_minimize_roundtrips :: Optional Boolean, default_operator :: Optional Operator, df :: Optional String, docvalue_fields :: Optional (Array String), expand_wildcards :: Optional ExpandWildcards, explain :: Optional Boolean, from :: Optional Number, ignore_throttled :: Optional Boolean, ignore_unavailable :: Optional Boolean, index :: Optional (Array String), lenient :: Optional Boolean, max_concurrent_shard_requests :: Optional Number, min_compatible_shard_node :: Optional String, pre_filter_shard_size :: Optional Number, preference :: Optional String, q :: Optional String, request_cache :: Optional Boolean, rest_total_hits_as_int :: Optional Boolean, routing :: Optional (Array String), scroll :: Optional String, search_type :: Optional SearchType, seq_no_primary_term :: Optional Boolean, size :: Optional Number, sort :: Optional (Array String), stats :: Optional (Array String), stored_fields :: Optional (Array String), suggest_field :: Optional String, suggest_mode :: Optional SuggestMode, suggest_size :: Optional Number, suggest_text :: Optional String, terminate_after :: Optional Number, timeout :: Optional String, track_scores :: Optional Boolean, track_total_hits :: Optional Boolean, type :: Optional (Array String), typed_keys :: Optional Boolean, version :: Optional Boolean)

type SearchBody = { _source :: Optional SearchSource, docvalue_fields :: Optional Fields, explain :: Optional Boolean, fields :: Optional Fields, from :: Optional Int, indices_boost :: Optional (Array (Object Number)), min_score :: Optional Number, pit :: Optional Pit, query :: Optional Query, runtime_mappings :: Optional (Object RuntimeMapping), seq_no_primary_term :: Optional Boolean, size :: Optional Int, stats :: Optional (Array String), terminate_after :: Optional Int, timeout :: Optional String, version :: Optional Boolean }

type RuntimeMapping = { script :: UndefinedOr String, type :: DataType }

type Pit = { id :: String, keep_alive :: Optional String }

type Fields = Array (String |+| { field :: String, format :: UndefinedOr String })

type ExpandWildcards = (StringLit "open") |+| (StringLit "closed") |+| (StringLit "hidden") |+| (StringLit "none") |+| (StringLit "all")

searchBody :: Cast SearchBody

search :: Api SearchParamsOpt SearchResult

runtimeMapping :: Cast RuntimeMapping

queryThenFetch :: SearchType

popular :: SuggestMode

pit :: Cast Pit

open :: ExpandWildcards

none :: ExpandWildcards

missing :: SuggestMode

hidden :: ExpandWildcards

dfsQueryThenFetch :: SearchType

closed :: ExpandWildcards

always :: SuggestMode

all :: ExpandWildcards

type UpdateParams = (_source :: Optional (Array String), _sourceExcludes :: Optional (Array String), _sourceIncludes :: Optional (Array String), body :: UpdateBody, id :: String, ifPrimaryTerm :: Optional Number, ifSeqNo :: Optional Number, index :: String, lang :: Optional String, refresh :: Optional Refresh, requireAlias :: Optional Boolean, retryOnConflict :: Optional Number, routing :: Optional String, timeout :: Optional String, waitForActiveShards :: Optional String)

type UpdateBody = { doc :: Object Json } |+| { script :: Script }

type Script = String |+| { lang :: String, params :: Object Json, source :: String }

update :: Api UpdateParams IndexResult

script :: forall a. Castable a Script => a -> UpdateBody

doc :: forall a. EncodeJson (Record a) => Record a -> UpdateBody