mskconnect

package
v4.38.1 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CustomPlugin 

type CustomPlugin struct {
	pulumi.CustomResourceState

	// the Amazon Resource Name (ARN) of the custom plugin.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// The type of the plugin file. Allowed values are `ZIP` and `JAR`.
	ContentType pulumi.StringOutput `pulumi:"contentType"`
	// A summary description of the custom plugin.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// an ID of the latest successfully created revision of the custom plugin.
	LatestRevision pulumi.IntOutput `pulumi:"latestRevision"`
	// Information about the location of a custom plugin. See below.
	Location CustomPluginLocationOutput `pulumi:"location"`
	// The name of the custom plugin..
	Name pulumi.StringOutput `pulumi:"name"`
	// the state of the custom plugin.
	State pulumi.StringOutput `pulumi:"state"`
}

Provides an Amazon MSK Connect Custom Plugin Resource.

## Example Usage ### Basic configuration

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/mskconnect"
"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/s3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleBucket, err := s3.NewBucket(ctx, "exampleBucket", nil)
		if err != nil {
			return err
		}
		exampleBucketObject, err := s3.NewBucketObject(ctx, "exampleBucketObject", &s3.BucketObjectArgs{
			Bucket: exampleBucket.ID(),
			Key:    pulumi.String("debezium.zip"),
			Source: pulumi.NewFileAsset("debezium.zip"),
		})
		if err != nil {
			return err
		}
		_, err = mskconnect.NewCustomPlugin(ctx, "exampleCustomPlugin", &mskconnect.CustomPluginArgs{
			ContentType: pulumi.String("ZIP"),
			Location: &mskconnect.CustomPluginLocationArgs{
				S3: &mskconnect.CustomPluginLocationS3Args{
					BucketArn: exampleBucket.Arn,
					FileKey:   exampleBucketObject.Key,
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

MSK Connect Custom Plugin can be imported using the plugin's `arn`, e.g.,

```sh 

$ pulumi import aws:mskconnect/customPlugin:CustomPlugin example 'arn:aws:kafkaconnect:eu-central-1:123456789012:custom-plugin/debezium-example/abcdefgh-1234-5678-9abc-defghijklmno-4'

```

func GetCustomPlugin 

func GetCustomPlugin(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *CustomPluginState, opts ...pulumi.ResourceOption) (*CustomPlugin, error)

GetCustomPlugin gets an existing CustomPlugin resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewCustomPlugin 

func NewCustomPlugin(ctx *pulumi.Context,
	name string, args *CustomPluginArgs, opts ...pulumi.ResourceOption) (*CustomPlugin, error)

NewCustomPlugin registers a new resource with the given unique name, arguments, and options.

func (*CustomPlugin) ElementType 

func (*CustomPlugin) ElementType() reflect.Type

func (*CustomPlugin) ToCustomPluginOutput 

func (i *CustomPlugin) ToCustomPluginOutput() CustomPluginOutput

func (*CustomPlugin) ToCustomPluginOutputWithContext 

func (i *CustomPlugin) ToCustomPluginOutputWithContext(ctx context.Context) CustomPluginOutput

type CustomPluginArgs 

type CustomPluginArgs struct {
	// The type of the plugin file. Allowed values are `ZIP` and `JAR`.
	ContentType pulumi.StringInput
	// A summary description of the custom plugin.
	Description pulumi.StringPtrInput
	// Information about the location of a custom plugin. See below.
	Location CustomPluginLocationInput
	// The name of the custom plugin..
	Name pulumi.StringPtrInput
}

The set of arguments for constructing a CustomPlugin resource.

func (CustomPluginArgs) ElementType 

func (CustomPluginArgs) ElementType() reflect.Type

type CustomPluginArray 

type CustomPluginArray []CustomPluginInput

func (CustomPluginArray) ElementType 

func (CustomPluginArray) ElementType() reflect.Type

func (CustomPluginArray) ToCustomPluginArrayOutput 

func (i CustomPluginArray) ToCustomPluginArrayOutput() CustomPluginArrayOutput

func (CustomPluginArray) ToCustomPluginArrayOutputWithContext 

func (i CustomPluginArray) ToCustomPluginArrayOutputWithContext(ctx context.Context) CustomPluginArrayOutput

type CustomPluginArrayInput 

type CustomPluginArrayInput interface {
	pulumi.Input

	ToCustomPluginArrayOutput() CustomPluginArrayOutput
	ToCustomPluginArrayOutputWithContext(context.Context) CustomPluginArrayOutput
}

CustomPluginArrayInput is an input type that accepts CustomPluginArray and CustomPluginArrayOutput values. You can construct a concrete instance of `CustomPluginArrayInput` via: 

CustomPluginArray{ CustomPluginArgs{...} }

type CustomPluginArrayOutput 

type CustomPluginArrayOutput struct{ *pulumi.OutputState }

func (CustomPluginArrayOutput) ElementType 

func (CustomPluginArrayOutput) ElementType() reflect.Type

func (CustomPluginArrayOutput) Index 

func (o CustomPluginArrayOutput) Index(i pulumi.IntInput) CustomPluginOutput

func (CustomPluginArrayOutput) ToCustomPluginArrayOutput 

func (o CustomPluginArrayOutput) ToCustomPluginArrayOutput() CustomPluginArrayOutput

func (CustomPluginArrayOutput) ToCustomPluginArrayOutputWithContext 

func (o CustomPluginArrayOutput) ToCustomPluginArrayOutputWithContext(ctx context.Context) CustomPluginArrayOutput

type CustomPluginInput 

type CustomPluginInput interface {
	pulumi.Input

	ToCustomPluginOutput() CustomPluginOutput
	ToCustomPluginOutputWithContext(ctx context.Context) CustomPluginOutput
}

type CustomPluginLocation 

type CustomPluginLocation struct {
	// Information of the plugin file stored in Amazon S3. See below.
	S3 CustomPluginLocationS3 `pulumi:"s3"`
}

type CustomPluginLocationArgs 

type CustomPluginLocationArgs struct {
	// Information of the plugin file stored in Amazon S3. See below.
	S3 CustomPluginLocationS3Input `pulumi:"s3"`
}

func (CustomPluginLocationArgs) ElementType 

func (CustomPluginLocationArgs) ElementType() reflect.Type

func (CustomPluginLocationArgs) ToCustomPluginLocationOutput 

func (i CustomPluginLocationArgs) ToCustomPluginLocationOutput() CustomPluginLocationOutput

func (CustomPluginLocationArgs) ToCustomPluginLocationOutputWithContext 

func (i CustomPluginLocationArgs) ToCustomPluginLocationOutputWithContext(ctx context.Context) CustomPluginLocationOutput

func (CustomPluginLocationArgs) ToCustomPluginLocationPtrOutput 

func (i CustomPluginLocationArgs) ToCustomPluginLocationPtrOutput() CustomPluginLocationPtrOutput

func (CustomPluginLocationArgs) ToCustomPluginLocationPtrOutputWithContext 

func (i CustomPluginLocationArgs) ToCustomPluginLocationPtrOutputWithContext(ctx context.Context) CustomPluginLocationPtrOutput

type CustomPluginLocationInput 

type CustomPluginLocationInput interface {
	pulumi.Input

	ToCustomPluginLocationOutput() CustomPluginLocationOutput
	ToCustomPluginLocationOutputWithContext(context.Context) CustomPluginLocationOutput
}

CustomPluginLocationInput is an input type that accepts CustomPluginLocationArgs and CustomPluginLocationOutput values. You can construct a concrete instance of `CustomPluginLocationInput` via: 

CustomPluginLocationArgs{...}

type CustomPluginLocationOutput 

type CustomPluginLocationOutput struct{ *pulumi.OutputState }

func (CustomPluginLocationOutput) ElementType 

func (CustomPluginLocationOutput) ElementType() reflect.Type

func (CustomPluginLocationOutput) S3 

func (o CustomPluginLocationOutput) S3() CustomPluginLocationS3Output

Information of the plugin file stored in Amazon S3. See below.

func (CustomPluginLocationOutput) ToCustomPluginLocationOutput 

func (o CustomPluginLocationOutput) ToCustomPluginLocationOutput() CustomPluginLocationOutput

func (CustomPluginLocationOutput) ToCustomPluginLocationOutputWithContext 

func (o CustomPluginLocationOutput) ToCustomPluginLocationOutputWithContext(ctx context.Context) CustomPluginLocationOutput

func (CustomPluginLocationOutput) ToCustomPluginLocationPtrOutput 

func (o CustomPluginLocationOutput) ToCustomPluginLocationPtrOutput() CustomPluginLocationPtrOutput

func (CustomPluginLocationOutput) ToCustomPluginLocationPtrOutputWithContext 

func (o CustomPluginLocationOutput) ToCustomPluginLocationPtrOutputWithContext(ctx context.Context) CustomPluginLocationPtrOutput

type CustomPluginLocationPtrInput 

type CustomPluginLocationPtrInput interface {
	pulumi.Input

	ToCustomPluginLocationPtrOutput() CustomPluginLocationPtrOutput
	ToCustomPluginLocationPtrOutputWithContext(context.Context) CustomPluginLocationPtrOutput
}

CustomPluginLocationPtrInput is an input type that accepts CustomPluginLocationArgs, CustomPluginLocationPtr and CustomPluginLocationPtrOutput values. You can construct a concrete instance of `CustomPluginLocationPtrInput` via: 

        CustomPluginLocationArgs{...}

or:

        nil

func CustomPluginLocationPtr 

func CustomPluginLocationPtr(v *CustomPluginLocationArgs) CustomPluginLocationPtrInput

type CustomPluginLocationPtrOutput 

type CustomPluginLocationPtrOutput struct{ *pulumi.OutputState }

func (CustomPluginLocationPtrOutput) Elem 

func (o CustomPluginLocationPtrOutput) Elem() CustomPluginLocationOutput

func (CustomPluginLocationPtrOutput) ElementType 

func (CustomPluginLocationPtrOutput) ElementType() reflect.Type

func (CustomPluginLocationPtrOutput) S3 

func (o CustomPluginLocationPtrOutput) S3() CustomPluginLocationS3PtrOutput

Information of the plugin file stored in Amazon S3. See below.

func (CustomPluginLocationPtrOutput) ToCustomPluginLocationPtrOutput 

func (o CustomPluginLocationPtrOutput) ToCustomPluginLocationPtrOutput() CustomPluginLocationPtrOutput

func (CustomPluginLocationPtrOutput) ToCustomPluginLocationPtrOutputWithContext 

func (o CustomPluginLocationPtrOutput) ToCustomPluginLocationPtrOutputWithContext(ctx context.Context) CustomPluginLocationPtrOutput

type CustomPluginLocationS3 

type CustomPluginLocationS3 struct {
	// The Amazon Resource Name (ARN) of an S3 bucket.
	BucketArn string `pulumi:"bucketArn"`
	// The file key for an object in an S3 bucket.
	FileKey string `pulumi:"fileKey"`
	// The version of an object in an S3 bucket.
	ObjectVersion *string `pulumi:"objectVersion"`
}

type CustomPluginLocationS3Args 

type CustomPluginLocationS3Args struct {
	// The Amazon Resource Name (ARN) of an S3 bucket.
	BucketArn pulumi.StringInput `pulumi:"bucketArn"`
	// The file key for an object in an S3 bucket.
	FileKey pulumi.StringInput `pulumi:"fileKey"`
	// The version of an object in an S3 bucket.
	ObjectVersion pulumi.StringPtrInput `pulumi:"objectVersion"`
}

func (CustomPluginLocationS3Args) ElementType 

func (CustomPluginLocationS3Args) ElementType() reflect.Type

func (CustomPluginLocationS3Args) ToCustomPluginLocationS3Output 

func (i CustomPluginLocationS3Args) ToCustomPluginLocationS3Output() CustomPluginLocationS3Output

func (CustomPluginLocationS3Args) ToCustomPluginLocationS3OutputWithContext 

func (i CustomPluginLocationS3Args) ToCustomPluginLocationS3OutputWithContext(ctx context.Context) CustomPluginLocationS3Output

func (CustomPluginLocationS3Args) ToCustomPluginLocationS3PtrOutput 

func (i CustomPluginLocationS3Args) ToCustomPluginLocationS3PtrOutput() CustomPluginLocationS3PtrOutput

func (CustomPluginLocationS3Args) ToCustomPluginLocationS3PtrOutputWithContext 

func (i CustomPluginLocationS3Args) ToCustomPluginLocationS3PtrOutputWithContext(ctx context.Context) CustomPluginLocationS3PtrOutput

type CustomPluginLocationS3Input 

type CustomPluginLocationS3Input interface {
	pulumi.Input

	ToCustomPluginLocationS3Output() CustomPluginLocationS3Output
	ToCustomPluginLocationS3OutputWithContext(context.Context) CustomPluginLocationS3Output
}

CustomPluginLocationS3Input is an input type that accepts CustomPluginLocationS3Args and CustomPluginLocationS3Output values. You can construct a concrete instance of `CustomPluginLocationS3Input` via: 

CustomPluginLocationS3Args{...}

type CustomPluginLocationS3Output 

type CustomPluginLocationS3Output struct{ *pulumi.OutputState }

func (CustomPluginLocationS3Output) BucketArn 

func (o CustomPluginLocationS3Output) BucketArn() pulumi.StringOutput

The Amazon Resource Name (ARN) of an S3 bucket.

func (CustomPluginLocationS3Output) ElementType 

func (CustomPluginLocationS3Output) ElementType() reflect.Type

func (CustomPluginLocationS3Output) FileKey 

func (o CustomPluginLocationS3Output) FileKey() pulumi.StringOutput

The file key for an object in an S3 bucket.

func (CustomPluginLocationS3Output) ObjectVersion 

func (o CustomPluginLocationS3Output) ObjectVersion() pulumi.StringPtrOutput

The version of an object in an S3 bucket.

func (CustomPluginLocationS3Output) ToCustomPluginLocationS3Output 

func (o CustomPluginLocationS3Output) ToCustomPluginLocationS3Output() CustomPluginLocationS3Output

func (CustomPluginLocationS3Output) ToCustomPluginLocationS3OutputWithContext 

func (o CustomPluginLocationS3Output) ToCustomPluginLocationS3OutputWithContext(ctx context.Context) CustomPluginLocationS3Output

func (CustomPluginLocationS3Output) ToCustomPluginLocationS3PtrOutput 

func (o CustomPluginLocationS3Output) ToCustomPluginLocationS3PtrOutput() CustomPluginLocationS3PtrOutput

func (CustomPluginLocationS3Output) ToCustomPluginLocationS3PtrOutputWithContext 

func (o CustomPluginLocationS3Output) ToCustomPluginLocationS3PtrOutputWithContext(ctx context.Context) CustomPluginLocationS3PtrOutput

type CustomPluginLocationS3PtrInput 

type CustomPluginLocationS3PtrInput interface {
	pulumi.Input

	ToCustomPluginLocationS3PtrOutput() CustomPluginLocationS3PtrOutput
	ToCustomPluginLocationS3PtrOutputWithContext(context.Context) CustomPluginLocationS3PtrOutput
}

CustomPluginLocationS3PtrInput is an input type that accepts CustomPluginLocationS3Args, CustomPluginLocationS3Ptr and CustomPluginLocationS3PtrOutput values. You can construct a concrete instance of `CustomPluginLocationS3PtrInput` via: 

        CustomPluginLocationS3Args{...}

or:

        nil

func CustomPluginLocationS3Ptr 

func CustomPluginLocationS3Ptr(v *CustomPluginLocationS3Args) CustomPluginLocationS3PtrInput

type CustomPluginLocationS3PtrOutput 

type CustomPluginLocationS3PtrOutput struct{ *pulumi.OutputState }

func (CustomPluginLocationS3PtrOutput) BucketArn 

func (o CustomPluginLocationS3PtrOutput) BucketArn() pulumi.StringPtrOutput

The Amazon Resource Name (ARN) of an S3 bucket.

func (CustomPluginLocationS3PtrOutput) Elem 

func (o CustomPluginLocationS3PtrOutput) Elem() CustomPluginLocationS3Output

func (CustomPluginLocationS3PtrOutput) ElementType 

func (CustomPluginLocationS3PtrOutput) ElementType() reflect.Type

func (CustomPluginLocationS3PtrOutput) FileKey 

func (o CustomPluginLocationS3PtrOutput) FileKey() pulumi.StringPtrOutput

The file key for an object in an S3 bucket.

func (CustomPluginLocationS3PtrOutput) ObjectVersion 

func (o CustomPluginLocationS3PtrOutput) ObjectVersion() pulumi.StringPtrOutput

The version of an object in an S3 bucket.

func (CustomPluginLocationS3PtrOutput) ToCustomPluginLocationS3PtrOutput 

func (o CustomPluginLocationS3PtrOutput) ToCustomPluginLocationS3PtrOutput() CustomPluginLocationS3PtrOutput

func (CustomPluginLocationS3PtrOutput) ToCustomPluginLocationS3PtrOutputWithContext 

func (o CustomPluginLocationS3PtrOutput) ToCustomPluginLocationS3PtrOutputWithContext(ctx context.Context) CustomPluginLocationS3PtrOutput

type CustomPluginMap 

type CustomPluginMap map[string]CustomPluginInput

func (CustomPluginMap) ElementType 

func (CustomPluginMap) ElementType() reflect.Type

func (CustomPluginMap) ToCustomPluginMapOutput 

func (i CustomPluginMap) ToCustomPluginMapOutput() CustomPluginMapOutput

func (CustomPluginMap) ToCustomPluginMapOutputWithContext 

func (i CustomPluginMap) ToCustomPluginMapOutputWithContext(ctx context.Context) CustomPluginMapOutput

type CustomPluginMapInput 

type CustomPluginMapInput interface {
	pulumi.Input

	ToCustomPluginMapOutput() CustomPluginMapOutput
	ToCustomPluginMapOutputWithContext(context.Context) CustomPluginMapOutput
}

CustomPluginMapInput is an input type that accepts CustomPluginMap and CustomPluginMapOutput values. You can construct a concrete instance of `CustomPluginMapInput` via: 

CustomPluginMap{ "key": CustomPluginArgs{...} }

type CustomPluginMapOutput 

type CustomPluginMapOutput struct{ *pulumi.OutputState }

func (CustomPluginMapOutput) ElementType 

func (CustomPluginMapOutput) ElementType() reflect.Type

func (CustomPluginMapOutput) MapIndex 

func (o CustomPluginMapOutput) MapIndex(k pulumi.StringInput) CustomPluginOutput

func (CustomPluginMapOutput) ToCustomPluginMapOutput 

func (o CustomPluginMapOutput) ToCustomPluginMapOutput() CustomPluginMapOutput

func (CustomPluginMapOutput) ToCustomPluginMapOutputWithContext 

func (o CustomPluginMapOutput) ToCustomPluginMapOutputWithContext(ctx context.Context) CustomPluginMapOutput

type CustomPluginOutput 

type CustomPluginOutput struct{ *pulumi.OutputState }

func (CustomPluginOutput) ElementType 

func (CustomPluginOutput) ElementType() reflect.Type

func (CustomPluginOutput) ToCustomPluginOutput 

func (o CustomPluginOutput) ToCustomPluginOutput() CustomPluginOutput

func (CustomPluginOutput) ToCustomPluginOutputWithContext 

func (o CustomPluginOutput) ToCustomPluginOutputWithContext(ctx context.Context) CustomPluginOutput

type CustomPluginState 

type CustomPluginState struct {
	// the Amazon Resource Name (ARN) of the custom plugin.
	Arn pulumi.StringPtrInput
	// The type of the plugin file. Allowed values are `ZIP` and `JAR`.
	ContentType pulumi.StringPtrInput
	// A summary description of the custom plugin.
	Description pulumi.StringPtrInput
	// an ID of the latest successfully created revision of the custom plugin.
	LatestRevision pulumi.IntPtrInput
	// Information about the location of a custom plugin. See below.
	Location CustomPluginLocationPtrInput
	// The name of the custom plugin..
	Name pulumi.StringPtrInput
	// the state of the custom plugin.
	State pulumi.StringPtrInput
}

func (CustomPluginState) ElementType 

func (CustomPluginState) ElementType() reflect.Type

type LookupCustomPluginArgs 

type LookupCustomPluginArgs struct {
	// Name of the custom plugin.
	Name string `pulumi:"name"`
}

A collection of arguments for invoking getCustomPlugin.

type LookupCustomPluginOutputArgs 

type LookupCustomPluginOutputArgs struct {
	// Name of the custom plugin.
	Name pulumi.StringInput `pulumi:"name"`
}

A collection of arguments for invoking getCustomPlugin.

func (LookupCustomPluginOutputArgs) ElementType 

func (LookupCustomPluginOutputArgs) ElementType() reflect.Type

type LookupCustomPluginResult 

type LookupCustomPluginResult struct {
	// the Amazon Resource Name (ARN) of the custom plugin.
	Arn string `pulumi:"arn"`
	// a summary description of the custom plugin.
	Description string `pulumi:"description"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// an ID of the latest successfully created revision of the custom plugin.
	LatestRevision int    `pulumi:"latestRevision"`
	Name           string `pulumi:"name"`
	// the state of the custom plugin.
	State string `pulumi:"state"`
}

A collection of values returned by getCustomPlugin.

func LookupCustomPlugin 

func LookupCustomPlugin(ctx *pulumi.Context, args *LookupCustomPluginArgs, opts ...pulumi.InvokeOption) (*LookupCustomPluginResult, error)

Get information on an Amazon MSK Connect custom plugin.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/mskconnect"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mskconnect.LookupCustomPlugin(ctx, &mskconnect.LookupCustomPluginArgs{
			Name: "example-debezium-1",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupCustomPluginResultOutput 

type LookupCustomPluginResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getCustomPlugin.

func LookupCustomPluginOutput 

func LookupCustomPluginOutput(ctx *pulumi.Context, args LookupCustomPluginOutputArgs, opts ...pulumi.InvokeOption) LookupCustomPluginResultOutput

func (LookupCustomPluginResultOutput) Arn 

func (o LookupCustomPluginResultOutput) Arn() pulumi.StringOutput

the Amazon Resource Name (ARN) of the custom plugin.

func (LookupCustomPluginResultOutput) Description 

func (o LookupCustomPluginResultOutput) Description() pulumi.StringOutput

a summary description of the custom plugin.

func (LookupCustomPluginResultOutput) ElementType 

func (LookupCustomPluginResultOutput) ElementType() reflect.Type

func (LookupCustomPluginResultOutput) Id 

func (o LookupCustomPluginResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupCustomPluginResultOutput) LatestRevision 

func (o LookupCustomPluginResultOutput) LatestRevision() pulumi.IntOutput

an ID of the latest successfully created revision of the custom plugin.

func (LookupCustomPluginResultOutput) Name 

func (o LookupCustomPluginResultOutput) Name() pulumi.StringOutput

func (LookupCustomPluginResultOutput) State 

func (o LookupCustomPluginResultOutput) State() pulumi.StringOutput

the state of the custom plugin.

func (LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutput 

func (o LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutput() LookupCustomPluginResultOutput

func (LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutputWithContext 

func (o LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutputWithContext(ctx context.Context) LookupCustomPluginResultOutput

type LookupWorkerConfigurationArgs 

type LookupWorkerConfigurationArgs struct {
	// Name of the worker configuration.
	Name string `pulumi:"name"`
}

A collection of arguments for invoking getWorkerConfiguration.

type LookupWorkerConfigurationOutputArgs 

type LookupWorkerConfigurationOutputArgs struct {
	// Name of the worker configuration.
	Name pulumi.StringInput `pulumi:"name"`
}

A collection of arguments for invoking getWorkerConfiguration.

func (LookupWorkerConfigurationOutputArgs) ElementType 

func (LookupWorkerConfigurationOutputArgs) ElementType() reflect.Type

type LookupWorkerConfigurationResult 

type LookupWorkerConfigurationResult struct {
	// the Amazon Resource Name (ARN) of the worker configuration.
	Arn string `pulumi:"arn"`
	// a summary description of the worker configuration.
	Description string `pulumi:"description"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// an ID of the latest successfully created revision of the worker configuration.
	LatestRevision int    `pulumi:"latestRevision"`
	Name           string `pulumi:"name"`
	// contents of connect-distributed.properties file.
	PropertiesFileContent string `pulumi:"propertiesFileContent"`
}

A collection of values returned by getWorkerConfiguration.

func LookupWorkerConfiguration 

func LookupWorkerConfiguration(ctx *pulumi.Context, args *LookupWorkerConfigurationArgs, opts ...pulumi.InvokeOption) (*LookupWorkerConfigurationResult, error)

Get information on an Amazon MSK Connect Worker Configuration.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/mskconnect"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mskconnect.LookupWorkerConfiguration(ctx, &mskconnect.LookupWorkerConfigurationArgs{
			Name: "example",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupWorkerConfigurationResultOutput 

type LookupWorkerConfigurationResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getWorkerConfiguration.

func LookupWorkerConfigurationOutput 

func LookupWorkerConfigurationOutput(ctx *pulumi.Context, args LookupWorkerConfigurationOutputArgs, opts ...pulumi.InvokeOption) LookupWorkerConfigurationResultOutput

func (LookupWorkerConfigurationResultOutput) Arn 

func (o LookupWorkerConfigurationResultOutput) Arn() pulumi.StringOutput

the Amazon Resource Name (ARN) of the worker configuration.

func (LookupWorkerConfigurationResultOutput) Description 

func (o LookupWorkerConfigurationResultOutput) Description() pulumi.StringOutput

a summary description of the worker configuration.

func (LookupWorkerConfigurationResultOutput) ElementType 

func (LookupWorkerConfigurationResultOutput) ElementType() reflect.Type

func (LookupWorkerConfigurationResultOutput) Id 

func (o LookupWorkerConfigurationResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupWorkerConfigurationResultOutput) LatestRevision 

func (o LookupWorkerConfigurationResultOutput) LatestRevision() pulumi.IntOutput

an ID of the latest successfully created revision of the worker configuration.

func (LookupWorkerConfigurationResultOutput) Name 

func (o LookupWorkerConfigurationResultOutput) Name() pulumi.StringOutput

func (LookupWorkerConfigurationResultOutput) PropertiesFileContent 

func (o LookupWorkerConfigurationResultOutput) PropertiesFileContent() pulumi.StringOutput

contents of connect-distributed.properties file.

func (LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutput 

func (o LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutput() LookupWorkerConfigurationResultOutput

func (LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutputWithContext 

func (o LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutputWithContext(ctx context.Context) LookupWorkerConfigurationResultOutput

type WorkerConfiguration 

type WorkerConfiguration struct {
	pulumi.CustomResourceState

	// the Amazon Resource Name (ARN) of the worker configuration.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// A summary description of the worker configuration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// an ID of the latest successfully created revision of the worker configuration.
	LatestRevision pulumi.IntOutput `pulumi:"latestRevision"`
	// The name of the worker configuration.
	Name pulumi.StringOutput `pulumi:"name"`
	// Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.
	PropertiesFileContent pulumi.StringOutput `pulumi:"propertiesFileContent"`
}

Provides an Amazon MSK Connect Worker Configuration Resource.

## Example Usage ### Basic configuration

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/mskconnect"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mskconnect.NewWorkerConfiguration(ctx, "example", &mskconnect.WorkerConfigurationArgs{
			PropertiesFileContent: pulumi.String(fmt.Sprintf("%v%v%v", "key.converter=org.apache.kafka.connect.storage.StringConverter\n", "value.converter=org.apache.kafka.connect.storage.StringConverter\n", "\n")),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

MSK Connect Worker Configuration can be imported using the plugin's `arn`, e.g.,

```sh 

$ pulumi import aws:mskconnect/workerConfiguration:WorkerConfiguration example 'arn:aws:kafkaconnect:eu-central-1:123456789012:worker-configuration/example/8848493b-7fcc-478c-a646-4a52634e3378-4'

```

func GetWorkerConfiguration 

func GetWorkerConfiguration(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *WorkerConfigurationState, opts ...pulumi.ResourceOption) (*WorkerConfiguration, error)

GetWorkerConfiguration gets an existing WorkerConfiguration resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewWorkerConfiguration 

func NewWorkerConfiguration(ctx *pulumi.Context,
	name string, args *WorkerConfigurationArgs, opts ...pulumi.ResourceOption) (*WorkerConfiguration, error)

NewWorkerConfiguration registers a new resource with the given unique name, arguments, and options.

func (*WorkerConfiguration) ElementType 

func (*WorkerConfiguration) ElementType() reflect.Type

func (*WorkerConfiguration) ToWorkerConfigurationOutput 

func (i *WorkerConfiguration) ToWorkerConfigurationOutput() WorkerConfigurationOutput

func (*WorkerConfiguration) ToWorkerConfigurationOutputWithContext 

func (i *WorkerConfiguration) ToWorkerConfigurationOutputWithContext(ctx context.Context) WorkerConfigurationOutput

type WorkerConfigurationArgs 

type WorkerConfigurationArgs struct {
	// A summary description of the worker configuration.
	Description pulumi.StringPtrInput
	// The name of the worker configuration.
	Name pulumi.StringPtrInput
	// Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.
	PropertiesFileContent pulumi.StringInput
}

The set of arguments for constructing a WorkerConfiguration resource.

func (WorkerConfigurationArgs) ElementType 

func (WorkerConfigurationArgs) ElementType() reflect.Type

type WorkerConfigurationArray 

type WorkerConfigurationArray []WorkerConfigurationInput

func (WorkerConfigurationArray) ElementType 

func (WorkerConfigurationArray) ElementType() reflect.Type

func (WorkerConfigurationArray) ToWorkerConfigurationArrayOutput 

func (i WorkerConfigurationArray) ToWorkerConfigurationArrayOutput() WorkerConfigurationArrayOutput

func (WorkerConfigurationArray) ToWorkerConfigurationArrayOutputWithContext 

func (i WorkerConfigurationArray) ToWorkerConfigurationArrayOutputWithContext(ctx context.Context) WorkerConfigurationArrayOutput

type WorkerConfigurationArrayInput 

type WorkerConfigurationArrayInput interface {
	pulumi.Input

	ToWorkerConfigurationArrayOutput() WorkerConfigurationArrayOutput
	ToWorkerConfigurationArrayOutputWithContext(context.Context) WorkerConfigurationArrayOutput
}

WorkerConfigurationArrayInput is an input type that accepts WorkerConfigurationArray and WorkerConfigurationArrayOutput values. You can construct a concrete instance of `WorkerConfigurationArrayInput` via: 

WorkerConfigurationArray{ WorkerConfigurationArgs{...} }

type WorkerConfigurationArrayOutput 

type WorkerConfigurationArrayOutput struct{ *pulumi.OutputState }

func (WorkerConfigurationArrayOutput) ElementType 

func (WorkerConfigurationArrayOutput) ElementType() reflect.Type

func (WorkerConfigurationArrayOutput) Index 

func (o WorkerConfigurationArrayOutput) Index(i pulumi.IntInput) WorkerConfigurationOutput

func (WorkerConfigurationArrayOutput) ToWorkerConfigurationArrayOutput 

func (o WorkerConfigurationArrayOutput) ToWorkerConfigurationArrayOutput() WorkerConfigurationArrayOutput

func (WorkerConfigurationArrayOutput) ToWorkerConfigurationArrayOutputWithContext 

func (o WorkerConfigurationArrayOutput) ToWorkerConfigurationArrayOutputWithContext(ctx context.Context) WorkerConfigurationArrayOutput

type WorkerConfigurationInput 

type WorkerConfigurationInput interface {
	pulumi.Input

	ToWorkerConfigurationOutput() WorkerConfigurationOutput
	ToWorkerConfigurationOutputWithContext(ctx context.Context) WorkerConfigurationOutput
}

type WorkerConfigurationMap 

type WorkerConfigurationMap map[string]WorkerConfigurationInput

func (WorkerConfigurationMap) ElementType 

func (WorkerConfigurationMap) ElementType() reflect.Type

func (WorkerConfigurationMap) ToWorkerConfigurationMapOutput 

func (i WorkerConfigurationMap) ToWorkerConfigurationMapOutput() WorkerConfigurationMapOutput

func (WorkerConfigurationMap) ToWorkerConfigurationMapOutputWithContext 

func (i WorkerConfigurationMap) ToWorkerConfigurationMapOutputWithContext(ctx context.Context) WorkerConfigurationMapOutput

type WorkerConfigurationMapInput 

type WorkerConfigurationMapInput interface {
	pulumi.Input

	ToWorkerConfigurationMapOutput() WorkerConfigurationMapOutput
	ToWorkerConfigurationMapOutputWithContext(context.Context) WorkerConfigurationMapOutput
}

WorkerConfigurationMapInput is an input type that accepts WorkerConfigurationMap and WorkerConfigurationMapOutput values. You can construct a concrete instance of `WorkerConfigurationMapInput` via: 

WorkerConfigurationMap{ "key": WorkerConfigurationArgs{...} }

type WorkerConfigurationMapOutput 

type WorkerConfigurationMapOutput struct{ *pulumi.OutputState }

func (WorkerConfigurationMapOutput) ElementType 

func (WorkerConfigurationMapOutput) ElementType() reflect.Type

func (WorkerConfigurationMapOutput) MapIndex 

func (o WorkerConfigurationMapOutput) MapIndex(k pulumi.StringInput) WorkerConfigurationOutput

func (WorkerConfigurationMapOutput) ToWorkerConfigurationMapOutput 

func (o WorkerConfigurationMapOutput) ToWorkerConfigurationMapOutput() WorkerConfigurationMapOutput

func (WorkerConfigurationMapOutput) ToWorkerConfigurationMapOutputWithContext 

func (o WorkerConfigurationMapOutput) ToWorkerConfigurationMapOutputWithContext(ctx context.Context) WorkerConfigurationMapOutput

type WorkerConfigurationOutput 

type WorkerConfigurationOutput struct{ *pulumi.OutputState }

func (WorkerConfigurationOutput) ElementType 

func (WorkerConfigurationOutput) ElementType() reflect.Type

func (WorkerConfigurationOutput) ToWorkerConfigurationOutput 

func (o WorkerConfigurationOutput) ToWorkerConfigurationOutput() WorkerConfigurationOutput

func (WorkerConfigurationOutput) ToWorkerConfigurationOutputWithContext 

func (o WorkerConfigurationOutput) ToWorkerConfigurationOutputWithContext(ctx context.Context) WorkerConfigurationOutput

type WorkerConfigurationState 

type WorkerConfigurationState struct {
	// the Amazon Resource Name (ARN) of the worker configuration.
	Arn pulumi.StringPtrInput
	// A summary description of the worker configuration.
	Description pulumi.StringPtrInput
	// an ID of the latest successfully created revision of the worker configuration.
	LatestRevision pulumi.IntPtrInput
	// The name of the worker configuration.
	Name pulumi.StringPtrInput
	// Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.
	PropertiesFileContent pulumi.StringPtrInput
}

func (WorkerConfigurationState) ElementType 

func (WorkerConfigurationState) ElementType() reflect.Type

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.