forwarder

package
v1.16.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 10, 2021 License: AGPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StaticLogger = metrics.MustStaticLogger([]metrics.DimensionSet{
		{
			"AnalysisType",
			"Severity",
		},
		{
			"AnalysisType",
			"AnalysisID",
		},
		{
			"AnalysisType",
		},
	}, []metrics.Metric{
		{
			Name: "AlertsCreated",
			Unit: metrics.UnitCount,
		},
	})
	AnalysisTypeDimension = metrics.Dimension{
		Name:  "AnalysisType",
		Value: "Rule",
	}
)

Functions

This section is empty.

Types

type Handler added in v1.6.0 

type Handler struct {
	SqsClient        sqsiface.SQSAPI
	Cache            RuleCache
	DdbClient        dynamodbiface.DynamoDBAPI
	AlertTable       string
	AlertingQueueURL string
	MetricsLogger    metrics.Logger
}

func (*Handler) Do added in v1.6.0 

func (h *Handler) Do(oldAlertDedupEvent, newAlertDedupEvent *alertApiModels.AlertDedupEvent) (err error)

type LRUCache added in v1.15.0 

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

s3ClientCacheKey -> S3 client

func NewCache added in v1.6.0 

func NewCache(ruleClient gatewayapi.API) *LRUCache

func (*LRUCache) Get added in v1.15.0 

func (c *LRUCache) Get(id, version string) (*models.Rule, error)

type RuleCache added in v1.6.0 

type RuleCache interface {
	Get(id, version string) (*models.Rule, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.