mirror of
https://github.com/minio/minio.git
synced 2024-12-26 07:05:55 -05:00
a2a8d54bb6
This change adds `access` format support for notifications to a Elasticsearch server, and it refactors `namespace` format support. In the case of `access` format, for each event in Minio, a JSON document is inserted into Elasticsearch with its timestamp set to the event's timestamp, and with the ID generated automatically by elasticsearch. No events are modified or deleted in this mode. In the case of `namespace` format, for each event in Minio, a JSON document is keyed together by the bucket and object name is updated in Elasticsearch. In the case of an object being created or over-written in Minio, a new document or an existing document is inserted into the Elasticsearch index. If an object is deleted in Minio, the corresponding document is deleted from the Elasticsearch index. Additionally, this change upgrades Elasticsearch support to the 5.x series. This is a breaking change, and users of previous elasticsearch versions should upgrade. Also updates documentation on Elasticsearch notification target usage and has a link to an elasticsearch upgrade guide. This is the last patch that finally resolves #3928.
161 lines
3.7 KiB
Go
161 lines
3.7 KiB
Go
// Copyright 2012-present Oliver Eilhard. All rights reserved.
|
|
// Use of this source code is governed by a MIT-license.
|
|
// See http://olivere.mit-license.org/license.txt for details.
|
|
|
|
package elastic
|
|
|
|
// InnerHit implements a simple join for parent/child, nested, and even
|
|
// top-level documents in Elasticsearch.
|
|
// It is an experimental feature for Elasticsearch versions 1.5 (or greater).
|
|
// See http://www.elastic.co/guide/en/elasticsearch/reference/5.2/search-request-inner-hits.html
|
|
// for documentation.
|
|
//
|
|
// See the tests for SearchSource, HasChildFilter, HasChildQuery,
|
|
// HasParentFilter, HasParentQuery, NestedFilter, and NestedQuery
|
|
// for usage examples.
|
|
type InnerHit struct {
|
|
source *SearchSource
|
|
path string
|
|
typ string
|
|
|
|
name string
|
|
}
|
|
|
|
// NewInnerHit creates a new InnerHit.
|
|
func NewInnerHit() *InnerHit {
|
|
return &InnerHit{source: NewSearchSource()}
|
|
}
|
|
|
|
func (hit *InnerHit) Path(path string) *InnerHit {
|
|
hit.path = path
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) Type(typ string) *InnerHit {
|
|
hit.typ = typ
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) Query(query Query) *InnerHit {
|
|
hit.source.Query(query)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) From(from int) *InnerHit {
|
|
hit.source.From(from)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) Size(size int) *InnerHit {
|
|
hit.source.Size(size)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) TrackScores(trackScores bool) *InnerHit {
|
|
hit.source.TrackScores(trackScores)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) Explain(explain bool) *InnerHit {
|
|
hit.source.Explain(explain)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) Version(version bool) *InnerHit {
|
|
hit.source.Version(version)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) StoredField(storedFieldName string) *InnerHit {
|
|
hit.source.StoredField(storedFieldName)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) StoredFields(storedFieldNames ...string) *InnerHit {
|
|
hit.source.StoredFields(storedFieldNames...)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) NoStoredFields() *InnerHit {
|
|
hit.source.NoStoredFields()
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) FetchSource(fetchSource bool) *InnerHit {
|
|
hit.source.FetchSource(fetchSource)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) FetchSourceContext(fetchSourceContext *FetchSourceContext) *InnerHit {
|
|
hit.source.FetchSourceContext(fetchSourceContext)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) DocvalueFields(docvalueFields ...string) *InnerHit {
|
|
hit.source.DocvalueFields(docvalueFields...)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) DocvalueField(docvalueField string) *InnerHit {
|
|
hit.source.DocvalueField(docvalueField)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) ScriptFields(scriptFields ...*ScriptField) *InnerHit {
|
|
hit.source.ScriptFields(scriptFields...)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) ScriptField(scriptField *ScriptField) *InnerHit {
|
|
hit.source.ScriptField(scriptField)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) Sort(field string, ascending bool) *InnerHit {
|
|
hit.source.Sort(field, ascending)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) SortWithInfo(info SortInfo) *InnerHit {
|
|
hit.source.SortWithInfo(info)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) SortBy(sorter ...Sorter) *InnerHit {
|
|
hit.source.SortBy(sorter...)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) Highlight(highlight *Highlight) *InnerHit {
|
|
hit.source.Highlight(highlight)
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) Highlighter() *Highlight {
|
|
return hit.source.Highlighter()
|
|
}
|
|
|
|
func (hit *InnerHit) Name(name string) *InnerHit {
|
|
hit.name = name
|
|
return hit
|
|
}
|
|
|
|
func (hit *InnerHit) Source() (interface{}, error) {
|
|
src, err := hit.source.Source()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
source, ok := src.(map[string]interface{})
|
|
if !ok {
|
|
return nil, nil
|
|
}
|
|
|
|
// Notice that hit.typ and hit.path are not exported here.
|
|
// They are only used with SearchSource and serialized there.
|
|
|
|
if hit.name != "" {
|
|
source["name"] = hit.name
|
|
}
|
|
return source, nil
|
|
}
|