provisioning

package
v0.0.0-...-980806f Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	// the time after which the operation is marked as expired
	CreateRuntimeTimeout = 1 * time.Hour
)
View Source 
const ServiceManagerComponentName = "service-manager-proxy"

Variables

This section is empty.

Functions

func NewLmsCertificatesStep 

func NewLmsCertificatesStep(certProvider LmsClient, os storage.Operations, isMandatory bool) *lmsCertStep

func NewProvideLmsTenantStep 

func NewProvideLmsTenantStep(tp LmsTenantProvider, repo storage.Operations, regionOverride string, isMandatory bool) *provideLmsTenantStep

Types

type AuditLogOverrides 

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

func NewAuditLogOverridesStep 

func NewAuditLogOverridesStep(os storage.Operations, cfg auditlog.Config) *AuditLogOverrides

func (*AuditLogOverrides) Name 

func (alo *AuditLogOverrides) Name() string

func (*AuditLogOverrides) Run 

func (alo *AuditLogOverrides) Run(operation internal.ProvisioningOperation, logger logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type CreateRuntimeStep 

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

func NewCreateRuntimeStep 

func NewCreateRuntimeStep(os storage.Operations, is storage.Instances, cli provisioner.Client) *CreateRuntimeStep

func (*CreateRuntimeStep) Name 

func (s *CreateRuntimeStep) Name() string

func (*CreateRuntimeStep) Run 

func (s *CreateRuntimeStep) Run(operation internal.ProvisioningOperation, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type DirectorClient 

type DirectorClient interface {
	GetConsoleURL(accountID, runtimeID string) (string, error)
	SetLabel(accountID, runtimeID, key, value string) error
}

type EDPClient 

type EDPClient interface {
	CreateDataTenant(data edp.DataTenantPayload) error
	CreateMetadataTenant(name, env string, data edp.MetadataTenantPayload) error
}

type EDPRegistrationStep 

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

func NewEDPRegistrationStep 

func NewEDPRegistrationStep(os storage.Operations, client EDPClient, config edp.Config) *EDPRegistrationStep

func (*EDPRegistrationStep) Name 

func (s *EDPRegistrationStep) Name() string

func (*EDPRegistrationStep) Run 

func (s *EDPRegistrationStep) Run(operation internal.ProvisioningOperation, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type ExternalEvalCreator 

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

func NewExternalEvalCreator 

func NewExternalEvalCreator(delegator *avs.Delegator, disabled bool, assistant *avs.ExternalEvalAssistant) *ExternalEvalCreator

type IASRegistrationStep 

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

func NewIASRegistrationStep 

func NewIASRegistrationStep(os storage.Operations, builder ias.BundleBuilder) *IASRegistrationStep

func (*IASRegistrationStep) Name 

func (s *IASRegistrationStep) Name() string

func (*IASRegistrationStep) Run 

func (s *IASRegistrationStep) Run(operation internal.ProvisioningOperation, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type IASType 

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

func NewIASType 

func NewIASType(builder ias.BundleBuilder, disabled bool) *IASType

func (*IASType) ConfigureType 

func (s *IASType) ConfigureType(operation internal.ProvisioningOperation, runtimeURL string, log logrus.FieldLogger) (time.Duration, error)

func (*IASType) Disabled 

func (s *IASType) Disabled() bool

type InitialisationStep 

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

func NewInitialisationStep 

func NewInitialisationStep(os storage.Operations,
	is storage.Instances,
	pc provisioner.Client,
	dc DirectorClient,
	b input.CreatorForPlan,
	avsExternalEvalCreator *ExternalEvalCreator,
	iasType *IASType,
	timeout time.Duration) *InitialisationStep

func (*InitialisationStep) Name 

func (s *InitialisationStep) Name() string

func (*InitialisationStep) Run 

func (s *InitialisationStep) Run(operation internal.ProvisioningOperation, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type InternalEvaluationStep 

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

func NewInternalEvaluationStep 

func NewInternalEvaluationStep(delegator *avs.Delegator, assistant *avs.InternalEvalAssistant) *InternalEvaluationStep

func (*InternalEvaluationStep) Name 

func (ies *InternalEvaluationStep) Name() string

func (*InternalEvaluationStep) Run 

func (ies *InternalEvaluationStep) Run(operation internal.ProvisioningOperation, logger logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type LmsClient 

type LmsClient interface {
	RequestCertificate(tenantID string, subject pkix.Name) (id string, privateKey []byte, err error)
	GetCertificateByURL(url string) (cert string, found bool, err error)
	GetCACertificate(tenantID string) (cert string, found bool, err error)
	GetTenantStatus(tenantID string) (status lms.TenantStatus, err error)
	GetTenantInfo(tenantID string) (status lms.TenantInfo, err error)
}

type LmsStep 

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

type LmsTenantProvider 

type LmsTenantProvider interface {
	ProvideLMSTenantID(name, region string) (string, error)
}

type Manager 

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

func NewManager 

func NewManager(storage storage.Operations, pub event.Publisher, logger logrus.FieldLogger) *Manager

func (*Manager) AddStep 

func (m *Manager) AddStep(weight int, step Step)

func (*Manager) Execute 

func (m *Manager) Execute(operationID string) (time.Duration, error)

func (*Manager) InitStep 

func (m *Manager) InitStep(step Step)

type OverridesFromSecretsAndConfigStep 

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

func NewOverridesFromSecretsAndConfigStep 

func NewOverridesFromSecretsAndConfigStep(c context.Context, cli client.Client, os storage.Operations) *OverridesFromSecretsAndConfigStep

func (*OverridesFromSecretsAndConfigStep) Name 

func (s *OverridesFromSecretsAndConfigStep) Name() string

func (*OverridesFromSecretsAndConfigStep) Run 

func (s *OverridesFromSecretsAndConfigStep) Run(operation internal.ProvisioningOperation, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type ProvisionAzureEventHubStep 

type ProvisionAzureEventHubStep struct {
	processazure.EventHub
	// contains filtered or unexported fields
}

func NewProvisionAzureEventHubStep 

func NewProvisionAzureEventHubStep(os storage.Operations, hyperscalerProvider azure.HyperscalerProvider, accountProvider hyperscaler.AccountProvider, ctx context.Context) *ProvisionAzureEventHubStep

func (*ProvisionAzureEventHubStep) Name 

func (p *ProvisionAzureEventHubStep) Name() string

func (*ProvisionAzureEventHubStep) Run 

func (p *ProvisionAzureEventHubStep) Run(operation internal.ProvisioningOperation,
	log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type ResolveCredentialsStep 

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

func NewResolveCredentialsStep 

func NewResolveCredentialsStep(os storage.Operations, accountProvider hyperscaler.AccountProvider) *ResolveCredentialsStep

func (*ResolveCredentialsStep) Name 

func (s *ResolveCredentialsStep) Name() string

func (*ResolveCredentialsStep) Run 

func (s *ResolveCredentialsStep) Run(operation internal.ProvisioningOperation, logger logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type ServiceManagerOverrideConfig 

type ServiceManagerOverrideConfig struct {
	OverrideMode ServiceManagerOverrideMode `envconfig:"default=Never"`
	URL          string
	Password     string
	Username     string
}

type ServiceManagerOverrideMode 

type ServiceManagerOverrideMode string
const (
	SMOverrideModeAlways               ServiceManagerOverrideMode = "Always"
	SMOverrideModeWhenNotSentInRequest ServiceManagerOverrideMode = "WhenNotSentInRequest"
	SMOverrideModeNever                ServiceManagerOverrideMode = "Never"
)

func (ServiceManagerOverrideMode) IsUnknown 

func (m ServiceManagerOverrideMode) IsUnknown() bool

func (ServiceManagerOverrideMode) Names 

func (m ServiceManagerOverrideMode) Names() string

func (*ServiceManagerOverrideMode) Unmarshal 

func (m *ServiceManagerOverrideMode) Unmarshal(in string) error

Unmarshal provides custom parsing of service manager credential mode. Implements envconfig.Unmarshal interface.

type ServiceManagerOverridesStep 

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

func NewServiceManagerOverridesStep 

func NewServiceManagerOverridesStep(os storage.Operations, smOverride ServiceManagerOverrideConfig) *ServiceManagerOverridesStep

func (*ServiceManagerOverridesStep) Name 

func (s *ServiceManagerOverridesStep) Name() string

func (*ServiceManagerOverridesStep) Run 

func (s *ServiceManagerOverridesStep) Run(operation internal.ProvisioningOperation, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)

type Step 

type Step interface {
	Name() string
	Run(operation internal.ProvisioningOperation, logger logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)
}

Source Files

View all Source files

Directories

Path Synopsis
automock

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.