Documentation ¶
Index ¶
- Constants
- type ClientSet
- type Config
- type DB
- type DBConfig
- type Offset
- type SortBy
- type Source
- func (s *Source) Category() api.Category
- func (s *Source) Commit(events []api.Event)
- func (s *Source) Config() interface{}
- func (s *Source) Init(context api.Context) error
- func (s *Source) ProductLoop(productFunc api.ProductFunc)
- func (s *Source) Start() error
- func (s *Source) Stop()
- func (s *Source) String() string
- func (s *Source) Type() api.Type
Constants ¶
View Source
const Type = "elasticsearch"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { PipelineName string Name string Hosts []string `yaml:"hosts,omitempty" validate:"required"` UserName string `yaml:"username,omitempty"` Password string `yaml:"password,omitempty"` Schema string `yaml:"schema,omitempty"` Sniff *bool `yaml:"sniff,omitempty"` Gzip *bool `yaml:"gzip,omitempty"` IncludeFields []string `yaml:"includeFields,omitempty"` ExcludeFields []string `yaml:"excludeFields,omitempty"` Query string `yaml:"query,omitempty"` SortBy []SortBy `yaml:"sortBy,omitempty" validate:"required"` Indices []string `yaml:"indices,omitempty" validate:"required"` Size int `yaml:"size,omitempty" default:"100"` Interval time.Duration `yaml:"interval,omitempty" default:"30s"` Timeout time.Duration `yaml:"timeout,omitempty" default:"5s"` DBConfig DBConfig `yaml:"db,omitempty"` }
func (*Config) AllSortByFields ¶ added in v1.5.0
type DBConfig ¶
type DBConfig struct { IndexPrefix string `yaml:"indexPrefix,omitempty" default:".loggie-db"` FlushTimeout time.Duration `yaml:"flushTimeout,omitempty" default:"2s"` CleanInactiveTimeout time.Duration `yaml:"cleanInactiveTimeout,omitempty" default:"504h"` // default records not updated in 21 days will be deleted CleanScanInterval time.Duration `yaml:"cleanScanInterval,omitempty" default:"1h"` }
type Source ¶
type Source struct {
// contains filtered or unexported fields
}
func (*Source) ProductLoop ¶
func (s *Source) ProductLoop(productFunc api.ProductFunc)
Click to show internal directories.
Click to hide internal directories.