providers

Documentation

Index

• type Config
• type DockerClassicProvider
  • func NewDockerClassicProvider() (*DockerClassicProvider, error)
  • func (provider *DockerClassicProvider) GetGroups(ctx context.Context) (map[string][]string, error)
  • func (provider *DockerClassicProvider) GetState(ctx context.Context, name string) (instance.State, error)
  • func (provider *DockerClassicProvider) NotifyInstanceStopped(ctx context.Context, instance chan<- string)
  • func (provider *DockerClassicProvider) Start(ctx context.Context, name string) (instance.State, error)
  • func (provider *DockerClassicProvider) Stop(ctx context.Context, name string) (instance.State, error)
• type DockerSwarmProvider
  • func NewDockerSwarmProvider() (*DockerSwarmProvider, error)
  • func (provider *DockerSwarmProvider) GetGroups(ctx context.Context) (map[string][]string, error)
  • func (provider *DockerSwarmProvider) GetState(ctx context.Context, name string) (instance.State, error)
  • func (provider *DockerSwarmProvider) NotifyInstanceStopped(ctx context.Context, instance chan<- string)
  • func (provider *DockerSwarmProvider) Start(ctx context.Context, name string) (instance.State, error)
  • func (provider *DockerSwarmProvider) Stop(ctx context.Context, name string) (instance.State, error)
• type KubernetesProvider
  • func NewKubernetesProvider(providerConfig providerConfig.Kubernetes) (*KubernetesProvider, error)
  • func (provider *KubernetesProvider) GetGroups(ctx context.Context) (map[string][]string, error)
  • func (provider *KubernetesProvider) GetState(ctx context.Context, name string) (instance.State, error)
  • func (provider *KubernetesProvider) NotifyInstanceStopped(ctx context.Context, instance chan<- string)
  • func (provider *KubernetesProvider) Start(ctx context.Context, name string) (instance.State, error)
  • func (provider *KubernetesProvider) Stop(ctx context.Context, name string) (instance.State, error)
• type Provider
  • func NewProvider(config config.Provider) (Provider, error)
• type Workload

Types

type Config

type Config struct {
	OriginalName string
	Kind         string // deployment or statefulset
	Namespace    string
	Name         string
	Replicas     int32
}

type DockerClassicProvider

type DockerClassicProvider struct {
	Client client.APIClient
	// contains filtered or unexported fields
}

func NewDockerClassicProvider

func NewDockerClassicProvider() (*DockerClassicProvider, error)

func (*DockerClassicProvider) GetGroups

func (provider *DockerClassicProvider) GetGroups(ctx context.Context) (map[string][]string, error)

func (*DockerClassicProvider) GetState

func (provider *DockerClassicProvider) GetState(ctx context.Context, name string) (instance.State, error)

func (*DockerClassicProvider) NotifyInstanceStopped

func (provider *DockerClassicProvider) NotifyInstanceStopped(ctx context.Context, instance chan<- string)

func (*DockerClassicProvider) Start

func (provider *DockerClassicProvider) Start(ctx context.Context, name string) (instance.State, error)

func (*DockerClassicProvider) Stop

func (provider *DockerClassicProvider) Stop(ctx context.Context, name string) (instance.State, error)

type DockerSwarmProvider

type DockerSwarmProvider struct {
	Client client.APIClient
	// contains filtered or unexported fields
}

func NewDockerSwarmProvider

func NewDockerSwarmProvider() (*DockerSwarmProvider, error)

func (*DockerSwarmProvider) GetGroups

func (provider *DockerSwarmProvider) GetGroups(ctx context.Context) (map[string][]string, error)

func (*DockerSwarmProvider) GetState

func (provider *DockerSwarmProvider) GetState(ctx context.Context, name string) (instance.State, error)

func (*DockerSwarmProvider) NotifyInstanceStopped

func (provider *DockerSwarmProvider) NotifyInstanceStopped(ctx context.Context, instance chan<- string)

func (*DockerSwarmProvider) Start

func (provider *DockerSwarmProvider) Start(ctx context.Context, name string) (instance.State, error)

func (*DockerSwarmProvider) Stop

func (provider *DockerSwarmProvider) Stop(ctx context.Context, name string) (instance.State, error)

type KubernetesProvider

type KubernetesProvider struct {
	Client kubernetes.Interface
	// contains filtered or unexported fields
}

func NewKubernetesProvider

func NewKubernetesProvider(providerConfig providerConfig.Kubernetes) (*KubernetesProvider, error)

func (*KubernetesProvider) GetGroups

func (provider *KubernetesProvider) GetGroups(ctx context.Context) (map[string][]string, error)

func (*KubernetesProvider) GetState

func (provider *KubernetesProvider) GetState(ctx context.Context, name string) (instance.State, error)

func (*KubernetesProvider) NotifyInstanceStopped

func (provider *KubernetesProvider) NotifyInstanceStopped(ctx context.Context, instance chan<- string)

func (*KubernetesProvider) Start

func (provider *KubernetesProvider) Start(ctx context.Context, name string) (instance.State, error)

func (*KubernetesProvider) Stop

func (provider *KubernetesProvider) Stop(ctx context.Context, name string) (instance.State, error)

type Provider

type Provider interface {
	Start(ctx context.Context, name string) (instance.State, error)
	Stop(ctx context.Context, name string) (instance.State, error)
	GetState(ctx context.Context, name string) (instance.State, error)
	GetGroups(ctx context.Context) (map[string][]string, error)

	NotifyInstanceStopped(ctx context.Context, instance chan<- string)
}

func NewProvider

func NewProvider(config config.Provider) (Provider, error)

type Workload

type Workload interface {
	GetScale(ctx context.Context, workloadName string, options metav1.GetOptions) (*autoscalingv1.Scale, error)
	UpdateScale(ctx context.Context, workloadName string, scale *autoscalingv1.Scale, opts metav1.UpdateOptions) (*autoscalingv1.Scale, error)
}