deploytest

package
v3.40.0-alpha.1662104122 Latest Latest
Warning

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

 Go to latest Published: Sep 2, 2022 License: Apache-2.0 Imports: 18 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var UseGrpcPluginsByDefault = false

Functions

func NewLanguageRuntime 

func NewLanguageRuntime(program ProgramFunc, requiredPlugins ...workspace.PluginSpec) plugin.LanguageRuntime

func NewPluginHost 

func NewPluginHost(sink, statusSink diag.Sink, languageRuntime plugin.LanguageRuntime,
	pluginLoaders ...*ProviderLoader) plugin.Host

func WithGrpc 

func WithGrpc(p *PluginLoader)

func WithPath added in v3.35.0 

func WithPath(path string) func(p *PluginLoader)

func WithoutGrpc 

func WithoutGrpc(p *PluginLoader)

Types

type Analyzer added in v3.22.0 

type Analyzer struct {
	Info plugin.AnalyzerInfo

	AnalyzeF      func(r plugin.AnalyzerResource) ([]plugin.AnalyzeDiagnostic, error)
	AnalyzeStackF func(resources []plugin.AnalyzerStackResource) ([]plugin.AnalyzeDiagnostic, error)

	ConfigureF func(policyConfig map[string]plugin.AnalyzerPolicyConfig) error
}

func (*Analyzer) Analyze added in v3.22.0 

func (a *Analyzer) Analyze(r plugin.AnalyzerResource) ([]plugin.AnalyzeDiagnostic, error)

func (*Analyzer) AnalyzeStack added in v3.22.0 

func (a *Analyzer) AnalyzeStack(resources []plugin.AnalyzerStackResource) ([]plugin.AnalyzeDiagnostic, error)

func (*Analyzer) Close added in v3.22.0 

func (a *Analyzer) Close() error

func (*Analyzer) Configure added in v3.22.0 

func (a *Analyzer) Configure(policyConfig map[string]plugin.AnalyzerPolicyConfig) error

func (*Analyzer) GetAnalyzerInfo added in v3.22.0 

func (a *Analyzer) GetAnalyzerInfo() (plugin.AnalyzerInfo, error)

func (*Analyzer) GetPluginInfo added in v3.22.0 

func (a *Analyzer) GetPluginInfo() (workspace.PluginInfo, error)

func (*Analyzer) Name added in v3.22.0 

func (a *Analyzer) Name() tokens.QName

type BackendClient 

type BackendClient struct {
	GetStackOutputsF         func(ctx context.Context, name string) (resource.PropertyMap, error)
	GetStackResourceOutputsF func(ctx context.Context, name string) (resource.PropertyMap, error)
}

BackendClient provides a simple implementation of deploy.BackendClient that defers to a function value.

func (*BackendClient) GetStackOutputs 

func (b *BackendClient) GetStackOutputs(ctx context.Context, name string) (resource.PropertyMap, error)

GetStackOutputs returns the outputs (if any) for the named stack or an error if the stack cannot be found.

func (*BackendClient) GetStackResourceOutputs 

func (b *BackendClient) GetStackResourceOutputs(
	ctx context.Context, name string) (resource.PropertyMap, error)

GetStackResourceOutputs returns the resource outputs for a stack, or an error if the stack cannot be found. Resources are retrieved from the latest stack snapshot, which may include ongoing updates. They are returned in a `PropertyMap` mapping resource URN to another `Propertymap` with members `type` (containing the Pulumi type ID for the resource) and `outputs` (containing the resource outputs themselves).

type LoadAnalyzerFunc added in v3.22.0 

type LoadAnalyzerFunc func(opts *plugin.PolicyAnalyzerOptions) (plugin.Analyzer, error)

type LoadAnalyzerWithHostFunc added in v3.22.0 

type LoadAnalyzerWithHostFunc func(opts *plugin.PolicyAnalyzerOptions, host plugin.Host) (plugin.Analyzer, error)

type LoadPluginFunc added in v3.22.0 

type LoadPluginFunc func(opts interface{}) (interface{}, error)

type LoadPluginWithHostFunc added in v3.22.0 

type LoadPluginWithHostFunc func(opts interface{}, host plugin.Host) (interface{}, error)

type LoadProviderFunc 

type LoadProviderFunc func() (plugin.Provider, error)

type LoadProviderWithHostFunc 

type LoadProviderWithHostFunc func(host plugin.Host) (plugin.Provider, error)

type PluginLoader added in v3.22.0 

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

func NewAnalyzerLoader added in v3.22.0 

func NewAnalyzerLoader(name string, load LoadAnalyzerFunc, opts ...PluginOption) *PluginLoader

func NewAnalyzerLoaderWithHost added in v3.22.0 

func NewAnalyzerLoaderWithHost(name string, load LoadAnalyzerWithHostFunc, opts ...PluginOption) *PluginLoader

type PluginOption added in v3.22.0 

type PluginOption func(p *PluginLoader)

type ProgramFunc 

type ProgramFunc func(runInfo plugin.RunInfo, monitor *ResourceMonitor) error

type Provider 

type Provider struct {
	Name    string
	Package tokens.Package
	Version semver.Version

	Config resource.PropertyMap

	GetSchemaF func(version int) ([]byte, error)

	CheckConfigF func(urn resource.URN, olds,
		news resource.PropertyMap, allowUnknowns bool) (resource.PropertyMap, []plugin.CheckFailure, error)
	DiffConfigF func(urn resource.URN, olds, news resource.PropertyMap,
		ignoreChanges []string) (plugin.DiffResult, error)
	ConfigureF func(news resource.PropertyMap) error

	CheckF func(urn resource.URN,
		olds, news resource.PropertyMap, randomSeed []byte) (resource.PropertyMap, []plugin.CheckFailure, error)
	DiffF func(urn resource.URN, id resource.ID, olds, news resource.PropertyMap,
		ignoreChanges []string) (plugin.DiffResult, error)
	CreateF func(urn resource.URN, inputs resource.PropertyMap, timeout float64,
		preview bool) (resource.ID, resource.PropertyMap, resource.Status, error)
	UpdateF func(urn resource.URN, id resource.ID, olds, news resource.PropertyMap, timeout float64,
		ignoreChanges []string, preview bool) (resource.PropertyMap, resource.Status, error)
	DeleteF func(urn resource.URN, id resource.ID, olds resource.PropertyMap, timeout float64) (resource.Status, error)
	ReadF   func(urn resource.URN, id resource.ID,
		inputs, state resource.PropertyMap) (plugin.ReadResult, resource.Status, error)

	ConstructF func(monitor *ResourceMonitor, typ, name string, parent resource.URN, inputs resource.PropertyMap,
		options plugin.ConstructOptions) (plugin.ConstructResult, error)

	InvokeF func(tok tokens.ModuleMember,
		inputs resource.PropertyMap) (resource.PropertyMap, []plugin.CheckFailure, error)

	CallF func(monitor *ResourceMonitor, tok tokens.ModuleMember, args resource.PropertyMap, info plugin.CallInfo,
		options plugin.CallOptions) (plugin.CallResult, error)

	CancelF func() error
	// contains filtered or unexported fields
}

func (*Provider) Call added in v3.6.0 

func (prov *Provider) Call(tok tokens.ModuleMember, args resource.PropertyMap, info plugin.CallInfo,
	options plugin.CallOptions) (plugin.CallResult, error)

func (*Provider) Check 

func (prov *Provider) Check(urn resource.URN,
	olds, news resource.PropertyMap, _ bool, randomSeed []byte) (resource.PropertyMap, []plugin.CheckFailure, error)

func (*Provider) CheckConfig 

func (prov *Provider) CheckConfig(urn resource.URN, olds,
	news resource.PropertyMap, allowUnknowns bool) (resource.PropertyMap, []plugin.CheckFailure, error)

func (*Provider) Close 

func (prov *Provider) Close() error

func (*Provider) Configure 

func (prov *Provider) Configure(inputs resource.PropertyMap) error

func (*Provider) Construct 

func (prov *Provider) Construct(info plugin.ConstructInfo, typ tokens.Type, name tokens.QName, parent resource.URN,
	inputs resource.PropertyMap, options plugin.ConstructOptions) (plugin.ConstructResult, error)

func (*Provider) Create 

func (prov *Provider) Create(urn resource.URN, props resource.PropertyMap, timeout float64,
	preview bool) (resource.ID, resource.PropertyMap, resource.Status, error)

func (*Provider) Delete 

func (prov *Provider) Delete(urn resource.URN,
	id resource.ID, props resource.PropertyMap, timeout float64) (resource.Status, error)

func (*Provider) Diff 

func (prov *Provider) Diff(urn resource.URN, id resource.ID,
	olds resource.PropertyMap, news resource.PropertyMap, _ bool, ignoreChanges []string) (plugin.DiffResult, error)

func (*Provider) DiffConfig 

func (prov *Provider) DiffConfig(urn resource.URN, olds, news resource.PropertyMap, _ bool,
	ignoreChanges []string) (plugin.DiffResult, error)

func (*Provider) GetPluginInfo 

func (prov *Provider) GetPluginInfo() (workspace.PluginInfo, error)

func (*Provider) GetSchema 

func (prov *Provider) GetSchema(version int) ([]byte, error)

func (*Provider) Invoke 

func (prov *Provider) Invoke(tok tokens.ModuleMember,
	args resource.PropertyMap) (resource.PropertyMap, []plugin.CheckFailure, error)

func (*Provider) Pkg 

func (prov *Provider) Pkg() tokens.Package

func (*Provider) Read 

func (prov *Provider) Read(urn resource.URN, id resource.ID,
	inputs, state resource.PropertyMap) (plugin.ReadResult, resource.Status, error)

func (*Provider) SignalCancellation 

func (prov *Provider) SignalCancellation() error

func (*Provider) StreamInvoke 

func (prov *Provider) StreamInvoke(
	tok tokens.ModuleMember, args resource.PropertyMap,
	onNext func(resource.PropertyMap) error) ([]plugin.CheckFailure, error)

func (*Provider) Update 

func (prov *Provider) Update(urn resource.URN, id resource.ID, olds resource.PropertyMap, news resource.PropertyMap,
	timeout float64, ignoreChanges []string, preview bool) (resource.PropertyMap, resource.Status, error)

type ProviderLoader 

type ProviderLoader = PluginLoader

func NewProviderLoader 

func NewProviderLoader(pkg tokens.Package, version semver.Version, load LoadProviderFunc,
	opts ...ProviderOption) *ProviderLoader

func NewProviderLoaderWithHost 

func NewProviderLoaderWithHost(pkg tokens.Package, version semver.Version,
	load LoadProviderWithHostFunc, opts ...ProviderOption) *ProviderLoader

type ProviderOption 

type ProviderOption = PluginOption

type ResourceMonitor 

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

func NewResourceMonitor 

func NewResourceMonitor(resmon pulumirpc.ResourceMonitorClient) *ResourceMonitor

func (*ResourceMonitor) Call added in v3.7.0 

func (rm *ResourceMonitor) Call(tok tokens.ModuleMember, inputs resource.PropertyMap,
	provider string, version string) (resource.PropertyMap, map[resource.PropertyKey][]resource.URN,
	[]*pulumirpc.CheckFailure, error)

func (*ResourceMonitor) Close 

func (rm *ResourceMonitor) Close() error

func (*ResourceMonitor) Invoke 

func (rm *ResourceMonitor) Invoke(tok tokens.ModuleMember, inputs resource.PropertyMap,
	provider string, version string) (resource.PropertyMap, []*pulumirpc.CheckFailure, error)

func (*ResourceMonitor) ReadResource 

func (rm *ResourceMonitor) ReadResource(t tokens.Type, name string, id resource.ID, parent resource.URN,
	inputs resource.PropertyMap, provider string, version string) (resource.URN, resource.PropertyMap, error)

func (*ResourceMonitor) RegisterResource 

func (rm *ResourceMonitor) RegisterResource(t tokens.Type, name string, custom bool,
	options ...ResourceOptions) (resource.URN, resource.ID, resource.PropertyMap, error)

func (*ResourceMonitor) RegisterResourceOutputs 

func (rm *ResourceMonitor) RegisterResourceOutputs(urn resource.URN, outputs resource.PropertyMap) error

type ResourceOptions 

type ResourceOptions struct {
	Parent                  resource.URN
	Protect                 bool
	Dependencies            []resource.URN
	Provider                string
	Inputs                  resource.PropertyMap
	PropertyDeps            map[resource.PropertyKey][]resource.URN
	DeleteBeforeReplace     *bool
	Version                 string
	PluginDownloadURL       string
	IgnoreChanges           []string
	ReplaceOnChanges        []string
	Aliases                 []resource.URN
	ImportID                resource.ID
	CustomTimeouts          *resource.CustomTimeouts
	RetainOnDelete          bool
	SupportsPartialValues   *bool
	Remote                  bool
	Providers               map[string]string
	AdditionalSecretOutputs []resource.PropertyKey

	DisableSecrets            bool
	DisableResourceReferences bool
}

Source Files

View all Source files

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.