Versions in this module Expand all Collapse all v0 v0.4.0 Nov 14, 2026 v0.3.1 Nov 14, 2026 v0.3.0 Nov 13, 2026 v0.2.1 Nov 7, 2026 v0.2.0 Nov 6, 2026 Changes in this version + var ErrScope = errors.New("elasticsearch source: the scope (time field, selector) is not verified") v0.1.0 Nov 6, 2026 Changes in this version + const AroundWindow + const DefaultMessageField + const DefaultTimeField + const FlavourElasticsearch + const FlavourOpenSearch + const InFlight + const KindElastic + const KindOpenSearch + const MaxCountBy + const MaxDescribeValues + const MaxHistogramBuckets + const MaxSize + const MaxSlices + const MaxTermsSize + const MinSlice + const SearchTimeout + var MaxAroundBytes int64 = 64 << 20 + type Agg struct + Aggs map[string]Agg + DateHistogram *DateHistogram + Terms *TermsAgg + type BoolQuery struct + Filter []Clause + MustNot []Clause + type Clause struct + Range map[string]RangeSpec + Term map[string]string + Terms map[string][]string + type Client interface + Send func(ctx context.Context, method, path string, q url.Values, body []byte) (egress.Response, error) + type CountBody struct + Query Query + type DateHistogram struct + Field string + FixedInterval string + MinDocCount int + Offset string + type FieldValues struct + Field string + Values []string + type Filter struct + In []FieldValues + NotIn []FieldValues + func DecodeFilter(s string) (Filter, error) + func (f Filter) Encode() (string, error) + type IndexPrivileges struct + Names []string + Privileges []string + type Info struct + Flavour string + Verified bool + Version string + Write []string + type Options struct + Client Client + InFlight int + Indices []string + Kind string + MessageField string + Name string + Now func() time.Time + Parser *parse.Parser + ReadOnlyRoles []string + Selector map[string]string + Size int + TieBreaker string + TimeField string + TrustedFields []string + type PrivilegesBody struct + Cluster []string + Index []IndexPrivileges + type Query struct + Bool BoolQuery + type RangeSpec struct + Format string + GTE string + LT string + type SearchBody struct + Aggs map[string]Agg + Fields []string + Query Query + SearchAfter []any + Size int + Sort []map[string]SortSpec + Source bool + Timeout string + TrackTotalHits bool + type SortSpec struct + NumericType string + Order string + UnmappedType string + type Source struct + func New(o Options) (*Source, error) + func (s *Source) Around(ctx context.Context, ref source.RawRef, before, after int) ([]source.RawRecord, error) + func (s *Source) Check(ctx context.Context, production bool) (info Info, retErr error) + func (s *Source) Describe(ctx context.Context) (source.Schema, error) + func (s *Source) IndexCounts(ctx context.Context, q source.CountQuery) (source.CountResult, error) + func (s *Source) Kind() string + func (s *Source) Name() string + func (s *Source) Plan(ctx context.Context, r source.Range, sel source.Selector) (source.Byteplan, error) + func (s *Source) Reread(ctx context.Context, ref source.RawRef) (source.RawRecord, error) + func (s *Source) Scan(ctx context.Context, c source.Chunk) (source.Iterator, error) + func (s *Source) Split(g source.Granule) []source.Granule + type TermsAgg struct + Field string + Missing *string + Size int
Go to main page