service

Documentation

Index

• Constants
• Variables
• type EngineService
  • func NewEngineService(store cluster.PersistentStore) *EngineService
  • func (e *EngineService) Create(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) (string, string, string, error)
  • func (e *EngineService) ETCDRemoveSnapshot(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) error
  • func (e *EngineService) ETCDRestore(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) (string, string, string, error)
  • func (e *EngineService) ETCDSave(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) error
  • func (e *EngineService) GenerateServiceAccount(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) (string, error)
  • func (e *EngineService) GetDriverCreateOptions(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) (*types.DriverFlags, error)
  • func (e *EngineService) GetDriverUpdateOptions(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) (*types.DriverFlags, error)
  • func (e *EngineService) GetK8sCapabilities(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) (*types.K8SCapabilities, error)
  • func (e *EngineService) Remove(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) error
  • func (e *EngineService) RemoveLegacyServiceAccount(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) error
  • func (e *EngineService) Update(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, ...) (string, string, string, error)
• type RunningDriver
  • func (r *RunningDriver) Start() (string, error)
  • func (r *RunningDriver) Stop()

Constants

const (
	ListenAddress                           = "127.0.0.1:"
	GoogleKubernetesEngineDriverName        = "googlekubernetesengine"
	AzureKubernetesServiceDriverName        = "azurekubernetesservice"
	AmazonElasticContainerServiceDriverName = "amazonelasticcontainerservice"
	ImportDriverName                        = "import"
	RancherKubernetesEngineDriverName       = "rancherkubernetesengine"
)

Variables

var (
	Drivers = map[string]types.Driver{
		GoogleKubernetesEngineDriverName:        gke.NewDriver(),
		AzureKubernetesServiceDriverName:        aks.NewDriver(),
		AmazonElasticContainerServiceDriverName: eks.NewDriver(),
		ImportDriverName:                        kubeimport.NewDriver(),
		RancherKubernetesEngineDriverName:       rke.NewDriver(),
	}
)

Types

type EngineService

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

func NewEngineService

func NewEngineService(store cluster.PersistentStore) *EngineService

func (*EngineService) Create

func (e *EngineService) Create(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec) (string, string, string, error)

Create creates the stub for cluster manager to call

func (*EngineService) ETCDRemoveSnapshot

func (e *EngineService) ETCDRemoveSnapshot(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec, snapshotName string) error

func (*EngineService) ETCDRestore

func (e *EngineService) ETCDRestore(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec, backup string) (string, string, string, error)

func (*EngineService) ETCDSave

func (e *EngineService) ETCDSave(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec, snapshotName string) error

func (*EngineService) GenerateServiceAccount

func (e *EngineService) GenerateServiceAccount(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec) (string, error)

func (*EngineService) GetDriverCreateOptions

func (e *EngineService) GetDriverCreateOptions(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec) (*types.DriverFlags,
	error)

func (*EngineService) GetDriverUpdateOptions

func (e *EngineService) GetDriverUpdateOptions(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec) (*types.DriverFlags,
	error)

func (*EngineService) GetK8sCapabilities

func (e *EngineService) GetK8sCapabilities(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver,
	clusterSpec v3.ClusterSpec) (*types.K8SCapabilities, error)

func (*EngineService) Remove

func (e *EngineService) Remove(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec, forceRemove bool) error

Remove removes stub for cluster manager to call

func (*EngineService) RemoveLegacyServiceAccount

func (e *EngineService) RemoveLegacyServiceAccount(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec) error

func (*EngineService) Update

func (e *EngineService) Update(ctx context.Context, name string, kontainerDriver *v3.KontainerDriver, clusterSpec v3.ClusterSpec) (string, string, string, error)

Update creates the stub for cluster manager to call

type RunningDriver

type RunningDriver struct {
	Name    string
	Path    string
	Builtin bool
	Server  *types.GrpcServer
	// contains filtered or unexported fields
}

func (*RunningDriver) Start

func (r *RunningDriver) Start() (string, error)

func (*RunningDriver) Stop

func (r *RunningDriver) Stop()