search

package

Go to main page

Versions in this module

v1

v1.8.0-rc.1

Feb 28, 2023

v1.7.17

Sep 13, 2024

v1.7.16

Aug 6, 2024

Changes in this version

type Sort

+ DisableDefaultPkSorter *bool

v1.7.15

Jun 7, 2024

Changes in this version

+ type GroupByComposite struct

+ GroupByName string

+ NextToken *string

+ Size *int32

+ SourceGroupByList []GroupBy

+ SubAggList []Aggregation

+ SubGroupByList []GroupBy

+ SuggestedSize *int32

+ func NewGroupByComposite(groupByName string) *GroupByComposite

+ func (g *GroupByComposite) GetName() string

+ func (g *GroupByComposite) GetType() GroupByType

+ func (g *GroupByComposite) Name(aggName string) *GroupByComposite

+ func (g *GroupByComposite) ProtoBuffer() (*otsprotocol.GroupBy, error)

+ func (g *GroupByComposite) Serialize() ([]byte, error)

+ func (g *GroupByComposite) SetNextToken(nextToken *string) *GroupByComposite

+ func (g *GroupByComposite) SetSize(size int32) *GroupByComposite

+ func (g *GroupByComposite) SetSuggestedSize(suggestedSize int32) *GroupByComposite

+ func (g *GroupByComposite) SourceGroupBy(groupBy GroupBy) *GroupByComposite

+ func (g *GroupByComposite) SourceGroupBys(groupBys ...GroupBy) *GroupByComposite

+ func (g *GroupByComposite) SubAggregation(subAggregation Aggregation) *GroupByComposite

+ func (g *GroupByComposite) SubAggregations(subAggregations ...Aggregation) *GroupByComposite

+ type GroupByCompositeResult struct

+ Items []GroupByCompositeResultItem

+ Name string

+ NextToken *string

+ SourceGroupByNames []string

+ func ParseGroupByCompositeResultFromPB(pbGroupByResult *otsprotocol.GroupByResult) (*GroupByCompositeResult, error)

+ func (g *GroupByCompositeResult) GetName() string

+ func (g *GroupByCompositeResult) GetType() GroupByType

+ type GroupByCompositeResultItem struct

+ Keys []*string

+ RowCount int64

+ SubAggregations AggregationResults

+ SubGroupBys GroupByResults

type GroupByResults

+ func (g GroupByResults) GroupByComposite(name string) (*GroupByCompositeResult, error)

type GroupByType

+ const GroupByCompositeType

v1.7.14

Jan 19, 2024

v1.7.13

Jan 18, 2024

Changes in this version

+ type KnnVectorQuery struct

+ FieldName string

+ Filter Query

+ Float32QueryVector []float32

+ Int8QueryVector []int8

+ TopK *int32

+ func (q *KnnVectorQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *KnnVectorQuery) Serialize() ([]byte, error)

+ func (q *KnnVectorQuery) Type() QueryType

type QueryType

+ const QueryType_KnnVectorQuery

v1.7.12

Jan 8, 2024

Changes in this version

+ type CombineMode int32

+ const CM_AVG

+ const CM_MAX

+ const CM_MIN

+ const CM_MULTIPLY

+ const CM_REPLACE

+ const CM_SUM

+ func (m *CombineMode) ProtoBuffer() *otsprotocol.FunctionCombineMode

+ func (m CombineMode) Enum() *CombineMode

+ type DecayFuncDateParam struct

+ Offset *model.DateTimeValue

+ OriginLong *int64

+ OriginString *string

+ Scale *model.DateTimeValue

+ func NewDecayFuncDateParam() *DecayFuncDateParam

+ func (p *DecayFuncDateParam) GetType() ParamType

+ func (p *DecayFuncDateParam) ProtoBuffer() (*otsprotocol.DecayFuncDateParam, error)

+ func (p *DecayFuncDateParam) SetOffset(value *model.DateTimeValue) *DecayFuncDateParam

+ func (p *DecayFuncDateParam) SetOriginLong(origin int64) *DecayFuncDateParam

+ func (p *DecayFuncDateParam) SetOriginString(origin string) *DecayFuncDateParam

+ func (p *DecayFuncDateParam) SetScale(value *model.DateTimeValue) *DecayFuncDateParam

+ type DecayFuncGeoParam struct

+ Offset *float64

+ Origin *string

+ Scale *float64

+ func NewDecayFuncGeoParam() *DecayFuncGeoParam

+ func (p *DecayFuncGeoParam) GetType() ParamType

+ func (p *DecayFuncGeoParam) ProtoBuffer() (*otsprotocol.DecayFuncGeoParam, error)

+ func (p *DecayFuncGeoParam) SetOffset(value float64) *DecayFuncGeoParam

+ func (p *DecayFuncGeoParam) SetOrigin(origin string) *DecayFuncGeoParam

+ func (p *DecayFuncGeoParam) SetScale(value float64) *DecayFuncGeoParam

+ type DecayFuncNumericParam struct

+ Offset *float64

+ Origin *float64

+ Scale *float64

+ func NewDecayFuncNumericParam() *DecayFuncNumericParam

+ func (p *DecayFuncNumericParam) GetType() ParamType

+ func (p *DecayFuncNumericParam) ProtoBuffer() (*otsprotocol.DecayFuncNumericParam, error)

+ func (p *DecayFuncNumericParam) SetOffset(value float64) *DecayFuncNumericParam

+ func (p *DecayFuncNumericParam) SetOrigin(origin float64) *DecayFuncNumericParam

+ func (p *DecayFuncNumericParam) SetScale(value float64) *DecayFuncNumericParam

+ type DecayFunction struct

+ Decay *float64

+ DecayParam DecayParam

+ FieldName *string

+ MathFunction *MathFunction

+ MultiValueMode *MultiValueMode

+ ParamType ParamType

+ func NewDecayFunction() *DecayFunction

+ func (f *DecayFunction) ProtoBuffer() (*otsprotocol.DecayFunction, error)

+ func (f *DecayFunction) SetDecay(decay float64) *DecayFunction

+ func (f *DecayFunction) SetDecayParam(param DecayParam) *DecayFunction

+ func (f *DecayFunction) SetFieldName(name string) *DecayFunction

+ func (f *DecayFunction) SetMathFunction(function MathFunction) *DecayFunction

+ func (f *DecayFunction) SetMultiValueMode(mode MultiValueMode) *DecayFunction

+ type DecayParam interface

+ GetType func() ParamType

+ type DocSort struct

+ SortOrder *SortOrder

+ func (docSort *DocSort) ProtoBuffer() (sorter *otsprotocol.Sorter, err error)

+ type FieldValueFactorFunction struct

+ Factor *float32

+ FieldName *string

+ Missing *float64

+ Modifier *FunctionModifier

+ func NewFieldValueFactorFunction() *FieldValueFactorFunction

+ func (f *FieldValueFactorFunction) ProtoBuffer() (*otsprotocol.FieldValueFactorFunction, error)

+ func (f *FieldValueFactorFunction) SetFactor(factor float32) *FieldValueFactorFunction

+ func (f *FieldValueFactorFunction) SetFieldName(name string) *FieldValueFactorFunction

+ func (f *FieldValueFactorFunction) SetFunctionModifier(modifier FunctionModifier) *FieldValueFactorFunction

+ func (f *FieldValueFactorFunction) SetMissing(missing float64) *FieldValueFactorFunction

+ type FunctionModifier int32

+ const LN

+ const LN1P

+ const LN2P

+ const LOG

+ const LOG1P

+ const LOG2P

+ const NONE

+ const RECIPROCAL

+ const SQRT

+ const SQUARE

+ func (m *FunctionModifier) ProtoBuffer() *otsprotocol.FunctionModifier

+ func (m FunctionModifier) Enum() *FunctionModifier

+ type FunctionsScoreQuery struct

+ CombineMode *CombineMode

+ Functions []*ScoreFunction

+ MaxScore *float32

+ MinScore *float32

+ Query Query

+ QueryAlias queryAlias

+ ScoreMode *ScoreMode

+ func NewFunctionsScoreQuery() *FunctionsScoreQuery

+ func (q *FunctionsScoreQuery) AddFunction(function *ScoreFunction) *FunctionsScoreQuery

+ func (q *FunctionsScoreQuery) MarshalJSON() ([]byte, error)

+ func (q *FunctionsScoreQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *FunctionsScoreQuery) Serialize() ([]byte, error)

+ func (q *FunctionsScoreQuery) SetCombineMode(mode CombineMode) *FunctionsScoreQuery

+ func (q *FunctionsScoreQuery) SetFunctions(functions []*ScoreFunction) *FunctionsScoreQuery

+ func (q *FunctionsScoreQuery) SetMaxScore(maxScore float32) *FunctionsScoreQuery

+ func (q *FunctionsScoreQuery) SetMinScore(minScore float32) *FunctionsScoreQuery

+ func (q *FunctionsScoreQuery) SetQuery(query Query) *FunctionsScoreQuery

+ func (q *FunctionsScoreQuery) SetScoreMode(mode ScoreMode) *FunctionsScoreQuery

+ func (q *FunctionsScoreQuery) Type() QueryType

+ func (q *FunctionsScoreQuery) UnmarshalJSON(data []byte) (err error)

+ type GeoGrid struct

+ BottomRight GeoPoint

+ TopLeft GeoPoint

+ type GroupByGeoGrid struct

+ Field string

+ GroupByName string

+ Precision model.GeoHashPrecision

+ Size int64

+ SubAggList []Aggregation

+ SubGroupByList []GroupBy

+ func NewGroupByGeoGrid(name string, fieldName string) *GroupByGeoGrid

+ func (g *GroupByGeoGrid) GetField() string

+ func (g *GroupByGeoGrid) GetName() string

+ func (g *GroupByGeoGrid) GetPrecision() model.GeoHashPrecision

+ func (g *GroupByGeoGrid) GetSize() int64

+ func (g *GroupByGeoGrid) GetType() GroupByType

+ func (g *GroupByGeoGrid) ProtoBuffer() (*otsprotocol.GroupBy, error)

+ func (g *GroupByGeoGrid) Serialize() ([]byte, error)

+ func (g *GroupByGeoGrid) SetField(fieldName string) *GroupByGeoGrid

+ func (g *GroupByGeoGrid) SetGroupByName(name string) *GroupByGeoGrid

+ func (g *GroupByGeoGrid) SetPrecision(precision model.GeoHashPrecision) *GroupByGeoGrid

+ func (g *GroupByGeoGrid) SetSize(size int64) *GroupByGeoGrid

+ func (g *GroupByGeoGrid) SubAggregation(subAggregation Aggregation) *GroupByGeoGrid

+ func (g *GroupByGeoGrid) SubAggregations(subAggregations ...Aggregation) *GroupByGeoGrid

+ func (g *GroupByGeoGrid) SubGroupBy(subGroupBy GroupBy) *GroupByGeoGrid

+ func (g *GroupByGeoGrid) SubGroupBys(subGroupBys ...GroupBy) *GroupByGeoGrid

+ type GroupByGeoGridResult struct

+ Items []GroupByGeoGridResultItem

+ Name string

+ func ParseGroupByGeoGridResultFromPB(pbGroupByResult *otsprotocol.GroupByResult) (*GroupByGeoGridResult, error)

+ func (g *GroupByGeoGridResult) GetName() string

+ func (g *GroupByGeoGridResult) GetType() GroupByType

+ type GroupByGeoGridResultItem struct

+ GeoGrid GeoGrid

+ Key string

+ RowCount int64

+ SubAggregations AggregationResults

+ SubGroupBys GroupByResults

type GroupByResults

+ func (g *GroupByResults) GroupByGeoGrid(name string) (*GroupByGeoGridResult, error)

type GroupByType

+ const GroupByGeoGridType

+ type InnerHits struct

+ Highlight *Highlight

+ Limit *int32

+ Offset *int32

+ Sort *Sort

+ func (innerHits *InnerHits) ProtoBuffer() (pbInnerHits *otsprotocol.InnerHits, err error)

+ type MathFunction int32

+ const EXP

+ const GAUSS

+ const LINEAR

+ func (f *MathFunction) ProtoBuffer() *otsprotocol.DecayMathFunction

+ func (m MathFunction) Enum() *MathFunction

+ type MultiValueMode int32

+ const MVM_AVG

+ const MVM_MAX

+ const MVM_MIN

+ const MVM_SUM

+ func (m *MultiValueMode) ProtoBuffer() *otsprotocol.MultiValueMode

+ func (m MultiValueMode) Enum() *MultiValueMode

type NestedQuery

+ InnerHits *InnerHits

+ type ParamType int32

+ const PT_DATE

+ const PT_GEO

+ const PT_NUMERIC

+ func (t *ParamType) ProtoBuffer() *otsprotocol.DecayFuncParamType

+ func (t ParamType) Enum() *ParamType

type QueryType

+ const QueryType_FunctionsScoreQuery

+ type RandomFunction struct

+ func NewRandomFunction() *RandomFunction

+ func (f *RandomFunction) ProtoBuffer() (*otsprotocol.RandomScoreFunction, error)

+ type ScoreFunction struct

+ DecayFunction *DecayFunction

+ FieldValueFactorFunction *FieldValueFactorFunction

+ Filter Query

+ RandomFunction *RandomFunction

+ Weight *float32

+ func NewScoreFunction() *ScoreFunction

+ func (f *ScoreFunction) ProtoBuffer() (*otsprotocol.Function, error)

+ func (f *ScoreFunction) SetDecayFunction(function *DecayFunction) *ScoreFunction

+ func (f *ScoreFunction) SetFieldValueFactorFunction(function *FieldValueFactorFunction) *ScoreFunction

+ func (f *ScoreFunction) SetFilter(filter Query) *ScoreFunction

+ func (f *ScoreFunction) SetRandomFunction(function *RandomFunction) *ScoreFunction

+ func (f *ScoreFunction) SetWeight(weight float32) *ScoreFunction

+ type ScoreMode int32

+ const SM_AVG

+ const SM_FIRST

+ const SM_MAX

+ const SM_MIN

+ const SM_MULTIPLY

+ const SM_SUM

+ func (m *ScoreMode) ProtoBuffer() *otsprotocol.FunctionScoreMode

+ func (m ScoreMode) Enum() *ScoreMode

v1.7.11

Sep 20, 2023

v1.7.10

Aug 28, 2023

Changes in this version

+ type GroupByDateHistogram struct

+ Field string

+ FieldRange model.FiledRange

+ GroupByName string

+ Interval model.DateTimeValue

+ MinDocCount *int64

+ Missing interface{}

+ Sorters []GroupBySorter

+ SubAggList []Aggregation

+ SubGroupByList []GroupBy

+ TimeZone *string

+ func NewGroupByDateHistogram(name string, filedName string) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) GetField() string

+ func (g *GroupByDateHistogram) GetInterval() model.DateTimeValue

+ func (g *GroupByDateHistogram) GetMinDocCount() *int64

+ func (g *GroupByDateHistogram) GetName() string

+ func (g *GroupByDateHistogram) GetTimeZone() *string

+ func (g *GroupByDateHistogram) GetType() GroupByType

+ func (g *GroupByDateHistogram) ProtoBuffer() (*otsprotocol.GroupBy, error)

+ func (g *GroupByDateHistogram) Serialize() ([]byte, error)

+ func (g *GroupByDateHistogram) SetFieldName(fieldName string) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SetFiledRange(min interface{}, max interface{}) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SetGroupBySorters(sorters []GroupBySorter) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SetInterval(interval model.DateTimeValue) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SetMinDocCount(minDocCount int64) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SetMissing(missing interface{}) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SetName(name string) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SetTimeZone(timeZone string) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SubAggregation(subAggregation Aggregation) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SubAggregations(subAggregations ...Aggregation) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SubGroupBy(subGroupBy GroupBy) *GroupByDateHistogram

+ func (g *GroupByDateHistogram) SubGroupBys(subGroupBys ...GroupBy) *GroupByDateHistogram

+ type GroupByDateHistogramItem struct

+ RowCount int64

+ SubAggregations AggregationResults

+ SubGroupBys GroupByResults

+ Timestamp int64

+ type GroupByDateHistogramResult struct

+ Items []GroupByDateHistogramItem

+ Name string

+ func ParseGroupByDateHistogramResultFromPB(pbGroupByResult *otsprotocol.GroupByResult) (*GroupByDateHistogramResult, error)

+ func (g *GroupByDateHistogramResult) GetName() string

+ func (g *GroupByDateHistogramResult) GetType() GroupByType

type GroupByResults

+ func (g GroupByResults) GroupByDateHistogram(name string) (*GroupByDateHistogramResult, error)

type GroupByType

+ const GroupByDateHistogramType

v1.7.9

Aug 2, 2023

Changes in this version

+ type Highlight struct

+ FieldHighlightParameters map[string]*HighlightParameter

+ HighlightEncoder *HighlightEncoder

+ func NewHighlight() *Highlight

+ func ToHighlight(pbHighlight *otsprotocol.Highlight) (*Highlight, error)

+ func (highlight *Highlight) AddFieldHighlightParameter(fieldName string, param *HighlightParameter) *Highlight

+ func (highlight *Highlight) ProtoBuffer() (*otsprotocol.Highlight, error)

+ func (highlight *Highlight) SetFieldHighlightParameters(fieldHighlightParameters map[string]*HighlightParameter) *Highlight

+ func (highlight *Highlight) SetHighlightEncoder(encoder HighlightEncoder) *Highlight

+ type HighlightEncoder int32

+ const HtmlMode

+ const PlainMode

+ func ToHighlightEncoder(encoderStr string) (HighlightEncoder, error)

+ func (encoder *HighlightEncoder) MarshalJSON() (data []byte, err error)

+ func (encoder *HighlightEncoder) ProtoBuffer() (*otsprotocol.HighlightEncoder, error)

+ func (encoder *HighlightEncoder) UnmarshalJSON(data []byte) (err error)

+ func (encoder HighlightEncoder) Enum() *HighlightEncoder

+ func (encoder HighlightEncoder) String() string

+ type HighlightFragmentOrder int32

+ const Score

+ const TextSequence

+ func ToHighlightFragmentOrder(orderStr string) (HighlightFragmentOrder, error)

+ func (order *HighlightFragmentOrder) MarshalJSON() (data []byte, err error)

+ func (order *HighlightFragmentOrder) ProtoBuffer() (*otsprotocol.HighlightFragmentOrder, error)

+ func (order *HighlightFragmentOrder) UnmarshalJSON(data []byte) (err error)

+ func (order HighlightFragmentOrder) Enum() *HighlightFragmentOrder

+ func (order HighlightFragmentOrder) String() string

+ type HighlightParameter struct

+ FragmentSize *int32

+ HighlightFragmentOrder *HighlightFragmentOrder

+ NumberOfFragments *int32

+ PostTag *string

+ PreTag *string

+ func NewHighlightParameter() *HighlightParameter

+ func ToHighlightParameter(pbParameter *otsprotocol.HighlightParameter) (param *HighlightParameter, err error)

+ func (param *HighlightParameter) ProtoBuffer() (*otsprotocol.HighlightParameter, error)

+ func (param *HighlightParameter) SetFragmentSize(fragmentSize int32) *HighlightParameter

+ func (param *HighlightParameter) SetHighlightFragmentOrder(order HighlightFragmentOrder) *HighlightParameter

+ func (param *HighlightParameter) SetNumberOfFragments(numberOfFragments int32) *HighlightParameter

+ func (param *HighlightParameter) SetPostTag(postTag string) *HighlightParameter

+ func (param *HighlightParameter) SetPreTag(preTag string) *HighlightParameter

v1.7.8

Jul 26, 2023

v1.7.7

Sep 20, 2022

Changes in this version

+ const FirstWhenMissing

+ const LastWhenMissing

type FieldSort

+ MissingField *string

+ MissingValue interface{}

v1.7.6

May 31, 2022

v1.7.5

May 26, 2022

v1.7.4

Apr 21, 2022

v1.7.3

Mar 15, 2022

Changes in this version

type Aggregation

+ func UnmarshalAggregation(name string, data json.RawMessage) (Aggregation, error)

type AggregationType

+ func ToAggregationType(q string) AggregationType

type BoolQuery

+ FilterQueriesAlias []queryAlias

+ MustNotQueriesAlias []queryAlias

+ MustQueriesAlias []queryAlias

+ ShouldQueriesAlias []queryAlias

+ func (q *BoolQuery) MarshalJSON() ([]byte, error)

+ func (q *BoolQuery) UnmarshalJSON(data []byte) (err error)

type ConstScoreQuery

+ FilterAlias queryAlias

+ func (q *ConstScoreQuery) MarshalJSON() ([]byte, error)

+ func (q *ConstScoreQuery) UnmarshalJSON(data []byte) (err error)

type FunctionScoreQuery

+ QueryAlias queryAlias

+ func (q *FunctionScoreQuery) MarshalJSON() ([]byte, error)

+ func (q *FunctionScoreQuery) UnmarshalJSON(data []byte) (err error)

type GeoDistanceType

+ func ToGeoDistanceType(t string) (GeoDistanceType, error)

+ func (op *GeoDistanceType) MarshalJSON() (data []byte, err error)

+ func (t *GeoDistanceType) UnmarshalJSON(data []byte) (err error)

+ func (t GeoDistanceType) String() string

type NestedQuery

+ QueryAlias queryAlias

+ func (q *NestedQuery) MarshalJSON() ([]byte, error)

+ func (q *NestedQuery) UnmarshalJSON(data []byte) (err error)

type Query

+ func UnmarshalQuery(name string, data json.RawMessage) (Query, error)

type QueryType

+ func ToQueryType(q string) QueryType

+ func (q QueryType) String() string

type Sort

+ func (r *Sort) UnmarshalJSON(data []byte) (err error)

+ func (s *Sort) MarshalJSON() ([]byte, error)

type SortMode

+ func ToSortMode(mode string) (SortMode, error)

+ func (mode SortMode) String() string

+ func (op *SortMode) MarshalJSON() (data []byte, err error)

+ func (op *SortMode) UnmarshalJSON(data []byte) (err error)

type SortOrder

+ func ToSortOrder(order string) (SortOrder, error)

+ func (op *SortOrder) MarshalJSON() (data []byte, err error)

+ func (op *SortOrder) UnmarshalJSON(data []byte) (err error)

+ func (order SortOrder) String() string

v1.7.1

Nov 2, 2021

v1.7.0

Oct 27, 2021

Changes in this version

+ func AsBoolean(bytes []byte) (bool, error)

+ func AsDouble(bytes []byte) (float64, error)

+ func AsInteger(bytes []byte) (int64, error)

+ func AsString(bytes []byte) (string, error)

+ func ForceConvertToDestColumnValue(bytes []byte) (*model.ColumnValue, error)

type AggregationResults

+ func (a AggregationResults) Percentiles(name string) (*PercentilesAggregationResult, error)

+ func (a AggregationResults) TopRows(name string) (*TopRowsAggregationResult, error)

type AggregationType

+ const AggregationPercentilesType

+ const AggregationTopRowsType

+ type GroupByHistogram struct

+ Field string

+ FieldRange model.FiledRange

+ GroupByName string

+ Interval interface{}

+ MinDocCount *int64

+ Missing interface{}

+ Sorters []GroupBySorter

+ SubAggList []Aggregation

+ SubGroupByList []GroupBy

+ func NewGroupByHistogram(name string, filedName string) *GroupByHistogram

+ func (g *GroupByHistogram) GetField() string

+ func (g *GroupByHistogram) GetName() string

+ func (g *GroupByHistogram) GetType() GroupByType

+ func (g *GroupByHistogram) ProtoBuffer() (*otsprotocol.GroupBy, error)

+ func (g *GroupByHistogram) Serialize() ([]byte, error)

+ func (g *GroupByHistogram) SetFieldName(fieldName string) *GroupByHistogram

+ func (g *GroupByHistogram) SetFiledRange(min interface{}, max interface{}) *GroupByHistogram

+ func (g *GroupByHistogram) SetGroupBySorters(sorters []GroupBySorter) *GroupByHistogram

+ func (g *GroupByHistogram) SetInterval(interval interface{}) *GroupByHistogram

+ func (g *GroupByHistogram) SetMinDocCount(minDocCount int64) *GroupByHistogram

+ func (g *GroupByHistogram) SetMissing(missing interface{}) *GroupByHistogram

+ func (g *GroupByHistogram) SetName(name string) *GroupByHistogram

+ func (g *GroupByHistogram) SubAggregation(subAggregation Aggregation) *GroupByHistogram

+ func (g *GroupByHistogram) SubAggregations(subAggregations ...Aggregation) *GroupByHistogram

+ func (g *GroupByHistogram) SubGroupBy(subGroupBy GroupBy) *GroupByHistogram

+ func (g *GroupByHistogram) SubGroupBys(subGroupBys ...GroupBy) *GroupByHistogram

+ type GroupByHistogramItem struct

+ Key model.ColumnValue

+ SubAggregations AggregationResults

+ SubGroupBys GroupByResults

+ Value int64

+ type GroupByHistogramResult struct

+ Items []GroupByHistogramItem

+ Name string

+ func ParseGroupByHistogramResultFromPB(pbGroupByResult *otsprotocol.GroupByResult) (*GroupByHistogramResult, error)

+ func (g *GroupByHistogramResult) GetName() string

+ func (g *GroupByHistogramResult) GetType() GroupByType

type GroupByResults

+ func (g GroupByResults) GroupByHistogram(name string) (*GroupByHistogramResult, error)

type GroupByType

+ const GroupByHistogramType

+ type PercentilesAggregation struct

+ AggName string

+ Field string

+ MissingValue interface{}

+ Percents []float64

+ func NewPercentilesAggregation(name string, filedName string) *PercentilesAggregation

+ func (a *PercentilesAggregation) GetName() string

+ func (a *PercentilesAggregation) GetPercents() []float64

+ func (a *PercentilesAggregation) GetType() AggregationType

+ func (a *PercentilesAggregation) ProtoBuffer() (*otsprotocol.Aggregation, error)

+ func (a *PercentilesAggregation) Serialize() ([]byte, error)

+ func (a *PercentilesAggregation) SetFieldName(fieldName string) *PercentilesAggregation

+ func (a *PercentilesAggregation) SetMissing(missing interface{}) *PercentilesAggregation

+ func (a *PercentilesAggregation) SetName(name string) *PercentilesAggregation

+ func (a *PercentilesAggregation) SetPercents(percents []float64) *PercentilesAggregation

+ type PercentilesAggregationItem struct

+ Key float64

+ Value model.ColumnValue

+ type PercentilesAggregationResult struct

+ Name string

+ PercentilesAggregationItems []PercentilesAggregationItem

+ func ParsePercentilesAggregationResultFromPB(pbAggResult *otsprotocol.AggregationResult) (*PercentilesAggregationResult, error)

+ func (a *PercentilesAggregationResult) GetName() string

+ func (a *PercentilesAggregationResult) GetType() AggregationType

+ func (a *PercentilesAggregationResult) HasValue() bool

+ type TopRowsAggregation struct

+ AggName string

+ Limit *int32

+ Sort *Sort

+ func NewTopRowsAggregation(name string) *TopRowsAggregation

+ func (a *TopRowsAggregation) GetName() string

+ func (a *TopRowsAggregation) GetType() AggregationType

+ func (a *TopRowsAggregation) ProtoBuffer() (*otsprotocol.Aggregation, error)

+ func (a *TopRowsAggregation) Serialize() ([]byte, error)

+ func (a *TopRowsAggregation) SetLimit(limit int32) *TopRowsAggregation

+ func (a *TopRowsAggregation) SetName(name string) *TopRowsAggregation

+ func (a *TopRowsAggregation) SetSort(sort *Sort) *TopRowsAggregation

+ type TopRowsAggregationResult struct

+ Name string

+ Value []model.Row

+ func ParseTopRowsAggregationResultFromPB(pbAggResult *otsprotocol.AggregationResult) (*TopRowsAggregationResult, error)

+ func (a *TopRowsAggregationResult) GetName() string

+ func (a *TopRowsAggregationResult) GetType() AggregationType

+ func (a *TopRowsAggregationResult) HasValue() bool

v1.6.0

Feb 26, 2021

Changes in this version

+ func NewScanQuery() *scanQuery

+ type ScanQuery interface

+ Serialize func() ([]byte, error)

v1.5.0

Dec 25, 2019

Changes in this version

+ var Inf = math.Inf(1)

+ var NegInf = math.Inf(-1)

+ func BuildPBForAggregation(a Aggregation) (*otsprotocol.Aggregation, error)

+ func BuildPBForAggregations(aggs []Aggregation) (*otsprotocol.Aggregations, error)

+ func BuildPBForGroupBy(g GroupBy) (*otsprotocol.GroupBy, error)

+ func BuildPBForGroupBys(groupBys []GroupBy) (*otsprotocol.GroupBys, error)

+ func BuildPBForQuery(q Query) (*otsprotocol.Query, error)

+ func BuildPBForRanges(ranges []Range) ([]*otsprotocol.Range, error)

+ func NewSearchQuery() *searchQuery

+ type Aggregation interface

+ GetName func() string

+ GetType func() AggregationType

+ ProtoBuffer func() (*otsprotocol.Aggregation, error)

+ Serialize func() ([]byte, error)

+ type AggregationResult interface

+ GetName func() string

+ GetType func() AggregationType

+ type AggregationResults struct

+ func ParseAggregationResultsFromPB(pbAggregationResults []*otsprotocol.AggregationResult) (*AggregationResults, error)

+ func (a *AggregationResults) GetRawResults() map[string]AggregationResult

+ func (a *AggregationResults) Put(name string, result AggregationResult)

+ func (a AggregationResults) Avg(name string) (*AvgAggregationResult, error)

+ func (a AggregationResults) Count(name string) (*CountAggregationResult, error)

+ func (a AggregationResults) DistinctCount(name string) (*DistinctCountAggregationResult, error)

+ func (a AggregationResults) Empty() bool

+ func (a AggregationResults) Max(name string) (*MaxAggregationResult, error)

+ func (a AggregationResults) Min(name string) (*MinAggregationResult, error)

+ func (a AggregationResults) Sum(name string) (*SumAggregationResult, error)

+ type AggregationType int

+ const AggregationAvgType

+ const AggregationCountType

+ const AggregationDistinctCountType

+ const AggregationMaxType

+ const AggregationMinType

+ const AggregationNoneType

+ const AggregationSumType

+ func (a AggregationType) Enum() *AggregationType

+ func (a AggregationType) String() string

+ func (a AggregationType) ToPB() *otsprotocol.AggregationType

+ type AvgAggregation struct

+ AggName string

+ Field string

+ MissingValue interface{}

+ func NewAvgAggregation(name string, fieldName string) *AvgAggregation

+ func (a *AvgAggregation) FieldName(fieldName string) *AvgAggregation

+ func (a *AvgAggregation) GetName() string

+ func (a *AvgAggregation) GetType() AggregationType

+ func (a *AvgAggregation) Missing(missing interface{}) *AvgAggregation

+ func (a *AvgAggregation) Name(name string) *AvgAggregation

+ func (a *AvgAggregation) ProtoBuffer() (*otsprotocol.Aggregation, error)

+ func (a *AvgAggregation) Serialize() ([]byte, error)

+ type AvgAggregationResult struct

+ Name string

+ Value float64

+ func ParseAvgAggregationResultFromPB(pbAggResult *otsprotocol.AggregationResult) (*AvgAggregationResult, error)

+ func (a *AvgAggregationResult) GetName() string

+ func (a *AvgAggregationResult) GetType() AggregationType

+ func (a *AvgAggregationResult) HasValue() bool

+ type BoolQuery struct

+ FilterQueries []Query

+ MinimumShouldMatch *int32

+ MustNotQueries []Query

+ MustQueries []Query

+ ShouldQueries []Query

+ func (q *BoolQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *BoolQuery) Serialize() ([]byte, error)

+ func (q *BoolQuery) Type() QueryType

+ type Collapse struct

+ FieldName string

+ func (c *Collapse) ProtoBuffer() (*otsprotocol.Collapse, error)

+ type ConstScoreQuery struct

+ Filter Query

+ func (q *ConstScoreQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *ConstScoreQuery) Serialize() ([]byte, error)

+ func (q *ConstScoreQuery) Type() QueryType

+ type CountAggregation struct

+ AggName string

+ Field string

+ func NewCountAggregation(name string, fieldName string) *CountAggregation

+ func (a *CountAggregation) FieldName(fieldName string) *CountAggregation

+ func (a *CountAggregation) GetName() string

+ func (a *CountAggregation) GetType() AggregationType

+ func (a *CountAggregation) Name(name string) *CountAggregation

+ func (a *CountAggregation) ProtoBuffer() (*otsprotocol.Aggregation, error)

+ func (a *CountAggregation) Serialize() ([]byte, error)

+ type CountAggregationResult struct

+ Name string

+ Value int64

+ func ParseCountAggregationResultFromPB(pbAggResult *otsprotocol.AggregationResult) (*CountAggregationResult, error)

+ func (a *CountAggregationResult) GetName() string

+ func (a *CountAggregationResult) GetType() AggregationType

+ type DistinctCountAggregation struct

+ AggName string

+ Field string

+ MissingValue interface{}

+ func NewDistinctCountAggregation(name string, fieldName string) *DistinctCountAggregation

+ func (a *DistinctCountAggregation) FieldName(fieldName string) *DistinctCountAggregation

+ func (a *DistinctCountAggregation) GetName() string

+ func (a *DistinctCountAggregation) GetType() AggregationType

+ func (a *DistinctCountAggregation) Missing(missing interface{}) *DistinctCountAggregation

+ func (a *DistinctCountAggregation) Name(name string) *DistinctCountAggregation

+ func (a *DistinctCountAggregation) ProtoBuffer() (*otsprotocol.Aggregation, error)

+ func (a *DistinctCountAggregation) Serialize() ([]byte, error)

+ type DistinctCountAggregationResult struct

+ Name string

+ Value int64

+ func ParseDistinctCountAggregationResultFromPB(pbAggResult *otsprotocol.AggregationResult) (*DistinctCountAggregationResult, error)

+ func (a *DistinctCountAggregationResult) GetName() string

+ func (a *DistinctCountAggregationResult) GetType() AggregationType

+ type ExistsQuery struct

+ FieldName string

+ func (q *ExistsQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *ExistsQuery) Serialize() ([]byte, error)

+ func (q *ExistsQuery) Type() QueryType

+ type FieldSort struct

+ FieldName string

+ Mode *SortMode

+ NestedFilter *NestedFilter

+ Order *SortOrder

+ func NewFieldSort(fieldName string, order SortOrder) *FieldSort

+ func (s *FieldSort) ProtoBuffer() (*otsprotocol.Sorter, error)

+ type FieldValueFactor struct

+ FieldName string

+ func (f *FieldValueFactor) ProtoBuffer() (*otsprotocol.FieldValueFactor, error)

+ type FunctionScoreQuery struct

+ FieldValueFactor *FieldValueFactor

+ Query Query

+ func (q *FunctionScoreQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *FunctionScoreQuery) Serialize() ([]byte, error)

+ func (q *FunctionScoreQuery) Type() QueryType

+ type GeoBoundingBoxQuery struct

+ BottomRight string

+ FieldName string

+ TopLeft string

+ func (q *GeoBoundingBoxQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *GeoBoundingBoxQuery) Serialize() ([]byte, error)

+ func (q *GeoBoundingBoxQuery) Type() QueryType

+ type GeoDistanceQuery struct

+ CenterPoint string

+ DistanceInMeter float64

+ FieldName string

+ func (q *GeoDistanceQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *GeoDistanceQuery) Serialize() ([]byte, error)

+ func (q *GeoDistanceQuery) Type() QueryType

+ type GeoDistanceSort struct

+ FieldName string

+ GeoDistanceType *GeoDistanceType

+ Mode *SortMode

+ NestedFilter *NestedFilter

+ Order *SortOrder

+ Points []string

+ func (s *GeoDistanceSort) ProtoBuffer() (*otsprotocol.Sorter, error)

+ type GeoDistanceType int8

+ const GeoDistanceType_ARC

+ const GeoDistanceType_PLANE

+ func (t *GeoDistanceType) ProtoBuffer() (*otsprotocol.GeoDistanceType, error)

+ type GeoPoint struct

+ Lat float64

+ Lon float64

+ type GeoPolygonQuery struct

+ FieldName string

+ Points []string

+ func (q *GeoPolygonQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *GeoPolygonQuery) Serialize() ([]byte, error)

+ func (q *GeoPolygonQuery) Type() QueryType

+ type GroupBy interface

+ GetName func() string

+ GetType func() GroupByType

+ ProtoBuffer func() (*otsprotocol.GroupBy, error)

+ Serialize func() ([]byte, error)

+ type GroupByField struct

+ AggName string

+ Field string

+ Sorters []GroupBySorter

+ SubAggList []Aggregation

+ SubGroupByList []GroupBy

+ Sz *int32

+ func NewGroupByField(name string, fieldName string) *GroupByField

+ func (g *GroupByField) FieldName(fieldName string) *GroupByField

+ func (g *GroupByField) GetName() string

+ func (g *GroupByField) GetType() GroupByType

+ func (g *GroupByField) GroupBySorters(sorters []GroupBySorter) *GroupByField

+ func (g *GroupByField) Name(name string) *GroupByField

+ func (g *GroupByField) ProtoBuffer() (*otsprotocol.GroupBy, error)

+ func (g *GroupByField) Serialize() ([]byte, error)

+ func (g *GroupByField) Size(size int32) *GroupByField

+ func (g *GroupByField) SubAggregation(subAggregation Aggregation) *GroupByField

+ func (g *GroupByField) SubAggregations(subAggregations ...Aggregation) *GroupByField

+ func (g *GroupByField) SubGroupBy(subGroupBy GroupBy) *GroupByField

+ func (g *GroupByField) SubGroupBys(subGroupBys ...GroupBy) *GroupByField

+ type GroupByFieldResult struct

+ Items []GroupByFieldResultItem

+ Name string

+ func ParseGroupByFieldResultFromPB(pbGroupByResult *otsprotocol.GroupByResult) (*GroupByFieldResult, error)

+ func (g *GroupByFieldResult) GetName() string

+ func (g *GroupByFieldResult) GetType() GroupByType

+ type GroupByFieldResultItem struct

+ Key string

+ RowCount int64

+ SubAggregations AggregationResults

+ SubGroupBys GroupByResults

+ type GroupByFilter struct

+ AggName string

+ Queries []Query

+ SubAggList []Aggregation

+ SubGroupByList []GroupBy

+ func NewGroupByFilter(name string) *GroupByFilter

+ func (g *GroupByFilter) GetName() string

+ func (g *GroupByFilter) GetType() GroupByType

+ func (g *GroupByFilter) Name(name string) *GroupByFilter

+ func (g *GroupByFilter) ProtoBuffer() (*otsprotocol.GroupBy, error)

+ func (g *GroupByFilter) Query(query Query) *GroupByFilter

+ func (g *GroupByFilter) Serialize() ([]byte, error)

+ func (g *GroupByFilter) SubAggregation(subAggregation Aggregation) *GroupByFilter

+ func (g *GroupByFilter) SubAggregations(subAggregations ...Aggregation) *GroupByFilter

+ func (g *GroupByFilter) SubGroupBy(subGroupBy GroupBy) *GroupByFilter

+ func (g *GroupByFilter) SubGroupBys(subGroupBys ...GroupBy) *GroupByFilter

+ type GroupByFilterResult struct

+ Items []GroupByFilterResultItem

+ Name string

+ func ParseGroupByFilterResultFromPB(pbGroupByResult *otsprotocol.GroupByResult) (*GroupByFilterResult, error)

+ func (g *GroupByFilterResult) GetName() string

+ func (g *GroupByFilterResult) GetType() GroupByType

+ type GroupByFilterResultItem struct

+ RowCount int64

+ SubAggregations AggregationResults

+ SubGroupBys GroupByResults

+ type GroupByGeoDistance struct

+ AggName string

+ Field string

+ Origin GeoPoint

+ RangeList []Range

+ SubAggList []Aggregation

+ SubGroupByList []GroupBy

+ func NewGroupByGeoDistance(name string, fieldName string, origin GeoPoint) *GroupByGeoDistance

+ func (g *GroupByGeoDistance) CenterPoint(latitude float64, longitude float64) *GroupByGeoDistance

+ func (g *GroupByGeoDistance) FieldName(fieldName string) *GroupByGeoDistance

+ func (g *GroupByGeoDistance) GetName() string

+ func (g *GroupByGeoDistance) GetType() GroupByType

+ func (g *GroupByGeoDistance) Name(name string) *GroupByGeoDistance

+ func (g *GroupByGeoDistance) ProtoBuffer() (*otsprotocol.GroupBy, error)

+ func (g *GroupByGeoDistance) Range(fromInclusive float64, toExclusive float64) *GroupByGeoDistance

+ func (g *GroupByGeoDistance) Serialize() ([]byte, error)

+ func (g *GroupByGeoDistance) SubAggregation(subAggregation Aggregation) *GroupByGeoDistance

+ func (g *GroupByGeoDistance) SubAggregations(subAggregations ...Aggregation) *GroupByGeoDistance

+ func (g *GroupByGeoDistance) SubGroupBy(subGroupBy GroupBy) *GroupByGeoDistance

+ func (g *GroupByGeoDistance) SubGroupBys(subGroupBys ...GroupBy) *GroupByGeoDistance

+ type GroupByGeoDistanceResult struct

+ Items []GroupByGeoDistanceResultItem

+ Name string

+ func ParseGroupByGeoDistanceResultFromPB(pbGroupByResult *otsprotocol.GroupByResult) (*GroupByGeoDistanceResult, error)

+ func (g *GroupByGeoDistanceResult) GetName() string

+ func (g *GroupByGeoDistanceResult) GetType() GroupByType

+ type GroupByGeoDistanceResultItem struct

+ From float64

+ RowCount int64

+ SubAggregations AggregationResults

+ SubGroupBys GroupByResults

+ To float64

+ type GroupByRange struct

+ AggName string

+ Field string

+ RangeList []Range

+ SubAggList []Aggregation

+ SubGroupByList []GroupBy

+ func NewGroupByRange(name string, fieldName string) *GroupByRange

+ func (g *GroupByRange) FieldName(fieldName string) *GroupByRange

+ func (g *GroupByRange) GetName() string

+ func (g *GroupByRange) GetType() GroupByType

+ func (g *GroupByRange) Name(name string) *GroupByRange

+ func (g *GroupByRange) ProtoBuffer() (*otsprotocol.GroupBy, error)

+ func (g *GroupByRange) Range(fromInclusive float64, toExclusive float64) *GroupByRange

+ func (g *GroupByRange) Serialize() ([]byte, error)

+ func (g *GroupByRange) SubAggregation(subAggregation Aggregation) *GroupByRange

+ func (g *GroupByRange) SubAggregations(subAggregations ...Aggregation) *GroupByRange

+ func (g *GroupByRange) SubGroupBy(subGroupBy GroupBy) *GroupByRange

+ func (g *GroupByRange) SubGroupBys(subGroupBys ...GroupBy) *GroupByRange

+ type GroupByRangeResult struct

+ Items []GroupByRangeResultItem

+ Name string

+ func ParseGroupByRangeResultFromPB(pbGroupByResult *otsprotocol.GroupByResult) (*GroupByRangeResult, error)

+ func (g *GroupByRangeResult) GetName() string

+ func (g *GroupByRangeResult) GetType() GroupByType

+ type GroupByRangeResultItem struct

+ From float64

+ RowCount int64

+ SubAggregations AggregationResults

+ SubGroupBys GroupByResults

+ To float64

+ type GroupByResult interface

+ GetName func() string

+ GetType func() GroupByType

+ type GroupByResults struct

+ func ParseGroupByResultsFromPB(pbGroupByResults []*otsprotocol.GroupByResult) (*GroupByResults, error)

+ func (g *GroupByResults) GetRawResults() map[string]GroupByResult

+ func (g *GroupByResults) Put(name string, result GroupByResult)

+ func (g GroupByResults) Empty() bool

+ func (g GroupByResults) GroupByField(name string) (*GroupByFieldResult, error)

+ func (g GroupByResults) GroupByFilter(name string) (*GroupByFilterResult, error)

+ func (g GroupByResults) GroupByGeoDistance(name string) (*GroupByGeoDistanceResult, error)

+ func (g GroupByResults) GroupByRange(name string) (*GroupByRangeResult, error)

+ type GroupBySort struct

+ Sorters []GroupBySorter

+ func (s *GroupBySort) ProtoBuffer() (*otsprotocol.GroupBySort, error)

+ type GroupBySorter interface

+ ProtoBuffer func() (*otsprotocol.GroupBySorter, error)

+ type GroupByType int

+ const GroupByFieldType

+ const GroupByFilterType

+ const GroupByGeoDistanceType

+ const GroupByNoneType

+ const GroupByRangeType

+ func (a GroupByType) String() string

+ func (g GroupByType) Enum() *GroupByType

+ func (g GroupByType) ToPB() *otsprotocol.GroupByType

+ type GroupKeyGroupBySort struct

+ Order *SortOrder

+ func (s *GroupKeyGroupBySort) ProtoBuffer() (*otsprotocol.GroupBySorter, error)

+ type MatchAllQuery struct

+ func (q *MatchAllQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *MatchAllQuery) Serialize() ([]byte, error)

+ func (q *MatchAllQuery) Type() QueryType

+ type MatchPhraseQuery struct

+ FieldName string

+ Text string

+ func (q *MatchPhraseQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *MatchPhraseQuery) Serialize() ([]byte, error)

+ func (q *MatchPhraseQuery) Type() QueryType

+ type MatchQuery struct

+ FieldName string

+ MinimumShouldMatch *int32

+ Operator *QueryOperator

+ Text string

+ func (q *MatchQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *MatchQuery) Serialize() ([]byte, error)

+ func (q *MatchQuery) Type() QueryType

+ type MaxAggregation struct

+ AggName string

+ Field string

+ MissingValue interface{}

+ func NewMaxAggregation(name string, fieldName string) *MaxAggregation

+ func (a *MaxAggregation) FieldName(fieldName string) *MaxAggregation

+ func (a *MaxAggregation) GetName() string

+ func (a *MaxAggregation) GetType() AggregationType

+ func (a *MaxAggregation) Missing(missing interface{}) *MaxAggregation

+ func (a *MaxAggregation) Name(name string) *MaxAggregation

+ func (a *MaxAggregation) ProtoBuffer() (*otsprotocol.Aggregation, error)

+ func (a *MaxAggregation) Serialize() ([]byte, error)

+ type MaxAggregationResult struct

+ Name string

+ Value float64

+ func ParseMaxAggregationResultFromPB(pbAggResult *otsprotocol.AggregationResult) (*MaxAggregationResult, error)

+ func (a *MaxAggregationResult) GetName() string

+ func (a *MaxAggregationResult) GetType() AggregationType

+ func (a *MaxAggregationResult) HasValue() bool

+ type MinAggregation struct

+ AggName string

+ Field string

+ MissingValue interface{}

+ func NewMinAggregation(name string, fieldName string) *MinAggregation

+ func (a *MinAggregation) FieldName(fieldName string) *MinAggregation

+ func (a *MinAggregation) GetName() string

+ func (a *MinAggregation) GetType() AggregationType

+ func (a *MinAggregation) Missing(missing interface{}) *MinAggregation

+ func (a *MinAggregation) Name(name string) *MinAggregation

+ func (a *MinAggregation) ProtoBuffer() (*otsprotocol.Aggregation, error)

+ func (a *MinAggregation) Serialize() ([]byte, error)

+ type MinAggregationResult struct

+ Name string

+ Value float64

+ func ParseMinAggregationResultFromPB(pbAggResult *otsprotocol.AggregationResult) (*MinAggregationResult, error)

+ func (a *MinAggregationResult) GetName() string

+ func (a *MinAggregationResult) GetType() AggregationType

+ func (a *MinAggregationResult) HasValue() bool

+ type NestedFilter struct

+ Filter Query

+ Path string

+ func (f *NestedFilter) ProtoBuffer() (*otsprotocol.NestedFilter, error)

+ type NestedQuery struct

+ Path string

+ Query Query

+ ScoreMode ScoreModeType

+ func (q *NestedQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *NestedQuery) Serialize() ([]byte, error)

+ func (q *NestedQuery) Type() QueryType

+ type PrefixQuery struct

+ FieldName string

+ Prefix string

+ func (q *PrefixQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *PrefixQuery) Serialize() ([]byte, error)

+ func (q *PrefixQuery) Type() QueryType

+ type PrimaryKeySort struct

+ Order *SortOrder

+ func NewPrimaryKeySort() *PrimaryKeySort

+ func (s *PrimaryKeySort) ProtoBuffer() (*otsprotocol.Sorter, error)

+ type Query interface

+ ProtoBuffer func() (*otsprotocol.Query, error)

+ Serialize func() ([]byte, error)

+ Type func() QueryType

+ type QueryOperator int8

+ const QueryOperator_AND

+ const QueryOperator_OR

+ func (o *QueryOperator) ProtoBuffer() (*otsprotocol.QueryOperator, error)

+ func (x QueryOperator) Enum() *QueryOperator

+ type QueryType int

+ const QueryType_BoolQuery

+ const QueryType_ConstScoreQuery

+ const QueryType_ExistsQuery

+ const QueryType_FunctionScoreQuery

+ const QueryType_GeoBoundingBoxQuery

+ const QueryType_GeoDistanceQuery

+ const QueryType_GeoPolygonQuery

+ const QueryType_MatchAllQuery

+ const QueryType_MatchPhraseQuery

+ const QueryType_MatchQuery

+ const QueryType_NestedQuery

+ const QueryType_None

+ const QueryType_PrefixQuery

+ const QueryType_RangeQuery

+ const QueryType_TermQuery

+ const QueryType_TermsQuery

+ const QueryType_WildcardQuery

+ func (q QueryType) Enum() *QueryType

+ func (q QueryType) ToPB() *otsprotocol.QueryType

+ type Range struct

+ type RangeQuery struct

+ FieldName string

+ From interface{}

+ IncludeLower bool

+ IncludeUpper bool

+ To interface{}

+ func (q *RangeQuery) GT(value interface{})

+ func (q *RangeQuery) GTE(value interface{})

+ func (q *RangeQuery) LT(value interface{})

+ func (q *RangeQuery) LTE(value interface{})

+ func (q *RangeQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *RangeQuery) Serialize() ([]byte, error)

+ func (q *RangeQuery) Type() QueryType

+ type RowCountGroupBySort struct

+ Order *SortOrder

+ func (s *RowCountGroupBySort) ProtoBuffer() (*otsprotocol.GroupBySorter, error)

+ type ScoreModeType int

+ const ScoreMode_Avg

+ const ScoreMode_Max

+ const ScoreMode_Min

+ const ScoreMode_None

+ const ScoreMode_Total

+ type ScoreSort struct

+ Order *SortOrder

+ func NewScoreSort() *ScoreSort

+ func (s *ScoreSort) ProtoBuffer() (*otsprotocol.Sorter, error)

+ type SearchQuery interface

+ Serialize func() ([]byte, error)

+ type Sort struct

+ Sorters []Sorter

+ func (s *Sort) ProtoBuffer() (*otsprotocol.Sort, error)

+ type SortMode int8

+ const SortMode_Avg

+ const SortMode_Max

+ const SortMode_Min

+ func (m *SortMode) ProtoBuffer() (*otsprotocol.SortMode, error)

+ func (x SortMode) Enum() *SortMode

+ type SortOrder int8

+ const SortOrder_ASC

+ const SortOrder_DESC

+ func ParseSortOrder(order *otsprotocol.SortOrder) *SortOrder

+ func (o *SortOrder) ProtoBuffer() (*otsprotocol.SortOrder, error)

+ func (x SortOrder) Enum() *SortOrder

+ type Sorter interface

+ ProtoBuffer func() (*otsprotocol.Sorter, error)

+ type SubAggGroupBySort struct

+ Order *SortOrder

+ SubAggName string

+ func (s *SubAggGroupBySort) ProtoBuffer() (*otsprotocol.GroupBySorter, error)

+ type SumAggregation struct

+ AggName string

+ Field string

+ MissingValue interface{}

+ func NewSumAggregation(name string, fieldName string) *SumAggregation

+ func (a *SumAggregation) FieldName(fieldName string) *SumAggregation

+ func (a *SumAggregation) GetName() string

+ func (a *SumAggregation) GetType() AggregationType

+ func (a *SumAggregation) Missing(missing interface{}) *SumAggregation

+ func (a *SumAggregation) Name(name string) *SumAggregation

+ func (a *SumAggregation) ProtoBuffer() (*otsprotocol.Aggregation, error)

+ func (a *SumAggregation) Serialize() ([]byte, error)

+ type SumAggregationResult struct

+ Name string

+ Value float64

+ func ParseSumAggregationResultFromPB(pbAggResult *otsprotocol.AggregationResult) (*SumAggregationResult, error)

+ func (a *SumAggregationResult) GetName() string

+ func (a *SumAggregationResult) GetType() AggregationType

+ type TermQuery struct

+ FieldName string

+ Term interface{}

+ func (q *TermQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *TermQuery) Serialize() ([]byte, error)

+ func (q *TermQuery) Type() QueryType

+ type TermsQuery struct

+ FieldName string

+ Terms []interface{}

+ func (q *TermsQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *TermsQuery) Serialize() ([]byte, error)

+ func (q *TermsQuery) Type() QueryType

+ type VariantType byte

+ const VT_BOOLEAN

+ const VT_DOUBLE

+ const VT_INTEGER

+ const VT_STRING

+ type VariantValue []byte

+ func ToVariantValue(value interface{}) (VariantValue, error)

+ func VTBoolean(b bool) VariantValue

+ func VTDouble(v float64) VariantValue

+ func VTInteger(v int64) VariantValue

+ func VTString(v string) VariantValue

+ func (v *VariantValue) GetType() VariantType

+ type WildcardQuery struct

+ FieldName string

+ Value string

+ func (q *WildcardQuery) ProtoBuffer() (*otsprotocol.Query, error)

+ func (q *WildcardQuery) Serialize() ([]byte, error)

+ func (q *WildcardQuery) Type() QueryType

Incompatible versions in this module

v4.1.3+incompatible

Jul 10, 2019

v4.1.2+incompatible

Jan 16, 2019

v4.1.1+incompatible

Nov 16, 2018

v4.1.0+incompatible

Sep 19, 2018

Other modules containing this package

github.com/aliyun/aliyun-tablestore-go-sdk/v5

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL