Versions in this module Expand all Collapse all v2 v2.0.2 Sep 27, 2020 v2.0.1 Sep 27, 2020 Changes in this version + const KafkaSASLTypeNone + const KafkaSASLTypePlaintext + const KafkaSASLTypeSCRAMSHA256 + const KafkaSASLTypeSCRAMSHA512 + var SHA256 scram.HashGeneratorFcn = func() hash.Hash + var SHA512 scram.HashGeneratorFcn = func() hash.Hash + func GetUnprocessedEventCountWithoutCheckpoint(partitionInfo *eventhub.HubPartitionRuntimeInformation) int64 + func GetValueFromResponse(body []byte, valueLocation string) (int64, error) + type GoogleApplicationCredentials struct + AuthProviderCertURL string + AuthURI string + ClientEmail string + ClientID string + ClientX509CertURL string + PrivateKey string + PrivateKeyID string + ProjectID string + TokenURI string + Type string + type PushScaler interface + Run func(ctx context.Context, active chan<- bool) + func NewExternalPushScaler(name, namespace string, metadata, resolvedEnv map[string]string) (PushScaler, error) + 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(resolvedSecrets, metadata, authParams map[string]string) (Scaler, error) + func NewAwsCloudwatchScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error) + func NewAwsKinesisStreamScaler(resolvedEnv, metadata map[string]string, authParams map[string]string) (Scaler, error) + func NewAwsSqsQueueScaler(resolvedEnv, metadata map[string]string, authParams map[string]string) (Scaler, error) + func NewAzureBlobScaler(resolvedEnv, metadata, authParams map[string]string, podIdentity string) (Scaler, error) + func NewAzureEventHubScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error) + func NewAzureLogAnalyticsScaler(resolvedSecrets, metadata, authParams map[string]string, podIdentity string) (Scaler, error) + func NewAzureMonitorScaler(resolvedEnv, metadata, authParams map[string]string, podIdentity string) (Scaler, error) + func NewAzureQueueScaler(resolvedEnv, metadata, authParams map[string]string, podIdentity string) (Scaler, error) + func NewAzureServiceBusScaler(resolvedEnv, metadata, authParams map[string]string, podIdentity string) (Scaler, error) + func NewCronScaler(resolvedEnv, metadata map[string]string) (Scaler, error) + func NewExternalScaler(name, namespace string, metadata, resolvedEnv map[string]string) (Scaler, error) + func NewHuaweiCloudeyeScaler(metadata, authParams map[string]string) (Scaler, error) + func NewKafkaScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error) + func NewLiiklusScaler(resolvedEnv map[string]string, metadata map[string]string) (Scaler, error) + func NewMetricsAPIScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error) + func NewMySQLScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error) + func NewPostgreSQLScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error) + func NewPrometheusScaler(resolvedEnv, metadata map[string]string) (Scaler, error) + func NewPubSubScaler(resolvedEnv, metadata map[string]string) (Scaler, error) + func NewRabbitMQScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error) + func NewRedisScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error) + func NewRedisStreamsScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error) + func NewStanScaler(resolvedSecrets, metadata map[string]string) (Scaler, error) + 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/zzxwill/keda
Go to main page