Versions in this module Expand all Collapse all v1 v1.0.0 Jul 13, 2023 Changes in this version + const ContentEndpoint + const GroupsEndpoint + const ProcessedTimestampFieldName + const ReceivedTimestampFieldName + const RequestIDFieldName + const RuleHitsFieldName + const ScanBatchCount + var RequestIDsScanPattern = "organization:%v:cluster:%v:request:?*[^:reports]" + var SimplifiedReportKey = "organization:%v:cluster:%v:request:%v:reports" + func CloseResponseBody(response *http.Response) + func GetContent(conf Configuration) (*types.RuleContentDirectory, error) + func GetGroups(conf Configuration) ([]groups.Group, error) + type Configuration struct + AggregatorBaseEndpoint string + ContentBaseEndpoint string + ContentDirectoryTimeout time.Duration + GroupsPollingTime time.Duration + UpgradeRisksPredictionEndpoint string + type RedisClient struct + func (redis *RedisClient) GetRequestIDsForClusterID(orgID types.OrgID, clusterID types.ClusterName) (requestIDs []types.RequestID, err error) + func (redis *RedisClient) GetRuleHitsForRequest(orgID types.OrgID, clusterID types.ClusterName, requestID types.RequestID) (ruleHits []types.RuleID, err error) + func (redis *RedisClient) GetTimestampsForRequestIDs(orgID types.OrgID, clusterID types.ClusterName, requestIDs []types.RequestID, ...) (requestStatuses []types.RequestStatus, err error) + type RedisConfiguration struct + RedisDatabase int + RedisEndpoint string + RedisPassword string + RedisTimeoutSeconds int + type RedisInterface interface + GetRequestIDsForClusterID func(types.OrgID, types.ClusterName) ([]types.RequestID, error) + GetRuleHitsForRequest func(types.OrgID, types.ClusterName, types.RequestID) ([]types.RuleID, error) + GetTimestampsForRequestIDs func(types.OrgID, types.ClusterName, []types.RequestID, bool) ([]types.RequestStatus, error) + HealthCheck func() error + func NewRedisClient(conf RedisConfiguration) (RedisInterface, error)
Go to main page