coordinator

Documentation

Overview

Package coordinator implements all features necessary to initialize and monitor elasticsearch components

On-start :

* Load Configuration :

• Instances + Logical Indices + Cron

* Check if any corresponding indices exists * If so, Check if any corresponding aliases exists * Check if any corresponding templates exists

Index

• func InitInstance(instanceName string, models map[int64]modeler.Model) error
• type Instance
  • func GetInstance() *Instance
  • func (i *Instance) LogicalIndex(modelName string) LogicalIndex
• type LogicalIndex
• type LogicalIndexCron
  • func NewLogicalIndexCron(instanceName string, model modeler.Model) (*LogicalIndexCron, error)
  • func (logicalIndex *LogicalIndexCron) FindIndices(t time.Time, depthDays int64) ([]string, error)
  • func (logicalIndex *LogicalIndexCron) GetCron() *cron.Cron
• type LogicalIndexTimeBased
  • func NewLogicalIndexTimeBased(instanceName string, model modeler.Model) (*LogicalIndexTimeBased, error)
  • func (logicalIndex *LogicalIndexTimeBased) FetchIndices()
  • func (logicalIndex *LogicalIndexTimeBased) FindIndices(t time.Time, depthDays int64) ([]string, error)
  • func (logicalIndex *LogicalIndexTimeBased) GetAllIndices() []string
  • func (logicalIndex *LogicalIndexTimeBased) GetCron() *cron.Cron
• type RollMode

Functions

func InitInstance

func InitInstance(instanceName string, models map[int64]modeler.Model) error

Types

type Instance

type Instance struct {
	Initialized    bool
	Name           string
	Urls           []string
	LogicalIndices map[string]LogicalIndex
}

Instance represents a functional Myrtea instance

func GetInstance

func GetInstance() *Instance

func (*Instance) LogicalIndex

func (i *Instance) LogicalIndex(modelName string) LogicalIndex

type LogicalIndex

type LogicalIndex interface {
	GetCron() *cron.Cron
	FindIndices(t time.Time, depthDays int64) ([]string, error)
}

type LogicalIndexCron

type LogicalIndexCron struct {
	Initialized bool
	Name        string
	Cron        *cron.Cron
	Model       modeler.Model
	// contains filtered or unexported fields
}

LogicalIndexCron abstracts a group a technical elasticsearchv8 indices, which are accessibles with specific aliases

func NewLogicalIndexCron

func NewLogicalIndexCron(instanceName string, model modeler.Model) (*LogicalIndexCron, error)

func (*LogicalIndexCron) FindIndices

func (logicalIndex *LogicalIndexCron) FindIndices(t time.Time, depthDays int64) ([]string, error)

FindIndices search in indices referential every indices between two dates (calculated using current time and depth)

func (*LogicalIndexCron) GetCron

func (logicalIndex *LogicalIndexCron) GetCron() *cron.Cron

type LogicalIndexTimeBased

type LogicalIndexTimeBased struct {
	Initialized bool
	Name        string
	Cron        *cron.Cron
	Model       modeler.Model
	LiveIndices []string
	// contains filtered or unexported fields
}

LogicalIndexTimeBased abstracts a group a technical elasticsearchv8 indices, which are accessibles with specific aliases

func NewLogicalIndexTimeBased

func NewLogicalIndexTimeBased(instanceName string, model modeler.Model) (*LogicalIndexTimeBased, error)

func (*LogicalIndexTimeBased) FetchIndices

func (logicalIndex *LogicalIndexTimeBased) FetchIndices()

func (*LogicalIndexTimeBased) FindIndices

func (logicalIndex *LogicalIndexTimeBased) FindIndices(t time.Time, depthDays int64) ([]string, error)

func (*LogicalIndexTimeBased) GetAllIndices

func (logicalIndex *LogicalIndexTimeBased) GetAllIndices() []string

func (*LogicalIndexTimeBased) GetCron

func (logicalIndex *LogicalIndexTimeBased) GetCron() *cron.Cron

type RollMode

type RollMode int

RollMode is a enumeration of all indices roll mode

const (
	// Rollover is the native elasticsearch roll mode, based on /_rollover API
	Rollover RollMode = iota + 1
	// IngestTimebased is ...
	IngestTimebased
)