Documentation
¶
Index ¶
Constants ¶
View Source
const ( Pinot readMode = "pinot" ES readMode = "es" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Analyzer ¶
type Analyzer struct {
// contains filtered or unexported fields
}
Analyzer is the background sub-system to query ElasticSearch and execute mitigations
func New ¶
func New( svcClient workflowserviceclient.Interface, frontendClient frontend.Client, clientBean client.Bean, esClient es.GenericClient, pinotClient pinot.GenericClient, esConfig *config.ElasticSearchConfig, pinotConfig *config.PinotVisibilityConfig, logger log.Logger, tallyScope tally.Scope, resource resource.Resource, domainCache cache.DomainCache, config *Config, ) *Analyzer
New returns a new instance as daemon
func (*Analyzer) StartDomainWFTypeCountWorkflow ¶ added in v1.0.0
func (*Analyzer) StartWorkflow ¶
type Config ¶
type Config struct {
ESAnalyzerPause dynamicproperties.BoolPropertyFn
ESAnalyzerTimeWindow dynamicproperties.DurationPropertyFn
ESAnalyzerMaxNumDomains dynamicproperties.IntPropertyFn
ESAnalyzerMaxNumWorkflowTypes dynamicproperties.IntPropertyFn
ESAnalyzerLimitToTypes dynamicproperties.StringPropertyFn
ESAnalyzerEnableAvgDurationBasedChecks dynamicproperties.BoolPropertyFn
ESAnalyzerLimitToDomains dynamicproperties.StringPropertyFn
ESAnalyzerNumWorkflowsToRefresh dynamicproperties.IntPropertyFnWithWorkflowTypeFilter
ESAnalyzerBufferWaitTime dynamicproperties.DurationPropertyFnWithWorkflowTypeFilter
ESAnalyzerMinNumWorkflowsForAvg dynamicproperties.IntPropertyFnWithWorkflowTypeFilter
ESAnalyzerWorkflowDurationWarnThresholds dynamicproperties.StringPropertyFn
ESAnalyzerWorkflowVersionDomains dynamicproperties.StringPropertyFn
ESAnalyzerWorkflowTypeDomains dynamicproperties.StringPropertyFn
}
Config contains all configs for ElasticSearch Analyzer
type DomainWorkflowTypeCount ¶ added in v1.0.0
type DomainWorkflowTypeCount struct {
WorkflowTypes []EsAggregateCount `json:"buckets"`
}
type DomainWorkflowVersionCount ¶ added in v1.0.0
type DomainWorkflowVersionCount struct {
WorkflowTypes []WorkflowTypeCount `json:"buckets"`
}
type EsAggregateCount ¶ added in v1.0.0
type WorkflowTypeCount ¶ added in v1.0.0
type WorkflowTypeCount struct {
EsAggregateCount
WorkflowVersions WorkflowVersionCount `json:"versions"`
}
type WorkflowVersionCount ¶ added in v1.0.0
type WorkflowVersionCount struct {
WorkflowVersions []EsAggregateCount `json:"buckets"`
}
Click to show internal directories.
Click to hide internal directories.