Documentation ¶
Index ¶
- Variables
- func AddAuth(ctx context.Context, authentication *clients.Authentication) (*clients.Source, error)
- func AddSource(ctx context.Context, provider models.ProviderType) (*clients.Source, error)
- func AddStubbedEC2KeyPair(ctx context.Context, info *types.KeyPairInfo) error
- func CountStubAzureVMs(ctx context.Context) int
- func CountStubInstancesGCP(ctx context.Context) int
- func DidCreateAzureResourceGroup(ctx context.Context, name string) bool
- func WithAzureClient(parent context.Context) context.Context
- func WithEC2Client(parent context.Context) context.Context
- func WithGCPCCustomerClient(parent context.Context) context.Context
- func WithGCPCServiceClient(parent context.Context) context.Context
- func WithImageBuilderClient(parent context.Context) context.Context
- func WithSourcesClient(parent context.Context) context.Context
- func WithSourcesIntegration(parent context.Context, init_store *[]sources.Source) context.Context
- type AzureClientStub
- func (stub *AzureClientStub) BeginCreateVM(ctx context.Context, vmParams clients.AzureInstanceParams, vmName string) (string, error)
- func (stub *AzureClientStub) CreateVMs(ctx context.Context, vmParams clients.AzureInstanceParams, amount int64, ...) ([]clients.InstanceDescription, error)
- func (stub *AzureClientStub) EnsureResourceGroup(ctx context.Context, name string, location string) (clients.AzureResourceGroup, error)
- func (stub *AzureClientStub) ListResourceGroups(ctx context.Context) ([]string, error)
- func (stub *AzureClientStub) Status(ctx context.Context) error
- func (stub *AzureClientStub) TenantId(ctx context.Context) (clients.AzureTenantId, error)
- func (stub *AzureClientStub) WaitForVM(ctx context.Context, resumeToken string) (clients.AzureInstanceID, error)
- type EC2ClientStub
- func (mock *EC2ClientStub) CheckPermission(ctx context.Context, auth *clients.Authentication) ([]string, error)
- func (mock *EC2ClientStub) DeleteSSHKey(ctx context.Context, handle string) error
- func (mock *EC2ClientStub) DescribeInstanceDetails(ctx context.Context, InstanceIds []string) ([]*clients.InstanceDescription, error)
- func (mock *EC2ClientStub) GetAccountId(ctx context.Context) (string, error)
- func (mock *EC2ClientStub) GetPubkeyName(ctx context.Context, fingerprint string) (string, error)
- func (mock *EC2ClientStub) ImportPubkey(ctx context.Context, key *models.Pubkey, tag string) (string, error)
- func (mock *EC2ClientStub) ListAllRegions(ctx context.Context) ([]clients.Region, error)
- func (mock *EC2ClientStub) ListAllZones(ctx context.Context, region clients.Region) ([]clients.Zone, error)
- func (mock *EC2ClientStub) ListInstanceTypes(ctx context.Context) ([]*clients.InstanceType, error)
- func (mock *EC2ClientStub) ListLaunchTemplates(ctx context.Context) ([]*clients.LaunchTemplate, string, error)
- func (mock *EC2ClientStub) RunInstances(ctx context.Context, details *clients.AWSInstanceParams, amount int32, ...) ([]*string, *string, error)
- func (mock *EC2ClientStub) Status(ctx context.Context) error
- type GCPClientStub
- func (mock *GCPClientStub) GetInstanceDescriptionByID(ctx context.Context, id, zone string) (*clients.InstanceDescription, error)
- func (mock *GCPClientStub) InsertInstances(ctx context.Context, params *clients.GCPInstanceParams, amount int64) ([]*string, *string, error)
- func (mock *GCPClientStub) ListAllRegions(ctx context.Context) ([]clients.Region, error)
- func (mock *GCPClientStub) ListInstancesIDsByLabel(ctx context.Context, _ string) ([]*string, error)
- func (mock *GCPClientStub) ListLaunchTemplates(ctx context.Context) ([]*clients.LaunchTemplate, string, error)
- func (mock *GCPClientStub) Status(ctx context.Context) error
- type GCPServiceClientStub
- func (mock *GCPServiceClientStub) ListAllRegionsAndZones(ctx context.Context) ([]clients.Region, []clients.Zone, error)
- func (mock *GCPServiceClientStub) ListMachineTypes(ctx context.Context, zone string) ([]*clients.InstanceType, error)
- func (mock *GCPServiceClientStub) RegisterInstanceTypes(ctx context.Context, instanceTypes *clients.RegisteredInstanceTypes, ...) error
- type ImageBuilderClientStub
- func (mock *ImageBuilderClientStub) GetAWSAmi(ctx context.Context, composeUUID uuid.UUID, instanceType clients.InstanceType) (string, error)
- func (mock *ImageBuilderClientStub) GetAzureImageInfo(ctx context.Context, composeUUID uuid.UUID, instanceType clients.InstanceType) (string, string, error)
- func (mock *ImageBuilderClientStub) GetGCPImageName(ctx context.Context, composeUUID uuid.UUID, instanceType clients.InstanceType) (string, error)
- func (*ImageBuilderClientStub) Ready(ctx context.Context) error
- type SourcesClientStub
- func (stub *SourcesClientStub) GetAuthentication(ctx context.Context, sourceId string) (*clients.Authentication, error)
- func (mock *SourcesClientStub) ListAllProvisioningSources(ctx context.Context) ([]*clients.Source, int, error)
- func (mock *SourcesClientStub) ListProvisioningSourcesByProvider(ctx context.Context, provider models.ProviderType) ([]*clients.Source, int, error)
- func (*SourcesClientStub) Ready(ctx context.Context) error
- type SourcesIntegrationStub
- func (mock *SourcesIntegrationStub) ListApplicationTypeSourcesWithResponse(ctx context.Context, appTypeId sources.ID, ...) (*sources.ListApplicationTypeSourcesResponse, error)
- func (mock *SourcesIntegrationStub) ListSourceAuthenticationsWithResponse(ctx context.Context, sourceId sources.ID, ...) (*sources.ListSourceAuthenticationsResponse, error)
- func (mock *SourcesIntegrationStub) ShowApplicationWithResponse(ctx context.Context, appId sources.ID, reqEditors ...sources.RequestEditorFn) (*sources.ShowApplicationResponse, error)
- func (mock *SourcesIntegrationStub) ShowSourceWithResponse(ctx context.Context, id sources.ID, reqEditors ...sources.RequestEditorFn) (*sources.ShowSourceResponse, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNotImplemented = errors.New("stub not yet implemented") ErrMissingInstanceID = errors.New("instance id is not present") ErrSourceAuthenticationNotFound = errors.New("stubbed authentication for source not found") ErrContextRead = errors.New("failed to find or convert dao stored in testing context") )
View Source
var ErrNotStartedVM = errors.New("the VM under given resumeToken not started")
Functions ¶
func AddStubbedEC2KeyPair ¶
func AddStubbedEC2KeyPair(ctx context.Context, info *types.KeyPairInfo) error
func CountStubAzureVMs ¶
func CountStubInstancesGCP ¶
func WithGCPCCustomerClient ¶
GCPCustomerClient
func WithGCPCServiceClient ¶
GCPServiceClient
func WithSourcesClient ¶
SourcesClient
Types ¶
type AzureClientStub ¶
type AzureClientStub struct {
// contains filtered or unexported fields
}
func (*AzureClientStub) BeginCreateVM ¶
func (stub *AzureClientStub) BeginCreateVM(ctx context.Context, vmParams clients.AzureInstanceParams, vmName string) (string, error)
func (*AzureClientStub) CreateVMs ¶
func (stub *AzureClientStub) CreateVMs(ctx context.Context, vmParams clients.AzureInstanceParams, amount int64, vmNamePrefix string) ([]clients.InstanceDescription, error)
func (*AzureClientStub) EnsureResourceGroup ¶
func (stub *AzureClientStub) EnsureResourceGroup(ctx context.Context, name string, location string) (clients.AzureResourceGroup, error)
func (*AzureClientStub) ListResourceGroups ¶
func (stub *AzureClientStub) ListResourceGroups(ctx context.Context) ([]string, error)
func (*AzureClientStub) TenantId ¶
func (stub *AzureClientStub) TenantId(ctx context.Context) (clients.AzureTenantId, error)
func (*AzureClientStub) WaitForVM ¶
func (stub *AzureClientStub) WaitForVM(ctx context.Context, resumeToken string) (clients.AzureInstanceID, error)
type EC2ClientStub ¶
type EC2ClientStub struct {
Imported []*types.KeyPairInfo
}
func (*EC2ClientStub) CheckPermission ¶
func (mock *EC2ClientStub) CheckPermission(ctx context.Context, auth *clients.Authentication) ([]string, error)
func (*EC2ClientStub) DeleteSSHKey ¶
func (mock *EC2ClientStub) DeleteSSHKey(ctx context.Context, handle string) error
func (*EC2ClientStub) DescribeInstanceDetails ¶
func (mock *EC2ClientStub) DescribeInstanceDetails(ctx context.Context, InstanceIds []string) ([]*clients.InstanceDescription, error)
func (*EC2ClientStub) GetAccountId ¶
func (mock *EC2ClientStub) GetAccountId(ctx context.Context) (string, error)
func (*EC2ClientStub) GetPubkeyName ¶
func (*EC2ClientStub) ImportPubkey ¶
func (*EC2ClientStub) ListAllRegions ¶
func (*EC2ClientStub) ListAllZones ¶
func (*EC2ClientStub) ListInstanceTypes ¶
func (mock *EC2ClientStub) ListInstanceTypes(ctx context.Context) ([]*clients.InstanceType, error)
func (*EC2ClientStub) ListLaunchTemplates ¶
func (mock *EC2ClientStub) ListLaunchTemplates(ctx context.Context) ([]*clients.LaunchTemplate, string, error)
func (*EC2ClientStub) RunInstances ¶
func (mock *EC2ClientStub) RunInstances(ctx context.Context, details *clients.AWSInstanceParams, amount int32, name string, reservation *models.AWSReservation) ([]*string, *string, error)
type GCPClientStub ¶
type GCPClientStub struct {
Instances []*string
}
func (*GCPClientStub) GetInstanceDescriptionByID ¶
func (mock *GCPClientStub) GetInstanceDescriptionByID(ctx context.Context, id, zone string) (*clients.InstanceDescription, error)
func (*GCPClientStub) InsertInstances ¶
func (mock *GCPClientStub) InsertInstances(ctx context.Context, params *clients.GCPInstanceParams, amount int64) ([]*string, *string, error)
func (*GCPClientStub) ListAllRegions ¶
func (*GCPClientStub) ListInstancesIDsByLabel ¶
func (*GCPClientStub) ListLaunchTemplates ¶
func (mock *GCPClientStub) ListLaunchTemplates(ctx context.Context) ([]*clients.LaunchTemplate, string, error)
type GCPServiceClientStub ¶
type GCPServiceClientStub struct{}
func (*GCPServiceClientStub) ListAllRegionsAndZones ¶
func (*GCPServiceClientStub) ListMachineTypes ¶
func (mock *GCPServiceClientStub) ListMachineTypes(ctx context.Context, zone string) ([]*clients.InstanceType, error)
func (*GCPServiceClientStub) RegisterInstanceTypes ¶
func (mock *GCPServiceClientStub) RegisterInstanceTypes(ctx context.Context, instanceTypes *clients.RegisteredInstanceTypes, regionalTypes *clients.RegionalTypeAvailability) error
type ImageBuilderClientStub ¶
type ImageBuilderClientStub struct{}
func (*ImageBuilderClientStub) GetAWSAmi ¶
func (mock *ImageBuilderClientStub) GetAWSAmi(ctx context.Context, composeUUID uuid.UUID, instanceType clients.InstanceType) (string, error)
func (*ImageBuilderClientStub) GetAzureImageInfo ¶
func (mock *ImageBuilderClientStub) GetAzureImageInfo(ctx context.Context, composeUUID uuid.UUID, instanceType clients.InstanceType) (string, string, error)
func (*ImageBuilderClientStub) GetGCPImageName ¶
func (mock *ImageBuilderClientStub) GetGCPImageName(ctx context.Context, composeUUID uuid.UUID, instanceType clients.InstanceType) (string, error)
type SourcesClientStub ¶
type SourcesClientStub struct {
// contains filtered or unexported fields
}
func (*SourcesClientStub) GetAuthentication ¶
func (stub *SourcesClientStub) GetAuthentication(ctx context.Context, sourceId string) (*clients.Authentication, error)
func (*SourcesClientStub) ListAllProvisioningSources ¶
func (*SourcesClientStub) ListProvisioningSourcesByProvider ¶
func (mock *SourcesClientStub) ListProvisioningSourcesByProvider(ctx context.Context, provider models.ProviderType) ([]*clients.Source, int, error)
type SourcesIntegrationStub ¶
type SourcesIntegrationStub struct {
// contains filtered or unexported fields
}
func (*SourcesIntegrationStub) ListApplicationTypeSourcesWithResponse ¶
func (mock *SourcesIntegrationStub) ListApplicationTypeSourcesWithResponse(ctx context.Context, appTypeId sources.ID, params *sources.ListApplicationTypeSourcesParams, reqEditors ...sources.RequestEditorFn) (*sources.ListApplicationTypeSourcesResponse, error)
func (*SourcesIntegrationStub) ListSourceAuthenticationsWithResponse ¶
func (mock *SourcesIntegrationStub) ListSourceAuthenticationsWithResponse(ctx context.Context, sourceId sources.ID, params *sources.ListSourceAuthenticationsParams, reqEditors ...sources.RequestEditorFn) (*sources.ListSourceAuthenticationsResponse, error)
func (*SourcesIntegrationStub) ShowApplicationWithResponse ¶
func (mock *SourcesIntegrationStub) ShowApplicationWithResponse(ctx context.Context, appId sources.ID, reqEditors ...sources.RequestEditorFn) (*sources.ShowApplicationResponse, error)
func (*SourcesIntegrationStub) ShowSourceWithResponse ¶
func (mock *SourcesIntegrationStub) ShowSourceWithResponse(ctx context.Context, id sources.ID, reqEditors ...sources.RequestEditorFn) (*sources.ShowSourceResponse, error)
Click to show internal directories.
Click to hide internal directories.