template

Documentation

Index

• Variables
• type ESClient
• type Loader
  • func NewLoader(cfg *common.Config, client ESClient, beatInfo beat.Info) (*Loader, error)
  • func (l *Loader) CheckTemplate(templateName string) bool
  • func (l *Loader) Load() error
  • func (l *Loader) LoadTemplate(templateName string, template map[string]interface{}) error
• type Processor
• type Template
  • func New(beatVersion string, beatName string, esVersion string, config TemplateConfig) (*Template, error)
  • func (t *Template) GetName() string
  • func (t *Template) GetPattern() string
  • func (t *Template) Load(file string) (common.MapStr, error)
• type TemplateConfig
• type TemplateSettings

Variables

var (
	// DefaultConfig for index template
	DefaultConfig = TemplateConfig{
		Enabled: true,
		Fields:  "fields.yml",
	}
)

Types

type ESClient

type ESClient interface {
	LoadJSON(path string, json map[string]interface{}) ([]byte, error)
	Request(method, path string, pipeline string, params map[string]string, body interface{}) (int, []byte, error)
	GetVersion() string
}

TemplateLoader is a subset of the Elasticsearch client API capable of loading the template.

type Loader

type Loader struct {
	// contains filtered or unexported fields
}

func NewLoader

func NewLoader(cfg *common.Config, client ESClient, beatInfo beat.Info) (*Loader, error)

func (*Loader) CheckTemplate

func (l *Loader) CheckTemplate(templateName string) bool

CheckTemplate checks if a given template already exist. It returns true if and only if Elasticsearch returns with HTTP status code 200.

func (*Loader) Load

func (l *Loader) Load() error

Load checks if the index mapping template should be loaded In case the template is not already loaded or overwriting is enabled, the template is written to index

func (*Loader) LoadTemplate

func (l *Loader) LoadTemplate(templateName string, template map[string]interface{}) error

LoadTemplate loads a template into Elasticsearch overwriting the existing template if it exists. If you wish to not overwrite an existing template then use CheckTemplate prior to calling this method.

type Processor

type Processor struct {
	EsVersion common.Version
}

type Template

type Template struct {
	// contains filtered or unexported fields
}

func New

func New(beatVersion string, beatName string, esVersion string, config TemplateConfig) (*Template, error)

New creates a new template instance

func (*Template) GetName

func (t *Template) GetName() string

GetName returns the name of the template

func (*Template) GetPattern

func (t *Template) GetPattern() string

GetPattern returns the pattern of the template

func (*Template) Load

func (t *Template) Load(file string) (common.MapStr, error)

Load the given input and generates the input based on it

type TemplateConfig

type TemplateConfig struct {
	Enabled   bool             `config:"enabled"`
	Name      string           `config:"name"`
	Pattern   string           `config:"pattern"`
	Fields    string           `config:"fields"`
	Overwrite bool             `config:"overwrite"`
	Settings  TemplateSettings `config:"settings"`
}

type TemplateSettings

type TemplateSettings struct {
	Index  map[string]interface{} `config:"index"`
	Source map[string]interface{} `config:"_source"`
}