Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

scalers

package

Go to main page

Versions in this module

v1

v1.5.0

Jul 7, 2020

Changes in this version

+ func GetUnprocessedEventCountWithoutCheckpoint(partitionInfo *eventhub.HubPartitionRuntimeInformation) int64

type Scaler

+ func NewArtemisQueueScaler(resolvedSecrets, metadata, authParams map[string]string) (Scaler, error)

+ func NewCronScaler(resolvedEnv, metadata map[string]string) (Scaler, error)

+ func NewRedisStreamsScaler(resolvedEnv, metadata, authParams map[string]string) (Scaler, error)

v1.4.1

Apr 27, 2020

v1.4.0

Apr 17, 2020

Changes in this version

+ var SHA256 scram.HashGeneratorFcn = func() hash.Hash

+ var SHA512 scram.HashGeneratorFcn = func() hash.Hash

+ func GetAzureBlobListLength(ctx context.Context, podIdentity string, ...) (int, error)

+ func GetAzureMetricValue(ctx context.Context, metricMetadata *azureMonitorMetadata) (int32, error)

+ func GetAzureQueueLength(ctx context.Context, podIdentity string, connectionString, queueName string, ...) (int32, error)

+ func GetEventHubClient(connectionString string) (*eventhub.Hub, error)

+ func GetQueueEntityFromNamespace(ctx context.Context, ns *servicebus.Namespace, queueName string) (int32, error)

+ func GetStorageCredentials(storageConnection string) (azure.Environment, *azblob.SharedKeyCredential, error)

+ func GetSubscriptionEntityFromNamespace(ctx context.Context, ns *servicebus.Namespace, ...) (int32, error)

+ func NewLiiklusScaler(resolvedEnv map[string]string, metadata map[string]string) (*liiklusScaler, error)

+ func ParseAzureEventHubConnectionString(connectionString string) (string, string, error)

+ func ParseAzureStorageConnectionString(connectionString string) (string, string, string, string, error)

+ type AADToken struct

+ AccessToken string

+ ExpiresIn string

+ ExpiresOn string

+ NotBefore string

+ RefreshToken string

+ Resource string

+ TokenType string

+ type AzureEventHubScaler struct

+ func (scaler *AzureEventHubScaler) Close() error

+ func (scaler *AzureEventHubScaler) GetMetricSpecForScaling() []v2beta1.MetricSpec

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

+ func (scaler *AzureEventHubScaler) GetUnprocessedEventCountInPartition(ctx context.Context, partitionID string) (newEventCount int64, err error)

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

+ type Checkpoint struct

+ PartitionID string

+ SequenceNumber int64

+ func GetCheckpointFromBlobStorage(ctx context.Context, partitionID string, eventHubMetadata EventHubMetadata) (Checkpoint, error)

+ type EntityType int

+ const None

+ const Queue

+ const Subscription

+ type EventHubMetadata struct

+ type GoogleApplicationCredentials struct

+ AuthProviderCertURL string

+ AuthURI string

+ ClientEmail string

+ ClientID string

+ ClientX509CertURL string

+ PrivateKey string

+ PrivateKeyID string

+ ProjectID string

+ TokenURI string

+ Type string

+ type Scaler interface

+ Close func() error

+ GetMetricSpecForScaling func() []v2beta1.MetricSpec

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

+ IsActive func(ctx context.Context) (bool, 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 map[string]string) (Scaler, error)

+ func NewAzureMonitorScaler(resolvedEnv, metadata, authParams map[string]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 NewExternalScaler(name, namespace string, resolvedEnv, metadata 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 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 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/kedacore/keda/v2