forwarder

Documentation

Index

• Variables
• type Handler
  • func (h *Handler) Do(oldAlertDedupEvent, newAlertDedupEvent *alertApiModels.AlertDedupEvent) (err error)
• type LRUCache
  • func NewCache(ruleClient gatewayapi.API) *LRUCache
  • func (c *LRUCache) Get(id, version string) (*models.Rule, error)
• type RuleCache

Variables

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",
	}
)

Types

type Handler

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

func (*Handler) Do

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

type LRUCache

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

s3ClientCacheKey -> S3 client

func NewCache

func NewCache(ruleClient gatewayapi.API) *LRUCache

func (*LRUCache) Get

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

type RuleCache

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