stubs

package
v0.0.0-...-4263410 Latest Latest
Warning

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

Go to latest
Published: Mar 11, 2024 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

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 AddAuth

func AddAuth(ctx context.Context, authentication *clients.Authentication) (*clients.Source, error)

func AddSource

func AddSource(ctx context.Context, provider models.ProviderType) (*clients.Source, error)

func AddStubbedEC2KeyPair

func AddStubbedEC2KeyPair(ctx context.Context, info *types.KeyPairInfo) error

func CountStubAzureVMs

func CountStubAzureVMs(ctx context.Context) int

func CountStubInstancesGCP

func CountStubInstancesGCP(ctx context.Context) int

func DidCreateAzureResourceGroup

func DidCreateAzureResourceGroup(ctx context.Context, name string) bool

func WithAzureClient

func WithAzureClient(parent context.Context) context.Context

func WithEC2Client

func WithEC2Client(parent context.Context) context.Context

func WithGCPCCustomerClient

func WithGCPCCustomerClient(parent context.Context) context.Context

GCPCustomerClient

func WithGCPCServiceClient

func WithGCPCServiceClient(parent context.Context) context.Context

GCPServiceClient

func WithImageBuilderClient

func WithImageBuilderClient(parent context.Context) context.Context

func WithSourcesClient

func WithSourcesClient(parent context.Context) context.Context

SourcesClient

func WithSourcesIntegration

func WithSourcesIntegration(parent context.Context, init_store *[]sources.Source) context.Context

APIClient

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) Status

func (stub *AzureClientStub) Status(ctx context.Context) 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 (mock *EC2ClientStub) GetPubkeyName(ctx context.Context, fingerprint string) (string, error)

func (*EC2ClientStub) ImportPubkey

func (mock *EC2ClientStub) ImportPubkey(ctx context.Context, key *models.Pubkey, tag string) (string, error)

func (*EC2ClientStub) ListAllRegions

func (mock *EC2ClientStub) ListAllRegions(ctx context.Context) ([]clients.Region, error)

func (*EC2ClientStub) ListAllZones

func (mock *EC2ClientStub) ListAllZones(ctx context.Context, region clients.Region) ([]clients.Zone, error)

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)

func (*EC2ClientStub) Status

func (mock *EC2ClientStub) Status(ctx context.Context) 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 (mock *GCPClientStub) ListAllRegions(ctx context.Context) ([]clients.Region, error)

func (*GCPClientStub) ListInstancesIDsByLabel

func (mock *GCPClientStub) ListInstancesIDsByLabel(ctx context.Context, _ string) ([]*string, error)

func (*GCPClientStub) ListLaunchTemplates

func (mock *GCPClientStub) ListLaunchTemplates(ctx context.Context) ([]*clients.LaunchTemplate, string, error)

func (*GCPClientStub) Status

func (mock *GCPClientStub) Status(ctx context.Context) error

type GCPServiceClientStub

type GCPServiceClientStub struct{}

func (*GCPServiceClientStub) ListAllRegionsAndZones

func (mock *GCPServiceClientStub) ListAllRegionsAndZones(ctx context.Context) ([]clients.Region, []clients.Zone, error)

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)

func (*ImageBuilderClientStub) Ready

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 (mock *SourcesClientStub) ListAllProvisioningSources(ctx context.Context) ([]*clients.Source, int, error)

func (*SourcesClientStub) ListProvisioningSourcesByProvider

func (mock *SourcesClientStub) ListProvisioningSourcesByProvider(ctx context.Context, provider models.ProviderType) ([]*clients.Source, int, error)

func (*SourcesClientStub) Ready

func (*SourcesClientStub) Ready(ctx context.Context) 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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL