runners

Documentation

Index

• Constants
• type FilterResponse
• type IndexStatsResponse
• type Runnerable
  • func NewRunner(criteria criterias.Criteriable, connection *golastic.Connection, ...) (Runnerable, error)

Constants

const CLOSED_STATUS string = "close"

const GIGABYTE_CONVERSION float64 = 1000000000

const MEGABYTE_CONVERSION float64 = 1000000

const NOT_VALID_DATE_PARAMETER = "Field is not a valid date parameter"

NOT_VALID_DATE_PARAMETER error message

const OPEN_STATUS string = "open"

const SECONDS_PER_DAY float64 = 86400

const SECONDS_PER_MONTH float64 = 2628000

const SECONDS_PER_YEAR float64 = 31540000

Types

type FilterResponse

type FilterResponse struct {
	Passed bool               `json:"passed"`
	Err    error              `json:"error"`
	List   []string           `json:"list"`
	Report reports.Reportable `json:"report"`
}

FilterResponse is the response of a filter run

type IndexStatsResponse

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

IndexStatsResponse represents the response of an index stats call

type Runnerable

type Runnerable interface {
	// Init initializes the filter runner
	Init(criteria criterias.Criteriable, builder *golastic.Connection, info ...infos.Informable) (Runnerable, error)

	// RunFilter filters out elements from the actionable list
	RunFilter(channel chan *FilterResponse)
}

Runnerable represents a contract to be implemented by filter runners

func NewRunner

func NewRunner(criteria criterias.Criteriable, connection *golastic.Connection, info ...infos.Informable) (Runnerable, error)

NewRunner return a filter runner