mskconnect

package
v4.36.0 Latest Latest
Warning

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

Go to latest
Published: Jan 24, 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

func (*CustomPlugin) ToCustomPluginPtrOutput

func (i *CustomPlugin) ToCustomPluginPtrOutput() CustomPluginPtrOutput

func (*CustomPlugin) ToCustomPluginPtrOutputWithContext

func (i *CustomPlugin) ToCustomPluginPtrOutputWithContext(ctx context.Context) CustomPluginPtrOutput

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 (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

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

type CustomPluginLocationPtrOutput

type CustomPluginLocationPtrOutput struct{ *pulumi.OutputState }

func (CustomPluginLocationPtrOutput) Elem

func (CustomPluginLocationPtrOutput) ElementType

func (CustomPluginLocationPtrOutput) S3

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

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

func (CustomPluginLocationS3Output) ElementType

func (CustomPluginLocationS3Output) FileKey

The file key for an object in an S3 bucket.

func (CustomPluginLocationS3Output) ObjectVersion

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

type CustomPluginLocationS3PtrOutput

type CustomPluginLocationS3PtrOutput struct{ *pulumi.OutputState }

func (CustomPluginLocationS3PtrOutput) BucketArn

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

func (CustomPluginLocationS3PtrOutput) Elem

func (CustomPluginLocationS3PtrOutput) ElementType

func (CustomPluginLocationS3PtrOutput) FileKey

The file key for an object in an S3 bucket.

func (CustomPluginLocationS3PtrOutput) ObjectVersion

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 (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

func (CustomPluginOutput) ToCustomPluginPtrOutput

func (o CustomPluginOutput) ToCustomPluginPtrOutput() CustomPluginPtrOutput

func (CustomPluginOutput) ToCustomPluginPtrOutputWithContext

func (o CustomPluginOutput) ToCustomPluginPtrOutputWithContext(ctx context.Context) CustomPluginPtrOutput

type CustomPluginPtrInput

type CustomPluginPtrInput interface {
	pulumi.Input

	ToCustomPluginPtrOutput() CustomPluginPtrOutput
	ToCustomPluginPtrOutputWithContext(ctx context.Context) CustomPluginPtrOutput
}

type CustomPluginPtrOutput

type CustomPluginPtrOutput struct{ *pulumi.OutputState }

func (CustomPluginPtrOutput) Elem

func (CustomPluginPtrOutput) ElementType

func (CustomPluginPtrOutput) ElementType() reflect.Type

func (CustomPluginPtrOutput) ToCustomPluginPtrOutput

func (o CustomPluginPtrOutput) ToCustomPluginPtrOutput() CustomPluginPtrOutput

func (CustomPluginPtrOutput) ToCustomPluginPtrOutputWithContext

func (o CustomPluginPtrOutput) ToCustomPluginPtrOutputWithContext(ctx context.Context) CustomPluginPtrOutput

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

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 (LookupCustomPluginResultOutput) Arn

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

func (LookupCustomPluginResultOutput) Description

a summary description of the custom plugin.

func (LookupCustomPluginResultOutput) ElementType

func (LookupCustomPluginResultOutput) Id

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 (LookupCustomPluginResultOutput) State

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

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 (LookupWorkerConfigurationResultOutput) Arn

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

func (LookupWorkerConfigurationResultOutput) Description

a summary description of the worker configuration.

func (LookupWorkerConfigurationResultOutput) ElementType

func (LookupWorkerConfigurationResultOutput) Id

The provider-assigned unique ID for this managed resource.

func (LookupWorkerConfigurationResultOutput) LatestRevision

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

func (LookupWorkerConfigurationResultOutput) Name

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

func (*WorkerConfiguration) ToWorkerConfigurationPtrOutput

func (i *WorkerConfiguration) ToWorkerConfigurationPtrOutput() WorkerConfigurationPtrOutput

func (*WorkerConfiguration) ToWorkerConfigurationPtrOutputWithContext

func (i *WorkerConfiguration) ToWorkerConfigurationPtrOutputWithContext(ctx context.Context) WorkerConfigurationPtrOutput

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

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

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

func (WorkerConfigurationOutput) ToWorkerConfigurationPtrOutput

func (o WorkerConfigurationOutput) ToWorkerConfigurationPtrOutput() WorkerConfigurationPtrOutput

func (WorkerConfigurationOutput) ToWorkerConfigurationPtrOutputWithContext

func (o WorkerConfigurationOutput) ToWorkerConfigurationPtrOutputWithContext(ctx context.Context) WorkerConfigurationPtrOutput

type WorkerConfigurationPtrInput

type WorkerConfigurationPtrInput interface {
	pulumi.Input

	ToWorkerConfigurationPtrOutput() WorkerConfigurationPtrOutput
	ToWorkerConfigurationPtrOutputWithContext(ctx context.Context) WorkerConfigurationPtrOutput
}

type WorkerConfigurationPtrOutput

type WorkerConfigurationPtrOutput struct{ *pulumi.OutputState }

func (WorkerConfigurationPtrOutput) Elem

func (WorkerConfigurationPtrOutput) ElementType

func (WorkerConfigurationPtrOutput) ToWorkerConfigurationPtrOutput

func (o WorkerConfigurationPtrOutput) ToWorkerConfigurationPtrOutput() WorkerConfigurationPtrOutput

func (WorkerConfigurationPtrOutput) ToWorkerConfigurationPtrOutputWithContext

func (o WorkerConfigurationPtrOutput) ToWorkerConfigurationPtrOutputWithContext(ctx context.Context) WorkerConfigurationPtrOutput

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

Jump to

Keyboard shortcuts

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