Versions in this module Expand all Collapse all v0 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