internal

package
v0.38.0 Latest Latest
Warning

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

 Go to latest Published: Jan 11, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const ServerlessTransformName = "serverless-2024"

Variables

This section is empty.

Functions

func LoadInstanceState 

func LoadInstanceState(
	stateSnapshotFile string,
) (*state.InstanceState, error)

func LoadStringFromFile 

func LoadStringFromFile(
	filePath string,
) (string, error)

func NewTestLogger 

func NewTestLogger() (core.Logger, error)

NewTestLogger creates a new instance of a logger to be used for testing.

func NormaliseResourceChanges 

func NormaliseResourceChanges(changes *provider.Changes, excludeResourceInfo bool) *provider.Changes

NormaliseResourceChanges normalises the order of fields in a provider.Changes struct so that it can be compared deterministically in tests.

func OrderFieldChanges 

func OrderFieldChanges(fieldChanges []provider.FieldChange) []provider.FieldChange

func OrderStringSlice 

func OrderStringSlice(fields []string) []string

func RenderErrorTree 

func RenderErrorTree(err error) string

RenderErrorTree produces a tree representation of a blueprint error.

func UnpackError 

func UnpackError(err error) (error, bool)

UnpackError recursively unpacks a LoadError that can contain child errors. This is to be used when the terminating error is not a LoadError.

func UnpackLoadError 

func UnpackLoadError(err error) (*errors.LoadError, bool)

UnpackLoadError recursively unpacks a LoadError that can contain child errors. This will recursively unpack the first child error until it reaches the last child error.

Types

type BlueprintSpecMock 

type BlueprintSpecMock struct {
	Blueprint *schema.Blueprint
}

func NewBlueprintSpecMock 

func NewBlueprintSpecMock(blueprint *schema.Blueprint) *BlueprintSpecMock

func (*BlueprintSpecMock) ResourceSchema 

func (b *BlueprintSpecMock) ResourceSchema(resourceName string) *schema.Resource

func (*BlueprintSpecMock) Schema 

func (b *BlueprintSpecMock) Schema() *schema.Blueprint

type DataSourceRegistryMock 

type DataSourceRegistryMock struct {
	DataSources map[string]provider.DataSource
}

func (*DataSourceRegistryMock) CustomValidate 

func (r *DataSourceRegistryMock) CustomValidate(
	ctx context.Context,
	dataSourceType string,
	input *provider.DataSourceValidateInput,
) (*provider.DataSourceValidateOutput, error)

func (*DataSourceRegistryMock) Fetch 

func (r *DataSourceRegistryMock) Fetch(
	ctx context.Context,
	dataSourceType string,
	input *provider.DataSourceFetchInput,
) (*provider.DataSourceFetchOutput, error)

func (*DataSourceRegistryMock) GetFilterFields 

func (r *DataSourceRegistryMock) GetFilterFields(
	ctx context.Context,
	dataSourceType string,
	input *provider.DataSourceGetFilterFieldsInput,
) (*provider.DataSourceGetFilterFieldsOutput, error)

func (*DataSourceRegistryMock) GetSpecDefinition 

func (r *DataSourceRegistryMock) GetSpecDefinition(
	ctx context.Context,
	dataSourceType string,
	input *provider.DataSourceGetSpecDefinitionInput,
) (*provider.DataSourceGetSpecDefinitionOutput, error)

func (*DataSourceRegistryMock) GetTypeDescription 

func (r *DataSourceRegistryMock) GetTypeDescription(
	ctx context.Context,
	dataSourceType string,
	input *provider.DataSourceGetTypeDescriptionInput,
) (*provider.DataSourceGetTypeDescriptionOutput, error)

func (*DataSourceRegistryMock) HasDataSourceType 

func (r *DataSourceRegistryMock) HasDataSourceType(ctx context.Context, dataSourceType string) (bool, error)

func (*DataSourceRegistryMock) ListDataSourceTypes 

func (r *DataSourceRegistryMock) ListDataSourceTypes(
	ctx context.Context,
) ([]string, error)

type DynamoDBStreamResource 

type DynamoDBStreamResource struct {
	// A stub for the resource state value to return when requesting the state
	// of the resource in the external provider.
	ExternalState                            *core.MappingNode
	FallbackToStateContainerForExternalState bool
	StateContainer                           state.Container
}

func (*DynamoDBStreamResource) CanLinkTo 

func (r *DynamoDBStreamResource) CanLinkTo(
	ctx context.Context,
	input *provider.ResourceCanLinkToInput,
) (*provider.ResourceCanLinkToOutput, error)

func (*DynamoDBStreamResource) CustomValidate 

func (r *DynamoDBStreamResource) CustomValidate(
	ctx context.Context,
	input *provider.ResourceValidateInput,
) (*provider.ResourceValidateOutput, error)

func (*DynamoDBStreamResource) Deploy 

func (r *DynamoDBStreamResource) Deploy(
	ctx context.Context,
	input *provider.ResourceDeployInput,
) (*provider.ResourceDeployOutput, error)

func (*DynamoDBStreamResource) Destroy 

func (r *DynamoDBStreamResource) Destroy(
	ctx context.Context,
	input *provider.ResourceDestroyInput,
) error

func (*DynamoDBStreamResource) GetExamples 

func (r *DynamoDBStreamResource) GetExamples(
	ctx context.Context,
	input *provider.ResourceGetExamplesInput,
) (*provider.ResourceGetExamplesOutput, error)

func (*DynamoDBStreamResource) GetExternalState 

func (r *DynamoDBStreamResource) GetExternalState(
	ctx context.Context,
	input *provider.ResourceGetExternalStateInput,
) (*provider.ResourceGetExternalStateOutput, error)

func (*DynamoDBStreamResource) GetSpecDefinition 

func (r *DynamoDBStreamResource) GetSpecDefinition(
	ctx context.Context,
	input *provider.ResourceGetSpecDefinitionInput,
) (*provider.ResourceGetSpecDefinitionOutput, error)

func (*DynamoDBStreamResource) GetStabilisedDependencies 

func (r *DynamoDBStreamResource) GetStabilisedDependencies(
	ctx context.Context,
	input *provider.ResourceStabilisedDependenciesInput,
) (*provider.ResourceStabilisedDependenciesOutput, error)

func (*DynamoDBStreamResource) GetType 

func (r *DynamoDBStreamResource) GetType(
	ctx context.Context,
	input *provider.ResourceGetTypeInput,
) (*provider.ResourceGetTypeOutput, error)

func (*DynamoDBStreamResource) GetTypeDescription 

func (r *DynamoDBStreamResource) GetTypeDescription(
	ctx context.Context,
	input *provider.ResourceGetTypeDescriptionInput,
) (*provider.ResourceGetTypeDescriptionOutput, error)

func (*DynamoDBStreamResource) HasStabilised 

func (r *DynamoDBStreamResource) HasStabilised(
	ctx context.Context,
	input *provider.ResourceHasStabilisedInput,
) (*provider.ResourceHasStabilisedOutput, error)

func (*DynamoDBStreamResource) IsCommonTerminal 

func (r *DynamoDBStreamResource) IsCommonTerminal(
	ctx context.Context,
	input *provider.ResourceIsCommonTerminalInput,
) (*provider.ResourceIsCommonTerminalOutput, error)

type DynamoDBTableResource 

type DynamoDBTableResource struct {
	// A stub for the resource state value to return when requesting the state
	// of the resource in the external provider.
	ExternalState                            *core.MappingNode
	FallbackToStateContainerForExternalState bool
	StateContainer                           state.Container
	// Tracks the number of stabilise calls have been made for a resource ID.
	// Unlike the test lambda resource, this is not used to test polling behaviour,
	// this is used to test that transient failures are handled correctly by the
	// resource deployer.
	CurrentStabiliseCalls map[string]int
	// contains filtered or unexported fields
}

func (*DynamoDBTableResource) CanLinkTo 

func (r *DynamoDBTableResource) CanLinkTo(
	ctx context.Context,
	input *provider.ResourceCanLinkToInput,
) (*provider.ResourceCanLinkToOutput, error)

func (*DynamoDBTableResource) CustomValidate 

func (r *DynamoDBTableResource) CustomValidate(
	ctx context.Context,
	input *provider.ResourceValidateInput,
) (*provider.ResourceValidateOutput, error)

func (*DynamoDBTableResource) Deploy 

func (r *DynamoDBTableResource) Deploy(
	ctx context.Context,
	input *provider.ResourceDeployInput,
) (*provider.ResourceDeployOutput, error)

func (*DynamoDBTableResource) Destroy 

func (r *DynamoDBTableResource) Destroy(
	ctx context.Context,
	input *provider.ResourceDestroyInput,
) error

func (*DynamoDBTableResource) GetExamples 

func (r *DynamoDBTableResource) GetExamples(
	ctx context.Context,
	input *provider.ResourceGetExamplesInput,
) (*provider.ResourceGetExamplesOutput, error)

func (*DynamoDBTableResource) GetExternalState 

func (r *DynamoDBTableResource) GetExternalState(
	ctx context.Context,
	input *provider.ResourceGetExternalStateInput,
) (*provider.ResourceGetExternalStateOutput, error)

func (*DynamoDBTableResource) GetSpecDefinition 

func (r *DynamoDBTableResource) GetSpecDefinition(
	ctx context.Context,
	input *provider.ResourceGetSpecDefinitionInput,
) (*provider.ResourceGetSpecDefinitionOutput, error)

func (*DynamoDBTableResource) GetStabilisedDependencies 

func (r *DynamoDBTableResource) GetStabilisedDependencies(
	ctx context.Context,
	input *provider.ResourceStabilisedDependenciesInput,
) (*provider.ResourceStabilisedDependenciesOutput, error)

func (*DynamoDBTableResource) GetType 

func (r *DynamoDBTableResource) GetType(
	ctx context.Context,
	input *provider.ResourceGetTypeInput,
) (*provider.ResourceGetTypeOutput, error)

func (*DynamoDBTableResource) GetTypeDescription 

func (r *DynamoDBTableResource) GetTypeDescription(
	ctx context.Context,
	input *provider.ResourceGetTypeDescriptionInput,
) (*provider.ResourceGetTypeDescriptionOutput, error)

func (*DynamoDBTableResource) HasStabilised 

func (r *DynamoDBTableResource) HasStabilised(
	ctx context.Context,
	input *provider.ResourceHasStabilisedInput,
) (*provider.ResourceHasStabilisedOutput, error)

func (*DynamoDBTableResource) IsCommonTerminal 

func (r *DynamoDBTableResource) IsCommonTerminal(
	ctx context.Context,
	input *provider.ResourceIsCommonTerminalInput,
) (*provider.ResourceIsCommonTerminalOutput, error)

type ExampleComplexResource 

type ExampleComplexResource struct {
	// A stub for the resource state value to return when requesting the state
	// of the resource in the external provider.
	ExternalState                            *core.MappingNode
	FallbackToStateContainerForExternalState bool
	StateContainer                           state.Container
}

func (*ExampleComplexResource) CanLinkTo 

func (r *ExampleComplexResource) CanLinkTo(
	ctx context.Context,
	input *provider.ResourceCanLinkToInput,
) (*provider.ResourceCanLinkToOutput, error)

func (*ExampleComplexResource) CustomValidate 

func (r *ExampleComplexResource) CustomValidate(
	ctx context.Context,
	input *provider.ResourceValidateInput,
) (*provider.ResourceValidateOutput, error)

func (*ExampleComplexResource) Deploy 

func (r *ExampleComplexResource) Deploy(
	ctx context.Context,
	input *provider.ResourceDeployInput,
) (*provider.ResourceDeployOutput, error)

func (*ExampleComplexResource) Destroy 

func (r *ExampleComplexResource) Destroy(
	ctx context.Context,
	input *provider.ResourceDestroyInput,
) error

func (*ExampleComplexResource) GetExamples 

func (r *ExampleComplexResource) GetExamples(
	ctx context.Context,
	input *provider.ResourceGetExamplesInput,
) (*provider.ResourceGetExamplesOutput, error)

func (*ExampleComplexResource) GetExternalState 

func (r *ExampleComplexResource) GetExternalState(
	ctx context.Context,
	input *provider.ResourceGetExternalStateInput,
) (*provider.ResourceGetExternalStateOutput, error)

func (*ExampleComplexResource) GetSpecDefinition 

func (r *ExampleComplexResource) GetSpecDefinition(
	ctx context.Context,
	input *provider.ResourceGetSpecDefinitionInput,
) (*provider.ResourceGetSpecDefinitionOutput, error)

func (*ExampleComplexResource) GetStabilisedDependencies 

func (r *ExampleComplexResource) GetStabilisedDependencies(
	ctx context.Context,
	input *provider.ResourceStabilisedDependenciesInput,
) (*provider.ResourceStabilisedDependenciesOutput, error)

func (*ExampleComplexResource) GetType 

func (r *ExampleComplexResource) GetType(
	ctx context.Context,
	input *provider.ResourceGetTypeInput,
) (*provider.ResourceGetTypeOutput, error)

func (*ExampleComplexResource) GetTypeDescription 

func (r *ExampleComplexResource) GetTypeDescription(
	ctx context.Context,
	input *provider.ResourceGetTypeDescriptionInput,
) (*provider.ResourceGetTypeDescriptionOutput, error)

func (*ExampleComplexResource) HasStabilised 

func (r *ExampleComplexResource) HasStabilised(
	ctx context.Context,
	input *provider.ResourceHasStabilisedInput,
) (*provider.ResourceHasStabilisedOutput, error)

func (*ExampleComplexResource) IsCommonTerminal 

func (r *ExampleComplexResource) IsCommonTerminal(
	ctx context.Context,
	input *provider.ResourceIsCommonTerminalInput,
) (*provider.ResourceIsCommonTerminalOutput, error)

type ExampleNullableFieldResource added in v0.37.0 

type ExampleNullableFieldResource struct{}

ExampleNullableFieldResource is a test resource implementation that demonstrates nullable fields with default values, simulating resources like SQS queues where fields like delaySeconds have defaults but can also be explicitly set to null.

func (*ExampleNullableFieldResource) CanLinkTo added in v0.37.0 

func (r *ExampleNullableFieldResource) CanLinkTo(
	ctx context.Context,
	input *provider.ResourceCanLinkToInput,
) (*provider.ResourceCanLinkToOutput, error)

func (*ExampleNullableFieldResource) CustomValidate added in v0.37.0 

func (r *ExampleNullableFieldResource) CustomValidate(
	ctx context.Context,
	input *provider.ResourceValidateInput,
) (*provider.ResourceValidateOutput, error)

func (*ExampleNullableFieldResource) Deploy added in v0.37.0 

func (r *ExampleNullableFieldResource) Deploy(
	ctx context.Context,
	input *provider.ResourceDeployInput,
) (*provider.ResourceDeployOutput, error)

func (*ExampleNullableFieldResource) Destroy added in v0.37.0 

func (r *ExampleNullableFieldResource) Destroy(
	ctx context.Context,
	input *provider.ResourceDestroyInput,
) error

func (*ExampleNullableFieldResource) GetExamples added in v0.37.0 

func (r *ExampleNullableFieldResource) GetExamples(
	ctx context.Context,
	input *provider.ResourceGetExamplesInput,
) (*provider.ResourceGetExamplesOutput, error)

func (*ExampleNullableFieldResource) GetExternalState added in v0.37.0 

func (r *ExampleNullableFieldResource) GetExternalState(
	ctx context.Context,
	input *provider.ResourceGetExternalStateInput,
) (*provider.ResourceGetExternalStateOutput, error)

func (*ExampleNullableFieldResource) GetSpecDefinition added in v0.37.0 

func (r *ExampleNullableFieldResource) GetSpecDefinition(
	ctx context.Context,
	input *provider.ResourceGetSpecDefinitionInput,
) (*provider.ResourceGetSpecDefinitionOutput, error)

func (*ExampleNullableFieldResource) GetStabilisedDependencies added in v0.37.0 

func (r *ExampleNullableFieldResource) GetStabilisedDependencies(
	ctx context.Context,
	input *provider.ResourceStabilisedDependenciesInput,
) (*provider.ResourceStabilisedDependenciesOutput, error)

func (*ExampleNullableFieldResource) GetType added in v0.37.0 

func (r *ExampleNullableFieldResource) GetType(
	ctx context.Context,
	input *provider.ResourceGetTypeInput,
) (*provider.ResourceGetTypeOutput, error)

func (*ExampleNullableFieldResource) GetTypeDescription added in v0.37.0 

func (r *ExampleNullableFieldResource) GetTypeDescription(
	ctx context.Context,
	input *provider.ResourceGetTypeDescriptionInput,
) (*provider.ResourceGetTypeDescriptionOutput, error)

func (*ExampleNullableFieldResource) HasStabilised added in v0.37.0 

func (r *ExampleNullableFieldResource) HasStabilised(
	ctx context.Context,
	input *provider.ResourceHasStabilisedInput,
) (*provider.ResourceHasStabilisedOutput, error)

func (*ExampleNullableFieldResource) IsCommonTerminal added in v0.37.0 

func (r *ExampleNullableFieldResource) IsCommonTerminal(
	ctx context.Context,
	input *provider.ResourceIsCommonTerminalInput,
) (*provider.ResourceIsCommonTerminalOutput, error)

type ExampleTaggableResource added in v0.37.0 

type ExampleTaggableResource struct{}

ExampleTaggableResource is a test resource implementation that demonstrates the use of SortArrayByField for order-independent tag comparison.

func (*ExampleTaggableResource) CanLinkTo added in v0.37.0 

func (r *ExampleTaggableResource) CanLinkTo(
	ctx context.Context,
	input *provider.ResourceCanLinkToInput,
) (*provider.ResourceCanLinkToOutput, error)

func (*ExampleTaggableResource) CustomValidate added in v0.37.0 

func (r *ExampleTaggableResource) CustomValidate(
	ctx context.Context,
	input *provider.ResourceValidateInput,
) (*provider.ResourceValidateOutput, error)

func (*ExampleTaggableResource) Deploy added in v0.37.0 

func (r *ExampleTaggableResource) Deploy(
	ctx context.Context,
	input *provider.ResourceDeployInput,
) (*provider.ResourceDeployOutput, error)

func (*ExampleTaggableResource) Destroy added in v0.37.0 

func (r *ExampleTaggableResource) Destroy(
	ctx context.Context,
	input *provider.ResourceDestroyInput,
) error

func (*ExampleTaggableResource) GetExamples added in v0.37.0 

func (r *ExampleTaggableResource) GetExamples(
	ctx context.Context,
	input *provider.ResourceGetExamplesInput,
) (*provider.ResourceGetExamplesOutput, error)

func (*ExampleTaggableResource) GetExternalState added in v0.37.0 

func (r *ExampleTaggableResource) GetExternalState(
	ctx context.Context,
	input *provider.ResourceGetExternalStateInput,
) (*provider.ResourceGetExternalStateOutput, error)

func (*ExampleTaggableResource) GetSpecDefinition added in v0.37.0 

func (r *ExampleTaggableResource) GetSpecDefinition(
	ctx context.Context,
	input *provider.ResourceGetSpecDefinitionInput,
) (*provider.ResourceGetSpecDefinitionOutput, error)

func (*ExampleTaggableResource) GetStabilisedDependencies added in v0.37.0 

func (r *ExampleTaggableResource) GetStabilisedDependencies(
	ctx context.Context,
	input *provider.ResourceStabilisedDependenciesInput,
) (*provider.ResourceStabilisedDependenciesOutput, error)

func (*ExampleTaggableResource) GetType added in v0.37.0 

func (r *ExampleTaggableResource) GetType(
	ctx context.Context,
	input *provider.ResourceGetTypeInput,
) (*provider.ResourceGetTypeOutput, error)

func (*ExampleTaggableResource) GetTypeDescription added in v0.37.0 

func (r *ExampleTaggableResource) GetTypeDescription(
	ctx context.Context,
	input *provider.ResourceGetTypeDescriptionInput,
) (*provider.ResourceGetTypeDescriptionOutput, error)

func (*ExampleTaggableResource) HasStabilised added in v0.37.0 

func (r *ExampleTaggableResource) HasStabilised(
	ctx context.Context,
	input *provider.ResourceHasStabilisedInput,
) (*provider.ResourceHasStabilisedOutput, error)

func (*ExampleTaggableResource) IsCommonTerminal added in v0.37.0 

func (r *ExampleTaggableResource) IsCommonTerminal(
	ctx context.Context,
	input *provider.ResourceIsCommonTerminalInput,
) (*provider.ResourceIsCommonTerminalOutput, error)

type FunctionRegistryMock 

type FunctionRegistryMock struct {
	Functions map[string]provider.Function
	CallStack function.Stack
}

func (*FunctionRegistryMock) Call 

func (f *FunctionRegistryMock) Call(
	ctx context.Context,
	functionName string,
	input *provider.FunctionCallInput,
) (*provider.FunctionCallOutput, error)

func (*FunctionRegistryMock) ForCallContext 

func (f *FunctionRegistryMock) ForCallContext(stack function.Stack) provider.FunctionRegistry

func (*FunctionRegistryMock) GetDefinition 

func (f *FunctionRegistryMock) GetDefinition(
	ctx context.Context,
	functionName string,
	input *provider.FunctionGetDefinitionInput,
) (*provider.FunctionGetDefinitionOutput, error)

func (*FunctionRegistryMock) HasFunction 

func (f *FunctionRegistryMock) HasFunction(ctx context.Context, functionName string) (bool, error)

func (*FunctionRegistryMock) ListFunctions 

func (r *FunctionRegistryMock) ListFunctions(
	ctx context.Context,
) ([]string, error)

type IAMRoleResource 

type IAMRoleResource struct{}

IAMRoleResource is a stub implementation of a resource that represents an IAM role. This has been prepared primarily to be used in tests for intermediary resource deployment as a part of a link plugin implementation.

func (*IAMRoleResource) CanLinkTo 

func (r *IAMRoleResource) CanLinkTo(
	ctx context.Context,
	input *provider.ResourceCanLinkToInput,
) (*provider.ResourceCanLinkToOutput, error)

func (*IAMRoleResource) CustomValidate 

func (r *IAMRoleResource) CustomValidate(
	ctx context.Context,
	input *provider.ResourceValidateInput,
) (*provider.ResourceValidateOutput, error)

func (*IAMRoleResource) Deploy 

func (r *IAMRoleResource) Deploy(
	ctx context.Context,
	input *provider.ResourceDeployInput,
) (*provider.ResourceDeployOutput, error)

func (*IAMRoleResource) Destroy 

func (r *IAMRoleResource) Destroy(
	ctx context.Context,
	input *provider.ResourceDestroyInput,
) error

func (*IAMRoleResource) GetExamples 

func (r *IAMRoleResource) GetExamples(
	ctx context.Context,
	input *provider.ResourceGetExamplesInput,
) (*provider.ResourceGetExamplesOutput, error)

func (*IAMRoleResource) GetExternalState 

func (r *IAMRoleResource) GetExternalState(
	ctx context.Context,
	input *provider.ResourceGetExternalStateInput,
) (*provider.ResourceGetExternalStateOutput, error)

func (*IAMRoleResource) GetSpecDefinition 

func (r *IAMRoleResource) GetSpecDefinition(
	ctx context.Context,
	input *provider.ResourceGetSpecDefinitionInput,
) (*provider.ResourceGetSpecDefinitionOutput, error)

func (*IAMRoleResource) GetStabilisedDependencies 

func (r *IAMRoleResource) GetStabilisedDependencies(
	ctx context.Context,
	input *provider.ResourceStabilisedDependenciesInput,
) (*provider.ResourceStabilisedDependenciesOutput, error)

func (*IAMRoleResource) GetType 

func (r *IAMRoleResource) GetType(
	ctx context.Context,
	input *provider.ResourceGetTypeInput,
) (*provider.ResourceGetTypeOutput, error)

func (*IAMRoleResource) GetTypeDescription 

func (r *IAMRoleResource) GetTypeDescription(
	ctx context.Context,
	input *provider.ResourceGetTypeDescriptionInput,
) (*provider.ResourceGetTypeDescriptionOutput, error)

func (*IAMRoleResource) HasStabilised 

func (r *IAMRoleResource) HasStabilised(
	ctx context.Context,
	input *provider.ResourceHasStabilisedInput,
) (*provider.ResourceHasStabilisedOutput, error)

func (*IAMRoleResource) IsCommonTerminal 

func (r *IAMRoleResource) IsCommonTerminal(
	ctx context.Context,
	input *provider.ResourceIsCommonTerminalInput,
) (*provider.ResourceIsCommonTerminalOutput, error)

type InstanceTypeCustomVariableType 

type InstanceTypeCustomVariableType struct{}

func (*InstanceTypeCustomVariableType) GetDescription 

func (t *InstanceTypeCustomVariableType) GetDescription(
	ctx context.Context,
	input *provider.CustomVariableTypeGetDescriptionInput,
) (*provider.CustomVariableTypeGetDescriptionOutput, error)

func (*InstanceTypeCustomVariableType) GetExamples 

func (t *InstanceTypeCustomVariableType) GetExamples(
	ctx context.Context,
	input *provider.CustomVariableTypeGetExamplesInput,
) (*provider.CustomVariableTypeGetExamplesOutput, error)

func (*InstanceTypeCustomVariableType) GetType 

func (t *InstanceTypeCustomVariableType) GetType(
	ctx context.Context,
	input *provider.CustomVariableTypeGetTypeInput,
) (*provider.CustomVariableTypeGetTypeOutput, error)

func (*InstanceTypeCustomVariableType) Options 

func (t *InstanceTypeCustomVariableType) Options(
	ctx context.Context,
	input *provider.CustomVariableTypeOptionsInput,
) (*provider.CustomVariableTypeOptionsOutput, error)

type Lambda2FunctionResource 

type Lambda2FunctionResource struct {
	// A stub for the resource state value to return when requesting the state
	// of the resource in the external provider.
	ExternalState                            *core.MappingNode
	FallbackToStateContainerForExternalState bool
	StateContainer                           state.Container
}

func (*Lambda2FunctionResource) CanLinkTo 

func (r *Lambda2FunctionResource) CanLinkTo(
	ctx context.Context,
	input *provider.ResourceCanLinkToInput,
) (*provider.ResourceCanLinkToOutput, error)

func (*Lambda2FunctionResource) CustomValidate 

func (r *Lambda2FunctionResource) CustomValidate(
	ctx context.Context,
	input *provider.ResourceValidateInput,
) (*provider.ResourceValidateOutput, error)

func (*Lambda2FunctionResource) Deploy 

func (r *Lambda2FunctionResource) Deploy(
	ctx context.Context,
	input *provider.ResourceDeployInput,
) (*provider.ResourceDeployOutput, error)

func (*Lambda2FunctionResource) Destroy 

func (r *Lambda2FunctionResource) Destroy(
	ctx context.Context,
	input *provider.ResourceDestroyInput,
) error

func (*Lambda2FunctionResource) GetExamples 

func (r *Lambda2FunctionResource) GetExamples(
	ctx context.Context,
	input *provider.ResourceGetExamplesInput,
) (*provider.ResourceGetExamplesOutput, error)

func (*Lambda2FunctionResource) GetExternalState 

func (r *Lambda2FunctionResource) GetExternalState(
	ctx context.Context,
	input *provider.ResourceGetExternalStateInput,
) (*provider.ResourceGetExternalStateOutput, error)

func (*Lambda2FunctionResource) GetSpecDefinition 

func (r *Lambda2FunctionResource) GetSpecDefinition(
	ctx context.Context,
	input *provider.ResourceGetSpecDefinitionInput,
) (*provider.ResourceGetSpecDefinitionOutput, error)

func (*Lambda2FunctionResource) GetStabilisedDependencies 

func (r *Lambda2FunctionResource) GetStabilisedDependencies(
	ctx context.Context,
	input *provider.ResourceStabilisedDependenciesInput,
) (*provider.ResourceStabilisedDependenciesOutput, error)

func (*Lambda2FunctionResource) GetType 

func (r *Lambda2FunctionResource) GetType(
	ctx context.Context,
	input *provider.ResourceGetTypeInput,
) (*provider.ResourceGetTypeOutput, error)

func (*Lambda2FunctionResource) GetTypeDescription 

func (r *Lambda2FunctionResource) GetTypeDescription(
	ctx context.Context,
	input *provider.ResourceGetTypeDescriptionInput,
) (*provider.ResourceGetTypeDescriptionOutput, error)

func (*Lambda2FunctionResource) HasStabilised 

func (r *Lambda2FunctionResource) HasStabilised(
	ctx context.Context,
	input *provider.ResourceHasStabilisedInput,
) (*provider.ResourceHasStabilisedOutput, error)

func (*Lambda2FunctionResource) IsCommonTerminal 

func (r *Lambda2FunctionResource) IsCommonTerminal(
	ctx context.Context,
	input *provider.ResourceIsCommonTerminalInput,
) (*provider.ResourceIsCommonTerminalOutput, error)

type LambdaFunctionResource 

type LambdaFunctionResource struct {
	// Tracks the number of destroy attempts for each unique resource ID.
	// This is used to emulate transient failures when destroying resources,
	// the blueprint container will retry destroying the resource until the
	// destroy attempt count exceeds the max destroy attempts.
	CurrentDestroyAttempts map[string]int
	// Tracks the number of deploy attempts for each unique resource ID.
	// This is used to emulate transient failures when deploying resources,
	// the blueprint container will retry deploying the resource until the
	// deploy attempt count exceeds the max deploy attempts.
	CurrentDeployAttemps map[string]int
	// Tracks the number of get external state attempts for each unique resource ID.
	// This is used to emulate transient failures when getting the external state
	// of resources, the drift checker will retry getting the external state
	// until the get external state attempt count exceeds the max get external state attempts.
	CurrentGetExternalStateAttemps map[string]int
	// Resource IDs for which the lambda function resource implementation
	// should fail with a terminal error.
	FailResourceIDs []string
	// A mapping of resource IDs to their respective stub resource stabilisation
	// configuration.
	StabiliseResourceIDs map[string]*StubResourceStabilisationConfig
	// Override stabilisation config to always report the resource as stabilised
	// on first check.
	AlwaysStabilise bool
	// Tracks the number of stabilise calls have been made for a resource ID.
	CurrentStabiliseCalls map[string]int
	// A list of instance IDs for which retry failures should be skipped.
	SkipRetryFailuresForInstances []string
	// A stub for the resource state value to return when requesting the state
	// of the resource in the external provider.
	ExternalState                            *core.MappingNode
	FallbackToStateContainerForExternalState bool
	StateContainer                           state.Container
	// contains filtered or unexported fields
}

func (*LambdaFunctionResource) CanLinkTo 

func (r *LambdaFunctionResource) CanLinkTo(
	ctx context.Context,
	input *provider.ResourceCanLinkToInput,
) (*provider.ResourceCanLinkToOutput, error)

func (*LambdaFunctionResource) CustomValidate 

func (r *LambdaFunctionResource) CustomValidate(
	ctx context.Context,
	input *provider.ResourceValidateInput,
) (*provider.ResourceValidateOutput, error)

func (*LambdaFunctionResource) Deploy 

func (r *LambdaFunctionResource) Deploy(
	ctx context.Context,
	input *provider.ResourceDeployInput,
) (*provider.ResourceDeployOutput, error)

func (*LambdaFunctionResource) Destroy 

func (r *LambdaFunctionResource) Destroy(
	ctx context.Context,
	input *provider.ResourceDestroyInput,
) error

func (*LambdaFunctionResource) GetExamples 

func (r *LambdaFunctionResource) GetExamples(
	ctx context.Context,
	input *provider.ResourceGetExamplesInput,
) (*provider.ResourceGetExamplesOutput, error)

func (*LambdaFunctionResource) GetExternalState 

func (r *LambdaFunctionResource) GetExternalState(
	ctx context.Context,
	input *provider.ResourceGetExternalStateInput,
) (*provider.ResourceGetExternalStateOutput, error)

func (*LambdaFunctionResource) GetSpecDefinition 

func (r *LambdaFunctionResource) GetSpecDefinition(
	ctx context.Context,
	input *provider.ResourceGetSpecDefinitionInput,
) (*provider.ResourceGetSpecDefinitionOutput, error)

func (*LambdaFunctionResource) GetStabilisedDependencies 

func (r *LambdaFunctionResource) GetStabilisedDependencies(
	ctx context.Context,
	input *provider.ResourceStabilisedDependenciesInput,
) (*provider.ResourceStabilisedDependenciesOutput, error)

func (*LambdaFunctionResource) GetType 

func (r *LambdaFunctionResource) GetType(
	ctx context.Context,
	input *provider.ResourceGetTypeInput,
) (*provider.ResourceGetTypeOutput, error)

func (*LambdaFunctionResource) GetTypeDescription 

func (r *LambdaFunctionResource) GetTypeDescription(
	ctx context.Context,
	input *provider.ResourceGetTypeDescriptionInput,
) (*provider.ResourceGetTypeDescriptionOutput, error)

func (*LambdaFunctionResource) HasStabilised 

func (r *LambdaFunctionResource) HasStabilised(
	ctx context.Context,
	input *provider.ResourceHasStabilisedInput,
) (*provider.ResourceHasStabilisedOutput, error)

func (*LambdaFunctionResource) IsCommonTerminal 

func (r *LambdaFunctionResource) IsCommonTerminal(
	ctx context.Context,
	input *provider.ResourceIsCommonTerminalInput,
) (*provider.ResourceIsCommonTerminalOutput, error)

type ProviderMock 

type ProviderMock struct {
	NamespaceValue      string
	Resources           map[string]provider.Resource
	DataSources         map[string]provider.DataSource
	Links               map[string]provider.Link
	CustomVariableTypes map[string]provider.CustomVariableType
	ProviderRetryPolicy *provider.RetryPolicy
}

func (*ProviderMock) ConfigDefinition 

func (p *ProviderMock) ConfigDefinition(ctx context.Context) (*core.ConfigDefinition, error)

func (*ProviderMock) CustomVariableType 

func (p *ProviderMock) CustomVariableType(ctx context.Context, customVariableType string) (provider.CustomVariableType, error)

func (*ProviderMock) DataSource 

func (p *ProviderMock) DataSource(ctx context.Context, dataSourceType string) (provider.DataSource, error)

func (*ProviderMock) Function 

func (p *ProviderMock) Function(ctx context.Context, functionName string) (provider.Function, error)
func (p *ProviderMock) Link(ctx context.Context, resourceTypeA string, resourceTypeB string) (provider.Link, error)

func (*ProviderMock) ListCustomVariableTypes 

func (p *ProviderMock) ListCustomVariableTypes(ctx context.Context) ([]string, error)

func (*ProviderMock) ListDataSourceTypes 

func (p *ProviderMock) ListDataSourceTypes(ctx context.Context) ([]string, error)

func (*ProviderMock) ListFunctions 

func (p *ProviderMock) ListFunctions(ctx context.Context) ([]string, error)

func (*ProviderMock) ListLinkTypes 

func (p *ProviderMock) ListLinkTypes(ctx context.Context) ([]string, error)

func (*ProviderMock) ListResourceTypes 

func (p *ProviderMock) ListResourceTypes(ctx context.Context) ([]string, error)

func (*ProviderMock) Namespace 

func (p *ProviderMock) Namespace(ctx context.Context) (string, error)

func (*ProviderMock) Resource 

func (p *ProviderMock) Resource(ctx context.Context, resourceType string) (provider.Resource, error)

func (*ProviderMock) RetryPolicy 

func (p *ProviderMock) RetryPolicy(ctx context.Context) (*provider.RetryPolicy, error)

type ResourceRegistryMock 

type ResourceRegistryMock struct {
	Resources      map[string]provider.Resource
	StateContainer state.Container

	// OnLockAcquired is called after a lock is successfully acquired.
	// This can be used in tests to cancel context after lock acquisition.
	OnLockAcquired func()
	// contains filtered or unexported fields
}

func NewResourceRegistryMock added in v0.30.0 

func NewResourceRegistryMock(
	resources map[string]provider.Resource,
	opts ...ResourceRegistryMockOption,
) *ResourceRegistryMock

func (*ResourceRegistryMock) AcquireResourceLock added in v0.30.0 

func (r *ResourceRegistryMock) AcquireResourceLock(
	ctx context.Context,
	input *provider.AcquireResourceLockInput,
) error

func (*ResourceRegistryMock) CustomValidate 

func (r *ResourceRegistryMock) CustomValidate(
	ctx context.Context,
	resourceType string,
	input *provider.ResourceValidateInput,
) (*provider.ResourceValidateOutput, error)

func (*ResourceRegistryMock) Deploy 

func (r *ResourceRegistryMock) Deploy(
	ctx context.Context,
	resourceType string,
	input *provider.ResourceDeployServiceInput,
) (*provider.ResourceDeployOutput, error)

func (*ResourceRegistryMock) Destroy 

func (r *ResourceRegistryMock) Destroy(
	ctx context.Context,
	resourceType string,
	input *provider.ResourceDestroyInput,
) error

func (*ResourceRegistryMock) GetSpecDefinition 

func (r *ResourceRegistryMock) GetSpecDefinition(
	ctx context.Context,
	resourceType string,
	input *provider.ResourceGetSpecDefinitionInput,
) (*provider.ResourceGetSpecDefinitionOutput, error)

func (*ResourceRegistryMock) GetStabilisedDependencies 

func (r *ResourceRegistryMock) GetStabilisedDependencies(
	ctx context.Context,
	resourceType string,
	input *provider.ResourceStabilisedDependenciesInput,
) (*provider.ResourceStabilisedDependenciesOutput, error)

func (*ResourceRegistryMock) GetTypeDescription 

func (r *ResourceRegistryMock) GetTypeDescription(
	ctx context.Context,
	resourceType string,
	input *provider.ResourceGetTypeDescriptionInput,
) (*provider.ResourceGetTypeDescriptionOutput, error)

func (*ResourceRegistryMock) HasLocks added in v0.37.0 

func (r *ResourceRegistryMock) HasLocks() bool

HasLocks returns true if there are any resource locks held. This is useful for testing that locks are properly released.

func (*ResourceRegistryMock) HasResourceInState added in v0.25.0 

func (r *ResourceRegistryMock) HasResourceInState(
	ctx context.Context,
	input *provider.ResourceLookupInput,
) (bool, error)

func (*ResourceRegistryMock) HasResourceType 

func (r *ResourceRegistryMock) HasResourceType(ctx context.Context, resourceType string) (bool, error)

func (*ResourceRegistryMock) ListResourceTypes 

func (r *ResourceRegistryMock) ListResourceTypes(
	ctx context.Context,
) ([]string, error)

func (*ResourceRegistryMock) LookupResourceInState added in v0.25.0 

func (r *ResourceRegistryMock) LookupResourceInState(
	ctx context.Context,
	input *provider.ResourceLookupInput,
) (*state.ResourceState, error)

func (*ResourceRegistryMock) ReleaseResourceLock added in v0.30.0 

func (r *ResourceRegistryMock) ReleaseResourceLock(
	ctx context.Context,
	instanceID string,
	resourceName string,
)

func (*ResourceRegistryMock) ReleaseResourceLocks added in v0.30.0 

func (r *ResourceRegistryMock) ReleaseResourceLocks(ctx context.Context, instanceID string)

func (*ResourceRegistryMock) ReleaseResourceLocksAcquiredBy added in v0.30.0 

func (r *ResourceRegistryMock) ReleaseResourceLocksAcquiredBy(
	ctx context.Context,
	instanceID string,
	acquiredBy string,
)

func (*ResourceRegistryMock) WithParams 

func (r *ResourceRegistryMock) WithParams(
	params core.BlueprintParams,
) resourcehelpers.Registry

type ResourceRegistryMockOption added in v0.30.0 

type ResourceRegistryMockOption func(*ResourceRegistryMock)

func WithResourceRegistryClock added in v0.30.0 

func WithResourceRegistryClock(clock core.Clock) ResourceRegistryMockOption

func WithResourceRegistryLockCheckInterval added in v0.30.0 

func WithResourceRegistryLockCheckInterval(interval time.Duration) ResourceRegistryMockOption

func WithResourceRegistryLockTimeout added in v0.30.0 

func WithResourceRegistryLockTimeout(timeout time.Duration) ResourceRegistryMockOption

func WithResourceRegistryStateContainer added in v0.30.0 

func WithResourceRegistryStateContainer(stateContainer state.Container) ResourceRegistryMockOption

type ServerlessTransformer 

type ServerlessTransformer struct{}

func (*ServerlessTransformer) AbstractResource 

func (t *ServerlessTransformer) AbstractResource(
	ctx context.Context,
	resourceType string,
) (transform.AbstractResource, error)

func (*ServerlessTransformer) ConfigDefinition 

func (t *ServerlessTransformer) ConfigDefinition(
	ctx context.Context,
) (*core.ConfigDefinition, error)

func (*ServerlessTransformer) GetTransformName 

func (t *ServerlessTransformer) GetTransformName(ctx context.Context) (string, error)

func (*ServerlessTransformer) ListAbstractResourceTypes 

func (t *ServerlessTransformer) ListAbstractResourceTypes(
	ctx context.Context,
) ([]string, error)

func (*ServerlessTransformer) Transform 

func (t *ServerlessTransformer) Transform(
	ctx context.Context,
	input *transform.SpecTransformerTransformInput,
) (*transform.SpecTransformerTransformOutput, error)

type StaticIDGenerator 

type StaticIDGenerator struct {
	ID string
}

func (*StaticIDGenerator) GenerateID 

func (m *StaticIDGenerator) GenerateID() (string, error)

type StubResourceStabilisationConfig 

type StubResourceStabilisationConfig struct {
	// The number of attempts to wait for a resource to stabilise
	// before giving up.
	// Set this to -1 for a resource that should never stabilise.
	StabilisesAfterAttempts int
}

StubResourceStabilisationConfig provides configuration for the test resource implementations to simulate eventual resource stabilisation.

type TestLogger 

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

TestLogger is an implementation of the core.Logger interface that is used for automated testing.

func (*TestLogger) Debug 

func (l *TestLogger) Debug(message string, fields ...core.LogField)

func (*TestLogger) Error 

func (l *TestLogger) Error(message string, fields ...core.LogField)

func (*TestLogger) Fatal 

func (l *TestLogger) Fatal(message string, fields ...core.LogField)

func (*TestLogger) Info 

func (l *TestLogger) Info(message string, fields ...core.LogField)

func (*TestLogger) Named 

func (l *TestLogger) Named(name string) core.Logger

func (*TestLogger) Warn 

func (l *TestLogger) Warn(message string, fields ...core.LogField)

func (*TestLogger) WithFields 

func (l *TestLogger) WithFields(fields ...core.LogField) core.Logger

type VPCDataSource 

type VPCDataSource struct{}

func (*VPCDataSource) CustomValidate 

func (d *VPCDataSource) CustomValidate(
	ctx context.Context,
	input *provider.DataSourceValidateInput,
) (*provider.DataSourceValidateOutput, error)

func (*VPCDataSource) Fetch 

func (d *VPCDataSource) Fetch(
	ctx context.Context,
	input *provider.DataSourceFetchInput,
) (*provider.DataSourceFetchOutput, error)

func (*VPCDataSource) GetExamples 

func (d *VPCDataSource) GetExamples(
	ctx context.Context,
	input *provider.DataSourceGetExamplesInput,
) (*provider.DataSourceGetExamplesOutput, error)

func (*VPCDataSource) GetFilterFields 

func (d *VPCDataSource) GetFilterFields(
	ctx context.Context,
	input *provider.DataSourceGetFilterFieldsInput,
) (*provider.DataSourceGetFilterFieldsOutput, error)

func (*VPCDataSource) GetSpecDefinition 

func (d *VPCDataSource) GetSpecDefinition(
	ctx context.Context,
	input *provider.DataSourceGetSpecDefinitionInput,
) (*provider.DataSourceGetSpecDefinitionOutput, error)

func (*VPCDataSource) GetType 

func (d *VPCDataSource) GetType(
	ctx context.Context,
	input *provider.DataSourceGetTypeInput,
) (*provider.DataSourceGetTypeOutput, error)

func (*VPCDataSource) GetTypeDescription 

func (d *VPCDataSource) GetTypeDescription(
	ctx context.Context,
	input *provider.DataSourceGetTypeDescriptionInput,
) (*provider.DataSourceGetTypeDescriptionOutput, error)

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.