streaming

package
v1.33.0 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 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 ConnectHarness 

type ConnectHarness struct {
	pulumi.CustomResourceState

	// (Updatable) The OCID of the compartment that contains the connect harness.
	CompartmentId pulumi.StringOutput `pulumi:"compartmentId"`
	// (Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations.CostCenter": "42"}`
	DefinedTags pulumi.MapOutput `pulumi:"definedTags"`
	// (Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapOutput `pulumi:"freeformTags"`
	// Any additional details about the current state of the connect harness.
	LifecycleStateDetails pulumi.StringOutput `pulumi:"lifecycleStateDetails"`
	// The name of the connect harness. Avoid entering confidential information.  Example: `JDBCConnector`
	//
	// ** IMPORTANT **
	// Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values
	Name pulumi.StringOutput `pulumi:"name"`
	// The current state of the connect harness.
	State pulumi.StringOutput `pulumi:"state"`
	// The date and time the connect harness was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated pulumi.StringOutput `pulumi:"timeCreated"`
}

This resource provides the Connect Harness resource in Oracle Cloud Infrastructure Streaming service.

Starts the provisioning of a new connect harness. To track the progress of the provisioning, you can periodically call GetConnectHarness. In the response, the `lifecycleState` parameter of the ConnectHarness(https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/ConnectHarness/) object tells you its current state.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-oci/sdk/go/oci/Streaming"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Streaming.NewConnectHarness(ctx, "test_connect_harness", &Streaming.ConnectHarnessArgs{
			CompartmentId: pulumi.Any(compartmentId),
			Name:          pulumi.Any(connectHarnessName),
			DefinedTags:   pulumi.Any(connectHarnessDefinedTags),
			FreeformTags: pulumi.Map{
				"Department": pulumi.Any("Finance"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

ConnectHarnesses can be imported using the `id`, e.g.

```sh $ pulumi import oci:Streaming/connectHarness:ConnectHarness test_connect_harness "id" ```

func GetConnectHarness 

func GetConnectHarness(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ConnectHarnessState, opts ...pulumi.ResourceOption) (*ConnectHarness, error)

GetConnectHarness gets an existing ConnectHarness 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 NewConnectHarness 

func NewConnectHarness(ctx *pulumi.Context,
	name string, args *ConnectHarnessArgs, opts ...pulumi.ResourceOption) (*ConnectHarness, error)

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

func (*ConnectHarness) ElementType 

func (*ConnectHarness) ElementType() reflect.Type

func (*ConnectHarness) ToConnectHarnessOutput 

func (i *ConnectHarness) ToConnectHarnessOutput() ConnectHarnessOutput

func (*ConnectHarness) ToConnectHarnessOutputWithContext 

func (i *ConnectHarness) ToConnectHarnessOutputWithContext(ctx context.Context) ConnectHarnessOutput

type ConnectHarnessArgs 

type ConnectHarnessArgs struct {
	// (Updatable) The OCID of the compartment that contains the connect harness.
	CompartmentId pulumi.StringInput
	// (Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations.CostCenter": "42"}`
	DefinedTags pulumi.MapInput
	// (Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapInput
	// The name of the connect harness. Avoid entering confidential information.  Example: `JDBCConnector`
	//
	// ** IMPORTANT **
	// Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values
	Name pulumi.StringPtrInput
}

The set of arguments for constructing a ConnectHarness resource.

func (ConnectHarnessArgs) ElementType 

func (ConnectHarnessArgs) ElementType() reflect.Type

type ConnectHarnessArray 

type ConnectHarnessArray []ConnectHarnessInput

func (ConnectHarnessArray) ElementType 

func (ConnectHarnessArray) ElementType() reflect.Type

func (ConnectHarnessArray) ToConnectHarnessArrayOutput 

func (i ConnectHarnessArray) ToConnectHarnessArrayOutput() ConnectHarnessArrayOutput

func (ConnectHarnessArray) ToConnectHarnessArrayOutputWithContext 

func (i ConnectHarnessArray) ToConnectHarnessArrayOutputWithContext(ctx context.Context) ConnectHarnessArrayOutput

type ConnectHarnessArrayInput 

type ConnectHarnessArrayInput interface {
	pulumi.Input

	ToConnectHarnessArrayOutput() ConnectHarnessArrayOutput
	ToConnectHarnessArrayOutputWithContext(context.Context) ConnectHarnessArrayOutput
}

ConnectHarnessArrayInput is an input type that accepts ConnectHarnessArray and ConnectHarnessArrayOutput values. You can construct a concrete instance of `ConnectHarnessArrayInput` via: 

ConnectHarnessArray{ ConnectHarnessArgs{...} }

type ConnectHarnessArrayOutput 

type ConnectHarnessArrayOutput struct{ *pulumi.OutputState }

func (ConnectHarnessArrayOutput) ElementType 

func (ConnectHarnessArrayOutput) ElementType() reflect.Type

func (ConnectHarnessArrayOutput) Index 

func (o ConnectHarnessArrayOutput) Index(i pulumi.IntInput) ConnectHarnessOutput

func (ConnectHarnessArrayOutput) ToConnectHarnessArrayOutput 

func (o ConnectHarnessArrayOutput) ToConnectHarnessArrayOutput() ConnectHarnessArrayOutput

func (ConnectHarnessArrayOutput) ToConnectHarnessArrayOutputWithContext 

func (o ConnectHarnessArrayOutput) ToConnectHarnessArrayOutputWithContext(ctx context.Context) ConnectHarnessArrayOutput

type ConnectHarnessInput 

type ConnectHarnessInput interface {
	pulumi.Input

	ToConnectHarnessOutput() ConnectHarnessOutput
	ToConnectHarnessOutputWithContext(ctx context.Context) ConnectHarnessOutput
}

type ConnectHarnessMap 

type ConnectHarnessMap map[string]ConnectHarnessInput

func (ConnectHarnessMap) ElementType 

func (ConnectHarnessMap) ElementType() reflect.Type

func (ConnectHarnessMap) ToConnectHarnessMapOutput 

func (i ConnectHarnessMap) ToConnectHarnessMapOutput() ConnectHarnessMapOutput

func (ConnectHarnessMap) ToConnectHarnessMapOutputWithContext 

func (i ConnectHarnessMap) ToConnectHarnessMapOutputWithContext(ctx context.Context) ConnectHarnessMapOutput

type ConnectHarnessMapInput 

type ConnectHarnessMapInput interface {
	pulumi.Input

	ToConnectHarnessMapOutput() ConnectHarnessMapOutput
	ToConnectHarnessMapOutputWithContext(context.Context) ConnectHarnessMapOutput
}

ConnectHarnessMapInput is an input type that accepts ConnectHarnessMap and ConnectHarnessMapOutput values. You can construct a concrete instance of `ConnectHarnessMapInput` via: 

ConnectHarnessMap{ "key": ConnectHarnessArgs{...} }

type ConnectHarnessMapOutput 

type ConnectHarnessMapOutput struct{ *pulumi.OutputState }

func (ConnectHarnessMapOutput) ElementType 

func (ConnectHarnessMapOutput) ElementType() reflect.Type

func (ConnectHarnessMapOutput) MapIndex 

func (o ConnectHarnessMapOutput) MapIndex(k pulumi.StringInput) ConnectHarnessOutput

func (ConnectHarnessMapOutput) ToConnectHarnessMapOutput 

func (o ConnectHarnessMapOutput) ToConnectHarnessMapOutput() ConnectHarnessMapOutput

func (ConnectHarnessMapOutput) ToConnectHarnessMapOutputWithContext 

func (o ConnectHarnessMapOutput) ToConnectHarnessMapOutputWithContext(ctx context.Context) ConnectHarnessMapOutput

type ConnectHarnessOutput 

type ConnectHarnessOutput struct{ *pulumi.OutputState }

func (ConnectHarnessOutput) CompartmentId added in v0.4.0 

func (o ConnectHarnessOutput) CompartmentId() pulumi.StringOutput

(Updatable) The OCID of the compartment that contains the connect harness.

func (ConnectHarnessOutput) DefinedTags added in v0.4.0 

func (o ConnectHarnessOutput) DefinedTags() pulumi.MapOutput

(Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Operations.CostCenter": "42"}`

func (ConnectHarnessOutput) ElementType 

func (ConnectHarnessOutput) ElementType() reflect.Type

func (ConnectHarnessOutput) FreeformTags added in v0.4.0 

func (o ConnectHarnessOutput) FreeformTags() pulumi.MapOutput

(Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Department": "Finance"}`

func (ConnectHarnessOutput) LifecycleStateDetails added in v0.4.0 

func (o ConnectHarnessOutput) LifecycleStateDetails() pulumi.StringOutput

Any additional details about the current state of the connect harness.

func (ConnectHarnessOutput) Name added in v0.4.0 

func (o ConnectHarnessOutput) Name() pulumi.StringOutput

The name of the connect harness. Avoid entering confidential information. Example: `JDBCConnector`

** IMPORTANT ** Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values

func (ConnectHarnessOutput) State added in v0.4.0 

func (o ConnectHarnessOutput) State() pulumi.StringOutput

The current state of the connect harness.

func (ConnectHarnessOutput) TimeCreated added in v0.4.0 

func (o ConnectHarnessOutput) TimeCreated() pulumi.StringOutput

The date and time the connect harness was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format. Example: `2018-04-20T00:00:07.405Z`

func (ConnectHarnessOutput) ToConnectHarnessOutput 

func (o ConnectHarnessOutput) ToConnectHarnessOutput() ConnectHarnessOutput

func (ConnectHarnessOutput) ToConnectHarnessOutputWithContext 

func (o ConnectHarnessOutput) ToConnectHarnessOutputWithContext(ctx context.Context) ConnectHarnessOutput

type ConnectHarnessState 

type ConnectHarnessState struct {
	// (Updatable) The OCID of the compartment that contains the connect harness.
	CompartmentId pulumi.StringPtrInput
	// (Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations.CostCenter": "42"}`
	DefinedTags pulumi.MapInput
	// (Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapInput
	// Any additional details about the current state of the connect harness.
	LifecycleStateDetails pulumi.StringPtrInput
	// The name of the connect harness. Avoid entering confidential information.  Example: `JDBCConnector`
	//
	// ** IMPORTANT **
	// Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values
	Name pulumi.StringPtrInput
	// The current state of the connect harness.
	State pulumi.StringPtrInput
	// The date and time the connect harness was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated pulumi.StringPtrInput
}

func (ConnectHarnessState) ElementType 

func (ConnectHarnessState) ElementType() reflect.Type

type GetConnectHarnessesArgs 

type GetConnectHarnessesArgs struct {
	// The OCID of the compartment.
	CompartmentId string                      `pulumi:"compartmentId"`
	Filters       []GetConnectHarnessesFilter `pulumi:"filters"`
	// A filter to return only resources that match the given ID exactly.
	Id *string `pulumi:"id"`
	// A filter to return only resources that match the given name exactly.
	Name *string `pulumi:"name"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State *string `pulumi:"state"`
}

A collection of arguments for invoking getConnectHarnesses.

type GetConnectHarnessesConnectHarness 

type GetConnectHarnessesConnectHarness struct {
	// The OCID of the compartment.
	CompartmentId string `pulumi:"compartmentId"`
	// Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations": {"CostCenter": "42"}}'
	DefinedTags map[string]interface{} `pulumi:"definedTags"`
	// Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags map[string]interface{} `pulumi:"freeformTags"`
	// A filter to return only resources that match the given ID exactly.
	Id string `pulumi:"id"`
	// Any additional details about the current state of the connect harness.
	LifecycleStateDetails string `pulumi:"lifecycleStateDetails"`
	// A filter to return only resources that match the given name exactly.
	Name string `pulumi:"name"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State string `pulumi:"state"`
	// The date and time the connect harness was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated string `pulumi:"timeCreated"`
}

type GetConnectHarnessesConnectHarnessArgs 

type GetConnectHarnessesConnectHarnessArgs struct {
	// The OCID of the compartment.
	CompartmentId pulumi.StringInput `pulumi:"compartmentId"`
	// Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations": {"CostCenter": "42"}}'
	DefinedTags pulumi.MapInput `pulumi:"definedTags"`
	// Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapInput `pulumi:"freeformTags"`
	// A filter to return only resources that match the given ID exactly.
	Id pulumi.StringInput `pulumi:"id"`
	// Any additional details about the current state of the connect harness.
	LifecycleStateDetails pulumi.StringInput `pulumi:"lifecycleStateDetails"`
	// A filter to return only resources that match the given name exactly.
	Name pulumi.StringInput `pulumi:"name"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State pulumi.StringInput `pulumi:"state"`
	// The date and time the connect harness was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated pulumi.StringInput `pulumi:"timeCreated"`
}

func (GetConnectHarnessesConnectHarnessArgs) ElementType 

func (GetConnectHarnessesConnectHarnessArgs) ElementType() reflect.Type

func (GetConnectHarnessesConnectHarnessArgs) ToGetConnectHarnessesConnectHarnessOutput 

func (i GetConnectHarnessesConnectHarnessArgs) ToGetConnectHarnessesConnectHarnessOutput() GetConnectHarnessesConnectHarnessOutput

func (GetConnectHarnessesConnectHarnessArgs) ToGetConnectHarnessesConnectHarnessOutputWithContext 

func (i GetConnectHarnessesConnectHarnessArgs) ToGetConnectHarnessesConnectHarnessOutputWithContext(ctx context.Context) GetConnectHarnessesConnectHarnessOutput

type GetConnectHarnessesConnectHarnessArray 

type GetConnectHarnessesConnectHarnessArray []GetConnectHarnessesConnectHarnessInput

func (GetConnectHarnessesConnectHarnessArray) ElementType 

func (GetConnectHarnessesConnectHarnessArray) ElementType() reflect.Type

func (GetConnectHarnessesConnectHarnessArray) ToGetConnectHarnessesConnectHarnessArrayOutput 

func (i GetConnectHarnessesConnectHarnessArray) ToGetConnectHarnessesConnectHarnessArrayOutput() GetConnectHarnessesConnectHarnessArrayOutput

func (GetConnectHarnessesConnectHarnessArray) ToGetConnectHarnessesConnectHarnessArrayOutputWithContext 

func (i GetConnectHarnessesConnectHarnessArray) ToGetConnectHarnessesConnectHarnessArrayOutputWithContext(ctx context.Context) GetConnectHarnessesConnectHarnessArrayOutput

type GetConnectHarnessesConnectHarnessArrayInput 

type GetConnectHarnessesConnectHarnessArrayInput interface {
	pulumi.Input

	ToGetConnectHarnessesConnectHarnessArrayOutput() GetConnectHarnessesConnectHarnessArrayOutput
	ToGetConnectHarnessesConnectHarnessArrayOutputWithContext(context.Context) GetConnectHarnessesConnectHarnessArrayOutput
}

GetConnectHarnessesConnectHarnessArrayInput is an input type that accepts GetConnectHarnessesConnectHarnessArray and GetConnectHarnessesConnectHarnessArrayOutput values. You can construct a concrete instance of `GetConnectHarnessesConnectHarnessArrayInput` via: 

GetConnectHarnessesConnectHarnessArray{ GetConnectHarnessesConnectHarnessArgs{...} }

type GetConnectHarnessesConnectHarnessArrayOutput 

type GetConnectHarnessesConnectHarnessArrayOutput struct{ *pulumi.OutputState }

func (GetConnectHarnessesConnectHarnessArrayOutput) ElementType 

func (GetConnectHarnessesConnectHarnessArrayOutput) ElementType() reflect.Type

func (GetConnectHarnessesConnectHarnessArrayOutput) Index 

func (o GetConnectHarnessesConnectHarnessArrayOutput) Index(i pulumi.IntInput) GetConnectHarnessesConnectHarnessOutput

func (GetConnectHarnessesConnectHarnessArrayOutput) ToGetConnectHarnessesConnectHarnessArrayOutput 

func (o GetConnectHarnessesConnectHarnessArrayOutput) ToGetConnectHarnessesConnectHarnessArrayOutput() GetConnectHarnessesConnectHarnessArrayOutput

func (GetConnectHarnessesConnectHarnessArrayOutput) ToGetConnectHarnessesConnectHarnessArrayOutputWithContext 

func (o GetConnectHarnessesConnectHarnessArrayOutput) ToGetConnectHarnessesConnectHarnessArrayOutputWithContext(ctx context.Context) GetConnectHarnessesConnectHarnessArrayOutput

type GetConnectHarnessesConnectHarnessInput 

type GetConnectHarnessesConnectHarnessInput interface {
	pulumi.Input

	ToGetConnectHarnessesConnectHarnessOutput() GetConnectHarnessesConnectHarnessOutput
	ToGetConnectHarnessesConnectHarnessOutputWithContext(context.Context) GetConnectHarnessesConnectHarnessOutput
}

GetConnectHarnessesConnectHarnessInput is an input type that accepts GetConnectHarnessesConnectHarnessArgs and GetConnectHarnessesConnectHarnessOutput values. You can construct a concrete instance of `GetConnectHarnessesConnectHarnessInput` via: 

GetConnectHarnessesConnectHarnessArgs{...}

type GetConnectHarnessesConnectHarnessOutput 

type GetConnectHarnessesConnectHarnessOutput struct{ *pulumi.OutputState }

func (GetConnectHarnessesConnectHarnessOutput) CompartmentId 

func (o GetConnectHarnessesConnectHarnessOutput) CompartmentId() pulumi.StringOutput

The OCID of the compartment.

func (GetConnectHarnessesConnectHarnessOutput) DefinedTags 

func (o GetConnectHarnessesConnectHarnessOutput) DefinedTags() pulumi.MapOutput

Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Operations": {"CostCenter": "42"}}'

func (GetConnectHarnessesConnectHarnessOutput) ElementType 

func (GetConnectHarnessesConnectHarnessOutput) ElementType() reflect.Type

func (GetConnectHarnessesConnectHarnessOutput) FreeformTags 

func (o GetConnectHarnessesConnectHarnessOutput) FreeformTags() pulumi.MapOutput

Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Department": "Finance"}`

func (GetConnectHarnessesConnectHarnessOutput) Id 

func (o GetConnectHarnessesConnectHarnessOutput) Id() pulumi.StringOutput

A filter to return only resources that match the given ID exactly.

func (GetConnectHarnessesConnectHarnessOutput) LifecycleStateDetails 

func (o GetConnectHarnessesConnectHarnessOutput) LifecycleStateDetails() pulumi.StringOutput

Any additional details about the current state of the connect harness.

func (GetConnectHarnessesConnectHarnessOutput) Name 

func (o GetConnectHarnessesConnectHarnessOutput) Name() pulumi.StringOutput

A filter to return only resources that match the given name exactly.

func (GetConnectHarnessesConnectHarnessOutput) State 

func (o GetConnectHarnessesConnectHarnessOutput) State() pulumi.StringOutput

A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.

func (GetConnectHarnessesConnectHarnessOutput) TimeCreated 

func (o GetConnectHarnessesConnectHarnessOutput) TimeCreated() pulumi.StringOutput

The date and time the connect harness was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format. Example: `2018-04-20T00:00:07.405Z`

func (GetConnectHarnessesConnectHarnessOutput) ToGetConnectHarnessesConnectHarnessOutput 

func (o GetConnectHarnessesConnectHarnessOutput) ToGetConnectHarnessesConnectHarnessOutput() GetConnectHarnessesConnectHarnessOutput

func (GetConnectHarnessesConnectHarnessOutput) ToGetConnectHarnessesConnectHarnessOutputWithContext 

func (o GetConnectHarnessesConnectHarnessOutput) ToGetConnectHarnessesConnectHarnessOutputWithContext(ctx context.Context) GetConnectHarnessesConnectHarnessOutput

type GetConnectHarnessesFilter 

type GetConnectHarnessesFilter struct {
	// A filter to return only resources that match the given name exactly.
	Name   string   `pulumi:"name"`
	Regex  *bool    `pulumi:"regex"`
	Values []string `pulumi:"values"`
}

type GetConnectHarnessesFilterArgs 

type GetConnectHarnessesFilterArgs struct {
	// A filter to return only resources that match the given name exactly.
	Name   pulumi.StringInput      `pulumi:"name"`
	Regex  pulumi.BoolPtrInput     `pulumi:"regex"`
	Values pulumi.StringArrayInput `pulumi:"values"`
}

func (GetConnectHarnessesFilterArgs) ElementType 

func (GetConnectHarnessesFilterArgs) ElementType() reflect.Type

func (GetConnectHarnessesFilterArgs) ToGetConnectHarnessesFilterOutput 

func (i GetConnectHarnessesFilterArgs) ToGetConnectHarnessesFilterOutput() GetConnectHarnessesFilterOutput

func (GetConnectHarnessesFilterArgs) ToGetConnectHarnessesFilterOutputWithContext 

func (i GetConnectHarnessesFilterArgs) ToGetConnectHarnessesFilterOutputWithContext(ctx context.Context) GetConnectHarnessesFilterOutput

type GetConnectHarnessesFilterArray 

type GetConnectHarnessesFilterArray []GetConnectHarnessesFilterInput

func (GetConnectHarnessesFilterArray) ElementType 

func (GetConnectHarnessesFilterArray) ElementType() reflect.Type

func (GetConnectHarnessesFilterArray) ToGetConnectHarnessesFilterArrayOutput 

func (i GetConnectHarnessesFilterArray) ToGetConnectHarnessesFilterArrayOutput() GetConnectHarnessesFilterArrayOutput

func (GetConnectHarnessesFilterArray) ToGetConnectHarnessesFilterArrayOutputWithContext 

func (i GetConnectHarnessesFilterArray) ToGetConnectHarnessesFilterArrayOutputWithContext(ctx context.Context) GetConnectHarnessesFilterArrayOutput

type GetConnectHarnessesFilterArrayInput 

type GetConnectHarnessesFilterArrayInput interface {
	pulumi.Input

	ToGetConnectHarnessesFilterArrayOutput() GetConnectHarnessesFilterArrayOutput
	ToGetConnectHarnessesFilterArrayOutputWithContext(context.Context) GetConnectHarnessesFilterArrayOutput
}

GetConnectHarnessesFilterArrayInput is an input type that accepts GetConnectHarnessesFilterArray and GetConnectHarnessesFilterArrayOutput values. You can construct a concrete instance of `GetConnectHarnessesFilterArrayInput` via: 

GetConnectHarnessesFilterArray{ GetConnectHarnessesFilterArgs{...} }

type GetConnectHarnessesFilterArrayOutput 

type GetConnectHarnessesFilterArrayOutput struct{ *pulumi.OutputState }

func (GetConnectHarnessesFilterArrayOutput) ElementType 

func (GetConnectHarnessesFilterArrayOutput) ElementType() reflect.Type

func (GetConnectHarnessesFilterArrayOutput) Index 

func (o GetConnectHarnessesFilterArrayOutput) Index(i pulumi.IntInput) GetConnectHarnessesFilterOutput

func (GetConnectHarnessesFilterArrayOutput) ToGetConnectHarnessesFilterArrayOutput 

func (o GetConnectHarnessesFilterArrayOutput) ToGetConnectHarnessesFilterArrayOutput() GetConnectHarnessesFilterArrayOutput

func (GetConnectHarnessesFilterArrayOutput) ToGetConnectHarnessesFilterArrayOutputWithContext 

func (o GetConnectHarnessesFilterArrayOutput) ToGetConnectHarnessesFilterArrayOutputWithContext(ctx context.Context) GetConnectHarnessesFilterArrayOutput

type GetConnectHarnessesFilterInput 

type GetConnectHarnessesFilterInput interface {
	pulumi.Input

	ToGetConnectHarnessesFilterOutput() GetConnectHarnessesFilterOutput
	ToGetConnectHarnessesFilterOutputWithContext(context.Context) GetConnectHarnessesFilterOutput
}

GetConnectHarnessesFilterInput is an input type that accepts GetConnectHarnessesFilterArgs and GetConnectHarnessesFilterOutput values. You can construct a concrete instance of `GetConnectHarnessesFilterInput` via: 

GetConnectHarnessesFilterArgs{...}

type GetConnectHarnessesFilterOutput 

type GetConnectHarnessesFilterOutput struct{ *pulumi.OutputState }

func (GetConnectHarnessesFilterOutput) ElementType 

func (GetConnectHarnessesFilterOutput) ElementType() reflect.Type

func (GetConnectHarnessesFilterOutput) Name 

func (o GetConnectHarnessesFilterOutput) Name() pulumi.StringOutput

A filter to return only resources that match the given name exactly.

func (GetConnectHarnessesFilterOutput) Regex 

func (o GetConnectHarnessesFilterOutput) Regex() pulumi.BoolPtrOutput

func (GetConnectHarnessesFilterOutput) ToGetConnectHarnessesFilterOutput 

func (o GetConnectHarnessesFilterOutput) ToGetConnectHarnessesFilterOutput() GetConnectHarnessesFilterOutput

func (GetConnectHarnessesFilterOutput) ToGetConnectHarnessesFilterOutputWithContext 

func (o GetConnectHarnessesFilterOutput) ToGetConnectHarnessesFilterOutputWithContext(ctx context.Context) GetConnectHarnessesFilterOutput

func (GetConnectHarnessesFilterOutput) Values 

func (o GetConnectHarnessesFilterOutput) Values() pulumi.StringArrayOutput

type GetConnectHarnessesOutputArgs 

type GetConnectHarnessesOutputArgs struct {
	// The OCID of the compartment.
	CompartmentId pulumi.StringInput                  `pulumi:"compartmentId"`
	Filters       GetConnectHarnessesFilterArrayInput `pulumi:"filters"`
	// A filter to return only resources that match the given ID exactly.
	Id pulumi.StringPtrInput `pulumi:"id"`
	// A filter to return only resources that match the given name exactly.
	Name pulumi.StringPtrInput `pulumi:"name"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State pulumi.StringPtrInput `pulumi:"state"`
}

A collection of arguments for invoking getConnectHarnesses.

func (GetConnectHarnessesOutputArgs) ElementType 

func (GetConnectHarnessesOutputArgs) ElementType() reflect.Type

type GetConnectHarnessesResult 

type GetConnectHarnessesResult struct {
	// The OCID of the compartment that contains the connect harness.
	CompartmentId string `pulumi:"compartmentId"`
	// The list of connect_harness.
	ConnectHarnesses []GetConnectHarnessesConnectHarness `pulumi:"connectHarnesses"`
	Filters          []GetConnectHarnessesFilter         `pulumi:"filters"`
	// The OCID of the connect harness.
	Id *string `pulumi:"id"`
	// The name of the connect harness. Avoid entering confidential information.  Example: `JDBCConnector`
	Name *string `pulumi:"name"`
	// The current state of the connect harness.
	State *string `pulumi:"state"`
}

A collection of values returned by getConnectHarnesses.

func GetConnectHarnesses 

func GetConnectHarnesses(ctx *pulumi.Context, args *GetConnectHarnessesArgs, opts ...pulumi.InvokeOption) (*GetConnectHarnessesResult, error)

This data source provides the list of Connect Harnesses in Oracle Cloud Infrastructure Streaming service.

Lists the connectharness.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-oci/sdk/go/oci/Streaming"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Streaming.GetConnectHarnesses(ctx, &streaming.GetConnectHarnessesArgs{
			CompartmentId: compartmentId,
			Id:            pulumi.StringRef(connectHarnessId),
			Name:          pulumi.StringRef(connectHarnessName),
			State:         pulumi.StringRef(connectHarnessState),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetConnectHarnessesResultOutput 

type GetConnectHarnessesResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getConnectHarnesses.

func GetConnectHarnessesOutput 

func GetConnectHarnessesOutput(ctx *pulumi.Context, args GetConnectHarnessesOutputArgs, opts ...pulumi.InvokeOption) GetConnectHarnessesResultOutput

func (GetConnectHarnessesResultOutput) CompartmentId 

func (o GetConnectHarnessesResultOutput) CompartmentId() pulumi.StringOutput

The OCID of the compartment that contains the connect harness.

func (GetConnectHarnessesResultOutput) ConnectHarnesses 

func (o GetConnectHarnessesResultOutput) ConnectHarnesses() GetConnectHarnessesConnectHarnessArrayOutput

The list of connect_harness.

func (GetConnectHarnessesResultOutput) ElementType 

func (GetConnectHarnessesResultOutput) ElementType() reflect.Type

func (GetConnectHarnessesResultOutput) Filters 

func (o GetConnectHarnessesResultOutput) Filters() GetConnectHarnessesFilterArrayOutput

func (GetConnectHarnessesResultOutput) Id 

func (o GetConnectHarnessesResultOutput) Id() pulumi.StringPtrOutput

The OCID of the connect harness.

func (GetConnectHarnessesResultOutput) Name 

func (o GetConnectHarnessesResultOutput) Name() pulumi.StringPtrOutput

The name of the connect harness. Avoid entering confidential information. Example: `JDBCConnector`

func (GetConnectHarnessesResultOutput) State 

func (o GetConnectHarnessesResultOutput) State() pulumi.StringPtrOutput

The current state of the connect harness.

func (GetConnectHarnessesResultOutput) ToGetConnectHarnessesResultOutput 

func (o GetConnectHarnessesResultOutput) ToGetConnectHarnessesResultOutput() GetConnectHarnessesResultOutput

func (GetConnectHarnessesResultOutput) ToGetConnectHarnessesResultOutputWithContext 

func (o GetConnectHarnessesResultOutput) ToGetConnectHarnessesResultOutputWithContext(ctx context.Context) GetConnectHarnessesResultOutput

type GetStreamPoolCustomEncryptionKey 

type GetStreamPoolCustomEncryptionKey struct {
	// Life cycle State of the custom key
	KeyState string `pulumi:"keyState"`
	// Custom Encryption Key (Master Key) ocid.
	KmsKeyId string `pulumi:"kmsKeyId"`
}

type GetStreamPoolCustomEncryptionKeyArgs 

type GetStreamPoolCustomEncryptionKeyArgs struct {
	// Life cycle State of the custom key
	KeyState pulumi.StringInput `pulumi:"keyState"`
	// Custom Encryption Key (Master Key) ocid.
	KmsKeyId pulumi.StringInput `pulumi:"kmsKeyId"`
}

func (GetStreamPoolCustomEncryptionKeyArgs) ElementType 

func (GetStreamPoolCustomEncryptionKeyArgs) ElementType() reflect.Type

func (GetStreamPoolCustomEncryptionKeyArgs) ToGetStreamPoolCustomEncryptionKeyOutput 

func (i GetStreamPoolCustomEncryptionKeyArgs) ToGetStreamPoolCustomEncryptionKeyOutput() GetStreamPoolCustomEncryptionKeyOutput

func (GetStreamPoolCustomEncryptionKeyArgs) ToGetStreamPoolCustomEncryptionKeyOutputWithContext 

func (i GetStreamPoolCustomEncryptionKeyArgs) ToGetStreamPoolCustomEncryptionKeyOutputWithContext(ctx context.Context) GetStreamPoolCustomEncryptionKeyOutput

type GetStreamPoolCustomEncryptionKeyArray 

type GetStreamPoolCustomEncryptionKeyArray []GetStreamPoolCustomEncryptionKeyInput

func (GetStreamPoolCustomEncryptionKeyArray) ElementType 

func (GetStreamPoolCustomEncryptionKeyArray) ElementType() reflect.Type

func (GetStreamPoolCustomEncryptionKeyArray) ToGetStreamPoolCustomEncryptionKeyArrayOutput 

func (i GetStreamPoolCustomEncryptionKeyArray) ToGetStreamPoolCustomEncryptionKeyArrayOutput() GetStreamPoolCustomEncryptionKeyArrayOutput

func (GetStreamPoolCustomEncryptionKeyArray) ToGetStreamPoolCustomEncryptionKeyArrayOutputWithContext 

func (i GetStreamPoolCustomEncryptionKeyArray) ToGetStreamPoolCustomEncryptionKeyArrayOutputWithContext(ctx context.Context) GetStreamPoolCustomEncryptionKeyArrayOutput

type GetStreamPoolCustomEncryptionKeyArrayInput 

type GetStreamPoolCustomEncryptionKeyArrayInput interface {
	pulumi.Input

	ToGetStreamPoolCustomEncryptionKeyArrayOutput() GetStreamPoolCustomEncryptionKeyArrayOutput
	ToGetStreamPoolCustomEncryptionKeyArrayOutputWithContext(context.Context) GetStreamPoolCustomEncryptionKeyArrayOutput
}

GetStreamPoolCustomEncryptionKeyArrayInput is an input type that accepts GetStreamPoolCustomEncryptionKeyArray and GetStreamPoolCustomEncryptionKeyArrayOutput values. You can construct a concrete instance of `GetStreamPoolCustomEncryptionKeyArrayInput` via: 

GetStreamPoolCustomEncryptionKeyArray{ GetStreamPoolCustomEncryptionKeyArgs{...} }

type GetStreamPoolCustomEncryptionKeyArrayOutput 

type GetStreamPoolCustomEncryptionKeyArrayOutput struct{ *pulumi.OutputState }

func (GetStreamPoolCustomEncryptionKeyArrayOutput) ElementType 

func (GetStreamPoolCustomEncryptionKeyArrayOutput) ElementType() reflect.Type

func (GetStreamPoolCustomEncryptionKeyArrayOutput) Index 

func (o GetStreamPoolCustomEncryptionKeyArrayOutput) Index(i pulumi.IntInput) GetStreamPoolCustomEncryptionKeyOutput

func (GetStreamPoolCustomEncryptionKeyArrayOutput) ToGetStreamPoolCustomEncryptionKeyArrayOutput 

func (o GetStreamPoolCustomEncryptionKeyArrayOutput) ToGetStreamPoolCustomEncryptionKeyArrayOutput() GetStreamPoolCustomEncryptionKeyArrayOutput

func (GetStreamPoolCustomEncryptionKeyArrayOutput) ToGetStreamPoolCustomEncryptionKeyArrayOutputWithContext 

func (o GetStreamPoolCustomEncryptionKeyArrayOutput) ToGetStreamPoolCustomEncryptionKeyArrayOutputWithContext(ctx context.Context) GetStreamPoolCustomEncryptionKeyArrayOutput

type GetStreamPoolCustomEncryptionKeyInput 

type GetStreamPoolCustomEncryptionKeyInput interface {
	pulumi.Input

	ToGetStreamPoolCustomEncryptionKeyOutput() GetStreamPoolCustomEncryptionKeyOutput
	ToGetStreamPoolCustomEncryptionKeyOutputWithContext(context.Context) GetStreamPoolCustomEncryptionKeyOutput
}

GetStreamPoolCustomEncryptionKeyInput is an input type that accepts GetStreamPoolCustomEncryptionKeyArgs and GetStreamPoolCustomEncryptionKeyOutput values. You can construct a concrete instance of `GetStreamPoolCustomEncryptionKeyInput` via: 

GetStreamPoolCustomEncryptionKeyArgs{...}

type GetStreamPoolCustomEncryptionKeyOutput 

type GetStreamPoolCustomEncryptionKeyOutput struct{ *pulumi.OutputState }

func (GetStreamPoolCustomEncryptionKeyOutput) ElementType 

func (GetStreamPoolCustomEncryptionKeyOutput) ElementType() reflect.Type

func (GetStreamPoolCustomEncryptionKeyOutput) KeyState 

func (o GetStreamPoolCustomEncryptionKeyOutput) KeyState() pulumi.StringOutput

Life cycle State of the custom key

func (GetStreamPoolCustomEncryptionKeyOutput) KmsKeyId 

func (o GetStreamPoolCustomEncryptionKeyOutput) KmsKeyId() pulumi.StringOutput

Custom Encryption Key (Master Key) ocid.

func (GetStreamPoolCustomEncryptionKeyOutput) ToGetStreamPoolCustomEncryptionKeyOutput 

func (o GetStreamPoolCustomEncryptionKeyOutput) ToGetStreamPoolCustomEncryptionKeyOutput() GetStreamPoolCustomEncryptionKeyOutput

func (GetStreamPoolCustomEncryptionKeyOutput) ToGetStreamPoolCustomEncryptionKeyOutputWithContext 

func (o GetStreamPoolCustomEncryptionKeyOutput) ToGetStreamPoolCustomEncryptionKeyOutputWithContext(ctx context.Context) GetStreamPoolCustomEncryptionKeyOutput

type GetStreamPoolKafkaSetting 

type GetStreamPoolKafkaSetting struct {
	// Enable auto creation of topic on the server.
	AutoCreateTopicsEnable bool `pulumi:"autoCreateTopicsEnable"`
	// Bootstrap servers.
	BootstrapServers string `pulumi:"bootstrapServers"`
	// The number of hours to keep a log file before deleting it (in hours).
	LogRetentionHours int `pulumi:"logRetentionHours"`
	// The default number of log partitions per topic.
	NumPartitions int `pulumi:"numPartitions"`
}

type GetStreamPoolKafkaSettingArgs 

type GetStreamPoolKafkaSettingArgs struct {
	// Enable auto creation of topic on the server.
	AutoCreateTopicsEnable pulumi.BoolInput `pulumi:"autoCreateTopicsEnable"`
	// Bootstrap servers.
	BootstrapServers pulumi.StringInput `pulumi:"bootstrapServers"`
	// The number of hours to keep a log file before deleting it (in hours).
	LogRetentionHours pulumi.IntInput `pulumi:"logRetentionHours"`
	// The default number of log partitions per topic.
	NumPartitions pulumi.IntInput `pulumi:"numPartitions"`
}

func (GetStreamPoolKafkaSettingArgs) ElementType 

func (GetStreamPoolKafkaSettingArgs) ElementType() reflect.Type

func (GetStreamPoolKafkaSettingArgs) ToGetStreamPoolKafkaSettingOutput 

func (i GetStreamPoolKafkaSettingArgs) ToGetStreamPoolKafkaSettingOutput() GetStreamPoolKafkaSettingOutput

func (GetStreamPoolKafkaSettingArgs) ToGetStreamPoolKafkaSettingOutputWithContext 

func (i GetStreamPoolKafkaSettingArgs) ToGetStreamPoolKafkaSettingOutputWithContext(ctx context.Context) GetStreamPoolKafkaSettingOutput

type GetStreamPoolKafkaSettingArray 

type GetStreamPoolKafkaSettingArray []GetStreamPoolKafkaSettingInput

func (GetStreamPoolKafkaSettingArray) ElementType 

func (GetStreamPoolKafkaSettingArray) ElementType() reflect.Type

func (GetStreamPoolKafkaSettingArray) ToGetStreamPoolKafkaSettingArrayOutput 

func (i GetStreamPoolKafkaSettingArray) ToGetStreamPoolKafkaSettingArrayOutput() GetStreamPoolKafkaSettingArrayOutput

func (GetStreamPoolKafkaSettingArray) ToGetStreamPoolKafkaSettingArrayOutputWithContext 

func (i GetStreamPoolKafkaSettingArray) ToGetStreamPoolKafkaSettingArrayOutputWithContext(ctx context.Context) GetStreamPoolKafkaSettingArrayOutput

type GetStreamPoolKafkaSettingArrayInput 

type GetStreamPoolKafkaSettingArrayInput interface {
	pulumi.Input

	ToGetStreamPoolKafkaSettingArrayOutput() GetStreamPoolKafkaSettingArrayOutput
	ToGetStreamPoolKafkaSettingArrayOutputWithContext(context.Context) GetStreamPoolKafkaSettingArrayOutput
}

GetStreamPoolKafkaSettingArrayInput is an input type that accepts GetStreamPoolKafkaSettingArray and GetStreamPoolKafkaSettingArrayOutput values. You can construct a concrete instance of `GetStreamPoolKafkaSettingArrayInput` via: 

GetStreamPoolKafkaSettingArray{ GetStreamPoolKafkaSettingArgs{...} }

type GetStreamPoolKafkaSettingArrayOutput 

type GetStreamPoolKafkaSettingArrayOutput struct{ *pulumi.OutputState }

func (GetStreamPoolKafkaSettingArrayOutput) ElementType 

func (GetStreamPoolKafkaSettingArrayOutput) ElementType() reflect.Type

func (GetStreamPoolKafkaSettingArrayOutput) Index 

func (o GetStreamPoolKafkaSettingArrayOutput) Index(i pulumi.IntInput) GetStreamPoolKafkaSettingOutput

func (GetStreamPoolKafkaSettingArrayOutput) ToGetStreamPoolKafkaSettingArrayOutput 

func (o GetStreamPoolKafkaSettingArrayOutput) ToGetStreamPoolKafkaSettingArrayOutput() GetStreamPoolKafkaSettingArrayOutput

func (GetStreamPoolKafkaSettingArrayOutput) ToGetStreamPoolKafkaSettingArrayOutputWithContext 

func (o GetStreamPoolKafkaSettingArrayOutput) ToGetStreamPoolKafkaSettingArrayOutputWithContext(ctx context.Context) GetStreamPoolKafkaSettingArrayOutput

type GetStreamPoolKafkaSettingInput 

type GetStreamPoolKafkaSettingInput interface {
	pulumi.Input

	ToGetStreamPoolKafkaSettingOutput() GetStreamPoolKafkaSettingOutput
	ToGetStreamPoolKafkaSettingOutputWithContext(context.Context) GetStreamPoolKafkaSettingOutput
}

GetStreamPoolKafkaSettingInput is an input type that accepts GetStreamPoolKafkaSettingArgs and GetStreamPoolKafkaSettingOutput values. You can construct a concrete instance of `GetStreamPoolKafkaSettingInput` via: 

GetStreamPoolKafkaSettingArgs{...}

type GetStreamPoolKafkaSettingOutput 

type GetStreamPoolKafkaSettingOutput struct{ *pulumi.OutputState }

func (GetStreamPoolKafkaSettingOutput) AutoCreateTopicsEnable 

func (o GetStreamPoolKafkaSettingOutput) AutoCreateTopicsEnable() pulumi.BoolOutput

Enable auto creation of topic on the server.

func (GetStreamPoolKafkaSettingOutput) BootstrapServers 

func (o GetStreamPoolKafkaSettingOutput) BootstrapServers() pulumi.StringOutput

Bootstrap servers.

func (GetStreamPoolKafkaSettingOutput) ElementType 

func (GetStreamPoolKafkaSettingOutput) ElementType() reflect.Type

func (GetStreamPoolKafkaSettingOutput) LogRetentionHours 

func (o GetStreamPoolKafkaSettingOutput) LogRetentionHours() pulumi.IntOutput

The number of hours to keep a log file before deleting it (in hours).

func (GetStreamPoolKafkaSettingOutput) NumPartitions 

func (o GetStreamPoolKafkaSettingOutput) NumPartitions() pulumi.IntOutput

The default number of log partitions per topic.

func (GetStreamPoolKafkaSettingOutput) ToGetStreamPoolKafkaSettingOutput 

func (o GetStreamPoolKafkaSettingOutput) ToGetStreamPoolKafkaSettingOutput() GetStreamPoolKafkaSettingOutput

func (GetStreamPoolKafkaSettingOutput) ToGetStreamPoolKafkaSettingOutputWithContext 

func (o GetStreamPoolKafkaSettingOutput) ToGetStreamPoolKafkaSettingOutputWithContext(ctx context.Context) GetStreamPoolKafkaSettingOutput

type GetStreamPoolPrivateEndpointSetting 

type GetStreamPoolPrivateEndpointSetting struct {
	// The optional list of network security groups that are associated with the private endpoint of the stream pool.
	NsgIds []string `pulumi:"nsgIds"`
	// The private IP associated with the stream pool in the associated subnetId. The stream pool's FQDN resolves to that IP and should be used - instead of the private IP - in order to not trigger any TLS issues.
	PrivateEndpointIp string `pulumi:"privateEndpointIp"`
	// The subnet id from which the private stream pool can be accessed. Trying to access the streams from another network location will result in an error.
	SubnetId string `pulumi:"subnetId"`
}

type GetStreamPoolPrivateEndpointSettingArgs 

type GetStreamPoolPrivateEndpointSettingArgs struct {
	// The optional list of network security groups that are associated with the private endpoint of the stream pool.
	NsgIds pulumi.StringArrayInput `pulumi:"nsgIds"`
	// The private IP associated with the stream pool in the associated subnetId. The stream pool's FQDN resolves to that IP and should be used - instead of the private IP - in order to not trigger any TLS issues.
	PrivateEndpointIp pulumi.StringInput `pulumi:"privateEndpointIp"`
	// The subnet id from which the private stream pool can be accessed. Trying to access the streams from another network location will result in an error.
	SubnetId pulumi.StringInput `pulumi:"subnetId"`
}

func (GetStreamPoolPrivateEndpointSettingArgs) ElementType 

func (GetStreamPoolPrivateEndpointSettingArgs) ElementType() reflect.Type

func (GetStreamPoolPrivateEndpointSettingArgs) ToGetStreamPoolPrivateEndpointSettingOutput 

func (i GetStreamPoolPrivateEndpointSettingArgs) ToGetStreamPoolPrivateEndpointSettingOutput() GetStreamPoolPrivateEndpointSettingOutput

func (GetStreamPoolPrivateEndpointSettingArgs) ToGetStreamPoolPrivateEndpointSettingOutputWithContext 

func (i GetStreamPoolPrivateEndpointSettingArgs) ToGetStreamPoolPrivateEndpointSettingOutputWithContext(ctx context.Context) GetStreamPoolPrivateEndpointSettingOutput

type GetStreamPoolPrivateEndpointSettingArray 

type GetStreamPoolPrivateEndpointSettingArray []GetStreamPoolPrivateEndpointSettingInput

func (GetStreamPoolPrivateEndpointSettingArray) ElementType 

func (GetStreamPoolPrivateEndpointSettingArray) ElementType() reflect.Type

func (GetStreamPoolPrivateEndpointSettingArray) ToGetStreamPoolPrivateEndpointSettingArrayOutput 

func (i GetStreamPoolPrivateEndpointSettingArray) ToGetStreamPoolPrivateEndpointSettingArrayOutput() GetStreamPoolPrivateEndpointSettingArrayOutput

func (GetStreamPoolPrivateEndpointSettingArray) ToGetStreamPoolPrivateEndpointSettingArrayOutputWithContext 

func (i GetStreamPoolPrivateEndpointSettingArray) ToGetStreamPoolPrivateEndpointSettingArrayOutputWithContext(ctx context.Context) GetStreamPoolPrivateEndpointSettingArrayOutput

type GetStreamPoolPrivateEndpointSettingArrayInput 

type GetStreamPoolPrivateEndpointSettingArrayInput interface {
	pulumi.Input

	ToGetStreamPoolPrivateEndpointSettingArrayOutput() GetStreamPoolPrivateEndpointSettingArrayOutput
	ToGetStreamPoolPrivateEndpointSettingArrayOutputWithContext(context.Context) GetStreamPoolPrivateEndpointSettingArrayOutput
}

GetStreamPoolPrivateEndpointSettingArrayInput is an input type that accepts GetStreamPoolPrivateEndpointSettingArray and GetStreamPoolPrivateEndpointSettingArrayOutput values. You can construct a concrete instance of `GetStreamPoolPrivateEndpointSettingArrayInput` via: 

GetStreamPoolPrivateEndpointSettingArray{ GetStreamPoolPrivateEndpointSettingArgs{...} }

type GetStreamPoolPrivateEndpointSettingArrayOutput 

type GetStreamPoolPrivateEndpointSettingArrayOutput struct{ *pulumi.OutputState }

func (GetStreamPoolPrivateEndpointSettingArrayOutput) ElementType 

func (GetStreamPoolPrivateEndpointSettingArrayOutput) ElementType() reflect.Type

func (GetStreamPoolPrivateEndpointSettingArrayOutput) Index 

func (o GetStreamPoolPrivateEndpointSettingArrayOutput) Index(i pulumi.IntInput) GetStreamPoolPrivateEndpointSettingOutput

func (GetStreamPoolPrivateEndpointSettingArrayOutput) ToGetStreamPoolPrivateEndpointSettingArrayOutput 

func (o GetStreamPoolPrivateEndpointSettingArrayOutput) ToGetStreamPoolPrivateEndpointSettingArrayOutput() GetStreamPoolPrivateEndpointSettingArrayOutput

func (GetStreamPoolPrivateEndpointSettingArrayOutput) ToGetStreamPoolPrivateEndpointSettingArrayOutputWithContext 

func (o GetStreamPoolPrivateEndpointSettingArrayOutput) ToGetStreamPoolPrivateEndpointSettingArrayOutputWithContext(ctx context.Context) GetStreamPoolPrivateEndpointSettingArrayOutput

type GetStreamPoolPrivateEndpointSettingInput 

type GetStreamPoolPrivateEndpointSettingInput interface {
	pulumi.Input

	ToGetStreamPoolPrivateEndpointSettingOutput() GetStreamPoolPrivateEndpointSettingOutput
	ToGetStreamPoolPrivateEndpointSettingOutputWithContext(context.Context) GetStreamPoolPrivateEndpointSettingOutput
}

GetStreamPoolPrivateEndpointSettingInput is an input type that accepts GetStreamPoolPrivateEndpointSettingArgs and GetStreamPoolPrivateEndpointSettingOutput values. You can construct a concrete instance of `GetStreamPoolPrivateEndpointSettingInput` via: 

GetStreamPoolPrivateEndpointSettingArgs{...}

type GetStreamPoolPrivateEndpointSettingOutput 

type GetStreamPoolPrivateEndpointSettingOutput struct{ *pulumi.OutputState }

func (GetStreamPoolPrivateEndpointSettingOutput) ElementType 

func (GetStreamPoolPrivateEndpointSettingOutput) ElementType() reflect.Type

func (GetStreamPoolPrivateEndpointSettingOutput) NsgIds 

func (o GetStreamPoolPrivateEndpointSettingOutput) NsgIds() pulumi.StringArrayOutput

The optional list of network security groups that are associated with the private endpoint of the stream pool.

func (GetStreamPoolPrivateEndpointSettingOutput) PrivateEndpointIp 

func (o GetStreamPoolPrivateEndpointSettingOutput) PrivateEndpointIp() pulumi.StringOutput

The private IP associated with the stream pool in the associated subnetId. The stream pool's FQDN resolves to that IP and should be used - instead of the private IP - in order to not trigger any TLS issues.

func (GetStreamPoolPrivateEndpointSettingOutput) SubnetId 

func (o GetStreamPoolPrivateEndpointSettingOutput) SubnetId() pulumi.StringOutput

The subnet id from which the private stream pool can be accessed. Trying to access the streams from another network location will result in an error.

func (GetStreamPoolPrivateEndpointSettingOutput) ToGetStreamPoolPrivateEndpointSettingOutput 

func (o GetStreamPoolPrivateEndpointSettingOutput) ToGetStreamPoolPrivateEndpointSettingOutput() GetStreamPoolPrivateEndpointSettingOutput

func (GetStreamPoolPrivateEndpointSettingOutput) ToGetStreamPoolPrivateEndpointSettingOutputWithContext 

func (o GetStreamPoolPrivateEndpointSettingOutput) ToGetStreamPoolPrivateEndpointSettingOutputWithContext(ctx context.Context) GetStreamPoolPrivateEndpointSettingOutput

type GetStreamPoolsArgs 

type GetStreamPoolsArgs struct {
	// The OCID of the compartment.
	CompartmentId string                 `pulumi:"compartmentId"`
	Filters       []GetStreamPoolsFilter `pulumi:"filters"`
	// A filter to return only resources that match the given ID exactly.
	Id *string `pulumi:"id"`
	// A filter to return only resources that match the given name exactly.
	Name *string `pulumi:"name"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State *string `pulumi:"state"`
}

A collection of arguments for invoking getStreamPools.

type GetStreamPoolsFilter 

type GetStreamPoolsFilter struct {
	// A filter to return only resources that match the given name exactly.
	Name   string   `pulumi:"name"`
	Regex  *bool    `pulumi:"regex"`
	Values []string `pulumi:"values"`
}

type GetStreamPoolsFilterArgs 

type GetStreamPoolsFilterArgs struct {
	// A filter to return only resources that match the given name exactly.
	Name   pulumi.StringInput      `pulumi:"name"`
	Regex  pulumi.BoolPtrInput     `pulumi:"regex"`
	Values pulumi.StringArrayInput `pulumi:"values"`
}

func (GetStreamPoolsFilterArgs) ElementType 

func (GetStreamPoolsFilterArgs) ElementType() reflect.Type

func (GetStreamPoolsFilterArgs) ToGetStreamPoolsFilterOutput 

func (i GetStreamPoolsFilterArgs) ToGetStreamPoolsFilterOutput() GetStreamPoolsFilterOutput

func (GetStreamPoolsFilterArgs) ToGetStreamPoolsFilterOutputWithContext 

func (i GetStreamPoolsFilterArgs) ToGetStreamPoolsFilterOutputWithContext(ctx context.Context) GetStreamPoolsFilterOutput

type GetStreamPoolsFilterArray 

type GetStreamPoolsFilterArray []GetStreamPoolsFilterInput

func (GetStreamPoolsFilterArray) ElementType 

func (GetStreamPoolsFilterArray) ElementType() reflect.Type

func (GetStreamPoolsFilterArray) ToGetStreamPoolsFilterArrayOutput 

func (i GetStreamPoolsFilterArray) ToGetStreamPoolsFilterArrayOutput() GetStreamPoolsFilterArrayOutput

func (GetStreamPoolsFilterArray) ToGetStreamPoolsFilterArrayOutputWithContext 

func (i GetStreamPoolsFilterArray) ToGetStreamPoolsFilterArrayOutputWithContext(ctx context.Context) GetStreamPoolsFilterArrayOutput

type GetStreamPoolsFilterArrayInput 

type GetStreamPoolsFilterArrayInput interface {
	pulumi.Input

	ToGetStreamPoolsFilterArrayOutput() GetStreamPoolsFilterArrayOutput
	ToGetStreamPoolsFilterArrayOutputWithContext(context.Context) GetStreamPoolsFilterArrayOutput
}

GetStreamPoolsFilterArrayInput is an input type that accepts GetStreamPoolsFilterArray and GetStreamPoolsFilterArrayOutput values. You can construct a concrete instance of `GetStreamPoolsFilterArrayInput` via: 

GetStreamPoolsFilterArray{ GetStreamPoolsFilterArgs{...} }

type GetStreamPoolsFilterArrayOutput 

type GetStreamPoolsFilterArrayOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsFilterArrayOutput) ElementType 

func (GetStreamPoolsFilterArrayOutput) ElementType() reflect.Type

func (GetStreamPoolsFilterArrayOutput) Index 

func (o GetStreamPoolsFilterArrayOutput) Index(i pulumi.IntInput) GetStreamPoolsFilterOutput

func (GetStreamPoolsFilterArrayOutput) ToGetStreamPoolsFilterArrayOutput 

func (o GetStreamPoolsFilterArrayOutput) ToGetStreamPoolsFilterArrayOutput() GetStreamPoolsFilterArrayOutput

func (GetStreamPoolsFilterArrayOutput) ToGetStreamPoolsFilterArrayOutputWithContext 

func (o GetStreamPoolsFilterArrayOutput) ToGetStreamPoolsFilterArrayOutputWithContext(ctx context.Context) GetStreamPoolsFilterArrayOutput

type GetStreamPoolsFilterInput 

type GetStreamPoolsFilterInput interface {
	pulumi.Input

	ToGetStreamPoolsFilterOutput() GetStreamPoolsFilterOutput
	ToGetStreamPoolsFilterOutputWithContext(context.Context) GetStreamPoolsFilterOutput
}

GetStreamPoolsFilterInput is an input type that accepts GetStreamPoolsFilterArgs and GetStreamPoolsFilterOutput values. You can construct a concrete instance of `GetStreamPoolsFilterInput` via: 

GetStreamPoolsFilterArgs{...}

type GetStreamPoolsFilterOutput 

type GetStreamPoolsFilterOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsFilterOutput) ElementType 

func (GetStreamPoolsFilterOutput) ElementType() reflect.Type

func (GetStreamPoolsFilterOutput) Name 

func (o GetStreamPoolsFilterOutput) Name() pulumi.StringOutput

A filter to return only resources that match the given name exactly.

func (GetStreamPoolsFilterOutput) Regex 

func (o GetStreamPoolsFilterOutput) Regex() pulumi.BoolPtrOutput

func (GetStreamPoolsFilterOutput) ToGetStreamPoolsFilterOutput 

func (o GetStreamPoolsFilterOutput) ToGetStreamPoolsFilterOutput() GetStreamPoolsFilterOutput

func (GetStreamPoolsFilterOutput) ToGetStreamPoolsFilterOutputWithContext 

func (o GetStreamPoolsFilterOutput) ToGetStreamPoolsFilterOutputWithContext(ctx context.Context) GetStreamPoolsFilterOutput

func (GetStreamPoolsFilterOutput) Values 

func (o GetStreamPoolsFilterOutput) Values() pulumi.StringArrayOutput

type GetStreamPoolsOutputArgs 

type GetStreamPoolsOutputArgs struct {
	// The OCID of the compartment.
	CompartmentId pulumi.StringInput             `pulumi:"compartmentId"`
	Filters       GetStreamPoolsFilterArrayInput `pulumi:"filters"`
	// A filter to return only resources that match the given ID exactly.
	Id pulumi.StringPtrInput `pulumi:"id"`
	// A filter to return only resources that match the given name exactly.
	Name pulumi.StringPtrInput `pulumi:"name"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State pulumi.StringPtrInput `pulumi:"state"`
}

A collection of arguments for invoking getStreamPools.

func (GetStreamPoolsOutputArgs) ElementType 

func (GetStreamPoolsOutputArgs) ElementType() reflect.Type

type GetStreamPoolsResult 

type GetStreamPoolsResult struct {
	// Compartment OCID that the pool belongs to.
	CompartmentId string                 `pulumi:"compartmentId"`
	Filters       []GetStreamPoolsFilter `pulumi:"filters"`
	// The OCID of the stream pool.
	Id *string `pulumi:"id"`
	// The name of the stream pool.
	Name *string `pulumi:"name"`
	// The current state of the stream pool.
	State *string `pulumi:"state"`
	// The list of stream_pools.
	StreamPools []GetStreamPoolsStreamPool `pulumi:"streamPools"`
}

A collection of values returned by getStreamPools.

func GetStreamPools 

func GetStreamPools(ctx *pulumi.Context, args *GetStreamPoolsArgs, opts ...pulumi.InvokeOption) (*GetStreamPoolsResult, error)

This data source provides the list of Stream Pools in Oracle Cloud Infrastructure Streaming service.

List the stream pools for a given compartment ID.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-oci/sdk/go/oci/Streaming"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Streaming.GetStreamPools(ctx, &streaming.GetStreamPoolsArgs{
			CompartmentId: compartmentId,
			Id:            pulumi.StringRef(streamPoolId),
			Name:          pulumi.StringRef(streamPoolName),
			State:         pulumi.StringRef(streamPoolState),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetStreamPoolsResultOutput 

type GetStreamPoolsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getStreamPools.

func GetStreamPoolsOutput 

func GetStreamPoolsOutput(ctx *pulumi.Context, args GetStreamPoolsOutputArgs, opts ...pulumi.InvokeOption) GetStreamPoolsResultOutput

func (GetStreamPoolsResultOutput) CompartmentId 

func (o GetStreamPoolsResultOutput) CompartmentId() pulumi.StringOutput

Compartment OCID that the pool belongs to.

func (GetStreamPoolsResultOutput) ElementType 

func (GetStreamPoolsResultOutput) ElementType() reflect.Type

func (GetStreamPoolsResultOutput) Filters 

func (o GetStreamPoolsResultOutput) Filters() GetStreamPoolsFilterArrayOutput

func (GetStreamPoolsResultOutput) Id 

func (o GetStreamPoolsResultOutput) Id() pulumi.StringPtrOutput

The OCID of the stream pool.

func (GetStreamPoolsResultOutput) Name 

func (o GetStreamPoolsResultOutput) Name() pulumi.StringPtrOutput

The name of the stream pool.

func (GetStreamPoolsResultOutput) State 

func (o GetStreamPoolsResultOutput) State() pulumi.StringPtrOutput

The current state of the stream pool.

func (GetStreamPoolsResultOutput) StreamPools 

func (o GetStreamPoolsResultOutput) StreamPools() GetStreamPoolsStreamPoolArrayOutput

The list of stream_pools.

func (GetStreamPoolsResultOutput) ToGetStreamPoolsResultOutput 

func (o GetStreamPoolsResultOutput) ToGetStreamPoolsResultOutput() GetStreamPoolsResultOutput

func (GetStreamPoolsResultOutput) ToGetStreamPoolsResultOutputWithContext 

func (o GetStreamPoolsResultOutput) ToGetStreamPoolsResultOutputWithContext(ctx context.Context) GetStreamPoolsResultOutput

type GetStreamPoolsStreamPool 

type GetStreamPoolsStreamPool struct {
	// The OCID of the compartment.
	CompartmentId string `pulumi:"compartmentId"`
	// Custom Encryption Key which will be used for encryption by all the streams in the pool.
	CustomEncryptionKeys []GetStreamPoolsStreamPoolCustomEncryptionKey `pulumi:"customEncryptionKeys"`
	// Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations": {"CostCenter": "42"}}'
	DefinedTags map[string]interface{} `pulumi:"definedTags"`
	// The FQDN used to access the streams inside the stream pool (same FQDN as the messagesEndpoint attribute of a [Stream](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream) object). If the stream pool is private, the FQDN is customized and can only be accessed from inside the associated subnetId, otherwise the FQDN is publicly resolvable. Depending on which protocol you attempt to use, you need to either prepend https or append the Kafka port.
	EndpointFqdn string `pulumi:"endpointFqdn"`
	// Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags map[string]interface{} `pulumi:"freeformTags"`
	// A filter to return only resources that match the given ID exactly.
	Id string `pulumi:"id"`
	// True if the stream pool is private, false otherwise. The associated endpoint and subnetId of a private stream pool can be retrieved through the [GetStreamPool](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/StreamPool/GetStreamPool) API.
	IsPrivate bool `pulumi:"isPrivate"`
	// Settings for the Kafka compatibility layer.
	KafkaSettings []GetStreamPoolsStreamPoolKafkaSetting `pulumi:"kafkaSettings"`
	// Any additional details about the current state of the stream.
	LifecycleStateDetails string `pulumi:"lifecycleStateDetails"`
	// A filter to return only resources that match the given name exactly.
	Name string `pulumi:"name"`
	// Optional settings if the stream pool is private.
	PrivateEndpointSettings []GetStreamPoolsStreamPoolPrivateEndpointSetting `pulumi:"privateEndpointSettings"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State string `pulumi:"state"`
	// The date and time the stream pool was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated string `pulumi:"timeCreated"`
}

type GetStreamPoolsStreamPoolArgs 

type GetStreamPoolsStreamPoolArgs struct {
	// The OCID of the compartment.
	CompartmentId pulumi.StringInput `pulumi:"compartmentId"`
	// Custom Encryption Key which will be used for encryption by all the streams in the pool.
	CustomEncryptionKeys GetStreamPoolsStreamPoolCustomEncryptionKeyArrayInput `pulumi:"customEncryptionKeys"`
	// Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations": {"CostCenter": "42"}}'
	DefinedTags pulumi.MapInput `pulumi:"definedTags"`
	// The FQDN used to access the streams inside the stream pool (same FQDN as the messagesEndpoint attribute of a [Stream](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream) object). If the stream pool is private, the FQDN is customized and can only be accessed from inside the associated subnetId, otherwise the FQDN is publicly resolvable. Depending on which protocol you attempt to use, you need to either prepend https or append the Kafka port.
	EndpointFqdn pulumi.StringInput `pulumi:"endpointFqdn"`
	// Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapInput `pulumi:"freeformTags"`
	// A filter to return only resources that match the given ID exactly.
	Id pulumi.StringInput `pulumi:"id"`
	// True if the stream pool is private, false otherwise. The associated endpoint and subnetId of a private stream pool can be retrieved through the [GetStreamPool](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/StreamPool/GetStreamPool) API.
	IsPrivate pulumi.BoolInput `pulumi:"isPrivate"`
	// Settings for the Kafka compatibility layer.
	KafkaSettings GetStreamPoolsStreamPoolKafkaSettingArrayInput `pulumi:"kafkaSettings"`
	// Any additional details about the current state of the stream.
	LifecycleStateDetails pulumi.StringInput `pulumi:"lifecycleStateDetails"`
	// A filter to return only resources that match the given name exactly.
	Name pulumi.StringInput `pulumi:"name"`
	// Optional settings if the stream pool is private.
	PrivateEndpointSettings GetStreamPoolsStreamPoolPrivateEndpointSettingArrayInput `pulumi:"privateEndpointSettings"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State pulumi.StringInput `pulumi:"state"`
	// The date and time the stream pool was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated pulumi.StringInput `pulumi:"timeCreated"`
}

func (GetStreamPoolsStreamPoolArgs) ElementType 

func (GetStreamPoolsStreamPoolArgs) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolArgs) ToGetStreamPoolsStreamPoolOutput 

func (i GetStreamPoolsStreamPoolArgs) ToGetStreamPoolsStreamPoolOutput() GetStreamPoolsStreamPoolOutput

func (GetStreamPoolsStreamPoolArgs) ToGetStreamPoolsStreamPoolOutputWithContext 

func (i GetStreamPoolsStreamPoolArgs) ToGetStreamPoolsStreamPoolOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolOutput

type GetStreamPoolsStreamPoolArray 

type GetStreamPoolsStreamPoolArray []GetStreamPoolsStreamPoolInput

func (GetStreamPoolsStreamPoolArray) ElementType 

func (GetStreamPoolsStreamPoolArray) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolArray) ToGetStreamPoolsStreamPoolArrayOutput 

func (i GetStreamPoolsStreamPoolArray) ToGetStreamPoolsStreamPoolArrayOutput() GetStreamPoolsStreamPoolArrayOutput

func (GetStreamPoolsStreamPoolArray) ToGetStreamPoolsStreamPoolArrayOutputWithContext 

func (i GetStreamPoolsStreamPoolArray) ToGetStreamPoolsStreamPoolArrayOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolArrayOutput

type GetStreamPoolsStreamPoolArrayInput 

type GetStreamPoolsStreamPoolArrayInput interface {
	pulumi.Input

	ToGetStreamPoolsStreamPoolArrayOutput() GetStreamPoolsStreamPoolArrayOutput
	ToGetStreamPoolsStreamPoolArrayOutputWithContext(context.Context) GetStreamPoolsStreamPoolArrayOutput
}

GetStreamPoolsStreamPoolArrayInput is an input type that accepts GetStreamPoolsStreamPoolArray and GetStreamPoolsStreamPoolArrayOutput values. You can construct a concrete instance of `GetStreamPoolsStreamPoolArrayInput` via: 

GetStreamPoolsStreamPoolArray{ GetStreamPoolsStreamPoolArgs{...} }

type GetStreamPoolsStreamPoolArrayOutput 

type GetStreamPoolsStreamPoolArrayOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsStreamPoolArrayOutput) ElementType 

func (GetStreamPoolsStreamPoolArrayOutput) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolArrayOutput) Index 

func (o GetStreamPoolsStreamPoolArrayOutput) Index(i pulumi.IntInput) GetStreamPoolsStreamPoolOutput

func (GetStreamPoolsStreamPoolArrayOutput) ToGetStreamPoolsStreamPoolArrayOutput 

func (o GetStreamPoolsStreamPoolArrayOutput) ToGetStreamPoolsStreamPoolArrayOutput() GetStreamPoolsStreamPoolArrayOutput

func (GetStreamPoolsStreamPoolArrayOutput) ToGetStreamPoolsStreamPoolArrayOutputWithContext 

func (o GetStreamPoolsStreamPoolArrayOutput) ToGetStreamPoolsStreamPoolArrayOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolArrayOutput

type GetStreamPoolsStreamPoolCustomEncryptionKey 

type GetStreamPoolsStreamPoolCustomEncryptionKey struct {
	// Life cycle State of the custom key
	KeyState string `pulumi:"keyState"`
	// Custom Encryption Key (Master Key) ocid.
	KmsKeyId string `pulumi:"kmsKeyId"`
}

type GetStreamPoolsStreamPoolCustomEncryptionKeyArgs 

type GetStreamPoolsStreamPoolCustomEncryptionKeyArgs struct {
	// Life cycle State of the custom key
	KeyState pulumi.StringInput `pulumi:"keyState"`
	// Custom Encryption Key (Master Key) ocid.
	KmsKeyId pulumi.StringInput `pulumi:"kmsKeyId"`
}

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArgs) ElementType 

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArgs) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArgs) ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutput 

func (i GetStreamPoolsStreamPoolCustomEncryptionKeyArgs) ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutput() GetStreamPoolsStreamPoolCustomEncryptionKeyOutput

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArgs) ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutputWithContext 

func (i GetStreamPoolsStreamPoolCustomEncryptionKeyArgs) ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolCustomEncryptionKeyOutput

type GetStreamPoolsStreamPoolCustomEncryptionKeyArray 

type GetStreamPoolsStreamPoolCustomEncryptionKeyArray []GetStreamPoolsStreamPoolCustomEncryptionKeyInput

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArray) ElementType 

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArray) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArray) ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput 

func (i GetStreamPoolsStreamPoolCustomEncryptionKeyArray) ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput() GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArray) ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutputWithContext 

func (i GetStreamPoolsStreamPoolCustomEncryptionKeyArray) ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput

type GetStreamPoolsStreamPoolCustomEncryptionKeyArrayInput 

type GetStreamPoolsStreamPoolCustomEncryptionKeyArrayInput interface {
	pulumi.Input

	ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput() GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput
	ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutputWithContext(context.Context) GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput
}

GetStreamPoolsStreamPoolCustomEncryptionKeyArrayInput is an input type that accepts GetStreamPoolsStreamPoolCustomEncryptionKeyArray and GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput values. You can construct a concrete instance of `GetStreamPoolsStreamPoolCustomEncryptionKeyArrayInput` via: 

GetStreamPoolsStreamPoolCustomEncryptionKeyArray{ GetStreamPoolsStreamPoolCustomEncryptionKeyArgs{...} }

type GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput 

type GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput) ElementType 

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput) Index 

func (o GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput) Index(i pulumi.IntInput) GetStreamPoolsStreamPoolCustomEncryptionKeyOutput

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput) ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput 

func (o GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput) ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput() GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput

func (GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput) ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutputWithContext 

func (o GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput) ToGetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput

type GetStreamPoolsStreamPoolCustomEncryptionKeyInput 

type GetStreamPoolsStreamPoolCustomEncryptionKeyInput interface {
	pulumi.Input

	ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutput() GetStreamPoolsStreamPoolCustomEncryptionKeyOutput
	ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutputWithContext(context.Context) GetStreamPoolsStreamPoolCustomEncryptionKeyOutput
}

GetStreamPoolsStreamPoolCustomEncryptionKeyInput is an input type that accepts GetStreamPoolsStreamPoolCustomEncryptionKeyArgs and GetStreamPoolsStreamPoolCustomEncryptionKeyOutput values. You can construct a concrete instance of `GetStreamPoolsStreamPoolCustomEncryptionKeyInput` via: 

GetStreamPoolsStreamPoolCustomEncryptionKeyArgs{...}

type GetStreamPoolsStreamPoolCustomEncryptionKeyOutput 

type GetStreamPoolsStreamPoolCustomEncryptionKeyOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) ElementType 

func (GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) KeyState 

func (o GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) KeyState() pulumi.StringOutput

Life cycle State of the custom key

func (GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) KmsKeyId 

func (o GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) KmsKeyId() pulumi.StringOutput

Custom Encryption Key (Master Key) ocid.

func (GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutput 

func (o GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutput() GetStreamPoolsStreamPoolCustomEncryptionKeyOutput

func (GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutputWithContext 

func (o GetStreamPoolsStreamPoolCustomEncryptionKeyOutput) ToGetStreamPoolsStreamPoolCustomEncryptionKeyOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolCustomEncryptionKeyOutput

type GetStreamPoolsStreamPoolInput 

type GetStreamPoolsStreamPoolInput interface {
	pulumi.Input

	ToGetStreamPoolsStreamPoolOutput() GetStreamPoolsStreamPoolOutput
	ToGetStreamPoolsStreamPoolOutputWithContext(context.Context) GetStreamPoolsStreamPoolOutput
}

GetStreamPoolsStreamPoolInput is an input type that accepts GetStreamPoolsStreamPoolArgs and GetStreamPoolsStreamPoolOutput values. You can construct a concrete instance of `GetStreamPoolsStreamPoolInput` via: 

GetStreamPoolsStreamPoolArgs{...}

type GetStreamPoolsStreamPoolKafkaSetting 

type GetStreamPoolsStreamPoolKafkaSetting struct {
	// Enable auto creation of topic on the server.
	AutoCreateTopicsEnable bool `pulumi:"autoCreateTopicsEnable"`
	// Bootstrap servers.
	BootstrapServers string `pulumi:"bootstrapServers"`
	// The number of hours to keep a log file before deleting it (in hours).
	LogRetentionHours int `pulumi:"logRetentionHours"`
	// The default number of log partitions per topic.
	NumPartitions int `pulumi:"numPartitions"`
}

type GetStreamPoolsStreamPoolKafkaSettingArgs 

type GetStreamPoolsStreamPoolKafkaSettingArgs struct {
	// Enable auto creation of topic on the server.
	AutoCreateTopicsEnable pulumi.BoolInput `pulumi:"autoCreateTopicsEnable"`
	// Bootstrap servers.
	BootstrapServers pulumi.StringInput `pulumi:"bootstrapServers"`
	// The number of hours to keep a log file before deleting it (in hours).
	LogRetentionHours pulumi.IntInput `pulumi:"logRetentionHours"`
	// The default number of log partitions per topic.
	NumPartitions pulumi.IntInput `pulumi:"numPartitions"`
}

func (GetStreamPoolsStreamPoolKafkaSettingArgs) ElementType 

func (GetStreamPoolsStreamPoolKafkaSettingArgs) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolKafkaSettingArgs) ToGetStreamPoolsStreamPoolKafkaSettingOutput 

func (i GetStreamPoolsStreamPoolKafkaSettingArgs) ToGetStreamPoolsStreamPoolKafkaSettingOutput() GetStreamPoolsStreamPoolKafkaSettingOutput

func (GetStreamPoolsStreamPoolKafkaSettingArgs) ToGetStreamPoolsStreamPoolKafkaSettingOutputWithContext 

func (i GetStreamPoolsStreamPoolKafkaSettingArgs) ToGetStreamPoolsStreamPoolKafkaSettingOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolKafkaSettingOutput

type GetStreamPoolsStreamPoolKafkaSettingArray 

type GetStreamPoolsStreamPoolKafkaSettingArray []GetStreamPoolsStreamPoolKafkaSettingInput

func (GetStreamPoolsStreamPoolKafkaSettingArray) ElementType 

func (GetStreamPoolsStreamPoolKafkaSettingArray) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolKafkaSettingArray) ToGetStreamPoolsStreamPoolKafkaSettingArrayOutput 

func (i GetStreamPoolsStreamPoolKafkaSettingArray) ToGetStreamPoolsStreamPoolKafkaSettingArrayOutput() GetStreamPoolsStreamPoolKafkaSettingArrayOutput

func (GetStreamPoolsStreamPoolKafkaSettingArray) ToGetStreamPoolsStreamPoolKafkaSettingArrayOutputWithContext 

func (i GetStreamPoolsStreamPoolKafkaSettingArray) ToGetStreamPoolsStreamPoolKafkaSettingArrayOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolKafkaSettingArrayOutput

type GetStreamPoolsStreamPoolKafkaSettingArrayInput 

type GetStreamPoolsStreamPoolKafkaSettingArrayInput interface {
	pulumi.Input

	ToGetStreamPoolsStreamPoolKafkaSettingArrayOutput() GetStreamPoolsStreamPoolKafkaSettingArrayOutput
	ToGetStreamPoolsStreamPoolKafkaSettingArrayOutputWithContext(context.Context) GetStreamPoolsStreamPoolKafkaSettingArrayOutput
}

GetStreamPoolsStreamPoolKafkaSettingArrayInput is an input type that accepts GetStreamPoolsStreamPoolKafkaSettingArray and GetStreamPoolsStreamPoolKafkaSettingArrayOutput values. You can construct a concrete instance of `GetStreamPoolsStreamPoolKafkaSettingArrayInput` via: 

GetStreamPoolsStreamPoolKafkaSettingArray{ GetStreamPoolsStreamPoolKafkaSettingArgs{...} }

type GetStreamPoolsStreamPoolKafkaSettingArrayOutput 

type GetStreamPoolsStreamPoolKafkaSettingArrayOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsStreamPoolKafkaSettingArrayOutput) ElementType 

func (GetStreamPoolsStreamPoolKafkaSettingArrayOutput) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolKafkaSettingArrayOutput) Index 

func (o GetStreamPoolsStreamPoolKafkaSettingArrayOutput) Index(i pulumi.IntInput) GetStreamPoolsStreamPoolKafkaSettingOutput

func (GetStreamPoolsStreamPoolKafkaSettingArrayOutput) ToGetStreamPoolsStreamPoolKafkaSettingArrayOutput 

func (o GetStreamPoolsStreamPoolKafkaSettingArrayOutput) ToGetStreamPoolsStreamPoolKafkaSettingArrayOutput() GetStreamPoolsStreamPoolKafkaSettingArrayOutput

func (GetStreamPoolsStreamPoolKafkaSettingArrayOutput) ToGetStreamPoolsStreamPoolKafkaSettingArrayOutputWithContext 

func (o GetStreamPoolsStreamPoolKafkaSettingArrayOutput) ToGetStreamPoolsStreamPoolKafkaSettingArrayOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolKafkaSettingArrayOutput

type GetStreamPoolsStreamPoolKafkaSettingInput 

type GetStreamPoolsStreamPoolKafkaSettingInput interface {
	pulumi.Input

	ToGetStreamPoolsStreamPoolKafkaSettingOutput() GetStreamPoolsStreamPoolKafkaSettingOutput
	ToGetStreamPoolsStreamPoolKafkaSettingOutputWithContext(context.Context) GetStreamPoolsStreamPoolKafkaSettingOutput
}

GetStreamPoolsStreamPoolKafkaSettingInput is an input type that accepts GetStreamPoolsStreamPoolKafkaSettingArgs and GetStreamPoolsStreamPoolKafkaSettingOutput values. You can construct a concrete instance of `GetStreamPoolsStreamPoolKafkaSettingInput` via: 

GetStreamPoolsStreamPoolKafkaSettingArgs{...}

type GetStreamPoolsStreamPoolKafkaSettingOutput 

type GetStreamPoolsStreamPoolKafkaSettingOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsStreamPoolKafkaSettingOutput) AutoCreateTopicsEnable 

func (o GetStreamPoolsStreamPoolKafkaSettingOutput) AutoCreateTopicsEnable() pulumi.BoolOutput

Enable auto creation of topic on the server.

func (GetStreamPoolsStreamPoolKafkaSettingOutput) BootstrapServers 

func (o GetStreamPoolsStreamPoolKafkaSettingOutput) BootstrapServers() pulumi.StringOutput

Bootstrap servers.

func (GetStreamPoolsStreamPoolKafkaSettingOutput) ElementType 

func (GetStreamPoolsStreamPoolKafkaSettingOutput) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolKafkaSettingOutput) LogRetentionHours 

func (o GetStreamPoolsStreamPoolKafkaSettingOutput) LogRetentionHours() pulumi.IntOutput

The number of hours to keep a log file before deleting it (in hours).

func (GetStreamPoolsStreamPoolKafkaSettingOutput) NumPartitions 

func (o GetStreamPoolsStreamPoolKafkaSettingOutput) NumPartitions() pulumi.IntOutput

The default number of log partitions per topic.

func (GetStreamPoolsStreamPoolKafkaSettingOutput) ToGetStreamPoolsStreamPoolKafkaSettingOutput 

func (o GetStreamPoolsStreamPoolKafkaSettingOutput) ToGetStreamPoolsStreamPoolKafkaSettingOutput() GetStreamPoolsStreamPoolKafkaSettingOutput

func (GetStreamPoolsStreamPoolKafkaSettingOutput) ToGetStreamPoolsStreamPoolKafkaSettingOutputWithContext 

func (o GetStreamPoolsStreamPoolKafkaSettingOutput) ToGetStreamPoolsStreamPoolKafkaSettingOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolKafkaSettingOutput

type GetStreamPoolsStreamPoolOutput 

type GetStreamPoolsStreamPoolOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsStreamPoolOutput) CompartmentId 

func (o GetStreamPoolsStreamPoolOutput) CompartmentId() pulumi.StringOutput

The OCID of the compartment.

func (GetStreamPoolsStreamPoolOutput) CustomEncryptionKeys 

func (o GetStreamPoolsStreamPoolOutput) CustomEncryptionKeys() GetStreamPoolsStreamPoolCustomEncryptionKeyArrayOutput

Custom Encryption Key which will be used for encryption by all the streams in the pool.

func (GetStreamPoolsStreamPoolOutput) DefinedTags 

func (o GetStreamPoolsStreamPoolOutput) DefinedTags() pulumi.MapOutput

Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Operations": {"CostCenter": "42"}}'

func (GetStreamPoolsStreamPoolOutput) ElementType 

func (GetStreamPoolsStreamPoolOutput) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolOutput) EndpointFqdn 

func (o GetStreamPoolsStreamPoolOutput) EndpointFqdn() pulumi.StringOutput

The FQDN used to access the streams inside the stream pool (same FQDN as the messagesEndpoint attribute of a Stream(https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream) object). If the stream pool is private, the FQDN is customized and can only be accessed from inside the associated subnetId, otherwise the FQDN is publicly resolvable. Depending on which protocol you attempt to use, you need to either prepend https or append the Kafka port.

func (GetStreamPoolsStreamPoolOutput) FreeformTags 

func (o GetStreamPoolsStreamPoolOutput) FreeformTags() pulumi.MapOutput

Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Department": "Finance"}`

func (GetStreamPoolsStreamPoolOutput) Id 

func (o GetStreamPoolsStreamPoolOutput) Id() pulumi.StringOutput

A filter to return only resources that match the given ID exactly.

func (GetStreamPoolsStreamPoolOutput) IsPrivate 

func (o GetStreamPoolsStreamPoolOutput) IsPrivate() pulumi.BoolOutput

True if the stream pool is private, false otherwise. The associated endpoint and subnetId of a private stream pool can be retrieved through the GetStreamPool(https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/StreamPool/GetStreamPool) API.

func (GetStreamPoolsStreamPoolOutput) KafkaSettings 

func (o GetStreamPoolsStreamPoolOutput) KafkaSettings() GetStreamPoolsStreamPoolKafkaSettingArrayOutput

Settings for the Kafka compatibility layer.

func (GetStreamPoolsStreamPoolOutput) LifecycleStateDetails 

func (o GetStreamPoolsStreamPoolOutput) LifecycleStateDetails() pulumi.StringOutput

Any additional details about the current state of the stream.

func (GetStreamPoolsStreamPoolOutput) Name 

func (o GetStreamPoolsStreamPoolOutput) Name() pulumi.StringOutput

A filter to return only resources that match the given name exactly.

func (GetStreamPoolsStreamPoolOutput) PrivateEndpointSettings 

func (o GetStreamPoolsStreamPoolOutput) PrivateEndpointSettings() GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput

Optional settings if the stream pool is private.

func (GetStreamPoolsStreamPoolOutput) State 

func (o GetStreamPoolsStreamPoolOutput) State() pulumi.StringOutput

A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.

func (GetStreamPoolsStreamPoolOutput) TimeCreated 

func (o GetStreamPoolsStreamPoolOutput) TimeCreated() pulumi.StringOutput

The date and time the stream pool was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format. Example: `2018-04-20T00:00:07.405Z`

func (GetStreamPoolsStreamPoolOutput) ToGetStreamPoolsStreamPoolOutput 

func (o GetStreamPoolsStreamPoolOutput) ToGetStreamPoolsStreamPoolOutput() GetStreamPoolsStreamPoolOutput

func (GetStreamPoolsStreamPoolOutput) ToGetStreamPoolsStreamPoolOutputWithContext 

func (o GetStreamPoolsStreamPoolOutput) ToGetStreamPoolsStreamPoolOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolOutput

type GetStreamPoolsStreamPoolPrivateEndpointSetting 

type GetStreamPoolsStreamPoolPrivateEndpointSetting struct {
	// The optional list of network security groups that are associated with the private endpoint of the stream pool.
	NsgIds []string `pulumi:"nsgIds"`
	// The private IP associated with the stream pool in the associated subnetId. The stream pool's FQDN resolves to that IP and should be used - instead of the private IP - in order to not trigger any TLS issues.
	PrivateEndpointIp string `pulumi:"privateEndpointIp"`
	// The subnet id from which the private stream pool can be accessed. Trying to access the streams from another network location will result in an error.
	SubnetId string `pulumi:"subnetId"`
}

type GetStreamPoolsStreamPoolPrivateEndpointSettingArgs 

type GetStreamPoolsStreamPoolPrivateEndpointSettingArgs struct {
	// The optional list of network security groups that are associated with the private endpoint of the stream pool.
	NsgIds pulumi.StringArrayInput `pulumi:"nsgIds"`
	// The private IP associated with the stream pool in the associated subnetId. The stream pool's FQDN resolves to that IP and should be used - instead of the private IP - in order to not trigger any TLS issues.
	PrivateEndpointIp pulumi.StringInput `pulumi:"privateEndpointIp"`
	// The subnet id from which the private stream pool can be accessed. Trying to access the streams from another network location will result in an error.
	SubnetId pulumi.StringInput `pulumi:"subnetId"`
}

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArgs) ElementType 

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArgs) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArgs) ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutput 

func (i GetStreamPoolsStreamPoolPrivateEndpointSettingArgs) ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutput() GetStreamPoolsStreamPoolPrivateEndpointSettingOutput

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArgs) ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutputWithContext 

func (i GetStreamPoolsStreamPoolPrivateEndpointSettingArgs) ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolPrivateEndpointSettingOutput

type GetStreamPoolsStreamPoolPrivateEndpointSettingArray 

type GetStreamPoolsStreamPoolPrivateEndpointSettingArray []GetStreamPoolsStreamPoolPrivateEndpointSettingInput

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArray) ElementType 

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArray) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArray) ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput 

func (i GetStreamPoolsStreamPoolPrivateEndpointSettingArray) ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput() GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArray) ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutputWithContext 

func (i GetStreamPoolsStreamPoolPrivateEndpointSettingArray) ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput

type GetStreamPoolsStreamPoolPrivateEndpointSettingArrayInput 

type GetStreamPoolsStreamPoolPrivateEndpointSettingArrayInput interface {
	pulumi.Input

	ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput() GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput
	ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutputWithContext(context.Context) GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput
}

GetStreamPoolsStreamPoolPrivateEndpointSettingArrayInput is an input type that accepts GetStreamPoolsStreamPoolPrivateEndpointSettingArray and GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput values. You can construct a concrete instance of `GetStreamPoolsStreamPoolPrivateEndpointSettingArrayInput` via: 

GetStreamPoolsStreamPoolPrivateEndpointSettingArray{ GetStreamPoolsStreamPoolPrivateEndpointSettingArgs{...} }

type GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput 

type GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput) ElementType 

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput) Index 

func (o GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput) Index(i pulumi.IntInput) GetStreamPoolsStreamPoolPrivateEndpointSettingOutput

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput) ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput 

func (o GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput) ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput() GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput

func (GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput) ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutputWithContext 

func (o GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput) ToGetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolPrivateEndpointSettingArrayOutput

type GetStreamPoolsStreamPoolPrivateEndpointSettingInput 

type GetStreamPoolsStreamPoolPrivateEndpointSettingInput interface {
	pulumi.Input

	ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutput() GetStreamPoolsStreamPoolPrivateEndpointSettingOutput
	ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutputWithContext(context.Context) GetStreamPoolsStreamPoolPrivateEndpointSettingOutput
}

GetStreamPoolsStreamPoolPrivateEndpointSettingInput is an input type that accepts GetStreamPoolsStreamPoolPrivateEndpointSettingArgs and GetStreamPoolsStreamPoolPrivateEndpointSettingOutput values. You can construct a concrete instance of `GetStreamPoolsStreamPoolPrivateEndpointSettingInput` via: 

GetStreamPoolsStreamPoolPrivateEndpointSettingArgs{...}

type GetStreamPoolsStreamPoolPrivateEndpointSettingOutput 

type GetStreamPoolsStreamPoolPrivateEndpointSettingOutput struct{ *pulumi.OutputState }

func (GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) ElementType 

func (GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) ElementType() reflect.Type

func (GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) NsgIds 

func (o GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) NsgIds() pulumi.StringArrayOutput

The optional list of network security groups that are associated with the private endpoint of the stream pool.

func (GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) PrivateEndpointIp 

func (o GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) PrivateEndpointIp() pulumi.StringOutput

The private IP associated with the stream pool in the associated subnetId. The stream pool's FQDN resolves to that IP and should be used - instead of the private IP - in order to not trigger any TLS issues.

func (GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) SubnetId 

func (o GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) SubnetId() pulumi.StringOutput

The subnet id from which the private stream pool can be accessed. Trying to access the streams from another network location will result in an error.

func (GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutput 

func (o GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutput() GetStreamPoolsStreamPoolPrivateEndpointSettingOutput

func (GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutputWithContext 

func (o GetStreamPoolsStreamPoolPrivateEndpointSettingOutput) ToGetStreamPoolsStreamPoolPrivateEndpointSettingOutputWithContext(ctx context.Context) GetStreamPoolsStreamPoolPrivateEndpointSettingOutput

type GetStreamsArgs 

type GetStreamsArgs struct {
	// The OCID of the compartment. Is exclusive with the `streamPoolId` parameter. One of them is required.
	CompartmentId *string            `pulumi:"compartmentId"`
	Filters       []GetStreamsFilter `pulumi:"filters"`
	// A filter to return only resources that match the given ID exactly.
	Id *string `pulumi:"id"`
	// A filter to return only resources that match the given name exactly.
	Name *string `pulumi:"name"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State *string `pulumi:"state"`
	// The OCID of the stream pool. Is exclusive with the `compartmentId` parameter. One of them is required.
	StreamPoolId *string `pulumi:"streamPoolId"`
}

A collection of arguments for invoking getStreams.

type GetStreamsFilter 

type GetStreamsFilter struct {
	// A filter to return only resources that match the given name exactly.
	Name   string   `pulumi:"name"`
	Regex  *bool    `pulumi:"regex"`
	Values []string `pulumi:"values"`
}

type GetStreamsFilterArgs 

type GetStreamsFilterArgs struct {
	// A filter to return only resources that match the given name exactly.
	Name   pulumi.StringInput      `pulumi:"name"`
	Regex  pulumi.BoolPtrInput     `pulumi:"regex"`
	Values pulumi.StringArrayInput `pulumi:"values"`
}

func (GetStreamsFilterArgs) ElementType 

func (GetStreamsFilterArgs) ElementType() reflect.Type

func (GetStreamsFilterArgs) ToGetStreamsFilterOutput 

func (i GetStreamsFilterArgs) ToGetStreamsFilterOutput() GetStreamsFilterOutput

func (GetStreamsFilterArgs) ToGetStreamsFilterOutputWithContext 

func (i GetStreamsFilterArgs) ToGetStreamsFilterOutputWithContext(ctx context.Context) GetStreamsFilterOutput

type GetStreamsFilterArray 

type GetStreamsFilterArray []GetStreamsFilterInput

func (GetStreamsFilterArray) ElementType 

func (GetStreamsFilterArray) ElementType() reflect.Type

func (GetStreamsFilterArray) ToGetStreamsFilterArrayOutput 

func (i GetStreamsFilterArray) ToGetStreamsFilterArrayOutput() GetStreamsFilterArrayOutput

func (GetStreamsFilterArray) ToGetStreamsFilterArrayOutputWithContext 

func (i GetStreamsFilterArray) ToGetStreamsFilterArrayOutputWithContext(ctx context.Context) GetStreamsFilterArrayOutput

type GetStreamsFilterArrayInput 

type GetStreamsFilterArrayInput interface {
	pulumi.Input

	ToGetStreamsFilterArrayOutput() GetStreamsFilterArrayOutput
	ToGetStreamsFilterArrayOutputWithContext(context.Context) GetStreamsFilterArrayOutput
}

GetStreamsFilterArrayInput is an input type that accepts GetStreamsFilterArray and GetStreamsFilterArrayOutput values. You can construct a concrete instance of `GetStreamsFilterArrayInput` via: 

GetStreamsFilterArray{ GetStreamsFilterArgs{...} }

type GetStreamsFilterArrayOutput 

type GetStreamsFilterArrayOutput struct{ *pulumi.OutputState }

func (GetStreamsFilterArrayOutput) ElementType 

func (GetStreamsFilterArrayOutput) ElementType() reflect.Type

func (GetStreamsFilterArrayOutput) Index 

func (o GetStreamsFilterArrayOutput) Index(i pulumi.IntInput) GetStreamsFilterOutput

func (GetStreamsFilterArrayOutput) ToGetStreamsFilterArrayOutput 

func (o GetStreamsFilterArrayOutput) ToGetStreamsFilterArrayOutput() GetStreamsFilterArrayOutput

func (GetStreamsFilterArrayOutput) ToGetStreamsFilterArrayOutputWithContext 

func (o GetStreamsFilterArrayOutput) ToGetStreamsFilterArrayOutputWithContext(ctx context.Context) GetStreamsFilterArrayOutput

type GetStreamsFilterInput 

type GetStreamsFilterInput interface {
	pulumi.Input

	ToGetStreamsFilterOutput() GetStreamsFilterOutput
	ToGetStreamsFilterOutputWithContext(context.Context) GetStreamsFilterOutput
}

GetStreamsFilterInput is an input type that accepts GetStreamsFilterArgs and GetStreamsFilterOutput values. You can construct a concrete instance of `GetStreamsFilterInput` via: 

GetStreamsFilterArgs{...}

type GetStreamsFilterOutput 

type GetStreamsFilterOutput struct{ *pulumi.OutputState }

func (GetStreamsFilterOutput) ElementType 

func (GetStreamsFilterOutput) ElementType() reflect.Type

func (GetStreamsFilterOutput) Name 

func (o GetStreamsFilterOutput) Name() pulumi.StringOutput

A filter to return only resources that match the given name exactly.

func (GetStreamsFilterOutput) Regex 

func (o GetStreamsFilterOutput) Regex() pulumi.BoolPtrOutput

func (GetStreamsFilterOutput) ToGetStreamsFilterOutput 

func (o GetStreamsFilterOutput) ToGetStreamsFilterOutput() GetStreamsFilterOutput

func (GetStreamsFilterOutput) ToGetStreamsFilterOutputWithContext 

func (o GetStreamsFilterOutput) ToGetStreamsFilterOutputWithContext(ctx context.Context) GetStreamsFilterOutput

func (GetStreamsFilterOutput) Values 

func (o GetStreamsFilterOutput) Values() pulumi.StringArrayOutput

type GetStreamsOutputArgs 

type GetStreamsOutputArgs struct {
	// The OCID of the compartment. Is exclusive with the `streamPoolId` parameter. One of them is required.
	CompartmentId pulumi.StringPtrInput      `pulumi:"compartmentId"`
	Filters       GetStreamsFilterArrayInput `pulumi:"filters"`
	// A filter to return only resources that match the given ID exactly.
	Id pulumi.StringPtrInput `pulumi:"id"`
	// A filter to return only resources that match the given name exactly.
	Name pulumi.StringPtrInput `pulumi:"name"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State pulumi.StringPtrInput `pulumi:"state"`
	// The OCID of the stream pool. Is exclusive with the `compartmentId` parameter. One of them is required.
	StreamPoolId pulumi.StringPtrInput `pulumi:"streamPoolId"`
}

A collection of arguments for invoking getStreams.

func (GetStreamsOutputArgs) ElementType 

func (GetStreamsOutputArgs) ElementType() reflect.Type

type GetStreamsResult 

type GetStreamsResult struct {
	// The OCID of the compartment that contains the stream.
	CompartmentId *string            `pulumi:"compartmentId"`
	Filters       []GetStreamsFilter `pulumi:"filters"`
	// The OCID of the stream.
	Id *string `pulumi:"id"`
	// The name of the stream. Avoid entering confidential information.  Example: `TelemetryEvents`
	Name *string `pulumi:"name"`
	// The current state of the stream.
	State *string `pulumi:"state"`
	// The OCID of the stream pool that contains the stream.
	StreamPoolId *string `pulumi:"streamPoolId"`
	// The list of streams.
	Streams []GetStreamsStream `pulumi:"streams"`
}

A collection of values returned by getStreams.

func GetStreams 

func GetStreams(ctx *pulumi.Context, args *GetStreamsArgs, opts ...pulumi.InvokeOption) (*GetStreamsResult, error)

This data source provides the list of Streams in Oracle Cloud Infrastructure Streaming service.

Lists the streams in the given compartment id. If the compartment id is specified, it will list streams in the compartment, regardless of their stream pool. If the stream pool id is specified, the action will be scoped to that stream pool. The compartment id and stream pool id cannot be specified at the same time.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-oci/sdk/go/oci/Streaming"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Streaming.GetStreams(ctx, &streaming.GetStreamsArgs{
			CompartmentId: pulumi.StringRef(compartmentId),
			Id:            pulumi.StringRef(streamId),
			Name:          pulumi.StringRef(streamName),
			State:         pulumi.StringRef(streamState),
			StreamPoolId:  pulumi.StringRef(testStreamPool.Id),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetStreamsResultOutput 

type GetStreamsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getStreams.

func GetStreamsOutput 

func GetStreamsOutput(ctx *pulumi.Context, args GetStreamsOutputArgs, opts ...pulumi.InvokeOption) GetStreamsResultOutput

func (GetStreamsResultOutput) CompartmentId 

func (o GetStreamsResultOutput) CompartmentId() pulumi.StringPtrOutput

The OCID of the compartment that contains the stream.

func (GetStreamsResultOutput) ElementType 

func (GetStreamsResultOutput) ElementType() reflect.Type

func (GetStreamsResultOutput) Filters 

func (o GetStreamsResultOutput) Filters() GetStreamsFilterArrayOutput

func (GetStreamsResultOutput) Id 

func (o GetStreamsResultOutput) Id() pulumi.StringPtrOutput

The OCID of the stream.

func (GetStreamsResultOutput) Name 

func (o GetStreamsResultOutput) Name() pulumi.StringPtrOutput

The name of the stream. Avoid entering confidential information. Example: `TelemetryEvents`

func (GetStreamsResultOutput) State 

func (o GetStreamsResultOutput) State() pulumi.StringPtrOutput

The current state of the stream.

func (GetStreamsResultOutput) StreamPoolId 

func (o GetStreamsResultOutput) StreamPoolId() pulumi.StringPtrOutput

The OCID of the stream pool that contains the stream.

func (GetStreamsResultOutput) Streams 

func (o GetStreamsResultOutput) Streams() GetStreamsStreamArrayOutput

The list of streams.

func (GetStreamsResultOutput) ToGetStreamsResultOutput 

func (o GetStreamsResultOutput) ToGetStreamsResultOutput() GetStreamsResultOutput

func (GetStreamsResultOutput) ToGetStreamsResultOutputWithContext 

func (o GetStreamsResultOutput) ToGetStreamsResultOutputWithContext(ctx context.Context) GetStreamsResultOutput

type GetStreamsStream 

type GetStreamsStream struct {
	// The OCID of the compartment. Is exclusive with the `streamPoolId` parameter. One of them is required.
	CompartmentId string `pulumi:"compartmentId"`
	// Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations": {"CostCenter": "42"}}'
	DefinedTags map[string]interface{} `pulumi:"definedTags"`
	// Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags map[string]interface{} `pulumi:"freeformTags"`
	// A filter to return only resources that match the given ID exactly.
	Id string `pulumi:"id"`
	// Any additional details about the current state of the stream.
	LifecycleStateDetails string `pulumi:"lifecycleStateDetails"`
	// The endpoint to use when creating the StreamClient to consume or publish messages in the stream. If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.
	MessagesEndpoint string `pulumi:"messagesEndpoint"`
	// A filter to return only resources that match the given name exactly.
	Name string `pulumi:"name"`
	// The number of partitions in the stream.
	Partitions int `pulumi:"partitions"`
	// The retention period of the stream, in hours. This property is read-only.
	RetentionInHours int `pulumi:"retentionInHours"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State string `pulumi:"state"`
	// The OCID of the stream pool. Is exclusive with the `compartmentId` parameter. One of them is required.
	StreamPoolId string `pulumi:"streamPoolId"`
	// The date and time the stream was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated string `pulumi:"timeCreated"`
}

type GetStreamsStreamArgs 

type GetStreamsStreamArgs struct {
	// The OCID of the compartment. Is exclusive with the `streamPoolId` parameter. One of them is required.
	CompartmentId pulumi.StringInput `pulumi:"compartmentId"`
	// Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations": {"CostCenter": "42"}}'
	DefinedTags pulumi.MapInput `pulumi:"definedTags"`
	// Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapInput `pulumi:"freeformTags"`
	// A filter to return only resources that match the given ID exactly.
	Id pulumi.StringInput `pulumi:"id"`
	// Any additional details about the current state of the stream.
	LifecycleStateDetails pulumi.StringInput `pulumi:"lifecycleStateDetails"`
	// The endpoint to use when creating the StreamClient to consume or publish messages in the stream. If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.
	MessagesEndpoint pulumi.StringInput `pulumi:"messagesEndpoint"`
	// A filter to return only resources that match the given name exactly.
	Name pulumi.StringInput `pulumi:"name"`
	// The number of partitions in the stream.
	Partitions pulumi.IntInput `pulumi:"partitions"`
	// The retention period of the stream, in hours. This property is read-only.
	RetentionInHours pulumi.IntInput `pulumi:"retentionInHours"`
	// A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
	State pulumi.StringInput `pulumi:"state"`
	// The OCID of the stream pool. Is exclusive with the `compartmentId` parameter. One of them is required.
	StreamPoolId pulumi.StringInput `pulumi:"streamPoolId"`
	// The date and time the stream was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated pulumi.StringInput `pulumi:"timeCreated"`
}

func (GetStreamsStreamArgs) ElementType 

func (GetStreamsStreamArgs) ElementType() reflect.Type

func (GetStreamsStreamArgs) ToGetStreamsStreamOutput 

func (i GetStreamsStreamArgs) ToGetStreamsStreamOutput() GetStreamsStreamOutput

func (GetStreamsStreamArgs) ToGetStreamsStreamOutputWithContext 

func (i GetStreamsStreamArgs) ToGetStreamsStreamOutputWithContext(ctx context.Context) GetStreamsStreamOutput

type GetStreamsStreamArray 

type GetStreamsStreamArray []GetStreamsStreamInput

func (GetStreamsStreamArray) ElementType 

func (GetStreamsStreamArray) ElementType() reflect.Type

func (GetStreamsStreamArray) ToGetStreamsStreamArrayOutput 

func (i GetStreamsStreamArray) ToGetStreamsStreamArrayOutput() GetStreamsStreamArrayOutput

func (GetStreamsStreamArray) ToGetStreamsStreamArrayOutputWithContext 

func (i GetStreamsStreamArray) ToGetStreamsStreamArrayOutputWithContext(ctx context.Context) GetStreamsStreamArrayOutput

type GetStreamsStreamArrayInput 

type GetStreamsStreamArrayInput interface {
	pulumi.Input

	ToGetStreamsStreamArrayOutput() GetStreamsStreamArrayOutput
	ToGetStreamsStreamArrayOutputWithContext(context.Context) GetStreamsStreamArrayOutput
}

GetStreamsStreamArrayInput is an input type that accepts GetStreamsStreamArray and GetStreamsStreamArrayOutput values. You can construct a concrete instance of `GetStreamsStreamArrayInput` via: 

GetStreamsStreamArray{ GetStreamsStreamArgs{...} }

type GetStreamsStreamArrayOutput 

type GetStreamsStreamArrayOutput struct{ *pulumi.OutputState }

func (GetStreamsStreamArrayOutput) ElementType 

func (GetStreamsStreamArrayOutput) ElementType() reflect.Type

func (GetStreamsStreamArrayOutput) Index 

func (o GetStreamsStreamArrayOutput) Index(i pulumi.IntInput) GetStreamsStreamOutput

func (GetStreamsStreamArrayOutput) ToGetStreamsStreamArrayOutput 

func (o GetStreamsStreamArrayOutput) ToGetStreamsStreamArrayOutput() GetStreamsStreamArrayOutput

func (GetStreamsStreamArrayOutput) ToGetStreamsStreamArrayOutputWithContext 

func (o GetStreamsStreamArrayOutput) ToGetStreamsStreamArrayOutputWithContext(ctx context.Context) GetStreamsStreamArrayOutput

type GetStreamsStreamInput 

type GetStreamsStreamInput interface {
	pulumi.Input

	ToGetStreamsStreamOutput() GetStreamsStreamOutput
	ToGetStreamsStreamOutputWithContext(context.Context) GetStreamsStreamOutput
}

GetStreamsStreamInput is an input type that accepts GetStreamsStreamArgs and GetStreamsStreamOutput values. You can construct a concrete instance of `GetStreamsStreamInput` via: 

GetStreamsStreamArgs{...}

type GetStreamsStreamOutput 

type GetStreamsStreamOutput struct{ *pulumi.OutputState }

func (GetStreamsStreamOutput) CompartmentId 

func (o GetStreamsStreamOutput) CompartmentId() pulumi.StringOutput

The OCID of the compartment. Is exclusive with the `streamPoolId` parameter. One of them is required.

func (GetStreamsStreamOutput) DefinedTags 

func (o GetStreamsStreamOutput) DefinedTags() pulumi.MapOutput

Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Operations": {"CostCenter": "42"}}'

func (GetStreamsStreamOutput) ElementType 

func (GetStreamsStreamOutput) ElementType() reflect.Type

func (GetStreamsStreamOutput) FreeformTags 

func (o GetStreamsStreamOutput) FreeformTags() pulumi.MapOutput

Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Department": "Finance"}`

func (GetStreamsStreamOutput) Id 

func (o GetStreamsStreamOutput) Id() pulumi.StringOutput

A filter to return only resources that match the given ID exactly.

func (GetStreamsStreamOutput) LifecycleStateDetails 

func (o GetStreamsStreamOutput) LifecycleStateDetails() pulumi.StringOutput

Any additional details about the current state of the stream.

func (GetStreamsStreamOutput) MessagesEndpoint 

func (o GetStreamsStreamOutput) MessagesEndpoint() pulumi.StringOutput

The endpoint to use when creating the StreamClient to consume or publish messages in the stream. If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.

func (GetStreamsStreamOutput) Name 

func (o GetStreamsStreamOutput) Name() pulumi.StringOutput

A filter to return only resources that match the given name exactly.

func (GetStreamsStreamOutput) Partitions 

func (o GetStreamsStreamOutput) Partitions() pulumi.IntOutput

The number of partitions in the stream.

func (GetStreamsStreamOutput) RetentionInHours 

func (o GetStreamsStreamOutput) RetentionInHours() pulumi.IntOutput

The retention period of the stream, in hours. This property is read-only.

func (GetStreamsStreamOutput) State 

func (o GetStreamsStreamOutput) State() pulumi.StringOutput

A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.

func (GetStreamsStreamOutput) StreamPoolId 

func (o GetStreamsStreamOutput) StreamPoolId() pulumi.StringOutput

The OCID of the stream pool. Is exclusive with the `compartmentId` parameter. One of them is required.

func (GetStreamsStreamOutput) TimeCreated 

func (o GetStreamsStreamOutput) TimeCreated() pulumi.StringOutput

The date and time the stream was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format. Example: `2018-04-20T00:00:07.405Z`

func (GetStreamsStreamOutput) ToGetStreamsStreamOutput 

func (o GetStreamsStreamOutput) ToGetStreamsStreamOutput() GetStreamsStreamOutput

func (GetStreamsStreamOutput) ToGetStreamsStreamOutputWithContext 

func (o GetStreamsStreamOutput) ToGetStreamsStreamOutputWithContext(ctx context.Context) GetStreamsStreamOutput

type LookupConnectHarnessArgs 

type LookupConnectHarnessArgs struct {
	// The OCID of the connect harness.
	ConnectHarnessId string `pulumi:"connectHarnessId"`
}

A collection of arguments for invoking getConnectHarness.

type LookupConnectHarnessOutputArgs 

type LookupConnectHarnessOutputArgs struct {
	// The OCID of the connect harness.
	ConnectHarnessId pulumi.StringInput `pulumi:"connectHarnessId"`
}

A collection of arguments for invoking getConnectHarness.

func (LookupConnectHarnessOutputArgs) ElementType 

func (LookupConnectHarnessOutputArgs) ElementType() reflect.Type

type LookupConnectHarnessResult 

type LookupConnectHarnessResult struct {
	// The OCID of the compartment that contains the connect harness.
	CompartmentId    string `pulumi:"compartmentId"`
	ConnectHarnessId string `pulumi:"connectHarnessId"`
	// Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations": {"CostCenter": "42"}}'
	DefinedTags map[string]interface{} `pulumi:"definedTags"`
	// Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags map[string]interface{} `pulumi:"freeformTags"`
	// The OCID of the connect harness.
	Id string `pulumi:"id"`
	// Any additional details about the current state of the connect harness.
	LifecycleStateDetails string `pulumi:"lifecycleStateDetails"`
	// The name of the connect harness. Avoid entering confidential information.  Example: `JDBCConnector`
	Name string `pulumi:"name"`
	// The current state of the connect harness.
	State string `pulumi:"state"`
	// The date and time the connect harness was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated string `pulumi:"timeCreated"`
}

A collection of values returned by getConnectHarness.

func LookupConnectHarness 

func LookupConnectHarness(ctx *pulumi.Context, args *LookupConnectHarnessArgs, opts ...pulumi.InvokeOption) (*LookupConnectHarnessResult, error)

This data source provides details about a specific Connect Harness resource in Oracle Cloud Infrastructure Streaming service.

Gets detailed information about a connect harness.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-oci/sdk/go/oci/Streaming"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Streaming.GetConnectHarness(ctx, &streaming.GetConnectHarnessArgs{
			ConnectHarnessId: testConnectHarnes.Id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupConnectHarnessResultOutput 

type LookupConnectHarnessResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getConnectHarness.

func LookupConnectHarnessOutput 

func LookupConnectHarnessOutput(ctx *pulumi.Context, args LookupConnectHarnessOutputArgs, opts ...pulumi.InvokeOption) LookupConnectHarnessResultOutput

func (LookupConnectHarnessResultOutput) CompartmentId 

func (o LookupConnectHarnessResultOutput) CompartmentId() pulumi.StringOutput

The OCID of the compartment that contains the connect harness.

func (LookupConnectHarnessResultOutput) ConnectHarnessId 

func (o LookupConnectHarnessResultOutput) ConnectHarnessId() pulumi.StringOutput

func (LookupConnectHarnessResultOutput) DefinedTags 

func (o LookupConnectHarnessResultOutput) DefinedTags() pulumi.MapOutput

Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Operations": {"CostCenter": "42"}}'

func (LookupConnectHarnessResultOutput) ElementType 

func (LookupConnectHarnessResultOutput) ElementType() reflect.Type

func (LookupConnectHarnessResultOutput) FreeformTags 

func (o LookupConnectHarnessResultOutput) FreeformTags() pulumi.MapOutput

Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Department": "Finance"}`

func (LookupConnectHarnessResultOutput) Id 

func (o LookupConnectHarnessResultOutput) Id() pulumi.StringOutput

The OCID of the connect harness.

func (LookupConnectHarnessResultOutput) LifecycleStateDetails 

func (o LookupConnectHarnessResultOutput) LifecycleStateDetails() pulumi.StringOutput

Any additional details about the current state of the connect harness.

func (LookupConnectHarnessResultOutput) Name 

func (o LookupConnectHarnessResultOutput) Name() pulumi.StringOutput

The name of the connect harness. Avoid entering confidential information. Example: `JDBCConnector`

func (LookupConnectHarnessResultOutput) State 

func (o LookupConnectHarnessResultOutput) State() pulumi.StringOutput

The current state of the connect harness.

func (LookupConnectHarnessResultOutput) TimeCreated 

func (o LookupConnectHarnessResultOutput) TimeCreated() pulumi.StringOutput

The date and time the connect harness was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format. Example: `2018-04-20T00:00:07.405Z`

func (LookupConnectHarnessResultOutput) ToLookupConnectHarnessResultOutput 

func (o LookupConnectHarnessResultOutput) ToLookupConnectHarnessResultOutput() LookupConnectHarnessResultOutput

func (LookupConnectHarnessResultOutput) ToLookupConnectHarnessResultOutputWithContext 

func (o LookupConnectHarnessResultOutput) ToLookupConnectHarnessResultOutputWithContext(ctx context.Context) LookupConnectHarnessResultOutput

type LookupStreamArgs 

type LookupStreamArgs struct {
	// The OCID of the stream.
	StreamId string `pulumi:"streamId"`
}

A collection of arguments for invoking getStream.

type LookupStreamOutputArgs 

type LookupStreamOutputArgs struct {
	// The OCID of the stream.
	StreamId pulumi.StringInput `pulumi:"streamId"`
}

A collection of arguments for invoking getStream.

func (LookupStreamOutputArgs) ElementType 

func (LookupStreamOutputArgs) ElementType() reflect.Type

type LookupStreamPoolArgs 

type LookupStreamPoolArgs struct {
	// The OCID of the stream pool.
	StreamPoolId string `pulumi:"streamPoolId"`
}

A collection of arguments for invoking getStreamPool.

type LookupStreamPoolOutputArgs 

type LookupStreamPoolOutputArgs struct {
	// The OCID of the stream pool.
	StreamPoolId pulumi.StringInput `pulumi:"streamPoolId"`
}

A collection of arguments for invoking getStreamPool.

func (LookupStreamPoolOutputArgs) ElementType 

func (LookupStreamPoolOutputArgs) ElementType() reflect.Type

type LookupStreamPoolResult 

type LookupStreamPoolResult struct {
	// Compartment OCID that the pool belongs to.
	CompartmentId string `pulumi:"compartmentId"`
	// Custom Encryption Key which will be used for encryption by all the streams in the pool.
	CustomEncryptionKeys []GetStreamPoolCustomEncryptionKey `pulumi:"customEncryptionKeys"`
	// Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations": {"CostCenter": "42"}}'
	DefinedTags map[string]interface{} `pulumi:"definedTags"`
	// The FQDN used to access the streams inside the stream pool (same FQDN as the messagesEndpoint attribute of a [Stream](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream) object). If the stream pool is private, the FQDN is customized and can only be accessed from inside the associated subnetId, otherwise the FQDN is publicly resolvable. Depending on which protocol you attempt to use, you need to either prepend https or append the Kafka port.
	EndpointFqdn string `pulumi:"endpointFqdn"`
	// Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags map[string]interface{} `pulumi:"freeformTags"`
	// The OCID of the stream pool.
	Id string `pulumi:"id"`
	// True if the stream pool is private, false otherwise. The associated endpoint and subnetId of a private stream pool can be retrieved through the [GetStreamPool](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/StreamPool/GetStreamPool) API.
	IsPrivate bool `pulumi:"isPrivate"`
	// Settings for the Kafka compatibility layer.
	KafkaSettings []GetStreamPoolKafkaSetting `pulumi:"kafkaSettings"`
	// Any additional details about the current state of the stream.
	LifecycleStateDetails string `pulumi:"lifecycleStateDetails"`
	// The name of the stream pool.
	Name string `pulumi:"name"`
	// Optional settings if the stream pool is private.
	PrivateEndpointSettings []GetStreamPoolPrivateEndpointSetting `pulumi:"privateEndpointSettings"`
	// The current state of the stream pool.
	State        string `pulumi:"state"`
	StreamPoolId string `pulumi:"streamPoolId"`
	// The date and time the stream pool was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated string `pulumi:"timeCreated"`
}

A collection of values returned by getStreamPool.

func LookupStreamPool 

func LookupStreamPool(ctx *pulumi.Context, args *LookupStreamPoolArgs, opts ...pulumi.InvokeOption) (*LookupStreamPoolResult, error)

This data source provides details about a specific Stream Pool resource in Oracle Cloud Infrastructure Streaming service.

Gets detailed information about the stream pool, such as Kafka settings.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-oci/sdk/go/oci/Streaming"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Streaming.GetStreamPool(ctx, &streaming.GetStreamPoolArgs{
			StreamPoolId: testStreamPoolOciStreamingStreamPool.Id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupStreamPoolResultOutput 

type LookupStreamPoolResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getStreamPool.

func LookupStreamPoolOutput 

func LookupStreamPoolOutput(ctx *pulumi.Context, args LookupStreamPoolOutputArgs, opts ...pulumi.InvokeOption) LookupStreamPoolResultOutput

func (LookupStreamPoolResultOutput) CompartmentId 

func (o LookupStreamPoolResultOutput) CompartmentId() pulumi.StringOutput

Compartment OCID that the pool belongs to.

func (LookupStreamPoolResultOutput) CustomEncryptionKeys 

func (o LookupStreamPoolResultOutput) CustomEncryptionKeys() GetStreamPoolCustomEncryptionKeyArrayOutput

Custom Encryption Key which will be used for encryption by all the streams in the pool.

func (LookupStreamPoolResultOutput) DefinedTags 

func (o LookupStreamPoolResultOutput) DefinedTags() pulumi.MapOutput

Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Operations": {"CostCenter": "42"}}'

func (LookupStreamPoolResultOutput) ElementType 

func (LookupStreamPoolResultOutput) ElementType() reflect.Type

func (LookupStreamPoolResultOutput) EndpointFqdn 

func (o LookupStreamPoolResultOutput) EndpointFqdn() pulumi.StringOutput

The FQDN used to access the streams inside the stream pool (same FQDN as the messagesEndpoint attribute of a Stream(https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream) object). If the stream pool is private, the FQDN is customized and can only be accessed from inside the associated subnetId, otherwise the FQDN is publicly resolvable. Depending on which protocol you attempt to use, you need to either prepend https or append the Kafka port.

func (LookupStreamPoolResultOutput) FreeformTags 

func (o LookupStreamPoolResultOutput) FreeformTags() pulumi.MapOutput

Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Department": "Finance"}`

func (LookupStreamPoolResultOutput) Id 

func (o LookupStreamPoolResultOutput) Id() pulumi.StringOutput

The OCID of the stream pool.

func (LookupStreamPoolResultOutput) IsPrivate 

func (o LookupStreamPoolResultOutput) IsPrivate() pulumi.BoolOutput

True if the stream pool is private, false otherwise. The associated endpoint and subnetId of a private stream pool can be retrieved through the GetStreamPool(https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/StreamPool/GetStreamPool) API.

func (LookupStreamPoolResultOutput) KafkaSettings 

func (o LookupStreamPoolResultOutput) KafkaSettings() GetStreamPoolKafkaSettingArrayOutput

Settings for the Kafka compatibility layer.

func (LookupStreamPoolResultOutput) LifecycleStateDetails 

func (o LookupStreamPoolResultOutput) LifecycleStateDetails() pulumi.StringOutput

Any additional details about the current state of the stream.

func (LookupStreamPoolResultOutput) Name 

func (o LookupStreamPoolResultOutput) Name() pulumi.StringOutput

The name of the stream pool.

func (LookupStreamPoolResultOutput) PrivateEndpointSettings 

func (o LookupStreamPoolResultOutput) PrivateEndpointSettings() GetStreamPoolPrivateEndpointSettingArrayOutput

Optional settings if the stream pool is private.

func (LookupStreamPoolResultOutput) State 

func (o LookupStreamPoolResultOutput) State() pulumi.StringOutput

The current state of the stream pool.

func (LookupStreamPoolResultOutput) StreamPoolId 

func (o LookupStreamPoolResultOutput) StreamPoolId() pulumi.StringOutput

func (LookupStreamPoolResultOutput) TimeCreated 

func (o LookupStreamPoolResultOutput) TimeCreated() pulumi.StringOutput

The date and time the stream pool was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format. Example: `2018-04-20T00:00:07.405Z`

func (LookupStreamPoolResultOutput) ToLookupStreamPoolResultOutput 

func (o LookupStreamPoolResultOutput) ToLookupStreamPoolResultOutput() LookupStreamPoolResultOutput

func (LookupStreamPoolResultOutput) ToLookupStreamPoolResultOutputWithContext 

func (o LookupStreamPoolResultOutput) ToLookupStreamPoolResultOutputWithContext(ctx context.Context) LookupStreamPoolResultOutput

type LookupStreamResult 

type LookupStreamResult struct {
	// The OCID of the compartment that contains the stream.
	CompartmentId string `pulumi:"compartmentId"`
	// Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations": {"CostCenter": "42"}}'
	DefinedTags map[string]interface{} `pulumi:"definedTags"`
	// Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags map[string]interface{} `pulumi:"freeformTags"`
	// The OCID of the stream.
	Id string `pulumi:"id"`
	// Any additional details about the current state of the stream.
	LifecycleStateDetails string `pulumi:"lifecycleStateDetails"`
	// The endpoint to use when creating the StreamClient to consume or publish messages in the stream. If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.
	MessagesEndpoint string `pulumi:"messagesEndpoint"`
	// The name of the stream. Avoid entering confidential information.  Example: `TelemetryEvents`
	Name string `pulumi:"name"`
	// The number of partitions in the stream.
	Partitions int `pulumi:"partitions"`
	// The retention period of the stream, in hours. This property is read-only.
	RetentionInHours int `pulumi:"retentionInHours"`
	// The current state of the stream.
	State    string `pulumi:"state"`
	StreamId string `pulumi:"streamId"`
	// The OCID of the stream pool that contains the stream.
	StreamPoolId string `pulumi:"streamPoolId"`
	// The date and time the stream was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated string `pulumi:"timeCreated"`
}

A collection of values returned by getStream.

func LookupStream 

func LookupStream(ctx *pulumi.Context, args *LookupStreamArgs, opts ...pulumi.InvokeOption) (*LookupStreamResult, error)

This data source provides details about a specific Stream resource in Oracle Cloud Infrastructure Streaming service.

Gets detailed information about a stream, including the number of partitions.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-oci/sdk/go/oci/Streaming"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Streaming.GetStream(ctx, &streaming.GetStreamArgs{
			StreamId: testStreamOciStreamingStream.Id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupStreamResultOutput 

type LookupStreamResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getStream.

func LookupStreamOutput 

func LookupStreamOutput(ctx *pulumi.Context, args LookupStreamOutputArgs, opts ...pulumi.InvokeOption) LookupStreamResultOutput

func (LookupStreamResultOutput) CompartmentId 

func (o LookupStreamResultOutput) CompartmentId() pulumi.StringOutput

The OCID of the compartment that contains the stream.

func (LookupStreamResultOutput) DefinedTags 

func (o LookupStreamResultOutput) DefinedTags() pulumi.MapOutput

Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Operations": {"CostCenter": "42"}}'

func (LookupStreamResultOutput) ElementType 

func (LookupStreamResultOutput) ElementType() reflect.Type

func (LookupStreamResultOutput) FreeformTags 

func (o LookupStreamResultOutput) FreeformTags() pulumi.MapOutput

Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Department": "Finance"}`

func (LookupStreamResultOutput) Id 

func (o LookupStreamResultOutput) Id() pulumi.StringOutput

The OCID of the stream.

func (LookupStreamResultOutput) LifecycleStateDetails 

func (o LookupStreamResultOutput) LifecycleStateDetails() pulumi.StringOutput

Any additional details about the current state of the stream.

func (LookupStreamResultOutput) MessagesEndpoint 

func (o LookupStreamResultOutput) MessagesEndpoint() pulumi.StringOutput

The endpoint to use when creating the StreamClient to consume or publish messages in the stream. If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.

func (LookupStreamResultOutput) Name 

func (o LookupStreamResultOutput) Name() pulumi.StringOutput

The name of the stream. Avoid entering confidential information. Example: `TelemetryEvents`

func (LookupStreamResultOutput) Partitions 

func (o LookupStreamResultOutput) Partitions() pulumi.IntOutput

The number of partitions in the stream.

func (LookupStreamResultOutput) RetentionInHours 

func (o LookupStreamResultOutput) RetentionInHours() pulumi.IntOutput

The retention period of the stream, in hours. This property is read-only.

func (LookupStreamResultOutput) State 

func (o LookupStreamResultOutput) State() pulumi.StringOutput

The current state of the stream.

func (LookupStreamResultOutput) StreamId 

func (o LookupStreamResultOutput) StreamId() pulumi.StringOutput

func (LookupStreamResultOutput) StreamPoolId 

func (o LookupStreamResultOutput) StreamPoolId() pulumi.StringOutput

The OCID of the stream pool that contains the stream.

func (LookupStreamResultOutput) TimeCreated 

func (o LookupStreamResultOutput) TimeCreated() pulumi.StringOutput

The date and time the stream was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format. Example: `2018-04-20T00:00:07.405Z`

func (LookupStreamResultOutput) ToLookupStreamResultOutput 

func (o LookupStreamResultOutput) ToLookupStreamResultOutput() LookupStreamResultOutput

func (LookupStreamResultOutput) ToLookupStreamResultOutputWithContext 

func (o LookupStreamResultOutput) ToLookupStreamResultOutputWithContext(ctx context.Context) LookupStreamResultOutput

type Stream 

type Stream struct {
	pulumi.CustomResourceState

	// (Updatable) The OCID of the compartment that contains the stream.
	CompartmentId pulumi.StringOutput `pulumi:"compartmentId"`
	// (Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations.CostCenter": "42"}`
	DefinedTags pulumi.MapOutput `pulumi:"definedTags"`
	// (Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapOutput `pulumi:"freeformTags"`
	// Any additional details about the current state of the stream.
	LifecycleStateDetails pulumi.StringOutput `pulumi:"lifecycleStateDetails"`
	// The endpoint to use when creating the StreamClient to consume or publish messages in the stream. If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.
	MessagesEndpoint pulumi.StringOutput `pulumi:"messagesEndpoint"`
	// The name of the stream. Avoid entering confidential information.  Example: `TelemetryEvents`
	Name pulumi.StringOutput `pulumi:"name"`
	// The number of partitions in the stream.
	Partitions pulumi.IntOutput `pulumi:"partitions"`
	// The retention period of the stream, in hours. Accepted values are between 24 and 168 (7 days). If not specified, the stream will have a retention period of 24 hours.
	RetentionInHours pulumi.IntOutput `pulumi:"retentionInHours"`
	// The current state of the stream.
	State pulumi.StringOutput `pulumi:"state"`
	// (Updatable) The OCID of the stream pool that contains the stream.
	//
	// ** IMPORTANT **
	// Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values
	StreamPoolId pulumi.StringOutput `pulumi:"streamPoolId"`
	// The date and time the stream was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated pulumi.StringOutput `pulumi:"timeCreated"`
}

This resource provides the Stream resource in Oracle Cloud Infrastructure Streaming service.

Starts the provisioning of a new stream. The stream will be created in the given compartment id or stream pool id, depending on which parameter is specified. Compartment id and stream pool id cannot be specified at the same time. To track the progress of the provisioning, you can periodically call GetStream(https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream/GetStream). In the response, the `lifecycleState` parameter of the Stream(https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream/) object tells you its current state.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-oci/sdk/go/oci/Streaming"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Streaming.NewStream(ctx, "test_stream", &Streaming.StreamArgs{
			Name:          pulumi.Any(streamName),
			Partitions:    pulumi.Any(streamPartitions),
			CompartmentId: pulumi.Any(compartmentId),
			DefinedTags:   pulumi.Any(streamDefinedTags),
			FreeformTags: pulumi.Map{
				"Department": pulumi.Any("Finance"),
			},
			RetentionInHours: pulumi.Any(streamRetentionInHours),
			StreamPoolId:     pulumi.Any(testStreamPool.Id),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Streams can be imported using the `id`, e.g.

```sh $ pulumi import oci:Streaming/stream:Stream test_stream "id" ```

func GetStream 

func GetStream(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *StreamState, opts ...pulumi.ResourceOption) (*Stream, error)

GetStream gets an existing Stream 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 NewStream 

func NewStream(ctx *pulumi.Context,
	name string, args *StreamArgs, opts ...pulumi.ResourceOption) (*Stream, error)

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

func (*Stream) ElementType 

func (*Stream) ElementType() reflect.Type

func (*Stream) ToStreamOutput 

func (i *Stream) ToStreamOutput() StreamOutput

func (*Stream) ToStreamOutputWithContext 

func (i *Stream) ToStreamOutputWithContext(ctx context.Context) StreamOutput

type StreamArgs 

type StreamArgs struct {
	// (Updatable) The OCID of the compartment that contains the stream.
	CompartmentId pulumi.StringPtrInput
	// (Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations.CostCenter": "42"}`
	DefinedTags pulumi.MapInput
	// (Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapInput
	// The name of the stream. Avoid entering confidential information.  Example: `TelemetryEvents`
	Name pulumi.StringPtrInput
	// The number of partitions in the stream.
	Partitions pulumi.IntInput
	// The retention period of the stream, in hours. Accepted values are between 24 and 168 (7 days). If not specified, the stream will have a retention period of 24 hours.
	RetentionInHours pulumi.IntPtrInput
	// (Updatable) The OCID of the stream pool that contains the stream.
	//
	// ** IMPORTANT **
	// Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values
	StreamPoolId pulumi.StringPtrInput
}

The set of arguments for constructing a Stream resource.

func (StreamArgs) ElementType 

func (StreamArgs) ElementType() reflect.Type

type StreamArray 

type StreamArray []StreamInput

func (StreamArray) ElementType 

func (StreamArray) ElementType() reflect.Type

func (StreamArray) ToStreamArrayOutput 

func (i StreamArray) ToStreamArrayOutput() StreamArrayOutput

func (StreamArray) ToStreamArrayOutputWithContext 

func (i StreamArray) ToStreamArrayOutputWithContext(ctx context.Context) StreamArrayOutput

type StreamArrayInput 

type StreamArrayInput interface {
	pulumi.Input

	ToStreamArrayOutput() StreamArrayOutput
	ToStreamArrayOutputWithContext(context.Context) StreamArrayOutput
}

StreamArrayInput is an input type that accepts StreamArray and StreamArrayOutput values. You can construct a concrete instance of `StreamArrayInput` via: 

StreamArray{ StreamArgs{...} }

type StreamArrayOutput 

type StreamArrayOutput struct{ *pulumi.OutputState }

func (StreamArrayOutput) ElementType 

func (StreamArrayOutput) ElementType() reflect.Type

func (StreamArrayOutput) Index 

func (o StreamArrayOutput) Index(i pulumi.IntInput) StreamOutput

func (StreamArrayOutput) ToStreamArrayOutput 

func (o StreamArrayOutput) ToStreamArrayOutput() StreamArrayOutput

func (StreamArrayOutput) ToStreamArrayOutputWithContext 

func (o StreamArrayOutput) ToStreamArrayOutputWithContext(ctx context.Context) StreamArrayOutput

type StreamInput 

type StreamInput interface {
	pulumi.Input

	ToStreamOutput() StreamOutput
	ToStreamOutputWithContext(ctx context.Context) StreamOutput
}

type StreamMap 

type StreamMap map[string]StreamInput

func (StreamMap) ElementType 

func (StreamMap) ElementType() reflect.Type

func (StreamMap) ToStreamMapOutput 

func (i StreamMap) ToStreamMapOutput() StreamMapOutput

func (StreamMap) ToStreamMapOutputWithContext 

func (i StreamMap) ToStreamMapOutputWithContext(ctx context.Context) StreamMapOutput

type StreamMapInput 

type StreamMapInput interface {
	pulumi.Input

	ToStreamMapOutput() StreamMapOutput
	ToStreamMapOutputWithContext(context.Context) StreamMapOutput
}

StreamMapInput is an input type that accepts StreamMap and StreamMapOutput values. You can construct a concrete instance of `StreamMapInput` via: 

StreamMap{ "key": StreamArgs{...} }

type StreamMapOutput 

type StreamMapOutput struct{ *pulumi.OutputState }

func (StreamMapOutput) ElementType 

func (StreamMapOutput) ElementType() reflect.Type

func (StreamMapOutput) MapIndex 

func (o StreamMapOutput) MapIndex(k pulumi.StringInput) StreamOutput

func (StreamMapOutput) ToStreamMapOutput 

func (o StreamMapOutput) ToStreamMapOutput() StreamMapOutput

func (StreamMapOutput) ToStreamMapOutputWithContext 

func (o StreamMapOutput) ToStreamMapOutputWithContext(ctx context.Context) StreamMapOutput

type StreamOutput 

type StreamOutput struct{ *pulumi.OutputState }

func (StreamOutput) CompartmentId added in v0.4.0 

func (o StreamOutput) CompartmentId() pulumi.StringOutput

(Updatable) The OCID of the compartment that contains the stream.

func (StreamOutput) DefinedTags added in v0.4.0 

func (o StreamOutput) DefinedTags() pulumi.MapOutput

(Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Operations.CostCenter": "42"}`

func (StreamOutput) ElementType 

func (StreamOutput) ElementType() reflect.Type

func (StreamOutput) FreeformTags added in v0.4.0 

func (o StreamOutput) FreeformTags() pulumi.MapOutput

(Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Department": "Finance"}`

func (StreamOutput) LifecycleStateDetails added in v0.4.0 

func (o StreamOutput) LifecycleStateDetails() pulumi.StringOutput

Any additional details about the current state of the stream.

func (StreamOutput) MessagesEndpoint added in v0.4.0 

func (o StreamOutput) MessagesEndpoint() pulumi.StringOutput

The endpoint to use when creating the StreamClient to consume or publish messages in the stream. If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.

func (StreamOutput) Name added in v0.4.0 

func (o StreamOutput) Name() pulumi.StringOutput

The name of the stream. Avoid entering confidential information. Example: `TelemetryEvents`

func (StreamOutput) Partitions added in v0.4.0 

func (o StreamOutput) Partitions() pulumi.IntOutput

The number of partitions in the stream.

func (StreamOutput) RetentionInHours added in v0.4.0 

func (o StreamOutput) RetentionInHours() pulumi.IntOutput

The retention period of the stream, in hours. Accepted values are between 24 and 168 (7 days). If not specified, the stream will have a retention period of 24 hours.

func (StreamOutput) State added in v0.4.0 

func (o StreamOutput) State() pulumi.StringOutput

The current state of the stream.

func (StreamOutput) StreamPoolId added in v0.4.0 

func (o StreamOutput) StreamPoolId() pulumi.StringOutput

(Updatable) The OCID of the stream pool that contains the stream.

** IMPORTANT ** Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values

func (StreamOutput) TimeCreated added in v0.4.0 

func (o StreamOutput) TimeCreated() pulumi.StringOutput

The date and time the stream was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format. Example: `2018-04-20T00:00:07.405Z`

func (StreamOutput) ToStreamOutput 

func (o StreamOutput) ToStreamOutput() StreamOutput

func (StreamOutput) ToStreamOutputWithContext 

func (o StreamOutput) ToStreamOutputWithContext(ctx context.Context) StreamOutput

type StreamPool 

type StreamPool struct {
	pulumi.CustomResourceState

	// (Updatable) The OCID of the compartment that contains the stream.
	CompartmentId pulumi.StringOutput `pulumi:"compartmentId"`
	// (Updatable) The OCID of the custom encryption key to be used or deleted if currently being used.
	CustomEncryptionKey StreamPoolCustomEncryptionKeyOutput `pulumi:"customEncryptionKey"`
	// (Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations.CostCenter": "42"}`
	DefinedTags pulumi.MapOutput `pulumi:"definedTags"`
	// The FQDN used to access the streams inside the stream pool (same FQDN as the messagesEndpoint attribute of a [Stream](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream) object). If the stream pool is private, the FQDN is customized and can only be accessed from inside the associated subnetId, otherwise the FQDN is publicly resolvable. Depending on which protocol you attempt to use, you need to either prepend https or append the Kafka port.
	EndpointFqdn pulumi.StringOutput `pulumi:"endpointFqdn"`
	// (Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapOutput `pulumi:"freeformTags"`
	// True if the stream pool is private, false otherwise. The associated endpoint and subnetId of a private stream pool can be retrieved through the [GetStreamPool](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/StreamPool/GetStreamPool) API.
	IsPrivate pulumi.BoolOutput `pulumi:"isPrivate"`
	// (Updatable) Settings for the Kafka compatibility layer.
	KafkaSettings StreamPoolKafkaSettingsOutput `pulumi:"kafkaSettings"`
	// Any additional details about the current state of the stream.
	LifecycleStateDetails pulumi.StringOutput `pulumi:"lifecycleStateDetails"`
	// (Updatable) The name of the stream pool. Avoid entering confidential information.  Example: `MyStreamPool`
	Name pulumi.StringOutput `pulumi:"name"`
	// Optional parameters if a private stream pool is requested.
	PrivateEndpointSettings StreamPoolPrivateEndpointSettingsOutput `pulumi:"privateEndpointSettings"`
	// The current state of the stream pool.
	State pulumi.StringOutput `pulumi:"state"`
	// The date and time the stream pool was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated pulumi.StringOutput `pulumi:"timeCreated"`
}

This resource provides the Stream Pool resource in Oracle Cloud Infrastructure Streaming service.

Starts the provisioning of a new stream pool. To track the progress of the provisioning, you can periodically call GetStreamPool. In the response, the `lifecycleState` parameter of the object tells you its current state.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-oci/sdk/go/oci/Streaming"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Streaming.NewStreamPool(ctx, "test_stream_pool", &Streaming.StreamPoolArgs{
			CompartmentId: pulumi.Any(compartmentId),
			Name:          pulumi.Any(streamPoolName),
			CustomEncryptionKey: &streaming.StreamPoolCustomEncryptionKeyArgs{
				KmsKeyId: pulumi.Any(testKey.Id),
			},
			DefinedTags: pulumi.Any(streamPoolDefinedTags),
			FreeformTags: pulumi.Map{
				"Department": pulumi.Any("Finance"),
			},
			KafkaSettings: &streaming.StreamPoolKafkaSettingsArgs{
				AutoCreateTopicsEnable: pulumi.Any(streamPoolKafkaSettingsAutoCreateTopicsEnable),
				BootstrapServers:       pulumi.Any(streamPoolKafkaSettingsBootstrapServers),
				LogRetentionHours:      pulumi.Any(streamPoolKafkaSettingsLogRetentionHours),
				NumPartitions:          pulumi.Any(streamPoolKafkaSettingsNumPartitions),
			},
			PrivateEndpointSettings: &streaming.StreamPoolPrivateEndpointSettingsArgs{
				NsgIds:            pulumi.Any(streamPoolPrivateEndpointSettingsNsgIds),
				PrivateEndpointIp: pulumi.Any(streamPoolPrivateEndpointSettingsPrivateEndpointIp),
				SubnetId:          pulumi.Any(testSubnet.Id),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

StreamPools can be imported using the `id`, e.g.

```sh $ pulumi import oci:Streaming/streamPool:StreamPool test_stream_pool "id" ```

func GetStreamPool 

func GetStreamPool(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *StreamPoolState, opts ...pulumi.ResourceOption) (*StreamPool, error)

GetStreamPool gets an existing StreamPool 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 NewStreamPool 

func NewStreamPool(ctx *pulumi.Context,
	name string, args *StreamPoolArgs, opts ...pulumi.ResourceOption) (*StreamPool, error)

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

func (*StreamPool) ElementType 

func (*StreamPool) ElementType() reflect.Type

func (*StreamPool) ToStreamPoolOutput 

func (i *StreamPool) ToStreamPoolOutput() StreamPoolOutput

func (*StreamPool) ToStreamPoolOutputWithContext 

func (i *StreamPool) ToStreamPoolOutputWithContext(ctx context.Context) StreamPoolOutput

type StreamPoolArgs 

type StreamPoolArgs struct {
	// (Updatable) The OCID of the compartment that contains the stream.
	CompartmentId pulumi.StringInput
	// (Updatable) The OCID of the custom encryption key to be used or deleted if currently being used.
	CustomEncryptionKey StreamPoolCustomEncryptionKeyPtrInput
	// (Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations.CostCenter": "42"}`
	DefinedTags pulumi.MapInput
	// (Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapInput
	// (Updatable) Settings for the Kafka compatibility layer.
	KafkaSettings StreamPoolKafkaSettingsPtrInput
	// (Updatable) The name of the stream pool. Avoid entering confidential information.  Example: `MyStreamPool`
	Name pulumi.StringPtrInput
	// Optional parameters if a private stream pool is requested.
	PrivateEndpointSettings StreamPoolPrivateEndpointSettingsPtrInput
}

The set of arguments for constructing a StreamPool resource.

func (StreamPoolArgs) ElementType 

func (StreamPoolArgs) ElementType() reflect.Type

type StreamPoolArray 

type StreamPoolArray []StreamPoolInput

func (StreamPoolArray) ElementType 

func (StreamPoolArray) ElementType() reflect.Type

func (StreamPoolArray) ToStreamPoolArrayOutput 

func (i StreamPoolArray) ToStreamPoolArrayOutput() StreamPoolArrayOutput

func (StreamPoolArray) ToStreamPoolArrayOutputWithContext 

func (i StreamPoolArray) ToStreamPoolArrayOutputWithContext(ctx context.Context) StreamPoolArrayOutput

type StreamPoolArrayInput 

type StreamPoolArrayInput interface {
	pulumi.Input

	ToStreamPoolArrayOutput() StreamPoolArrayOutput
	ToStreamPoolArrayOutputWithContext(context.Context) StreamPoolArrayOutput
}

StreamPoolArrayInput is an input type that accepts StreamPoolArray and StreamPoolArrayOutput values. You can construct a concrete instance of `StreamPoolArrayInput` via: 

StreamPoolArray{ StreamPoolArgs{...} }

type StreamPoolArrayOutput 

type StreamPoolArrayOutput struct{ *pulumi.OutputState }

func (StreamPoolArrayOutput) ElementType 

func (StreamPoolArrayOutput) ElementType() reflect.Type

func (StreamPoolArrayOutput) Index 

func (o StreamPoolArrayOutput) Index(i pulumi.IntInput) StreamPoolOutput

func (StreamPoolArrayOutput) ToStreamPoolArrayOutput 

func (o StreamPoolArrayOutput) ToStreamPoolArrayOutput() StreamPoolArrayOutput

func (StreamPoolArrayOutput) ToStreamPoolArrayOutputWithContext 

func (o StreamPoolArrayOutput) ToStreamPoolArrayOutputWithContext(ctx context.Context) StreamPoolArrayOutput

type StreamPoolCustomEncryptionKey 

type StreamPoolCustomEncryptionKey struct {
	// Life cycle State of the custom key
	KeyState *string `pulumi:"keyState"`
	// (Updatable) Custom Encryption Key (Master Key) ocid.
	KmsKeyId string `pulumi:"kmsKeyId"`
}

type StreamPoolCustomEncryptionKeyArgs 

type StreamPoolCustomEncryptionKeyArgs struct {
	// Life cycle State of the custom key
	KeyState pulumi.StringPtrInput `pulumi:"keyState"`
	// (Updatable) Custom Encryption Key (Master Key) ocid.
	KmsKeyId pulumi.StringInput `pulumi:"kmsKeyId"`
}

func (StreamPoolCustomEncryptionKeyArgs) ElementType 

func (StreamPoolCustomEncryptionKeyArgs) ElementType() reflect.Type

func (StreamPoolCustomEncryptionKeyArgs) ToStreamPoolCustomEncryptionKeyOutput 

func (i StreamPoolCustomEncryptionKeyArgs) ToStreamPoolCustomEncryptionKeyOutput() StreamPoolCustomEncryptionKeyOutput

func (StreamPoolCustomEncryptionKeyArgs) ToStreamPoolCustomEncryptionKeyOutputWithContext 

func (i StreamPoolCustomEncryptionKeyArgs) ToStreamPoolCustomEncryptionKeyOutputWithContext(ctx context.Context) StreamPoolCustomEncryptionKeyOutput

func (StreamPoolCustomEncryptionKeyArgs) ToStreamPoolCustomEncryptionKeyPtrOutput 

func (i StreamPoolCustomEncryptionKeyArgs) ToStreamPoolCustomEncryptionKeyPtrOutput() StreamPoolCustomEncryptionKeyPtrOutput

func (StreamPoolCustomEncryptionKeyArgs) ToStreamPoolCustomEncryptionKeyPtrOutputWithContext 

func (i StreamPoolCustomEncryptionKeyArgs) ToStreamPoolCustomEncryptionKeyPtrOutputWithContext(ctx context.Context) StreamPoolCustomEncryptionKeyPtrOutput

type StreamPoolCustomEncryptionKeyInput 

type StreamPoolCustomEncryptionKeyInput interface {
	pulumi.Input

	ToStreamPoolCustomEncryptionKeyOutput() StreamPoolCustomEncryptionKeyOutput
	ToStreamPoolCustomEncryptionKeyOutputWithContext(context.Context) StreamPoolCustomEncryptionKeyOutput
}

StreamPoolCustomEncryptionKeyInput is an input type that accepts StreamPoolCustomEncryptionKeyArgs and StreamPoolCustomEncryptionKeyOutput values. You can construct a concrete instance of `StreamPoolCustomEncryptionKeyInput` via: 

StreamPoolCustomEncryptionKeyArgs{...}

type StreamPoolCustomEncryptionKeyOutput 

type StreamPoolCustomEncryptionKeyOutput struct{ *pulumi.OutputState }

func (StreamPoolCustomEncryptionKeyOutput) ElementType 

func (StreamPoolCustomEncryptionKeyOutput) ElementType() reflect.Type

func (StreamPoolCustomEncryptionKeyOutput) KeyState 

func (o StreamPoolCustomEncryptionKeyOutput) KeyState() pulumi.StringPtrOutput

Life cycle State of the custom key

func (StreamPoolCustomEncryptionKeyOutput) KmsKeyId 

func (o StreamPoolCustomEncryptionKeyOutput) KmsKeyId() pulumi.StringOutput

(Updatable) Custom Encryption Key (Master Key) ocid.

func (StreamPoolCustomEncryptionKeyOutput) ToStreamPoolCustomEncryptionKeyOutput 

func (o StreamPoolCustomEncryptionKeyOutput) ToStreamPoolCustomEncryptionKeyOutput() StreamPoolCustomEncryptionKeyOutput

func (StreamPoolCustomEncryptionKeyOutput) ToStreamPoolCustomEncryptionKeyOutputWithContext 

func (o StreamPoolCustomEncryptionKeyOutput) ToStreamPoolCustomEncryptionKeyOutputWithContext(ctx context.Context) StreamPoolCustomEncryptionKeyOutput

func (StreamPoolCustomEncryptionKeyOutput) ToStreamPoolCustomEncryptionKeyPtrOutput 

func (o StreamPoolCustomEncryptionKeyOutput) ToStreamPoolCustomEncryptionKeyPtrOutput() StreamPoolCustomEncryptionKeyPtrOutput

func (StreamPoolCustomEncryptionKeyOutput) ToStreamPoolCustomEncryptionKeyPtrOutputWithContext 

func (o StreamPoolCustomEncryptionKeyOutput) ToStreamPoolCustomEncryptionKeyPtrOutputWithContext(ctx context.Context) StreamPoolCustomEncryptionKeyPtrOutput

type StreamPoolCustomEncryptionKeyPtrInput 

type StreamPoolCustomEncryptionKeyPtrInput interface {
	pulumi.Input

	ToStreamPoolCustomEncryptionKeyPtrOutput() StreamPoolCustomEncryptionKeyPtrOutput
	ToStreamPoolCustomEncryptionKeyPtrOutputWithContext(context.Context) StreamPoolCustomEncryptionKeyPtrOutput
}

StreamPoolCustomEncryptionKeyPtrInput is an input type that accepts StreamPoolCustomEncryptionKeyArgs, StreamPoolCustomEncryptionKeyPtr and StreamPoolCustomEncryptionKeyPtrOutput values. You can construct a concrete instance of `StreamPoolCustomEncryptionKeyPtrInput` via: 

        StreamPoolCustomEncryptionKeyArgs{...}

or:

        nil

func StreamPoolCustomEncryptionKeyPtr 

func StreamPoolCustomEncryptionKeyPtr(v *StreamPoolCustomEncryptionKeyArgs) StreamPoolCustomEncryptionKeyPtrInput

type StreamPoolCustomEncryptionKeyPtrOutput 

type StreamPoolCustomEncryptionKeyPtrOutput struct{ *pulumi.OutputState }

func (StreamPoolCustomEncryptionKeyPtrOutput) Elem 

func (o StreamPoolCustomEncryptionKeyPtrOutput) Elem() StreamPoolCustomEncryptionKeyOutput

func (StreamPoolCustomEncryptionKeyPtrOutput) ElementType 

func (StreamPoolCustomEncryptionKeyPtrOutput) ElementType() reflect.Type

func (StreamPoolCustomEncryptionKeyPtrOutput) KeyState 

func (o StreamPoolCustomEncryptionKeyPtrOutput) KeyState() pulumi.StringPtrOutput

Life cycle State of the custom key

func (StreamPoolCustomEncryptionKeyPtrOutput) KmsKeyId 

func (o StreamPoolCustomEncryptionKeyPtrOutput) KmsKeyId() pulumi.StringPtrOutput

(Updatable) Custom Encryption Key (Master Key) ocid.

func (StreamPoolCustomEncryptionKeyPtrOutput) ToStreamPoolCustomEncryptionKeyPtrOutput 

func (o StreamPoolCustomEncryptionKeyPtrOutput) ToStreamPoolCustomEncryptionKeyPtrOutput() StreamPoolCustomEncryptionKeyPtrOutput

func (StreamPoolCustomEncryptionKeyPtrOutput) ToStreamPoolCustomEncryptionKeyPtrOutputWithContext 

func (o StreamPoolCustomEncryptionKeyPtrOutput) ToStreamPoolCustomEncryptionKeyPtrOutputWithContext(ctx context.Context) StreamPoolCustomEncryptionKeyPtrOutput

type StreamPoolInput 

type StreamPoolInput interface {
	pulumi.Input

	ToStreamPoolOutput() StreamPoolOutput
	ToStreamPoolOutputWithContext(ctx context.Context) StreamPoolOutput
}

type StreamPoolKafkaSettings 

type StreamPoolKafkaSettings struct {
	// (Updatable) Enable auto creation of topic on the server.
	AutoCreateTopicsEnable *bool `pulumi:"autoCreateTopicsEnable"`
	// (Updatable) Bootstrap servers.
	BootstrapServers *string `pulumi:"bootstrapServers"`
	// (Updatable) The number of hours to keep a log file before deleting it (in hours).
	LogRetentionHours *int `pulumi:"logRetentionHours"`
	// (Updatable) The default number of log partitions per topic.
	NumPartitions *int `pulumi:"numPartitions"`
}

type StreamPoolKafkaSettingsArgs 

type StreamPoolKafkaSettingsArgs struct {
	// (Updatable) Enable auto creation of topic on the server.
	AutoCreateTopicsEnable pulumi.BoolPtrInput `pulumi:"autoCreateTopicsEnable"`
	// (Updatable) Bootstrap servers.
	BootstrapServers pulumi.StringPtrInput `pulumi:"bootstrapServers"`
	// (Updatable) The number of hours to keep a log file before deleting it (in hours).
	LogRetentionHours pulumi.IntPtrInput `pulumi:"logRetentionHours"`
	// (Updatable) The default number of log partitions per topic.
	NumPartitions pulumi.IntPtrInput `pulumi:"numPartitions"`
}

func (StreamPoolKafkaSettingsArgs) ElementType 

func (StreamPoolKafkaSettingsArgs) ElementType() reflect.Type

func (StreamPoolKafkaSettingsArgs) ToStreamPoolKafkaSettingsOutput 

func (i StreamPoolKafkaSettingsArgs) ToStreamPoolKafkaSettingsOutput() StreamPoolKafkaSettingsOutput

func (StreamPoolKafkaSettingsArgs) ToStreamPoolKafkaSettingsOutputWithContext 

func (i StreamPoolKafkaSettingsArgs) ToStreamPoolKafkaSettingsOutputWithContext(ctx context.Context) StreamPoolKafkaSettingsOutput

func (StreamPoolKafkaSettingsArgs) ToStreamPoolKafkaSettingsPtrOutput 

func (i StreamPoolKafkaSettingsArgs) ToStreamPoolKafkaSettingsPtrOutput() StreamPoolKafkaSettingsPtrOutput

func (StreamPoolKafkaSettingsArgs) ToStreamPoolKafkaSettingsPtrOutputWithContext 

func (i StreamPoolKafkaSettingsArgs) ToStreamPoolKafkaSettingsPtrOutputWithContext(ctx context.Context) StreamPoolKafkaSettingsPtrOutput

type StreamPoolKafkaSettingsInput 

type StreamPoolKafkaSettingsInput interface {
	pulumi.Input

	ToStreamPoolKafkaSettingsOutput() StreamPoolKafkaSettingsOutput
	ToStreamPoolKafkaSettingsOutputWithContext(context.Context) StreamPoolKafkaSettingsOutput
}

StreamPoolKafkaSettingsInput is an input type that accepts StreamPoolKafkaSettingsArgs and StreamPoolKafkaSettingsOutput values. You can construct a concrete instance of `StreamPoolKafkaSettingsInput` via: 

StreamPoolKafkaSettingsArgs{...}

type StreamPoolKafkaSettingsOutput 

type StreamPoolKafkaSettingsOutput struct{ *pulumi.OutputState }

func (StreamPoolKafkaSettingsOutput) AutoCreateTopicsEnable 

func (o StreamPoolKafkaSettingsOutput) AutoCreateTopicsEnable() pulumi.BoolPtrOutput

(Updatable) Enable auto creation of topic on the server.

func (StreamPoolKafkaSettingsOutput) BootstrapServers 

func (o StreamPoolKafkaSettingsOutput) BootstrapServers() pulumi.StringPtrOutput

(Updatable) Bootstrap servers.

func (StreamPoolKafkaSettingsOutput) ElementType 

func (StreamPoolKafkaSettingsOutput) ElementType() reflect.Type

func (StreamPoolKafkaSettingsOutput) LogRetentionHours 

func (o StreamPoolKafkaSettingsOutput) LogRetentionHours() pulumi.IntPtrOutput

(Updatable) The number of hours to keep a log file before deleting it (in hours).

func (StreamPoolKafkaSettingsOutput) NumPartitions 

func (o StreamPoolKafkaSettingsOutput) NumPartitions() pulumi.IntPtrOutput

(Updatable) The default number of log partitions per topic.

func (StreamPoolKafkaSettingsOutput) ToStreamPoolKafkaSettingsOutput 

func (o StreamPoolKafkaSettingsOutput) ToStreamPoolKafkaSettingsOutput() StreamPoolKafkaSettingsOutput

func (StreamPoolKafkaSettingsOutput) ToStreamPoolKafkaSettingsOutputWithContext 

func (o StreamPoolKafkaSettingsOutput) ToStreamPoolKafkaSettingsOutputWithContext(ctx context.Context) StreamPoolKafkaSettingsOutput

func (StreamPoolKafkaSettingsOutput) ToStreamPoolKafkaSettingsPtrOutput 

func (o StreamPoolKafkaSettingsOutput) ToStreamPoolKafkaSettingsPtrOutput() StreamPoolKafkaSettingsPtrOutput

func (StreamPoolKafkaSettingsOutput) ToStreamPoolKafkaSettingsPtrOutputWithContext 

func (o StreamPoolKafkaSettingsOutput) ToStreamPoolKafkaSettingsPtrOutputWithContext(ctx context.Context) StreamPoolKafkaSettingsPtrOutput

type StreamPoolKafkaSettingsPtrInput 

type StreamPoolKafkaSettingsPtrInput interface {
	pulumi.Input

	ToStreamPoolKafkaSettingsPtrOutput() StreamPoolKafkaSettingsPtrOutput
	ToStreamPoolKafkaSettingsPtrOutputWithContext(context.Context) StreamPoolKafkaSettingsPtrOutput
}

StreamPoolKafkaSettingsPtrInput is an input type that accepts StreamPoolKafkaSettingsArgs, StreamPoolKafkaSettingsPtr and StreamPoolKafkaSettingsPtrOutput values. You can construct a concrete instance of `StreamPoolKafkaSettingsPtrInput` via: 

        StreamPoolKafkaSettingsArgs{...}

or:

        nil

func StreamPoolKafkaSettingsPtr 

func StreamPoolKafkaSettingsPtr(v *StreamPoolKafkaSettingsArgs) StreamPoolKafkaSettingsPtrInput

type StreamPoolKafkaSettingsPtrOutput 

type StreamPoolKafkaSettingsPtrOutput struct{ *pulumi.OutputState }

func (StreamPoolKafkaSettingsPtrOutput) AutoCreateTopicsEnable 

func (o StreamPoolKafkaSettingsPtrOutput) AutoCreateTopicsEnable() pulumi.BoolPtrOutput

(Updatable) Enable auto creation of topic on the server.

func (StreamPoolKafkaSettingsPtrOutput) BootstrapServers 

func (o StreamPoolKafkaSettingsPtrOutput) BootstrapServers() pulumi.StringPtrOutput

(Updatable) Bootstrap servers.

func (StreamPoolKafkaSettingsPtrOutput) Elem 

func (o StreamPoolKafkaSettingsPtrOutput) Elem() StreamPoolKafkaSettingsOutput

func (StreamPoolKafkaSettingsPtrOutput) ElementType 

func (StreamPoolKafkaSettingsPtrOutput) ElementType() reflect.Type

func (StreamPoolKafkaSettingsPtrOutput) LogRetentionHours 

func (o StreamPoolKafkaSettingsPtrOutput) LogRetentionHours() pulumi.IntPtrOutput

(Updatable) The number of hours to keep a log file before deleting it (in hours).

func (StreamPoolKafkaSettingsPtrOutput) NumPartitions 

func (o StreamPoolKafkaSettingsPtrOutput) NumPartitions() pulumi.IntPtrOutput

(Updatable) The default number of log partitions per topic.

func (StreamPoolKafkaSettingsPtrOutput) ToStreamPoolKafkaSettingsPtrOutput 

func (o StreamPoolKafkaSettingsPtrOutput) ToStreamPoolKafkaSettingsPtrOutput() StreamPoolKafkaSettingsPtrOutput

func (StreamPoolKafkaSettingsPtrOutput) ToStreamPoolKafkaSettingsPtrOutputWithContext 

func (o StreamPoolKafkaSettingsPtrOutput) ToStreamPoolKafkaSettingsPtrOutputWithContext(ctx context.Context) StreamPoolKafkaSettingsPtrOutput

type StreamPoolMap 

type StreamPoolMap map[string]StreamPoolInput

func (StreamPoolMap) ElementType 

func (StreamPoolMap) ElementType() reflect.Type

func (StreamPoolMap) ToStreamPoolMapOutput 

func (i StreamPoolMap) ToStreamPoolMapOutput() StreamPoolMapOutput

func (StreamPoolMap) ToStreamPoolMapOutputWithContext 

func (i StreamPoolMap) ToStreamPoolMapOutputWithContext(ctx context.Context) StreamPoolMapOutput

type StreamPoolMapInput 

type StreamPoolMapInput interface {
	pulumi.Input

	ToStreamPoolMapOutput() StreamPoolMapOutput
	ToStreamPoolMapOutputWithContext(context.Context) StreamPoolMapOutput
}

StreamPoolMapInput is an input type that accepts StreamPoolMap and StreamPoolMapOutput values. You can construct a concrete instance of `StreamPoolMapInput` via: 

StreamPoolMap{ "key": StreamPoolArgs{...} }

type StreamPoolMapOutput 

type StreamPoolMapOutput struct{ *pulumi.OutputState }

func (StreamPoolMapOutput) ElementType 

func (StreamPoolMapOutput) ElementType() reflect.Type

func (StreamPoolMapOutput) MapIndex 

func (o StreamPoolMapOutput) MapIndex(k pulumi.StringInput) StreamPoolOutput

func (StreamPoolMapOutput) ToStreamPoolMapOutput 

func (o StreamPoolMapOutput) ToStreamPoolMapOutput() StreamPoolMapOutput

func (StreamPoolMapOutput) ToStreamPoolMapOutputWithContext 

func (o StreamPoolMapOutput) ToStreamPoolMapOutputWithContext(ctx context.Context) StreamPoolMapOutput

type StreamPoolOutput 

type StreamPoolOutput struct{ *pulumi.OutputState }

func (StreamPoolOutput) CompartmentId added in v0.4.0 

func (o StreamPoolOutput) CompartmentId() pulumi.StringOutput

(Updatable) The OCID of the compartment that contains the stream.

func (StreamPoolOutput) CustomEncryptionKey added in v0.4.0 

func (o StreamPoolOutput) CustomEncryptionKey() StreamPoolCustomEncryptionKeyOutput

(Updatable) The OCID of the custom encryption key to be used or deleted if currently being used.

func (StreamPoolOutput) DefinedTags added in v0.4.0 

func (o StreamPoolOutput) DefinedTags() pulumi.MapOutput

(Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Operations.CostCenter": "42"}`

func (StreamPoolOutput) ElementType 

func (StreamPoolOutput) ElementType() reflect.Type

func (StreamPoolOutput) EndpointFqdn added in v0.4.0 

func (o StreamPoolOutput) EndpointFqdn() pulumi.StringOutput

The FQDN used to access the streams inside the stream pool (same FQDN as the messagesEndpoint attribute of a Stream(https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream) object). If the stream pool is private, the FQDN is customized and can only be accessed from inside the associated subnetId, otherwise the FQDN is publicly resolvable. Depending on which protocol you attempt to use, you need to either prepend https or append the Kafka port.

func (StreamPoolOutput) FreeformTags added in v0.4.0 

func (o StreamPoolOutput) FreeformTags() pulumi.MapOutput

(Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). Example: `{"Department": "Finance"}`

func (StreamPoolOutput) IsPrivate added in v0.4.0 

func (o StreamPoolOutput) IsPrivate() pulumi.BoolOutput

True if the stream pool is private, false otherwise. The associated endpoint and subnetId of a private stream pool can be retrieved through the GetStreamPool(https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/StreamPool/GetStreamPool) API.

func (StreamPoolOutput) KafkaSettings added in v0.4.0 

func (o StreamPoolOutput) KafkaSettings() StreamPoolKafkaSettingsOutput

(Updatable) Settings for the Kafka compatibility layer.

func (StreamPoolOutput) LifecycleStateDetails added in v0.4.0 

func (o StreamPoolOutput) LifecycleStateDetails() pulumi.StringOutput

Any additional details about the current state of the stream.

func (StreamPoolOutput) Name added in v0.4.0 

func (o StreamPoolOutput) Name() pulumi.StringOutput

(Updatable) The name of the stream pool. Avoid entering confidential information. Example: `MyStreamPool`

func (StreamPoolOutput) PrivateEndpointSettings added in v0.4.0 

func (o StreamPoolOutput) PrivateEndpointSettings() StreamPoolPrivateEndpointSettingsOutput

Optional parameters if a private stream pool is requested.

func (StreamPoolOutput) State added in v0.4.0 

func (o StreamPoolOutput) State() pulumi.StringOutput

The current state of the stream pool.

func (StreamPoolOutput) TimeCreated added in v0.4.0 

func (o StreamPoolOutput) TimeCreated() pulumi.StringOutput

The date and time the stream pool was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format. Example: `2018-04-20T00:00:07.405Z`

func (StreamPoolOutput) ToStreamPoolOutput 

func (o StreamPoolOutput) ToStreamPoolOutput() StreamPoolOutput

func (StreamPoolOutput) ToStreamPoolOutputWithContext 

func (o StreamPoolOutput) ToStreamPoolOutputWithContext(ctx context.Context) StreamPoolOutput

type StreamPoolPrivateEndpointSettings 

type StreamPoolPrivateEndpointSettings struct {
	// The optional list of network security groups to be used with the private endpoint of the stream pool. That value cannot be changed.
	NsgIds []string `pulumi:"nsgIds"`
	// The optional private IP you want to be associated with your private stream pool. That parameter can only be specified when the subnetId parameter is set. It cannot be changed. The private IP needs to be part of the CIDR range of the specified subnetId or the creation will fail. If not specified a random IP inside the subnet will be chosen. After the stream pool is created, a custom FQDN, pointing to this private IP, is created. The FQDN is then used to access the service instead of the private IP.
	PrivateEndpointIp *string `pulumi:"privateEndpointIp"`
	// If specified, the stream pool will be private and only accessible from inside that subnet. Producing-to and consuming-from a stream inside a private stream pool can also only be done from inside the subnet. That value cannot be changed.
	//
	// ** IMPORTANT **
	// Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values
	SubnetId *string `pulumi:"subnetId"`
}

type StreamPoolPrivateEndpointSettingsArgs 

type StreamPoolPrivateEndpointSettingsArgs struct {
	// The optional list of network security groups to be used with the private endpoint of the stream pool. That value cannot be changed.
	NsgIds pulumi.StringArrayInput `pulumi:"nsgIds"`
	// The optional private IP you want to be associated with your private stream pool. That parameter can only be specified when the subnetId parameter is set. It cannot be changed. The private IP needs to be part of the CIDR range of the specified subnetId or the creation will fail. If not specified a random IP inside the subnet will be chosen. After the stream pool is created, a custom FQDN, pointing to this private IP, is created. The FQDN is then used to access the service instead of the private IP.
	PrivateEndpointIp pulumi.StringPtrInput `pulumi:"privateEndpointIp"`
	// If specified, the stream pool will be private and only accessible from inside that subnet. Producing-to and consuming-from a stream inside a private stream pool can also only be done from inside the subnet. That value cannot be changed.
	//
	// ** IMPORTANT **
	// Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values
	SubnetId pulumi.StringPtrInput `pulumi:"subnetId"`
}

func (StreamPoolPrivateEndpointSettingsArgs) ElementType 

func (StreamPoolPrivateEndpointSettingsArgs) ElementType() reflect.Type

func (StreamPoolPrivateEndpointSettingsArgs) ToStreamPoolPrivateEndpointSettingsOutput 

func (i StreamPoolPrivateEndpointSettingsArgs) ToStreamPoolPrivateEndpointSettingsOutput() StreamPoolPrivateEndpointSettingsOutput

func (StreamPoolPrivateEndpointSettingsArgs) ToStreamPoolPrivateEndpointSettingsOutputWithContext 

func (i StreamPoolPrivateEndpointSettingsArgs) ToStreamPoolPrivateEndpointSettingsOutputWithContext(ctx context.Context) StreamPoolPrivateEndpointSettingsOutput

func (StreamPoolPrivateEndpointSettingsArgs) ToStreamPoolPrivateEndpointSettingsPtrOutput 

func (i StreamPoolPrivateEndpointSettingsArgs) ToStreamPoolPrivateEndpointSettingsPtrOutput() StreamPoolPrivateEndpointSettingsPtrOutput

func (StreamPoolPrivateEndpointSettingsArgs) ToStreamPoolPrivateEndpointSettingsPtrOutputWithContext 

func (i StreamPoolPrivateEndpointSettingsArgs) ToStreamPoolPrivateEndpointSettingsPtrOutputWithContext(ctx context.Context) StreamPoolPrivateEndpointSettingsPtrOutput

type StreamPoolPrivateEndpointSettingsInput 

type StreamPoolPrivateEndpointSettingsInput interface {
	pulumi.Input

	ToStreamPoolPrivateEndpointSettingsOutput() StreamPoolPrivateEndpointSettingsOutput
	ToStreamPoolPrivateEndpointSettingsOutputWithContext(context.Context) StreamPoolPrivateEndpointSettingsOutput
}

StreamPoolPrivateEndpointSettingsInput is an input type that accepts StreamPoolPrivateEndpointSettingsArgs and StreamPoolPrivateEndpointSettingsOutput values. You can construct a concrete instance of `StreamPoolPrivateEndpointSettingsInput` via: 

StreamPoolPrivateEndpointSettingsArgs{...}

type StreamPoolPrivateEndpointSettingsOutput 

type StreamPoolPrivateEndpointSettingsOutput struct{ *pulumi.OutputState }

func (StreamPoolPrivateEndpointSettingsOutput) ElementType 

func (StreamPoolPrivateEndpointSettingsOutput) ElementType() reflect.Type

func (StreamPoolPrivateEndpointSettingsOutput) NsgIds 

func (o StreamPoolPrivateEndpointSettingsOutput) NsgIds() pulumi.StringArrayOutput

The optional list of network security groups to be used with the private endpoint of the stream pool. That value cannot be changed.

func (StreamPoolPrivateEndpointSettingsOutput) PrivateEndpointIp 

func (o StreamPoolPrivateEndpointSettingsOutput) PrivateEndpointIp() pulumi.StringPtrOutput

The optional private IP you want to be associated with your private stream pool. That parameter can only be specified when the subnetId parameter is set. It cannot be changed. The private IP needs to be part of the CIDR range of the specified subnetId or the creation will fail. If not specified a random IP inside the subnet will be chosen. After the stream pool is created, a custom FQDN, pointing to this private IP, is created. The FQDN is then used to access the service instead of the private IP.

func (StreamPoolPrivateEndpointSettingsOutput) SubnetId 

func (o StreamPoolPrivateEndpointSettingsOutput) SubnetId() pulumi.StringPtrOutput

If specified, the stream pool will be private and only accessible from inside that subnet. Producing-to and consuming-from a stream inside a private stream pool can also only be done from inside the subnet. That value cannot be changed.

** IMPORTANT ** Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values

func (StreamPoolPrivateEndpointSettingsOutput) ToStreamPoolPrivateEndpointSettingsOutput 

func (o StreamPoolPrivateEndpointSettingsOutput) ToStreamPoolPrivateEndpointSettingsOutput() StreamPoolPrivateEndpointSettingsOutput

func (StreamPoolPrivateEndpointSettingsOutput) ToStreamPoolPrivateEndpointSettingsOutputWithContext 

func (o StreamPoolPrivateEndpointSettingsOutput) ToStreamPoolPrivateEndpointSettingsOutputWithContext(ctx context.Context) StreamPoolPrivateEndpointSettingsOutput

func (StreamPoolPrivateEndpointSettingsOutput) ToStreamPoolPrivateEndpointSettingsPtrOutput 

func (o StreamPoolPrivateEndpointSettingsOutput) ToStreamPoolPrivateEndpointSettingsPtrOutput() StreamPoolPrivateEndpointSettingsPtrOutput

func (StreamPoolPrivateEndpointSettingsOutput) ToStreamPoolPrivateEndpointSettingsPtrOutputWithContext 

func (o StreamPoolPrivateEndpointSettingsOutput) ToStreamPoolPrivateEndpointSettingsPtrOutputWithContext(ctx context.Context) StreamPoolPrivateEndpointSettingsPtrOutput

type StreamPoolPrivateEndpointSettingsPtrInput 

type StreamPoolPrivateEndpointSettingsPtrInput interface {
	pulumi.Input

	ToStreamPoolPrivateEndpointSettingsPtrOutput() StreamPoolPrivateEndpointSettingsPtrOutput
	ToStreamPoolPrivateEndpointSettingsPtrOutputWithContext(context.Context) StreamPoolPrivateEndpointSettingsPtrOutput
}

StreamPoolPrivateEndpointSettingsPtrInput is an input type that accepts StreamPoolPrivateEndpointSettingsArgs, StreamPoolPrivateEndpointSettingsPtr and StreamPoolPrivateEndpointSettingsPtrOutput values. You can construct a concrete instance of `StreamPoolPrivateEndpointSettingsPtrInput` via: 

        StreamPoolPrivateEndpointSettingsArgs{...}

or:

        nil

func StreamPoolPrivateEndpointSettingsPtr 

func StreamPoolPrivateEndpointSettingsPtr(v *StreamPoolPrivateEndpointSettingsArgs) StreamPoolPrivateEndpointSettingsPtrInput

type StreamPoolPrivateEndpointSettingsPtrOutput 

type StreamPoolPrivateEndpointSettingsPtrOutput struct{ *pulumi.OutputState }

func (StreamPoolPrivateEndpointSettingsPtrOutput) Elem 

func (o StreamPoolPrivateEndpointSettingsPtrOutput) Elem() StreamPoolPrivateEndpointSettingsOutput

func (StreamPoolPrivateEndpointSettingsPtrOutput) ElementType 

func (StreamPoolPrivateEndpointSettingsPtrOutput) ElementType() reflect.Type

func (StreamPoolPrivateEndpointSettingsPtrOutput) NsgIds 

func (o StreamPoolPrivateEndpointSettingsPtrOutput) NsgIds() pulumi.StringArrayOutput

The optional list of network security groups to be used with the private endpoint of the stream pool. That value cannot be changed.

func (StreamPoolPrivateEndpointSettingsPtrOutput) PrivateEndpointIp 

func (o StreamPoolPrivateEndpointSettingsPtrOutput) PrivateEndpointIp() pulumi.StringPtrOutput

The optional private IP you want to be associated with your private stream pool. That parameter can only be specified when the subnetId parameter is set. It cannot be changed. The private IP needs to be part of the CIDR range of the specified subnetId or the creation will fail. If not specified a random IP inside the subnet will be chosen. After the stream pool is created, a custom FQDN, pointing to this private IP, is created. The FQDN is then used to access the service instead of the private IP.

func (StreamPoolPrivateEndpointSettingsPtrOutput) SubnetId 

func (o StreamPoolPrivateEndpointSettingsPtrOutput) SubnetId() pulumi.StringPtrOutput

If specified, the stream pool will be private and only accessible from inside that subnet. Producing-to and consuming-from a stream inside a private stream pool can also only be done from inside the subnet. That value cannot be changed.

** IMPORTANT ** Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values

func (StreamPoolPrivateEndpointSettingsPtrOutput) ToStreamPoolPrivateEndpointSettingsPtrOutput 

func (o StreamPoolPrivateEndpointSettingsPtrOutput) ToStreamPoolPrivateEndpointSettingsPtrOutput() StreamPoolPrivateEndpointSettingsPtrOutput

func (StreamPoolPrivateEndpointSettingsPtrOutput) ToStreamPoolPrivateEndpointSettingsPtrOutputWithContext 

func (o StreamPoolPrivateEndpointSettingsPtrOutput) ToStreamPoolPrivateEndpointSettingsPtrOutputWithContext(ctx context.Context) StreamPoolPrivateEndpointSettingsPtrOutput

type StreamPoolState 

type StreamPoolState struct {
	// (Updatable) The OCID of the compartment that contains the stream.
	CompartmentId pulumi.StringPtrInput
	// (Updatable) The OCID of the custom encryption key to be used or deleted if currently being used.
	CustomEncryptionKey StreamPoolCustomEncryptionKeyPtrInput
	// (Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations.CostCenter": "42"}`
	DefinedTags pulumi.MapInput
	// The FQDN used to access the streams inside the stream pool (same FQDN as the messagesEndpoint attribute of a [Stream](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/Stream) object). If the stream pool is private, the FQDN is customized and can only be accessed from inside the associated subnetId, otherwise the FQDN is publicly resolvable. Depending on which protocol you attempt to use, you need to either prepend https or append the Kafka port.
	EndpointFqdn pulumi.StringPtrInput
	// (Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapInput
	// True if the stream pool is private, false otherwise. The associated endpoint and subnetId of a private stream pool can be retrieved through the [GetStreamPool](https://docs.cloud.oracle.com/iaas/api/#/en/streaming/20180418/StreamPool/GetStreamPool) API.
	IsPrivate pulumi.BoolPtrInput
	// (Updatable) Settings for the Kafka compatibility layer.
	KafkaSettings StreamPoolKafkaSettingsPtrInput
	// Any additional details about the current state of the stream.
	LifecycleStateDetails pulumi.StringPtrInput
	// (Updatable) The name of the stream pool. Avoid entering confidential information.  Example: `MyStreamPool`
	Name pulumi.StringPtrInput
	// Optional parameters if a private stream pool is requested.
	PrivateEndpointSettings StreamPoolPrivateEndpointSettingsPtrInput
	// The current state of the stream pool.
	State pulumi.StringPtrInput
	// The date and time the stream pool was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated pulumi.StringPtrInput
}

func (StreamPoolState) ElementType 

func (StreamPoolState) ElementType() reflect.Type

type StreamState 

type StreamState struct {
	// (Updatable) The OCID of the compartment that contains the stream.
	CompartmentId pulumi.StringPtrInput
	// (Updatable) Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Operations.CostCenter": "42"}`
	DefinedTags pulumi.MapInput
	// (Updatable) Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only. For more information, see [Resource Tags](https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm).  Example: `{"Department": "Finance"}`
	FreeformTags pulumi.MapInput
	// Any additional details about the current state of the stream.
	LifecycleStateDetails pulumi.StringPtrInput
	// The endpoint to use when creating the StreamClient to consume or publish messages in the stream. If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.
	MessagesEndpoint pulumi.StringPtrInput
	// The name of the stream. Avoid entering confidential information.  Example: `TelemetryEvents`
	Name pulumi.StringPtrInput
	// The number of partitions in the stream.
	Partitions pulumi.IntPtrInput
	// The retention period of the stream, in hours. Accepted values are between 24 and 168 (7 days). If not specified, the stream will have a retention period of 24 hours.
	RetentionInHours pulumi.IntPtrInput
	// The current state of the stream.
	State pulumi.StringPtrInput
	// (Updatable) The OCID of the stream pool that contains the stream.
	//
	// ** IMPORTANT **
	// Any change to a property that does not support update will force the destruction and recreation of the resource with the new property values
	StreamPoolId pulumi.StringPtrInput
	// The date and time the stream was created, expressed in in [RFC 3339](https://tools.ietf.org/rfc/rfc3339) timestamp format.  Example: `2018-04-20T00:00:07.405Z`
	TimeCreated pulumi.StringPtrInput
}

func (StreamState) ElementType 

func (StreamState) 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.