mirror of
https://github.com/sablierapp/sablier.git
synced 2025-12-21 21:33:06 +01:00
dfb9bacf59
This feature adds the capability to stop unregistered running instances upon startup. Previously, you had to stop running instances manually or issue an initial request that will shut down instances afterwards. With this change, all discovered instances will be shutdown. They need to be registered using labels. E.g.: sablier.enable=true Fixes #153
51 lines
1.5 KiB
Go
51 lines
1.5 KiB
Go
package config
|
|
|
|
import (
|
|
"fmt"
|
|
)
|
|
|
|
// Provider holds the provider configurations
|
|
type Provider struct {
|
|
// The provider name to use
|
|
// It can be either docker, swarm or kubernetes. Defaults to "docker"
|
|
Name string `mapstructure:"NAME" yaml:"name,omitempty" default:"docker"`
|
|
AutoStopOnStartup bool `yaml:"auto-stop-on-startup,omitempty" default:"true"`
|
|
Kubernetes Kubernetes
|
|
}
|
|
|
|
type Kubernetes struct {
|
|
//QPS limit for K8S API access client-side throttle
|
|
QPS float32 `mapstructure:"QPS" yaml:"QPS" default:"5"`
|
|
//Maximum burst for client-side throttle
|
|
Burst int `mapstructure:"BURST" yaml:"Burst" default:"10"`
|
|
//Delimiter used for namespace/resource type/name resolution. Defaults to "_" for backward compatibility. But you should use "/" or ".".
|
|
Delimiter string `mapstructure:"DELIMITER" yaml:"Delimiter" default:"_"`
|
|
}
|
|
|
|
var providers = []string{"docker", "docker_swarm", "swarm", "kubernetes"}
|
|
|
|
func NewProviderConfig() Provider {
|
|
return Provider{
|
|
|
|
Name: "docker",
|
|
Kubernetes: Kubernetes{
|
|
QPS: 5,
|
|
Burst: 10,
|
|
Delimiter: "_", //Delimiter used for namespace/resource type/name resolution. Defaults to "_" for backward compatibility. But you should use "/" or ".".
|
|
},
|
|
}
|
|
}
|
|
|
|
func (provider Provider) IsValid() error {
|
|
for _, p := range providers {
|
|
if p == provider.Name {
|
|
return nil
|
|
}
|
|
}
|
|
return fmt.Errorf("unrecognized provider %s. providers available: %v", provider.Name, providers)
|
|
}
|
|
|
|
func GetProviders() []string {
|
|
return providers
|
|
}
|