cluster

Documentation

Index

• type Client
  • func NewClusterClient(conf config.Config, name string) (Client, error)
• type EKSClusterClient
  • func (EKSClusterClient) CanBeRun(clusterName string, executableResources state.ExecutableResources) (bool, error)
  • func (EKSClusterClient) Initialize(conf config.Config) error
  • func (EKSClusterClient) ListClusters() ([]string, error)
  • func (EKSClusterClient) Name() string

Types

type Client

type Client interface {
	Name() string
	Initialize(conf config.Config) error
	CanBeRun(clusterName string, executableResources state.ExecutableResources) (bool, error)
	ListClusters() ([]string, error)
}

func NewClusterClient

func NewClusterClient(conf config.Config, name string) (Client, error)

NewClusterClient returns a cluster client

type EKSClusterClient

type EKSClusterClient struct{}

EKSClusterClient is the cluster client for EKS [NOTE] This client assumes the EKS cluster is capable is running a mixed varieties of jobs.

func (EKSClusterClient) CanBeRun

func (EKSClusterClient) CanBeRun(clusterName string, executableResources state.ExecutableResources) (bool, error)

CanBeRun for EKSCluster is always true

func (EKSClusterClient) Initialize

func (EKSClusterClient) Initialize(conf config.Config) error

func (EKSClusterClient) ListClusters

func (EKSClusterClient) ListClusters() ([]string, error)

Since it is a single cluster environment for EKS, slice of clusters is empty.

func (EKSClusterClient) Name

func (EKSClusterClient) Name() string