crd

package

v0.0.0-...-5e355cb Latest Latest Go to latest Published: Mar 20, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/akshay201/sqs-autoscaler-controller

Documentation ¶

Index ¶

Constants
Variables
func EnsureResource(client apiextensionsclient.Interface) error
func NewClient(cfg *rest.Config) (*rest.RESTClient, *runtime.Scheme, error)
type AutoScalerSpec
type Cache
- func NewCache(client *rest.RESTClient, syncInterval time.Duration) *Cache
- func (c Cache) Run(ctx context.Context)
type ScaleSpec
type SqsAutoScaler
- func (s *SqsAutoScaler) RecordEvent(k *kubernetes.Clientset, eventType, reason, message string) error
type SqsAutoScalerList

Constants ¶

View Source

const (
	GroupName = "aws.uswitch.com"
	Version   = "v1"
)

View Source

const (
	TypeNormal  = "Normal"
	TypeWarning = "Warning"
)

Variables ¶

View Source

var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: Version}

Functions ¶

func EnsureResource ¶

func EnsureResource(client apiextensionsclient.Interface) error

func NewClient ¶

func NewClient(cfg *rest.Config) (*rest.RESTClient, *runtime.Scheme, error)

Types ¶

type AutoScalerSpec ¶

type AutoScalerSpec struct {
	Queue      string    `json:"queue"`
	Deployment string    `json:"deployment"`
	MinPods    int32     `json:"minPods"`
	MaxPods    int32     `json:"maxPods"`
	ScaleUp    ScaleSpec `json:"scaleUp"`
	ScaleDown  ScaleSpec `json:"scaleDown"`
}

type Cache ¶

type Cache struct {
	Store cache.Indexer
	// contains filtered or unexported fields
}

func NewCache ¶

func NewCache(client *rest.RESTClient, syncInterval time.Duration) *Cache

func (Cache) Run ¶

func (c Cache) Run(ctx context.Context)

type ScaleSpec ¶

type ScaleSpec struct {
	Threshold int64 `json:"threshold"`
	Amount    int32 `json:"amount"`
}

type SqsAutoScaler ¶

type SqsAutoScaler struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              AutoScalerSpec `json:"spec"`
}

func (*SqsAutoScaler) RecordEvent ¶

func (s *SqsAutoScaler) RecordEvent(k *kubernetes.Clientset, eventType, reason, message string) error

type SqsAutoScalerList ¶

type SqsAutoScalerList struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Items             []SqsAutoScaler `json:"items"`
}

Source Files ¶

View all Source files

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