cluster

package
v1.0.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 3, 2020 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package cluster is a generated GoMock package.

Index

Constants

View Source 
const (
	TransitionTypeCancelInstallation         = "CancelInstallation"
	TransitionTypeResetCluster               = "ResetCluster"
	TransitionTypePrepareForInstallation     = "PrepareForInstallation"
	TransitionTypeCompleteInstallation       = "CompleteInstallation"
	TransitionTypeHandlePreInstallationError = "Handle pre-installation-error"
	TransitionTypeRefreshStatus              = "RefreshStatus"
)
View Source 
const (
	IsMachineCidrDefined = validationID(models.ClusterValidationIDMachineCidrDefined)

	AllHostsAreReadyToInstall = validationID(models.ClusterValidationIDAllHostsAreReadyToInstall)
	SufficientMastersCount    = validationID(models.ClusterValidationIDSufficientMastersCount)
	IsDNSDomainDefined        = validationID(models.ClusterValidationIDDNSDomainDefined)
	IsPullSecretSet           = validationID(models.ClusterValidationIDPullSecretSet)
)
View Source 
const (
	ValidationSuccess validationStatus = "success"
	ValidationFailure validationStatus = "failure"
	ValidationPending validationStatus = "pending"
)
View Source 
const (
	ApiVipName     = "api vip"
	IngressVipName = "ingress vip"
)
View Source 
const MinHostsNeededForInstallation = 3
View Source 
const (
	VipDhcpAllocationSet = conditionId("vip-dhcp-allocation-set")
)

Variables

This section is empty.

Functions

func If 

func If(id stringer) stateswitch.Condition

func MapHostsByStatus 

func MapHostsByStatus(c *common.Cluster) map[string][]*models.Host

func MapMasterHostsByStatus 

func MapMasterHostsByStatus(c *common.Cluster) map[string][]*models.Host

func NewClusterStateMachine 

func NewClusterStateMachine(th *transitionHandler) stateswitch.StateMachine

func NewInstaller 

func NewInstaller(log logrus.FieldLogger, db *gorm.DB) *installer

func NewRegistrar 

func NewRegistrar(log logrus.FieldLogger, db *gorm.DB) *registrar

func UpdateCluster 

func UpdateCluster(log logrus.FieldLogger, db *gorm.DB, clusterId strfmt.UUID, srcStatus string, extra ...interface{}) (*common.Cluster, error)

Types

type API 

type API interface {
	RegistrationAPI
	InstallationAPI
	// Refresh state in case of hosts update
	RefreshStatus(ctx context.Context, c *common.Cluster, db *gorm.DB) (*common.Cluster, error)
	ClusterMonitoring()
	DownloadFiles(c *common.Cluster) (err error)
	DownloadKubeconfig(c *common.Cluster) (err error)
	GetCredentials(c *common.Cluster) (err error)
	UploadIngressCert(c *common.Cluster) (err error)
	VerifyClusterUpdatability(c *common.Cluster) (err error)
	AcceptRegistration(c *common.Cluster) (err error)
	SetGeneratorVersion(c *common.Cluster, version string, db *gorm.DB) error
	CancelInstallation(ctx context.Context, c *common.Cluster, reason string, db *gorm.DB) *common.ApiErrorResponse
	ResetCluster(ctx context.Context, c *common.Cluster, reason string, db *gorm.DB) *common.ApiErrorResponse
	PrepareForInstallation(ctx context.Context, c *common.Cluster, db *gorm.DB) error
	HandlePreInstallError(ctx context.Context, c *common.Cluster, err error)
	CompleteInstallation(ctx context.Context, c *common.Cluster, successfullyFinished bool, reason string) *common.ApiErrorResponse
	SetVips(ctx context.Context, c *common.Cluster, apiVip, ingressVip string, db *gorm.DB) error
	IsReadyForInstallation(c *common.Cluster) (bool, string)
	CreateTarredClusterLogs(ctx context.Context, c *common.Cluster, objectHandler s3wrapper.API) (string, error)
}

type Config 

type Config struct {
	PrepareConfig PrepareConfig
}

type InstallationAPI 

type InstallationAPI interface {
	// Install cluster
	Install(ctx context.Context, c *common.Cluster, db *gorm.DB) error
	// Get the cluster master nodes ID's
	GetMasterNodesIds(ctx context.Context, c *common.Cluster, db *gorm.DB) ([]*strfmt.UUID, error)
}

type Manager 

type Manager struct {
	Config
	// contains filtered or unexported fields
}

func NewManager 

func NewManager(cfg Config, log logrus.FieldLogger, db *gorm.DB, eventsHandler events.Handler, hostAPI host.API, metricApi metrics.API) *Manager

func (*Manager) AcceptRegistration 

func (m *Manager) AcceptRegistration(c *common.Cluster) (err error)

func (*Manager) CancelInstallation 

func (m *Manager) CancelInstallation(ctx context.Context, c *common.Cluster, reason string, db *gorm.DB) *common.ApiErrorResponse

func (*Manager) ClusterMonitoring 

func (m *Manager) ClusterMonitoring()

func (*Manager) CompleteInstallation 

func (m *Manager) CompleteInstallation(ctx context.Context, c *common.Cluster, successfullyFinished bool, reason string) *common.ApiErrorResponse

func (*Manager) CreateTarredClusterLogs 

func (m *Manager) CreateTarredClusterLogs(ctx context.Context, c *common.Cluster, objectHandler s3wrapper.API) (string, error)

func (*Manager) DeregisterCluster 

func (m *Manager) DeregisterCluster(ctx context.Context, c *common.Cluster) error

func (*Manager) DownloadFiles 

func (m *Manager) DownloadFiles(c *common.Cluster) (err error)

func (*Manager) DownloadKubeconfig 

func (m *Manager) DownloadKubeconfig(c *common.Cluster) (err error)

func (*Manager) GetCredentials 

func (m *Manager) GetCredentials(c *common.Cluster) (err error)

func (*Manager) GetMasterNodesIds 

func (m *Manager) GetMasterNodesIds(ctx context.Context, c *common.Cluster, db *gorm.DB) ([]*strfmt.UUID, error)

func (*Manager) HandlePreInstallError 

func (m *Manager) HandlePreInstallError(ctx context.Context, c *common.Cluster, installErr error)

func (*Manager) Install 

func (m *Manager) Install(ctx context.Context, c *common.Cluster, db *gorm.DB) error

func (*Manager) IsReadyForInstallation 

func (m *Manager) IsReadyForInstallation(c *common.Cluster) (bool, string)

func (*Manager) PrepareForInstallation 

func (m *Manager) PrepareForInstallation(ctx context.Context, c *common.Cluster, db *gorm.DB) error

func (*Manager) RefreshStatus 

func (m *Manager) RefreshStatus(ctx context.Context, c *common.Cluster, db *gorm.DB) (*common.Cluster, error)

func (*Manager) RegisterCluster 

func (m *Manager) RegisterCluster(ctx context.Context, c *common.Cluster) error

func (*Manager) ResetCluster 

func (m *Manager) ResetCluster(ctx context.Context, c *common.Cluster, reason string, db *gorm.DB) *common.ApiErrorResponse

func (*Manager) SetGeneratorVersion 

func (m *Manager) SetGeneratorVersion(c *common.Cluster, version string, db *gorm.DB) error

func (*Manager) SetVips 

func (m *Manager) SetVips(ctx context.Context, c *common.Cluster, apiVip, ingressVip string, db *gorm.DB) error

func (*Manager) UploadIngressCert 

func (m *Manager) UploadIngressCert(c *common.Cluster) (err error)

func (*Manager) VerifyClusterUpdatability 

func (m *Manager) VerifyClusterUpdatability(c *common.Cluster) (err error)

type MockAPI 

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

MockAPI is a mock of API interface

func NewMockAPI 

func NewMockAPI(ctrl *gomock.Controller) *MockAPI

NewMockAPI creates a new mock instance

func (*MockAPI) AcceptRegistration 

func (m *MockAPI) AcceptRegistration(c *common.Cluster) error

AcceptRegistration mocks base method

func (*MockAPI) CancelInstallation 

func (m *MockAPI) CancelInstallation(ctx context.Context, c *common.Cluster, reason string, db *gorm.DB) *common.ApiErrorResponse

CancelInstallation mocks base method

func (*MockAPI) ClusterMonitoring 

func (m *MockAPI) ClusterMonitoring()

ClusterMonitoring mocks base method

func (*MockAPI) CompleteInstallation 

func (m *MockAPI) CompleteInstallation(ctx context.Context, c *common.Cluster, successfullyFinished bool, reason string) *common.ApiErrorResponse

CompleteInstallation mocks base method

func (*MockAPI) CreateTarredClusterLogs 

func (m *MockAPI) CreateTarredClusterLogs(ctx context.Context, c *common.Cluster, objectHandler s3wrapper.API) (string, error)

CreateTarredClusterLogs mocks base method

func (*MockAPI) DeregisterCluster 

func (m *MockAPI) DeregisterCluster(ctx context.Context, c *common.Cluster) error

DeregisterCluster mocks base method

func (*MockAPI) DownloadFiles 

func (m *MockAPI) DownloadFiles(c *common.Cluster) error

DownloadFiles mocks base method

func (*MockAPI) DownloadKubeconfig 

func (m *MockAPI) DownloadKubeconfig(c *common.Cluster) error

DownloadKubeconfig mocks base method

func (*MockAPI) EXPECT 

func (m *MockAPI) EXPECT() *MockAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockAPI) GetCredentials 

func (m *MockAPI) GetCredentials(c *common.Cluster) error

GetCredentials mocks base method

func (*MockAPI) GetMasterNodesIds 

func (m *MockAPI) GetMasterNodesIds(ctx context.Context, c *common.Cluster, db *gorm.DB) ([]*strfmt.UUID, error)

GetMasterNodesIds mocks base method

func (*MockAPI) HandlePreInstallError 

func (m *MockAPI) HandlePreInstallError(ctx context.Context, c *common.Cluster, err error)

HandlePreInstallError mocks base method

func (*MockAPI) Install 

func (m *MockAPI) Install(ctx context.Context, c *common.Cluster, db *gorm.DB) error

Install mocks base method

func (*MockAPI) IsReadyForInstallation 

func (m *MockAPI) IsReadyForInstallation(c *common.Cluster) (bool, string)

IsReadyForInstallation mocks base method

func (*MockAPI) PrepareForInstallation 

func (m *MockAPI) PrepareForInstallation(ctx context.Context, c *common.Cluster, db *gorm.DB) error

PrepareForInstallation mocks base method

func (*MockAPI) RefreshStatus 

func (m *MockAPI) RefreshStatus(ctx context.Context, c *common.Cluster, db *gorm.DB) (*common.Cluster, error)

RefreshStatus mocks base method

func (*MockAPI) RegisterCluster 

func (m *MockAPI) RegisterCluster(ctx context.Context, c *common.Cluster) error

RegisterCluster mocks base method

func (*MockAPI) ResetCluster 

func (m *MockAPI) ResetCluster(ctx context.Context, c *common.Cluster, reason string, db *gorm.DB) *common.ApiErrorResponse

ResetCluster mocks base method

func (*MockAPI) SetGeneratorVersion 

func (m *MockAPI) SetGeneratorVersion(c *common.Cluster, version string, db *gorm.DB) error

SetGeneratorVersion mocks base method

func (*MockAPI) SetVips 

func (m *MockAPI) SetVips(ctx context.Context, c *common.Cluster, apiVip, ingressVip string, db *gorm.DB) error

SetVips mocks base method

func (*MockAPI) UploadIngressCert 

func (m *MockAPI) UploadIngressCert(c *common.Cluster) error

UploadIngressCert mocks base method

func (*MockAPI) VerifyClusterUpdatability 

func (m *MockAPI) VerifyClusterUpdatability(c *common.Cluster) error

VerifyClusterUpdatability mocks base method

type MockAPIMockRecorder 

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

MockAPIMockRecorder is the mock recorder for MockAPI

func (*MockAPIMockRecorder) AcceptRegistration 

func (mr *MockAPIMockRecorder) AcceptRegistration(c interface{}) *gomock.Call

AcceptRegistration indicates an expected call of AcceptRegistration

func (*MockAPIMockRecorder) CancelInstallation 

func (mr *MockAPIMockRecorder) CancelInstallation(ctx, c, reason, db interface{}) *gomock.Call

CancelInstallation indicates an expected call of CancelInstallation

func (*MockAPIMockRecorder) ClusterMonitoring 

func (mr *MockAPIMockRecorder) ClusterMonitoring() *gomock.Call

ClusterMonitoring indicates an expected call of ClusterMonitoring

func (*MockAPIMockRecorder) CompleteInstallation 

func (mr *MockAPIMockRecorder) CompleteInstallation(ctx, c, successfullyFinished, reason interface{}) *gomock.Call

CompleteInstallation indicates an expected call of CompleteInstallation

func (*MockAPIMockRecorder) CreateTarredClusterLogs 

func (mr *MockAPIMockRecorder) CreateTarredClusterLogs(ctx, c, objectHandler interface{}) *gomock.Call

CreateTarredClusterLogs indicates an expected call of CreateTarredClusterLogs

func (*MockAPIMockRecorder) DeregisterCluster 

func (mr *MockAPIMockRecorder) DeregisterCluster(ctx, c interface{}) *gomock.Call

DeregisterCluster indicates an expected call of DeregisterCluster

func (*MockAPIMockRecorder) DownloadFiles 

func (mr *MockAPIMockRecorder) DownloadFiles(c interface{}) *gomock.Call

DownloadFiles indicates an expected call of DownloadFiles

func (*MockAPIMockRecorder) DownloadKubeconfig 

func (mr *MockAPIMockRecorder) DownloadKubeconfig(c interface{}) *gomock.Call

DownloadKubeconfig indicates an expected call of DownloadKubeconfig

func (*MockAPIMockRecorder) GetCredentials 

func (mr *MockAPIMockRecorder) GetCredentials(c interface{}) *gomock.Call

GetCredentials indicates an expected call of GetCredentials

func (*MockAPIMockRecorder) GetMasterNodesIds 

func (mr *MockAPIMockRecorder) GetMasterNodesIds(ctx, c, db interface{}) *gomock.Call

GetMasterNodesIds indicates an expected call of GetMasterNodesIds

func (*MockAPIMockRecorder) HandlePreInstallError 

func (mr *MockAPIMockRecorder) HandlePreInstallError(ctx, c, err interface{}) *gomock.Call

HandlePreInstallError indicates an expected call of HandlePreInstallError

func (*MockAPIMockRecorder) Install 

func (mr *MockAPIMockRecorder) Install(ctx, c, db interface{}) *gomock.Call

Install indicates an expected call of Install

func (*MockAPIMockRecorder) IsReadyForInstallation 

func (mr *MockAPIMockRecorder) IsReadyForInstallation(c interface{}) *gomock.Call

IsReadyForInstallation indicates an expected call of IsReadyForInstallation

func (*MockAPIMockRecorder) PrepareForInstallation 

func (mr *MockAPIMockRecorder) PrepareForInstallation(ctx, c, db interface{}) *gomock.Call

PrepareForInstallation indicates an expected call of PrepareForInstallation

func (*MockAPIMockRecorder) RefreshStatus 

func (mr *MockAPIMockRecorder) RefreshStatus(ctx, c, db interface{}) *gomock.Call

RefreshStatus indicates an expected call of RefreshStatus

func (*MockAPIMockRecorder) RegisterCluster 

func (mr *MockAPIMockRecorder) RegisterCluster(ctx, c interface{}) *gomock.Call

RegisterCluster indicates an expected call of RegisterCluster

func (*MockAPIMockRecorder) ResetCluster 

func (mr *MockAPIMockRecorder) ResetCluster(ctx, c, reason, db interface{}) *gomock.Call

ResetCluster indicates an expected call of ResetCluster

func (*MockAPIMockRecorder) SetGeneratorVersion 

func (mr *MockAPIMockRecorder) SetGeneratorVersion(c, version, db interface{}) *gomock.Call

SetGeneratorVersion indicates an expected call of SetGeneratorVersion

func (*MockAPIMockRecorder) SetVips 

func (mr *MockAPIMockRecorder) SetVips(ctx, c, apiVip, ingressVip, db interface{}) *gomock.Call

SetVips indicates an expected call of SetVips

func (*MockAPIMockRecorder) UploadIngressCert 

func (mr *MockAPIMockRecorder) UploadIngressCert(c interface{}) *gomock.Call

UploadIngressCert indicates an expected call of UploadIngressCert

func (*MockAPIMockRecorder) VerifyClusterUpdatability 

func (mr *MockAPIMockRecorder) VerifyClusterUpdatability(c interface{}) *gomock.Call

VerifyClusterUpdatability indicates an expected call of VerifyClusterUpdatability

type MockInstallationAPI 

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

MockInstallationAPI is a mock of InstallationAPI interface

func NewMockInstallationAPI 

func NewMockInstallationAPI(ctrl *gomock.Controller) *MockInstallationAPI

NewMockInstallationAPI creates a new mock instance

func (*MockInstallationAPI) EXPECT 

func (m *MockInstallationAPI) EXPECT() *MockInstallationAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockInstallationAPI) GetMasterNodesIds 

func (m *MockInstallationAPI) GetMasterNodesIds(ctx context.Context, c *common.Cluster, db *gorm.DB) ([]*strfmt.UUID, error)

GetMasterNodesIds mocks base method

func (*MockInstallationAPI) Install 

func (m *MockInstallationAPI) Install(ctx context.Context, c *common.Cluster, db *gorm.DB) error

Install mocks base method

type MockInstallationAPIMockRecorder 

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

MockInstallationAPIMockRecorder is the mock recorder for MockInstallationAPI

func (*MockInstallationAPIMockRecorder) GetMasterNodesIds 

func (mr *MockInstallationAPIMockRecorder) GetMasterNodesIds(ctx, c, db interface{}) *gomock.Call

GetMasterNodesIds indicates an expected call of GetMasterNodesIds

func (*MockInstallationAPIMockRecorder) Install 

func (mr *MockInstallationAPIMockRecorder) Install(ctx, c, db interface{}) *gomock.Call

Install indicates an expected call of Install

type MockRegistrationAPI 

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

MockRegistrationAPI is a mock of RegistrationAPI interface

func NewMockRegistrationAPI 

func NewMockRegistrationAPI(ctrl *gomock.Controller) *MockRegistrationAPI

NewMockRegistrationAPI creates a new mock instance

func (*MockRegistrationAPI) DeregisterCluster 

func (m *MockRegistrationAPI) DeregisterCluster(ctx context.Context, c *common.Cluster) error

DeregisterCluster mocks base method

func (*MockRegistrationAPI) EXPECT 

func (m *MockRegistrationAPI) EXPECT() *MockRegistrationAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockRegistrationAPI) RegisterCluster 

func (m *MockRegistrationAPI) RegisterCluster(ctx context.Context, c *common.Cluster) error

RegisterCluster mocks base method

type MockRegistrationAPIMockRecorder 

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

MockRegistrationAPIMockRecorder is the mock recorder for MockRegistrationAPI

func (*MockRegistrationAPIMockRecorder) DeregisterCluster 

func (mr *MockRegistrationAPIMockRecorder) DeregisterCluster(ctx, c interface{}) *gomock.Call

DeregisterCluster indicates an expected call of DeregisterCluster

func (*MockRegistrationAPIMockRecorder) RegisterCluster 

func (mr *MockRegistrationAPIMockRecorder) RegisterCluster(ctx, c interface{}) *gomock.Call

RegisterCluster indicates an expected call of RegisterCluster

type PrepareConfig 

type PrepareConfig struct {
	InstallationTimeout time.Duration `envconfig:"PREPARE_FOR_INSTALLATION_TIMEOUT" default:"10m"`
}

type RegistrationAPI 

type RegistrationAPI interface {
	// Register a new cluster
	RegisterCluster(ctx context.Context, c *common.Cluster) error
	//deregister cluster
	DeregisterCluster(ctx context.Context, c *common.Cluster) error
}

type TransitionArgsCancelInstallation 

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

type TransitionArgsCompleteInstallation 

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

type TransitionArgsHandlePreInstallationError 

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

type TransitionArgsPrepareForInstallation 

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

type TransitionArgsRefreshCluster 

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

type TransitionArgsResetCluster 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.