eb668ce · typeable/bloodhound

62 , status :: Int

63 , name :: Text

64 , version :: a

65− , tagline :: Text } deriving (Show)

65+ , tagline :: Text } deriving (Eq, Show)

66

67instance ToJSON Version

68instance FromJSON Version

78

79main = simpleHttp "http://localhost:9200/events/event/_search?q=hostname:localhost&size=1" >>= L.putStrLn

80

81−newtype ShardCount = ShardCount Int deriving (Show, Generic)

81+newtype ShardCount = ShardCount Int deriving (Eq, Show, Generic)

82−newtype ReplicaCount = ReplicaCount Int deriving (Show, Generic)

82+newtype ReplicaCount = ReplicaCount Int deriving (Eq, Show, Generic)

83

84mkShardCount :: Int -> Maybe ShardCount

85mkShardCount n

95

96data IndexSettings =

97 IndexSettings { indexShards :: ShardCount

98− , indexReplicas :: ReplicaCount } deriving (Show)

98+ , indexReplicas :: ReplicaCount } deriving (Eq, Show)

99

100instance ToJSON IndexSettings where

101 toJSON (IndexSettings s r) = object ["settings" .= object ["shards" .= s, "replicas" .= r]]

105

106defaultIndexSettings = IndexSettings (ShardCount 3) (ReplicaCount 2)

107

108−data Strategy = RoundRobinStrat | RandomStrat | HeadStrat deriving (Show)

108+data Strategy = RoundRobinStrat | RandomStrat | HeadStrat deriving (Eq, Show)

109

110−newtype Server = Server String deriving (Show)

110+newtype Server = Server String deriving (Eq, Show)

111

112type Reply = Network.HTTP.Conduit.Response L.ByteString

113type Method = NHTM.Method

171 method = NHTM.methodPost

172 body = Nothing

173

174−data OpenCloseIndex = OpenIndex | CloseIndex deriving (Show)

174+data OpenCloseIndex = OpenIndex | CloseIndex deriving (Eq, Show)

175

176stringifyOCIndex oci = case oci of

177 OpenIndex -> "_open"

293 url = joinPath [server, indexName, mappingName, "_search"]

294

295data Search = Search { queryBody :: Maybe Query

296− , filterBody :: Maybe Filter } deriving (Show)

296+ , filterBody :: Maybe Filter } deriving (Eq, Show)

297

298instance ToJSON Search where

299 toJSON (Search query filters) = object [--"query" .= fmap toJSON query,

306-- field title has no value or doesn't exist, _missing_:title

307-- field title has any non-null value, _exists:title

308

309−data BooleanOperator = AND | OR deriving (Show)

309+data BooleanOperator = AND | OR deriving (Eq, Show)

310

311type DisMax = Bool -- "use_dis_max"

312−newtype TieBreaker = TieBreaker Int deriving (Show)

312+newtype TieBreaker = TieBreaker Int deriving (Eq, Show)

313data QueryField = DefaultField Text

314− | Fields [Text] DisMax TieBreaker deriving (Show)

314+ | Fields [Text] DisMax TieBreaker deriving (Eq, Show)

315

316-- this is will go away later

317type Query = QueryStringQuery

350 , lenient :: Maybe Bool

351 -- default ROOT, locale used for string conversions

352 , locale :: Maybe Text

353− } deriving (Show)

353+ } deriving (Eq, Show)

354

355emptyQueryStringQuery = QueryStringQuery "" Nothing Nothing Nothing Nothing Nothing Nothing Nothing Nothing Nothing Nothing Nothing Nothing Nothing Nothing Nothing Nothing

356queryStringQuery query = emptyQueryStringQuery { query = query }

367 | ExistsFilter FieldName -- always cached

368 | GeoBoundingBoxFilter GeoBoundingBoxConstraint GeoFilterType

369 | GeoDistanceFilter GeoConstraint Distance

370− deriving (Show)

370+ deriving (Eq, Show)

371

372class Monoid a => Seminearring a where

373 -- 0, +, *

423 , "lon" .= lon]

424

425data Term = Term { termField :: Text

426− , termValue :: Text } deriving (Show)

426+ , termValue :: Text } deriving (Eq, Show)

427

428instance ToJSON Term where

429 toJSON (Term field value) = object ["term" .= object

431

432data BoolMatch = MustMatch Term Cache

433 | MustNotMatch Term Cache

434− | ShouldMatch [Term] Cache deriving (Show)

434+ | ShouldMatch [Term] Cache deriving (Eq, Show)

435

436instance ToJSON BoolMatch where

437 toJSON (MustMatch term cache) = object ["must" .= toJSON term,

442 "_cache" .= cache]

443

444-- "memory" or "indexed"

445−data GeoFilterType = GeoFilterMemory | GeoFilterIndexed deriving (Show)

445+data GeoFilterType = GeoFilterMemory | GeoFilterIndexed deriving (Eq, Show)

446

447

448data LatLon = LatLon { lat :: Double

449− , lon :: Double } deriving (Show)

449+ , lon :: Double } deriving (Eq, Show)

450

451data GeoBoundingBox =

452 GeoBoundingBox { topLeft :: LatLon

453− , bottomRight :: LatLon } deriving (Show)

453+ , bottomRight :: LatLon } deriving (Eq, Show)

454

455data GeoBoundingBoxConstraint =

456 GeoBoundingBoxConstraint { geoBBField :: FieldName

457 , constraintBox :: GeoBoundingBox

458 , cache :: Cache

459− } deriving (Show)

459+ } deriving (Eq, Show)

460

461data GeoConstraint =

462 GeoConstraint { geoField :: FieldName

463− , latLon :: LatLon } deriving (Show)

463+ , latLon :: LatLon } deriving (Eq, Show)

464

465data DistanceUnits = Miles

466 | Yards

470 | Meters

471 | Centimeters

472 | Millimeters

473− | NauticalMiles deriving (Show)

473+ | NauticalMiles deriving (Eq, Show)

474

475−data DistanceType = Arc | SloppyArc | Plane deriving (Show)

475+data DistanceType = Arc | SloppyArc | Plane deriving (Eq, Show)

476

477-- geo_point?

478−data OptimizeBbox = OptimizeGeoFilterType GeoFilterType | NoOptimizeBbox deriving (Show)

478+data OptimizeBbox = OptimizeGeoFilterType GeoFilterType | NoOptimizeBbox deriving (Eq, Show)

479

480data Distance =

481 Distance { coefficient :: Double

482− , unit :: DistanceUnits } deriving (Show)

482+ , unit :: DistanceUnits } deriving (Eq, Show)

483

484data FromJSON a => SearchResult a =

485 SearchResult { took :: Int

486 , timedOut :: Bool

487 , shards :: ShardResult

488− , searchHits :: SearchHits a } deriving (Show)

488+ , searchHits :: SearchHits a } deriving (Eq, Show)

489

490type Score = Double

491

492data FromJSON a => SearchHits a =

493 SearchHits { hitsTotal :: Int

494 , maxScore :: Score

495− , hits :: [Hit a] } deriving (Show)

495+ , hits :: [Hit a] } deriving (Eq, Show)

496

497data FromJSON a => Hit a =

498 Hit { hitIndex :: IndexName

499 , hitType :: MappingName

500 , hitDocumentID :: DocumentID

501 , hitScore :: Score

502− , hitSource :: a } deriving (Show)

502+ , hitSource :: a } deriving (Eq, Show)

503

504data ShardResult =

505 ShardResult { shardTotal :: Int

506 , shardsSuccessful :: Int

507− , shardsFailed :: Int } deriving (Show, Generic)

507+ , shardsFailed :: Int } deriving (Eq, Show, Generic)

508

509instance (FromJSON a, ToJSON a) => FromJSON (SearchResult a) where

510 parseJSON (Object v) = SearchResult <$>