/* SPDX-License-Identifier: Apache-2.0 * * The OpenSearch Contributors require contributions made to * this file be licensed under the Apache-2.0 license or a * compatible open source license. */ /* * Modifications Copyright OpenSearch Contributors. See * GitHub history for details. * * Licensed to Elasticsearch B.V. under one or more contributor * license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright * ownership. Elasticsearch B.V. licenses this file to you under * the Apache License, Version 2.0 (the "License"); you may * not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ using System; using System.Collections.Generic; using System.Linq; using System.Linq.Expressions; using System.Runtime.Serialization; using OpenSearch.Net.Utf8Json; namespace OpenSearch.Client { [InterfaceDataContract] [ReadAs(typeof(GeoDistanceAggregation))] public interface IGeoDistanceAggregation : IBucketAggregation { [DataMember(Name ="distance_type")] GeoDistanceType? DistanceType { get; set; } [DataMember(Name ="field")] Field Field { get; set; } [DataMember(Name ="origin")] GeoLocation Origin { get; set; } [DataMember(Name ="ranges")] IEnumerable Ranges { get; set; } [DataMember(Name ="unit")] DistanceUnit? Unit { get; set; } } public class GeoDistanceAggregation : BucketAggregationBase, IGeoDistanceAggregation { internal GeoDistanceAggregation() { } public GeoDistanceAggregation(string name) : base(name) { } public GeoDistanceType? DistanceType { get; set; } public Field Field { get; set; } public GeoLocation Origin { get; set; } public IEnumerable Ranges { get; set; } public DistanceUnit? Unit { get; set; } internal override void WrapInContainer(AggregationContainer c) => c.GeoDistance = this; } public class GeoDistanceAggregationDescriptor : BucketAggregationDescriptorBase, IGeoDistanceAggregation, T> , IGeoDistanceAggregation where T : class { GeoDistanceType? IGeoDistanceAggregation.DistanceType { get; set; } Field IGeoDistanceAggregation.Field { get; set; } GeoLocation IGeoDistanceAggregation.Origin { get; set; } IEnumerable IGeoDistanceAggregation.Ranges { get; set; } DistanceUnit? IGeoDistanceAggregation.Unit { get; set; } public GeoDistanceAggregationDescriptor Field(Field field) => Assign(field, (a, v) => a.Field = v); public GeoDistanceAggregationDescriptor Field(Expression> field) => Assign(field, (a, v) => a.Field = v); public GeoDistanceAggregationDescriptor Origin(double lat, double lon) => Assign(new GeoLocation(lat, lon), (a, v) => a.Origin = v); public GeoDistanceAggregationDescriptor Origin(GeoLocation geoLocation) => Assign(geoLocation, (a, v) => a.Origin = v); public GeoDistanceAggregationDescriptor Unit(DistanceUnit? unit) => Assign(unit, (a, v) => a.Unit = v); public GeoDistanceAggregationDescriptor DistanceType(GeoDistanceType? geoDistance) => Assign(geoDistance, (a, v) => a.DistanceType = v); public GeoDistanceAggregationDescriptor Ranges(params Func[] ranges) => Assign(ranges?.Select(r => r(new AggregationRangeDescriptor())), (a, v) => a.Ranges = v); } }