esanalyzer

Documentation

Index

• Constants
• type Analyzer
  • func New(svcClient workflowserviceclient.Interface, frontendClient frontend.Client, ...) *Analyzer
  • func (a *Analyzer) Start() error
  • func (a *Analyzer) StartDomainWFTypeCountWorkflow(ctx context.Context)
  • func (a *Analyzer) StartWorkflow(ctx context.Context)
• type Config
• type DomainWorkflowTypeCount
• type DomainWorkflowVersionCount
• type EsAggregateCount
• type Workflow
• type WorkflowTypeCount
• type WorkflowVersionCount

Constants

const (
	Pinot readMode = "pinot"
	ES    readMode = "es"
)

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) Start

func (a *Analyzer) Start() error

Start starts the scanner

func (*Analyzer) StartDomainWFTypeCountWorkflow

func (a *Analyzer) StartDomainWFTypeCountWorkflow(ctx context.Context)

func (*Analyzer) StartWorkflow

func (a *Analyzer) StartWorkflow(ctx context.Context)

type Config

type Config struct {
	ESAnalyzerPause                          dynamicconfig.BoolPropertyFn
	ESAnalyzerTimeWindow                     dynamicconfig.DurationPropertyFn
	ESAnalyzerMaxNumDomains                  dynamicconfig.IntPropertyFn
	ESAnalyzerMaxNumWorkflowTypes            dynamicconfig.IntPropertyFn
	ESAnalyzerLimitToTypes                   dynamicconfig.StringPropertyFn
	ESAnalyzerEnableAvgDurationBasedChecks   dynamicconfig.BoolPropertyFn
	ESAnalyzerLimitToDomains                 dynamicconfig.StringPropertyFn
	ESAnalyzerNumWorkflowsToRefresh          dynamicconfig.IntPropertyFnWithWorkflowTypeFilter
	ESAnalyzerBufferWaitTime                 dynamicconfig.DurationPropertyFnWithWorkflowTypeFilter
	ESAnalyzerMinNumWorkflowsForAvg          dynamicconfig.IntPropertyFnWithWorkflowTypeFilter
	ESAnalyzerWorkflowDurationWarnThresholds dynamicconfig.StringPropertyFn
	ESAnalyzerWorkflowVersionDomains         dynamicconfig.StringPropertyFn
	ESAnalyzerWorkflowTypeDomains            dynamicconfig.StringPropertyFn
}

Config contains all configs for ElasticSearch Analyzer

type DomainWorkflowTypeCount

type DomainWorkflowTypeCount struct {
	WorkflowTypes []EsAggregateCount `json:"buckets"`
}

type DomainWorkflowVersionCount

type DomainWorkflowVersionCount struct {
	WorkflowTypes []WorkflowTypeCount `json:"buckets"`
}

type EsAggregateCount

type EsAggregateCount struct {
	AggregateKey   string `json:"key"`
	AggregateCount int64  `json:"doc_count"`
}

type Workflow

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

type WorkflowTypeCount

type WorkflowTypeCount struct {
	EsAggregateCount
	WorkflowVersions WorkflowVersionCount `json:"versions"`
}

type WorkflowVersionCount

type WorkflowVersionCount struct {
	WorkflowVersions []EsAggregateCount `json:"buckets"`
}