scalers

package

Go to main page

Versions in this module

v2

v2.15.1

Aug 12, 2024

v2.15.0

Aug 1, 2024

Changes in this version

+ const QueueLengthStrategyAll

+ const QueueLengthStrategyVisibleOnly

+ func CreateAzureLogsClient(config *scalersconfig.ScalerConfig, meta *azureLogAnalyticsMetadata, ...) (*azquery.LogsClient, error)

+ func CreateAzureMetricsClient(config *scalersconfig.ScalerConfig, meta *azureMonitorMetadata, ...) (*azquery.MetricsClient, error)

type Response

+ Message []string

type Scaler

+ func NewDynatraceScaler(config *scalersconfig.ScalerConfig) (Scaler, error)

+ func NewSplunkScaler(config *scalersconfig.ScalerConfig) (Scaler, error)

type SolaceMetadata

+ ActivationMsgCountTarget int

+ ActivationMsgRxRateTarget int

+ ActivationMsgSpoolUsageTarget int

+ EndpointURL string

+ MessageVpn string

+ MsgCountTarget int64

+ MsgRxRateTarget int64

+ MsgSpoolUsageTarget int64

+ Password string

+ QueueName string

+ SolaceMetaSempBaseURL string

+ Username string

+ func (s *SolaceMetadata) Validate() error

+ type SplunkMetadata struct

+ APIToken string

+ ActivationValue int

+ Host string

+ Password string

+ SavedSearchName string

+ TargetValue int

+ UnsafeSsl bool

+ Username string

+ ValueField string

+ type SplunkScaler struct

+ func (s *SplunkScaler) Close(context.Context) error

+ func (s *SplunkScaler) GetMetricSpecForScaling(context.Context) []v2.MetricSpec

+ func (s *SplunkScaler) GetMetricsAndActivity(_ context.Context, metricName string) ([]external_metrics.ExternalMetricValue, bool, error)

v2.14.1

Jul 31, 2024

Changes in this version

+ const KafkaSASLOAuthTokenProviderAWSMSKIAM

+ const KafkaSASLOAuthTokenProviderBearer

v2.14.0

Apr 25, 2024

Changes in this version

+ type APIFormat string

+ const JSONFormat

+ const PrometheusFormat

+ const XMLFormat

+ const YAMLFormat

+ type Option func(*configOptions)

+ func IsOptional(optional bool) Option

+ func UseAuthentication(auth bool) Option

+ func UseMetadata(metadata bool) Option

+ func UseResolvedEnv(resolvedEnv bool) Option

+ func WithDefaultVal(defaultVal interface{}) Option

v2.13.1

Feb 29, 2024

v2.13.0

Jan 18, 2024

Changes in this version

+ const KafkaSASLTypeGSSAPI

v2.12.1

Nov 27, 2023

v2.12.0

Sep 28, 2023

Changes in this version

+ const KafkaSASLTypeMskIam

+ type DynamodbStreamWrapperClient interface

+ DescribeStream func(ctx context.Context, params *dynamodbstreams.DescribeStreamInput, ...) (*dynamodbstreams.DescribeStreamOutput, error)

+ type KinesisWrapperClient interface

+ DescribeStreamSummary func(context.Context, *kinesis.DescribeStreamSummaryInput, ...) (*kinesis.DescribeStreamSummaryOutput, error)

type Scaler

+ func NewApacheKafkaScaler(ctx context.Context, config *ScalerConfig) (Scaler, error)

+ func NewGcpCloudTasksScaler(config *ScalerConfig) (Scaler, error)

type ScalerConfig

+ AsMetricSource bool

+ type SqsWrapperClient interface

+ GetQueueAttributes func(ctx context.Context, params *sqs.GetQueueAttributesInput, ...) (*sqs.GetQueueAttributesOutput, error)

v2.11.2

Jul 27, 2023

v2.11.1

Jun 29, 2023

v2.11.0

Jun 22, 2023

Changes in this version

type Scaler

+ func NewSolrScaler(config *ScalerConfig) (Scaler, error)

v2.10.1

Apr 13, 2023

v2.10.0

Mar 9, 2023

Changes in this version

+ const DefaultPlatformName

+ const ENT

+ const ORG

+ const REPO

+ var ErrAwsDynamoEmptyExpressionAttributeNames = errors.New("empty map")

+ var ErrAwsDynamoInvalidExpressionAttributeNames = errors.New("invalid expressionAttributeNames")

+ var ErrAwsDynamoInvalidExpressionAttributeValues = errors.New("invalid expressionAttributeValues")

+ var ErrAwsDynamoNoAwsRegion = errors.New("no awsRegion given")

+ var ErrAwsDynamoNoExpressionAttributeNames = errors.New("no expressionAttributeNames given")

+ var ErrAwsDynamoNoExpressionAttributeValues = errors.New("no expressionAttributeValues given")

+ var ErrAwsDynamoNoKeyConditionExpression = errors.New("no keyConditionExpression given")

+ var ErrAwsDynamoNoTableName = errors.New("no tableName given")

+ var ErrAwsDynamoNoTargetValue = errors.New("no targetValue given")

+ var ErrAwsNoAccessKey = errors.New("awsAccessKeyID not found")

+ var ErrElasticsearchConfigConflict = errors.New("can't provide endpoint addresses and cloud config at the same time")

+ var ErrElasticsearchMissingAddressesOrCloudConfig = errors.New("must provide either endpoint addresses or cloud config")

+ var ErrLiiklusNoAddress = errors.New("no liiklus API address provided")

+ var ErrLiiklusNoGroup = errors.New("no consumer group provided")

+ var ErrLiiklusNoTopic = errors.New("no topic provided")

+ var ErrMsSQLNoQuery = errors.New("no query given")

+ var ErrMsSQLNoTargetValue = errors.New("no targetValue given")

+ var ErrRedisMissingPendingEntriesCount = errors.New("missing pending entries count")

+ var ErrRedisMissingStreamName = errors.New("missing redis stream name")

+ var ErrRedisNoAddresses = errors.New(...)

+ var ErrRedisNoListName = errors.New("no list name given")

+ var ErrRedisUnequalHostsAndPorts = errors.New(...)

+ var ErrScalerConfigMissingField = errors.New("missing required field in scaler config")

+ var ErrScalerUnsupportedUtilizationMetricType = errors.New(...)

+ type Job struct

+ CheckRunURL string

+ CompletedAt time.Time

+ Conclusion string

+ HTMLURL string

+ HeadBranch string

+ HeadSha string

+ ID int

+ Labels []string

+ Name string

+ NodeID string

+ RunID int

+ RunURL string

+ RunnerGroupID int

+ RunnerGroupName string

+ RunnerID int

+ RunnerName string

+ StartedAt time.Time

+ Status string

+ Steps []struct{ ... }

+ URL string

+ WorkflowName string

+ type Jobs struct

+ Jobs []Job

+ TotalCount int

+ type Repo struct

+ AllowAutoMerge bool

+ AllowMergeCommit bool

+ AllowRebaseMerge bool

+ AllowSquashMerge bool

+ ArchiveURL string

+ Archived bool

+ AssigneesURL string

+ BlobsURL string

+ BranchesURL string

+ CloneURL string

+ CollaboratorsURL string

+ CommentsURL string

+ CommitsURL string

+ CompareURL string

+ ContentsURL string

+ ContributorsURL string

+ CreatedAt time.Time

+ DefaultBranch string

+ DeleteBranchOnMerge bool

+ DeploymentsURL string

+ Description string

+ Disabled bool

+ DownloadsURL string

+ EventsURL string

+ Fork bool

+ Forks int

+ ForksCount int

+ ForksURL string

+ FullName string

+ GitCommitsURL string

+ GitRefsURL string

+ GitTagsURL string

+ GitURL string

+ HTMLURL string

+ HasDownloads bool

+ HasIssues bool

+ HasPages bool

+ HasProjects bool

+ HasWiki bool

+ Homepage string

+ HooksURL string

+ ID int

+ IsTemplate bool

+ IssueCommentURL string

+ IssueEventsURL string

+ IssuesURL string

+ KeysURL string

+ LabelsURL string

+ Language interface{}

+ LanguagesURL string

+ License struct{ ... }

+ MergesURL string

+ MilestonesURL string

+ MirrorURL string

+ Name string

+ NetworkCount int

+ NodeID string

+ NotificationsURL string

+ OpenIssues int

+ OpenIssuesCount int

+ Owner struct{ ... }

+ Permissions struct{ ... }

+ Private bool

+ PullsURL string

+ PushedAt time.Time

+ ReleasesURL string

+ SSHURL string

+ Size int

+ StargazersCount int

+ StargazersURL string

+ StatusesURL string

+ SubscribersCount int

+ SubscribersURL string

+ SubscriptionURL string

+ SvnURL string

+ TagsURL string

+ TeamsURL string

+ TempCloneToken string

+ TemplateRepository interface{}

+ Topics []string

+ TreesURL string

+ URL string

+ UpdatedAt time.Time

+ Visibility string

+ Watchers int

+ WatchersCount int

+ type Repos struct

+ Repo []Repo

type Scaler

+ func NewArangoDBScaler(config *ScalerConfig) (Scaler, error)

+ func NewGitHubRunnerScaler(config *ScalerConfig) (Scaler, error)

+ type WorkflowRun struct

+ Actor struct{ ... }

+ ArtifactsURL string

+ CancelURL string

+ CheckSuiteID int64

+ CheckSuiteNodeID string

+ CheckSuiteURL string

+ Conclusion *string

+ CreatedAt time.Time

+ DisplayTitle string

+ Event string

+ HTMLURL string

+ HeadBranch string

+ HeadCommit struct{ ... }

+ HeadRepository Repo

+ HeadSha string

+ ID int64

+ JobsURL string

+ LogsURL string

+ Name string

+ NodeID string

+ Path string

+ PreviousAttemptURL *string

+ PullRequests []struct{ ... }

+ ReferencedWorkflows []interface{}

+ Repository Repo

+ RerunURL string

+ RunAttempt int

+ RunNumber int

+ RunStartedAt time.Time

+ Status string

+ TriggeringActor struct{ ... }

+ URL string

+ UpdatedAt time.Time

+ WorkflowID int

+ WorkflowURL string

+ type WorkflowRuns struct

+ TotalCount int

+ WorkflowRuns []WorkflowRun

v2.9.3

Jan 31, 2023

v2.9.2

Jan 16, 2023

v2.9.1

Dec 16, 2022

v2.9.0

Dec 9, 2022

Changes in this version

+ const KafkaSASLTypeOAuthbearer

+ func OAuthBearerTokenProvider(clientID, clientSecret, tokenURL string, scopes []string) sarama.AccessTokenProvider

type IBMMQScaler

+ func (s *IBMMQScaler) GetMetricsAndActivity(ctx context.Context, metricName string) ([]external_metrics.ExternalMetricValue, bool, error)

+ type JobRequest struct

+ AssignTime time.Time

+ Data struct{ ... }

+ Definition struct{ ... }

+ Demands []string

+ HostID string

+ JobID string

+ LockedUntil time.Time

+ MatchedAgents ...

+ OrchestrationID string

+ Owner struct{ ... }

+ PlanID string

+ PlanType string

+ PoolID int

+ Priority int

+ QueueTime time.Time

+ ReceiveTime time.Time

+ RequestID int

+ ReservedAgent ...

+ Result *string

+ ScopeID string

+ ServiceOwner string

+ type JobRequests struct

+ Count int

+ Value []JobRequest

type PredictKubeScaler

+ func (s *PredictKubeScaler) GetMetricsAndActivity(ctx context.Context, metricName string) ([]external_metrics.ExternalMetricValue, bool, error)

+ type Res struct

+ Feet int

+ Greeting string

+ ID string

type Scaler

+ func NewCouchDBScaler(ctx context.Context, config *ScalerConfig) (Scaler, error)

+ func NewEtcdScaler(config *ScalerConfig) (Scaler, error)

+ func NewLokiScaler(config *ScalerConfig) (Scaler, error)

+ GetMetricsAndActivity func(ctx context.Context, metricName string) ([]external_metrics.ExternalMetricValue, bool, error)

type ScalerConfig

+ TriggerName string

+ TriggerUseCachedMetrics bool

type SolaceScaler

+ func (s *SolaceScaler) GetMetricsAndActivity(ctx context.Context, metricName string) ([]external_metrics.ExternalMetricValue, bool, error)

+ type TokenProvider struct

+ func (t *TokenProvider) Token() (*sarama.AccessToken, error)

v2.8.2

Jan 19, 2023

Changes in this version

+ func AvgFloatFromSlice(results []float64) float64

+ func MaxFloatFromSlice(results []float64) float64

v2.8.1

Sep 1, 2022

v2.8.0

Aug 10, 2022

Changes in this version

+ const MockExternalServerStatusOffline

+ const MockExternalServerStatusOnline

+ var ErrMock = errors.New("mock error")

+ var MockExternalServerStatus = MockExternalServerStatusOnline

+ var MockMetricName = "mockMetricName"

+ var MockMetricTarget int64 = 50

+ var MockMetricValue int64 = 100

+ func GenerateMetricInMili(metricName string, value float64) external_metrics.ExternalMetricValue

+ func GetMetricTargetMili(metricType v2beta2.MetricTargetType, metricValue float64) v2beta2.MetricTarget

+ func InitializeLogger(config *ScalerConfig, scalerName string) logr.Logger

+ func NewStackdriverAggregator(period int64, aligner string, reducer string) (*monitoringpb.Aggregation, error)

type Scaler

+ func NewAwsDynamoDBStreamsScaler(ctx context.Context, config *ScalerConfig) (Scaler, error)

+ func NewExternalMockScaler(config *ScalerConfig) (Scaler, error)

+ func NewNATSJetStreamScaler(config *ScalerConfig) (Scaler, error)

+ func NewPulsarScaler(config *ScalerConfig) (Scaler, error)

type ScalerConfig

+ ScalableObjectName string

+ ScalableObjectNamespace string

+ ScalableObjectType string

v2.7.1

May 10, 2022

v2.7.0

May 5, 2022

Changes in this version

+ func GetMetricTarget(metricType v2beta2.MetricTargetType, metricValue int64) v2beta2.MetricTarget

+ func GetMetricTargetType(config *ScalerConfig) (v2beta2.MetricTargetType, error)

+ func RemoveIndexFromMetricName(scalerIndex int, metricName string) (string, error)

type Scaler

+ func NewAwsDynamoDBScaler(config *ScalerConfig) (Scaler, error)

+ func NewAzureDataExplorerScaler(config *ScalerConfig) (Scaler, error)

+ func NewGcsScaler(config *ScalerConfig) (Scaler, error)

+ func NewStackdriverScaler(ctx context.Context, config *ScalerConfig) (Scaler, error)

type ScalerConfig

+ MetricType v2beta2.MetricTargetType

v2.6.1

Feb 10, 2022

v2.6.0

Jan 31, 2022

Changes in this version

+ type PredictKubeScaler struct

+ func NewPredictKubeScaler(ctx context.Context, config *ScalerConfig) (*PredictKubeScaler, error)

+ func (s *PredictKubeScaler) Close(_ context.Context) error

+ func (s *PredictKubeScaler) GetMetricSpecForScaling(context.Context) []v2beta2.MetricSpec

+ func (s *PredictKubeScaler) GetMetrics(ctx context.Context, metricName string, _ labels.Selector) ([]external_metrics.ExternalMetricValue, error)

+ func (s *PredictKubeScaler) IsActive(ctx context.Context) (bool, error)

type Scaler

+ func NewActiveMQScaler(config *ScalerConfig) (Scaler, error)

+ func NewAzureAppInsightsScaler(config *ScalerConfig) (Scaler, error)

+ func NewDatadogScaler(ctx context.Context, config *ScalerConfig) (Scaler, error)

+ func NewNewRelicScaler(config *ScalerConfig) (Scaler, error)

v2.5.0

Nov 25, 2021

Changes in this version

+ func GenerateMetricNameWithIndex(scalerIndex int, metricName string) string

+ func GetFromAuthOrMeta(config *ScalerConfig, field string) (string, error)

+ func NewCassandraSession(meta *CassandraMetadata) (*gocql.Session, error)

+ type CassandraMetadata struct

+ func ParseCassandraMetadata(config *ScalerConfig) (*CassandraMetadata, error)

type Scaler

+ func NewCassandraScaler(config *ScalerConfig) (Scaler, error)

+ func NewElasticsearchScaler(config *ScalerConfig) (Scaler, error)

+ func NewGraphiteScaler(config *ScalerConfig) (Scaler, error)

type ScalerConfig

+ ScalerIndex int

type StackDriverClient

+ func NewStackDriverClientPodIdentity(ctx context.Context) (*StackDriverClient, error)

v2.4.0

Aug 6, 2021

Changes in this version

+ const DefaultBrowserVersion

type Scaler

+ func NewKubernetesWorkloadScaler(kubeClient client.Client, config *ScalerConfig) (Scaler, error)

+ func NewSeleniumGridScaler(config *ScalerConfig) (Scaler, error)

+ func NewSolaceScaler(config *ScalerConfig) (Scaler, error)

+ type SolaceMetadata struct

+ type SolaceMetricValues struct

+ type SolaceScaler struct

+ func (s *SolaceScaler) Close() error

+ func (s *SolaceScaler) GetMetricSpecForScaling() []v2beta2.MetricSpec

+ func (s *SolaceScaler) GetMetrics(ctx context.Context, metricName string, metricSelector labels.Selector) ([]external_metrics.ExternalMetricValue, error)

+ func (s *SolaceScaler) IsActive(ctx context.Context) (bool, error)

v2.3.0

May 27, 2021

Changes in this version

type Scaler

+ func NewAzurePipelinesScaler(config *ScalerConfig) (Scaler, error)

+ func NewOpenstackMetricScaler(config *ScalerConfig) (Scaler, error)

v2.2.0

Mar 18, 2021

Changes in this version

type Scaler

+ func NewMSSQLScaler(config *ScalerConfig) (Scaler, error)

v2.1.0

Jan 27, 2021

Changes in this version

+ const KafkaSASLTypeNone

+ const KafkaSASLTypePlaintext

+ const KafkaSASLTypeSCRAMSHA256

+ const KafkaSASLTypeSCRAMSHA512

+ var SHA256 scram.HashGeneratorFcn = sha256.New

+ var SHA512 scram.HashGeneratorFcn = sha512.New

+ func GetUnprocessedEventCountWithoutCheckpoint(partitionInfo *eventhub.HubPartitionRuntimeInformation) int64

+ func GetValueFromResponse(body []byte, valueLocation string) (int64, error)

+ type CommandResponse struct

+ CommandResponse []Response

+ type GoogleApplicationCredentials struct

+ AuthProviderCertURL string

+ AuthURI string

+ ClientEmail string

+ ClientID string

+ ClientX509CertURL string

+ PrivateKey string

+ PrivateKeyID string

+ ProjectID string

+ TokenURI string

+ Type string

+ type IBMMQMetadata struct

+ type IBMMQScaler struct

+ func (s *IBMMQScaler) Close() error

+ func (s *IBMMQScaler) GetMetricSpecForScaling() []v2beta2.MetricSpec

+ func (s *IBMMQScaler) GetMetrics(ctx context.Context, metricName string, metricSelector labels.Selector) ([]external_metrics.ExternalMetricValue, error)

+ func (s *IBMMQScaler) IsActive(ctx context.Context) (bool, error)

+ type Parameters struct

+ Curdepth int

+ type PushScaler interface

+ Run func(ctx context.Context, active chan<- bool)

+ func NewExternalPushScaler(config *ScalerConfig) (PushScaler, error)

+ type Response struct

+ Parameters Parameters

+ type Scaler interface

+ Close func() error

+ GetMetricSpecForScaling func() []v2beta2.MetricSpec

+ GetMetrics func(ctx context.Context, metricName string, metricSelector labels.Selector) ([]external_metrics.ExternalMetricValue, error)

+ IsActive func(ctx context.Context) (bool, error)

+ func NewArtemisQueueScaler(config *ScalerConfig) (Scaler, error)

+ func NewAwsCloudwatchScaler(config *ScalerConfig) (Scaler, error)

+ func NewAwsKinesisStreamScaler(config *ScalerConfig) (Scaler, error)

+ func NewAwsSqsQueueScaler(config *ScalerConfig) (Scaler, error)

+ func NewAzureBlobScaler(config *ScalerConfig) (Scaler, error)

+ func NewAzureEventHubScaler(config *ScalerConfig) (Scaler, error)

+ func NewAzureLogAnalyticsScaler(config *ScalerConfig) (Scaler, error)

+ func NewAzureMonitorScaler(config *ScalerConfig) (Scaler, error)

+ func NewAzureQueueScaler(config *ScalerConfig) (Scaler, error)

+ func NewAzureServiceBusScaler(config *ScalerConfig) (Scaler, error)

+ func NewCPUMemoryScaler(resourceName v1.ResourceName, config *ScalerConfig) (Scaler, error)

+ func NewCronScaler(config *ScalerConfig) (Scaler, error)

+ func NewExternalScaler(config *ScalerConfig) (Scaler, error)

+ func NewHuaweiCloudeyeScaler(config *ScalerConfig) (Scaler, error)

+ func NewIBMMQScaler(config *ScalerConfig) (Scaler, error)

+ func NewInfluxDBScaler(config *ScalerConfig) (Scaler, error)

+ func NewKafkaScaler(config *ScalerConfig) (Scaler, error)

+ func NewLiiklusScaler(config *ScalerConfig) (Scaler, error)

+ func NewMetricsAPIScaler(config *ScalerConfig) (Scaler, error)

+ func NewMongoDBScaler(config *ScalerConfig) (Scaler, error)

+ func NewMySQLScaler(config *ScalerConfig) (Scaler, error)

+ func NewOpenstackSwiftScaler(config *ScalerConfig) (Scaler, error)

+ func NewPostgreSQLScaler(config *ScalerConfig) (Scaler, error)

+ func NewPrometheusScaler(config *ScalerConfig) (Scaler, error)

+ func NewPubSubScaler(config *ScalerConfig) (Scaler, error)

+ func NewRabbitMQScaler(config *ScalerConfig) (Scaler, error)

+ func NewRedisScaler(isClustered bool, config *ScalerConfig) (Scaler, error)

+ func NewRedisStreamsScaler(isClustered bool, config *ScalerConfig) (Scaler, error)

+ func NewStanScaler(config *ScalerConfig) (Scaler, error)

+ type ScalerConfig struct

+ AuthParams map[string]string

+ GlobalHTTPTimeout time.Duration

+ Name string

+ Namespace string

+ PodIdentity kedav1alpha1.PodIdentityProvider

+ ResolvedEnv map[string]string

+ TriggerMetadata map[string]string

+ type StackDriverClient struct

+ func NewStackDriverClient(ctx context.Context, credentials string) (*StackDriverClient, error)

+ func (s StackDriverClient) GetMetrics(ctx context.Context, filter string) (int64, error)

+ type XDGSCRAMClient struct

+ func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

+ func (x *XDGSCRAMClient) Done() bool

+ func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Other modules containing this package

github.com/kedacore/keda

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL