adapter

Documentation

Index

• type Executor
  • func NewKubernetesExecutor(url string, username string, password string) (Executor, error)
• type KubernetesAdapter
  • func (a KubernetesAdapter) CreateServices(services []*pmxadapter.Service) ([]pmxadapter.ServiceDeployment, error)
  • func (a KubernetesAdapter) DestroyService(id string) error
  • func (a KubernetesAdapter) GetMetadata() pmxadapter.Metadata
  • func (a KubernetesAdapter) GetService(id string) (pmxadapter.ServiceDeployment, error)
  • func (a KubernetesAdapter) GetServices() ([]pmxadapter.ServiceDeployment, error)
• type KubernetesExecutor
  • func (k KubernetesExecutor) CreateKServices(ks []api.Service) error
  • func (k KubernetesExecutor) CreateReplicationController(spec api.ReplicationController) (api.ReplicationController, error)
  • func (k KubernetesExecutor) DeleteReplicationController(id string) error
  • func (k KubernetesExecutor) GetPods(s labels.Selector) ([]api.Pod, error)
  • func (k KubernetesExecutor) GetReplicationController(id string) (api.ReplicationController, error)
  • func (k KubernetesExecutor) GetReplicationControllers() ([]api.ReplicationController, error)
  • func (k KubernetesExecutor) IsHealthy() bool

Types

type Executor

type Executor interface {
	GetReplicationControllers() ([]api.ReplicationController, error)
	GetReplicationController(string) (api.ReplicationController, error)
	GetPods(labels.Selector) ([]api.Pod, error)
	CreateReplicationController(api.ReplicationController) (api.ReplicationController, error)
	DeleteReplicationController(string) error
	CreateKServices([]api.Service) error
	IsHealthy() bool
}

var (
	DefaultExecutor Executor

	PublicIPs []string
)

func NewKubernetesExecutor

func NewKubernetesExecutor(url string, username string, password string) (Executor, error)

type KubernetesAdapter

type KubernetesAdapter struct{}

func (KubernetesAdapter) CreateServices

func (a KubernetesAdapter) CreateServices(services []*pmxadapter.Service) ([]pmxadapter.ServiceDeployment, error)

func (KubernetesAdapter) DestroyService

func (a KubernetesAdapter) DestroyService(id string) error

func (KubernetesAdapter) GetMetadata

func (a KubernetesAdapter) GetMetadata() pmxadapter.Metadata

func (KubernetesAdapter) GetService

func (a KubernetesAdapter) GetService(id string) (pmxadapter.ServiceDeployment, error)

func (KubernetesAdapter) GetServices

func (a KubernetesAdapter) GetServices() ([]pmxadapter.ServiceDeployment, error)

type KubernetesExecutor

type KubernetesExecutor struct {
	// contains filtered or unexported fields
}

func (KubernetesExecutor) CreateKServices

func (k KubernetesExecutor) CreateKServices(ks []api.Service) error

func (KubernetesExecutor) CreateReplicationController

func (k KubernetesExecutor) CreateReplicationController(spec api.ReplicationController) (api.ReplicationController, error)

func (KubernetesExecutor) DeleteReplicationController

func (k KubernetesExecutor) DeleteReplicationController(id string) error

func (KubernetesExecutor) GetPods

func (k KubernetesExecutor) GetPods(s labels.Selector) ([]api.Pod, error)

func (KubernetesExecutor) GetReplicationController

func (k KubernetesExecutor) GetReplicationController(id string) (api.ReplicationController, error)

func (KubernetesExecutor) GetReplicationControllers

func (k KubernetesExecutor) GetReplicationControllers() ([]api.ReplicationController, error)

func (KubernetesExecutor) IsHealthy

func (k KubernetesExecutor) IsHealthy() bool