rockset

package
v0.0.0-...-2624a34 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

A Pulumi package for creating and managing Rockset resources.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PkgVersion 

func PkgVersion() (semver.Version, error)

PkgVersion uses reflection to determine the version of the current package. If a version cannot be determined, v1 will be assumed. The second return value is always nil.

Types

type GetAccountCluster 

type GetAccountCluster struct {
	ApiServer string `pulumi:"apiServer"`
	AwsRegion string `pulumi:"awsRegion"`
	Type      string `pulumi:"type"`
}

type GetAccountClusterArgs 

type GetAccountClusterArgs struct {
	ApiServer pulumi.StringInput `pulumi:"apiServer"`
	AwsRegion pulumi.StringInput `pulumi:"awsRegion"`
	Type      pulumi.StringInput `pulumi:"type"`
}

func (GetAccountClusterArgs) ElementType 

func (GetAccountClusterArgs) ElementType() reflect.Type

func (GetAccountClusterArgs) ToGetAccountClusterOutput 

func (i GetAccountClusterArgs) ToGetAccountClusterOutput() GetAccountClusterOutput

func (GetAccountClusterArgs) ToGetAccountClusterOutputWithContext 

func (i GetAccountClusterArgs) ToGetAccountClusterOutputWithContext(ctx context.Context) GetAccountClusterOutput

type GetAccountClusterArray 

type GetAccountClusterArray []GetAccountClusterInput

func (GetAccountClusterArray) ElementType 

func (GetAccountClusterArray) ElementType() reflect.Type

func (GetAccountClusterArray) ToGetAccountClusterArrayOutput 

func (i GetAccountClusterArray) ToGetAccountClusterArrayOutput() GetAccountClusterArrayOutput

func (GetAccountClusterArray) ToGetAccountClusterArrayOutputWithContext 

func (i GetAccountClusterArray) ToGetAccountClusterArrayOutputWithContext(ctx context.Context) GetAccountClusterArrayOutput

type GetAccountClusterArrayInput 

type GetAccountClusterArrayInput interface {
	pulumi.Input

	ToGetAccountClusterArrayOutput() GetAccountClusterArrayOutput
	ToGetAccountClusterArrayOutputWithContext(context.Context) GetAccountClusterArrayOutput
}

GetAccountClusterArrayInput is an input type that accepts GetAccountClusterArray and GetAccountClusterArrayOutput values. You can construct a concrete instance of `GetAccountClusterArrayInput` via: 

GetAccountClusterArray{ GetAccountClusterArgs{...} }

type GetAccountClusterArrayOutput 

type GetAccountClusterArrayOutput struct{ *pulumi.OutputState }

func (GetAccountClusterArrayOutput) ElementType 

func (GetAccountClusterArrayOutput) ElementType() reflect.Type

func (GetAccountClusterArrayOutput) Index 

func (o GetAccountClusterArrayOutput) Index(i pulumi.IntInput) GetAccountClusterOutput

func (GetAccountClusterArrayOutput) ToGetAccountClusterArrayOutput 

func (o GetAccountClusterArrayOutput) ToGetAccountClusterArrayOutput() GetAccountClusterArrayOutput

func (GetAccountClusterArrayOutput) ToGetAccountClusterArrayOutputWithContext 

func (o GetAccountClusterArrayOutput) ToGetAccountClusterArrayOutputWithContext(ctx context.Context) GetAccountClusterArrayOutput

type GetAccountClusterInput 

type GetAccountClusterInput interface {
	pulumi.Input

	ToGetAccountClusterOutput() GetAccountClusterOutput
	ToGetAccountClusterOutputWithContext(context.Context) GetAccountClusterOutput
}

GetAccountClusterInput is an input type that accepts GetAccountClusterArgs and GetAccountClusterOutput values. You can construct a concrete instance of `GetAccountClusterInput` via: 

GetAccountClusterArgs{...}

type GetAccountClusterOutput 

type GetAccountClusterOutput struct{ *pulumi.OutputState }

func (GetAccountClusterOutput) ApiServer 

func (o GetAccountClusterOutput) ApiServer() pulumi.StringOutput

func (GetAccountClusterOutput) AwsRegion 

func (o GetAccountClusterOutput) AwsRegion() pulumi.StringOutput

func (GetAccountClusterOutput) ElementType 

func (GetAccountClusterOutput) ElementType() reflect.Type

func (GetAccountClusterOutput) ToGetAccountClusterOutput 

func (o GetAccountClusterOutput) ToGetAccountClusterOutput() GetAccountClusterOutput

func (GetAccountClusterOutput) ToGetAccountClusterOutputWithContext 

func (o GetAccountClusterOutput) ToGetAccountClusterOutputWithContext(ctx context.Context) GetAccountClusterOutput

func (GetAccountClusterOutput) Type 

func (o GetAccountClusterOutput) Type() pulumi.StringOutput

type GetAccountResult 

type GetAccountResult struct {
	// The AWS account ID to reference in AWS policies.
	AccountId string `pulumi:"accountId"`
	// The Rockset clusters available to this API key.
	Clusters []GetAccountCluster `pulumi:"clusters"`
	// The external ID to use in AWS trust policies.
	ExternalId string `pulumi:"externalId"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// The name of the organization for the API key.
	Organization string `pulumi:"organization"`
	// The name of the Rockset user used for AWS trust policies.
	RocksetUser string `pulumi:"rocksetUser"`
}

A collection of values returned by getAccount.

func GetAccount 

func GetAccount(ctx *pulumi.Context, opts ...pulumi.InvokeOption) (*GetAccountResult, error)

Gets information about the Rockset deployment for the specified api server.

type Provider 

type Provider struct {
	pulumi.ProviderResourceState

	// The API key used to access Rockset
	ApiKey pulumi.StringPtrOutput `pulumi:"apiKey"`
	// The API server for accessing Rockset
	ApiServer pulumi.StringPtrOutput `pulumi:"apiServer"`
}

The provider type for the rockset package. By default, resources use package-wide configuration settings, however an explicit `Provider` instance may be created and passed during resource construction to achieve fine-grained programmatic control over provider settings. See the [documentation](https://www.pulumi.com/docs/reference/programming-model/#providers) for more information.

func NewProvider 

func NewProvider(ctx *pulumi.Context,
	name string, args *ProviderArgs, opts ...pulumi.ResourceOption) (*Provider, error)

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

func (*Provider) ElementType 

func (*Provider) ElementType() reflect.Type

func (*Provider) ToProviderOutput 

func (i *Provider) ToProviderOutput() ProviderOutput

func (*Provider) ToProviderOutputWithContext 

func (i *Provider) ToProviderOutputWithContext(ctx context.Context) ProviderOutput

type ProviderArgs 

type ProviderArgs struct {
	// The API key used to access Rockset
	ApiKey pulumi.StringPtrInput
	// The API server for accessing Rockset
	ApiServer pulumi.StringPtrInput
}

The set of arguments for constructing a Provider resource.

func (ProviderArgs) ElementType 

func (ProviderArgs) ElementType() reflect.Type

type ProviderInput 

type ProviderInput interface {
	pulumi.Input

	ToProviderOutput() ProviderOutput
	ToProviderOutputWithContext(ctx context.Context) ProviderOutput
}

type ProviderOutput 

type ProviderOutput struct{ *pulumi.OutputState }

func (ProviderOutput) ApiKey 

func (o ProviderOutput) ApiKey() pulumi.StringPtrOutput

The API key used to access Rockset

func (ProviderOutput) ApiServer 

func (o ProviderOutput) ApiServer() pulumi.StringPtrOutput

The API server for accessing Rockset

func (ProviderOutput) ElementType 

func (ProviderOutput) ElementType() reflect.Type

func (ProviderOutput) ToProviderOutput 

func (o ProviderOutput) ToProviderOutput() ProviderOutput

func (ProviderOutput) ToProviderOutputWithContext 

func (o ProviderOutput) ToProviderOutputWithContext(ctx context.Context) ProviderOutput

type RocksetAlias 

type RocksetAlias struct {
	pulumi.CustomResourceState

	// List of collections for this alias to refer to.
	Collections pulumi.StringOutput `pulumi:"collections"`
	// Text describing the alias.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Unique identifier for the alias. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Name of the workspace the alias will be in.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages an alias for a set of collections.

func GetRocksetAlias 

func GetRocksetAlias(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetAliasState, opts ...pulumi.ResourceOption) (*RocksetAlias, error)

GetRocksetAlias gets an existing RocksetAlias 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 NewRocksetAlias 

func NewRocksetAlias(ctx *pulumi.Context,
	name string, args *RocksetAliasArgs, opts ...pulumi.ResourceOption) (*RocksetAlias, error)

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

func (*RocksetAlias) ElementType 

func (*RocksetAlias) ElementType() reflect.Type

func (*RocksetAlias) ToRocksetAliasOutput 

func (i *RocksetAlias) ToRocksetAliasOutput() RocksetAliasOutput

func (*RocksetAlias) ToRocksetAliasOutputWithContext 

func (i *RocksetAlias) ToRocksetAliasOutputWithContext(ctx context.Context) RocksetAliasOutput

type RocksetAliasArgs 

type RocksetAliasArgs struct {
	// List of collections for this alias to refer to.
	Collections pulumi.StringInput
	// Text describing the alias.
	Description pulumi.StringPtrInput
	// Unique identifier for the alias. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Name of the workspace the alias will be in.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetAlias resource.

func (RocksetAliasArgs) ElementType 

func (RocksetAliasArgs) ElementType() reflect.Type

type RocksetAliasArray 

type RocksetAliasArray []RocksetAliasInput

func (RocksetAliasArray) ElementType 

func (RocksetAliasArray) ElementType() reflect.Type

func (RocksetAliasArray) ToRocksetAliasArrayOutput 

func (i RocksetAliasArray) ToRocksetAliasArrayOutput() RocksetAliasArrayOutput

func (RocksetAliasArray) ToRocksetAliasArrayOutputWithContext 

func (i RocksetAliasArray) ToRocksetAliasArrayOutputWithContext(ctx context.Context) RocksetAliasArrayOutput

type RocksetAliasArrayInput 

type RocksetAliasArrayInput interface {
	pulumi.Input

	ToRocksetAliasArrayOutput() RocksetAliasArrayOutput
	ToRocksetAliasArrayOutputWithContext(context.Context) RocksetAliasArrayOutput
}

RocksetAliasArrayInput is an input type that accepts RocksetAliasArray and RocksetAliasArrayOutput values. You can construct a concrete instance of `RocksetAliasArrayInput` via: 

RocksetAliasArray{ RocksetAliasArgs{...} }

type RocksetAliasArrayOutput 

type RocksetAliasArrayOutput struct{ *pulumi.OutputState }

func (RocksetAliasArrayOutput) ElementType 

func (RocksetAliasArrayOutput) ElementType() reflect.Type

func (RocksetAliasArrayOutput) Index 

func (o RocksetAliasArrayOutput) Index(i pulumi.IntInput) RocksetAliasOutput

func (RocksetAliasArrayOutput) ToRocksetAliasArrayOutput 

func (o RocksetAliasArrayOutput) ToRocksetAliasArrayOutput() RocksetAliasArrayOutput

func (RocksetAliasArrayOutput) ToRocksetAliasArrayOutputWithContext 

func (o RocksetAliasArrayOutput) ToRocksetAliasArrayOutputWithContext(ctx context.Context) RocksetAliasArrayOutput

type RocksetAliasInput 

type RocksetAliasInput interface {
	pulumi.Input

	ToRocksetAliasOutput() RocksetAliasOutput
	ToRocksetAliasOutputWithContext(ctx context.Context) RocksetAliasOutput
}

type RocksetAliasMap 

type RocksetAliasMap map[string]RocksetAliasInput

func (RocksetAliasMap) ElementType 

func (RocksetAliasMap) ElementType() reflect.Type

func (RocksetAliasMap) ToRocksetAliasMapOutput 

func (i RocksetAliasMap) ToRocksetAliasMapOutput() RocksetAliasMapOutput

func (RocksetAliasMap) ToRocksetAliasMapOutputWithContext 

func (i RocksetAliasMap) ToRocksetAliasMapOutputWithContext(ctx context.Context) RocksetAliasMapOutput

type RocksetAliasMapInput 

type RocksetAliasMapInput interface {
	pulumi.Input

	ToRocksetAliasMapOutput() RocksetAliasMapOutput
	ToRocksetAliasMapOutputWithContext(context.Context) RocksetAliasMapOutput
}

RocksetAliasMapInput is an input type that accepts RocksetAliasMap and RocksetAliasMapOutput values. You can construct a concrete instance of `RocksetAliasMapInput` via: 

RocksetAliasMap{ "key": RocksetAliasArgs{...} }

type RocksetAliasMapOutput 

type RocksetAliasMapOutput struct{ *pulumi.OutputState }

func (RocksetAliasMapOutput) ElementType 

func (RocksetAliasMapOutput) ElementType() reflect.Type

func (RocksetAliasMapOutput) MapIndex 

func (o RocksetAliasMapOutput) MapIndex(k pulumi.StringInput) RocksetAliasOutput

func (RocksetAliasMapOutput) ToRocksetAliasMapOutput 

func (o RocksetAliasMapOutput) ToRocksetAliasMapOutput() RocksetAliasMapOutput

func (RocksetAliasMapOutput) ToRocksetAliasMapOutputWithContext 

func (o RocksetAliasMapOutput) ToRocksetAliasMapOutputWithContext(ctx context.Context) RocksetAliasMapOutput

type RocksetAliasOutput 

type RocksetAliasOutput struct{ *pulumi.OutputState }

func (RocksetAliasOutput) Collections 

func (o RocksetAliasOutput) Collections() pulumi.StringOutput

List of collections for this alias to refer to.

func (RocksetAliasOutput) Description 

func (o RocksetAliasOutput) Description() pulumi.StringPtrOutput

Text describing the alias.

func (RocksetAliasOutput) ElementType 

func (RocksetAliasOutput) ElementType() reflect.Type

func (RocksetAliasOutput) Name 

func (o RocksetAliasOutput) Name() pulumi.StringOutput

Unique identifier for the alias. Can contain alphanumeric or dash characters.

func (RocksetAliasOutput) ToRocksetAliasOutput 

func (o RocksetAliasOutput) ToRocksetAliasOutput() RocksetAliasOutput

func (RocksetAliasOutput) ToRocksetAliasOutputWithContext 

func (o RocksetAliasOutput) ToRocksetAliasOutputWithContext(ctx context.Context) RocksetAliasOutput

func (RocksetAliasOutput) Workspace 

func (o RocksetAliasOutput) Workspace() pulumi.StringOutput

Name of the workspace the alias will be in.

type RocksetAliasState 

type RocksetAliasState struct {
	// List of collections for this alias to refer to.
	Collections pulumi.StringPtrInput
	// Text describing the alias.
	Description pulumi.StringPtrInput
	// Unique identifier for the alias. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Name of the workspace the alias will be in.
	Workspace pulumi.StringPtrInput
}

func (RocksetAliasState) ElementType 

func (RocksetAliasState) ElementType() reflect.Type

type RocksetApiKey 

type RocksetApiKey struct {
	pulumi.CustomResourceState

	// The resulting Rockset api key.
	Key pulumi.StringOutput `pulumi:"key"`
	// Name of the api key.
	Name pulumi.StringOutput `pulumi:"name"`
	// The role the api key will use. If not specified, "All User Assigned Roles" will be used.
	Role pulumi.StringPtrOutput `pulumi:"role"`
	// The user the key is created for.
	User pulumi.StringOutput `pulumi:"user"`
}

Manage a Rockset Api Key.

Can be used together with roles to scope the actions the api key can take.

func GetRocksetApiKey 

func GetRocksetApiKey(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetApiKeyState, opts ...pulumi.ResourceOption) (*RocksetApiKey, error)

GetRocksetApiKey gets an existing RocksetApiKey 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 NewRocksetApiKey 

func NewRocksetApiKey(ctx *pulumi.Context,
	name string, args *RocksetApiKeyArgs, opts ...pulumi.ResourceOption) (*RocksetApiKey, error)

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

func (*RocksetApiKey) ElementType 

func (*RocksetApiKey) ElementType() reflect.Type

func (*RocksetApiKey) ToRocksetApiKeyOutput 

func (i *RocksetApiKey) ToRocksetApiKeyOutput() RocksetApiKeyOutput

func (*RocksetApiKey) ToRocksetApiKeyOutputWithContext 

func (i *RocksetApiKey) ToRocksetApiKeyOutputWithContext(ctx context.Context) RocksetApiKeyOutput

type RocksetApiKeyArgs 

type RocksetApiKeyArgs struct {
	// Name of the api key.
	Name pulumi.StringPtrInput
	// The role the api key will use. If not specified, "All User Assigned Roles" will be used.
	Role pulumi.StringPtrInput
}

The set of arguments for constructing a RocksetApiKey resource.

func (RocksetApiKeyArgs) ElementType 

func (RocksetApiKeyArgs) ElementType() reflect.Type

type RocksetApiKeyArray 

type RocksetApiKeyArray []RocksetApiKeyInput

func (RocksetApiKeyArray) ElementType 

func (RocksetApiKeyArray) ElementType() reflect.Type

func (RocksetApiKeyArray) ToRocksetApiKeyArrayOutput 

func (i RocksetApiKeyArray) ToRocksetApiKeyArrayOutput() RocksetApiKeyArrayOutput

func (RocksetApiKeyArray) ToRocksetApiKeyArrayOutputWithContext 

func (i RocksetApiKeyArray) ToRocksetApiKeyArrayOutputWithContext(ctx context.Context) RocksetApiKeyArrayOutput

type RocksetApiKeyArrayInput 

type RocksetApiKeyArrayInput interface {
	pulumi.Input

	ToRocksetApiKeyArrayOutput() RocksetApiKeyArrayOutput
	ToRocksetApiKeyArrayOutputWithContext(context.Context) RocksetApiKeyArrayOutput
}

RocksetApiKeyArrayInput is an input type that accepts RocksetApiKeyArray and RocksetApiKeyArrayOutput values. You can construct a concrete instance of `RocksetApiKeyArrayInput` via: 

RocksetApiKeyArray{ RocksetApiKeyArgs{...} }

type RocksetApiKeyArrayOutput 

type RocksetApiKeyArrayOutput struct{ *pulumi.OutputState }

func (RocksetApiKeyArrayOutput) ElementType 

func (RocksetApiKeyArrayOutput) ElementType() reflect.Type

func (RocksetApiKeyArrayOutput) Index 

func (o RocksetApiKeyArrayOutput) Index(i pulumi.IntInput) RocksetApiKeyOutput

func (RocksetApiKeyArrayOutput) ToRocksetApiKeyArrayOutput 

func (o RocksetApiKeyArrayOutput) ToRocksetApiKeyArrayOutput() RocksetApiKeyArrayOutput

func (RocksetApiKeyArrayOutput) ToRocksetApiKeyArrayOutputWithContext 

func (o RocksetApiKeyArrayOutput) ToRocksetApiKeyArrayOutputWithContext(ctx context.Context) RocksetApiKeyArrayOutput

type RocksetApiKeyInput 

type RocksetApiKeyInput interface {
	pulumi.Input

	ToRocksetApiKeyOutput() RocksetApiKeyOutput
	ToRocksetApiKeyOutputWithContext(ctx context.Context) RocksetApiKeyOutput
}

type RocksetApiKeyMap 

type RocksetApiKeyMap map[string]RocksetApiKeyInput

func (RocksetApiKeyMap) ElementType 

func (RocksetApiKeyMap) ElementType() reflect.Type

func (RocksetApiKeyMap) ToRocksetApiKeyMapOutput 

func (i RocksetApiKeyMap) ToRocksetApiKeyMapOutput() RocksetApiKeyMapOutput

func (RocksetApiKeyMap) ToRocksetApiKeyMapOutputWithContext 

func (i RocksetApiKeyMap) ToRocksetApiKeyMapOutputWithContext(ctx context.Context) RocksetApiKeyMapOutput

type RocksetApiKeyMapInput 

type RocksetApiKeyMapInput interface {
	pulumi.Input

	ToRocksetApiKeyMapOutput() RocksetApiKeyMapOutput
	ToRocksetApiKeyMapOutputWithContext(context.Context) RocksetApiKeyMapOutput
}

RocksetApiKeyMapInput is an input type that accepts RocksetApiKeyMap and RocksetApiKeyMapOutput values. You can construct a concrete instance of `RocksetApiKeyMapInput` via: 

RocksetApiKeyMap{ "key": RocksetApiKeyArgs{...} }

type RocksetApiKeyMapOutput 

type RocksetApiKeyMapOutput struct{ *pulumi.OutputState }

func (RocksetApiKeyMapOutput) ElementType 

func (RocksetApiKeyMapOutput) ElementType() reflect.Type

func (RocksetApiKeyMapOutput) MapIndex 

func (o RocksetApiKeyMapOutput) MapIndex(k pulumi.StringInput) RocksetApiKeyOutput

func (RocksetApiKeyMapOutput) ToRocksetApiKeyMapOutput 

func (o RocksetApiKeyMapOutput) ToRocksetApiKeyMapOutput() RocksetApiKeyMapOutput

func (RocksetApiKeyMapOutput) ToRocksetApiKeyMapOutputWithContext 

func (o RocksetApiKeyMapOutput) ToRocksetApiKeyMapOutputWithContext(ctx context.Context) RocksetApiKeyMapOutput

type RocksetApiKeyOutput 

type RocksetApiKeyOutput struct{ *pulumi.OutputState }

func (RocksetApiKeyOutput) ElementType 

func (RocksetApiKeyOutput) ElementType() reflect.Type

func (RocksetApiKeyOutput) Key 

func (o RocksetApiKeyOutput) Key() pulumi.StringOutput

The resulting Rockset api key.

func (RocksetApiKeyOutput) Name 

func (o RocksetApiKeyOutput) Name() pulumi.StringOutput

Name of the api key.

func (RocksetApiKeyOutput) Role 

func (o RocksetApiKeyOutput) Role() pulumi.StringPtrOutput

The role the api key will use. If not specified, "All User Assigned Roles" will be used.

func (RocksetApiKeyOutput) ToRocksetApiKeyOutput 

func (o RocksetApiKeyOutput) ToRocksetApiKeyOutput() RocksetApiKeyOutput

func (RocksetApiKeyOutput) ToRocksetApiKeyOutputWithContext 

func (o RocksetApiKeyOutput) ToRocksetApiKeyOutputWithContext(ctx context.Context) RocksetApiKeyOutput

func (RocksetApiKeyOutput) User 

func (o RocksetApiKeyOutput) User() pulumi.StringOutput

The user the key is created for.

type RocksetApiKeyState 

type RocksetApiKeyState struct {
	// The resulting Rockset api key.
	Key pulumi.StringPtrInput
	// Name of the api key.
	Name pulumi.StringPtrInput
	// The role the api key will use. If not specified, "All User Assigned Roles" will be used.
	Role pulumi.StringPtrInput
	// The user the key is created for.
	User pulumi.StringPtrInput
}

func (RocksetApiKeyState) ElementType 

func (RocksetApiKeyState) ElementType() reflect.Type

type RocksetCollection 

type RocksetCollection struct {
	pulumi.CustomResourceState

	// Text describing the collection.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrOutput `pulumi:"fieldMappingQuery"`
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrOutput `pulumi:"ingestTransformation"`
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrOutput `pulumi:"retentionSecs"`
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrOutput `pulumi:"waitForCollection"`
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrOutput `pulumi:"waitForDocuments"`
	// The name of the workspace.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a basic collection with no sources. Usually used for the write api.

func GetRocksetCollection 

func GetRocksetCollection(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetCollectionState, opts ...pulumi.ResourceOption) (*RocksetCollection, error)

GetRocksetCollection gets an existing RocksetCollection 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 NewRocksetCollection 

func NewRocksetCollection(ctx *pulumi.Context,
	name string, args *RocksetCollectionArgs, opts ...pulumi.ResourceOption) (*RocksetCollection, error)

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

func (*RocksetCollection) ElementType 

func (*RocksetCollection) ElementType() reflect.Type

func (*RocksetCollection) ToRocksetCollectionOutput 

func (i *RocksetCollection) ToRocksetCollectionOutput() RocksetCollectionOutput

func (*RocksetCollection) ToRocksetCollectionOutputWithContext 

func (i *RocksetCollection) ToRocksetCollectionOutputWithContext(ctx context.Context) RocksetCollectionOutput

type RocksetCollectionArgs 

type RocksetCollectionArgs struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetCollection resource.

func (RocksetCollectionArgs) ElementType 

func (RocksetCollectionArgs) ElementType() reflect.Type

type RocksetCollectionArray 

type RocksetCollectionArray []RocksetCollectionInput

func (RocksetCollectionArray) ElementType 

func (RocksetCollectionArray) ElementType() reflect.Type

func (RocksetCollectionArray) ToRocksetCollectionArrayOutput 

func (i RocksetCollectionArray) ToRocksetCollectionArrayOutput() RocksetCollectionArrayOutput

func (RocksetCollectionArray) ToRocksetCollectionArrayOutputWithContext 

func (i RocksetCollectionArray) ToRocksetCollectionArrayOutputWithContext(ctx context.Context) RocksetCollectionArrayOutput

type RocksetCollectionArrayInput 

type RocksetCollectionArrayInput interface {
	pulumi.Input

	ToRocksetCollectionArrayOutput() RocksetCollectionArrayOutput
	ToRocksetCollectionArrayOutputWithContext(context.Context) RocksetCollectionArrayOutput
}

RocksetCollectionArrayInput is an input type that accepts RocksetCollectionArray and RocksetCollectionArrayOutput values. You can construct a concrete instance of `RocksetCollectionArrayInput` via: 

RocksetCollectionArray{ RocksetCollectionArgs{...} }

type RocksetCollectionArrayOutput 

type RocksetCollectionArrayOutput struct{ *pulumi.OutputState }

func (RocksetCollectionArrayOutput) ElementType 

func (RocksetCollectionArrayOutput) ElementType() reflect.Type

func (RocksetCollectionArrayOutput) Index 

func (o RocksetCollectionArrayOutput) Index(i pulumi.IntInput) RocksetCollectionOutput

func (RocksetCollectionArrayOutput) ToRocksetCollectionArrayOutput 

func (o RocksetCollectionArrayOutput) ToRocksetCollectionArrayOutput() RocksetCollectionArrayOutput

func (RocksetCollectionArrayOutput) ToRocksetCollectionArrayOutputWithContext 

func (o RocksetCollectionArrayOutput) ToRocksetCollectionArrayOutputWithContext(ctx context.Context) RocksetCollectionArrayOutput

type RocksetCollectionInput 

type RocksetCollectionInput interface {
	pulumi.Input

	ToRocksetCollectionOutput() RocksetCollectionOutput
	ToRocksetCollectionOutputWithContext(ctx context.Context) RocksetCollectionOutput
}

type RocksetCollectionMap 

type RocksetCollectionMap map[string]RocksetCollectionInput

func (RocksetCollectionMap) ElementType 

func (RocksetCollectionMap) ElementType() reflect.Type

func (RocksetCollectionMap) ToRocksetCollectionMapOutput 

func (i RocksetCollectionMap) ToRocksetCollectionMapOutput() RocksetCollectionMapOutput

func (RocksetCollectionMap) ToRocksetCollectionMapOutputWithContext 

func (i RocksetCollectionMap) ToRocksetCollectionMapOutputWithContext(ctx context.Context) RocksetCollectionMapOutput

type RocksetCollectionMapInput 

type RocksetCollectionMapInput interface {
	pulumi.Input

	ToRocksetCollectionMapOutput() RocksetCollectionMapOutput
	ToRocksetCollectionMapOutputWithContext(context.Context) RocksetCollectionMapOutput
}

RocksetCollectionMapInput is an input type that accepts RocksetCollectionMap and RocksetCollectionMapOutput values. You can construct a concrete instance of `RocksetCollectionMapInput` via: 

RocksetCollectionMap{ "key": RocksetCollectionArgs{...} }

type RocksetCollectionMapOutput 

type RocksetCollectionMapOutput struct{ *pulumi.OutputState }

func (RocksetCollectionMapOutput) ElementType 

func (RocksetCollectionMapOutput) ElementType() reflect.Type

func (RocksetCollectionMapOutput) MapIndex 

func (o RocksetCollectionMapOutput) MapIndex(k pulumi.StringInput) RocksetCollectionOutput

func (RocksetCollectionMapOutput) ToRocksetCollectionMapOutput 

func (o RocksetCollectionMapOutput) ToRocksetCollectionMapOutput() RocksetCollectionMapOutput

func (RocksetCollectionMapOutput) ToRocksetCollectionMapOutputWithContext 

func (o RocksetCollectionMapOutput) ToRocksetCollectionMapOutputWithContext(ctx context.Context) RocksetCollectionMapOutput

type RocksetCollectionOutput 

type RocksetCollectionOutput struct{ *pulumi.OutputState }

func (RocksetCollectionOutput) Description 

func (o RocksetCollectionOutput) Description() pulumi.StringPtrOutput

Text describing the collection.

func (RocksetCollectionOutput) ElementType 

func (RocksetCollectionOutput) ElementType() reflect.Type

func (RocksetCollectionOutput) FieldMappingQuery deprecated 

func (o RocksetCollectionOutput) FieldMappingQuery() pulumi.StringPtrOutput

**Deprecated** use ingestTransformation instead

Deprecated: Use ingest_transformation instead

func (RocksetCollectionOutput) IngestTransformation 

func (o RocksetCollectionOutput) IngestTransformation() pulumi.StringPtrOutput

Ingest transformation SQL query. Turns the collection into insertOnly mode.

func (RocksetCollectionOutput) Name 

func (o RocksetCollectionOutput) Name() pulumi.StringOutput

Unique identifier for the collection. Can contain alphanumeric or dash characters.

func (RocksetCollectionOutput) RetentionSecs 

func (o RocksetCollectionOutput) RetentionSecs() pulumi.IntPtrOutput

Number of seconds after which data is purged. Based on event time.

func (RocksetCollectionOutput) ToRocksetCollectionOutput 

func (o RocksetCollectionOutput) ToRocksetCollectionOutput() RocksetCollectionOutput

func (RocksetCollectionOutput) ToRocksetCollectionOutputWithContext 

func (o RocksetCollectionOutput) ToRocksetCollectionOutputWithContext(ctx context.Context) RocksetCollectionOutput

func (RocksetCollectionOutput) WaitForCollection 

func (o RocksetCollectionOutput) WaitForCollection() pulumi.BoolPtrOutput

Wait until the collection is ready.

func (RocksetCollectionOutput) WaitForDocuments 

func (o RocksetCollectionOutput) WaitForDocuments() pulumi.IntPtrOutput

Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.

func (RocksetCollectionOutput) Workspace 

func (o RocksetCollectionOutput) Workspace() pulumi.StringOutput

The name of the workspace.

type RocksetCollectionState 

type RocksetCollectionState struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringPtrInput
}

func (RocksetCollectionState) ElementType 

func (RocksetCollectionState) ElementType() reflect.Type

type RocksetDynamodbCollection 

type RocksetDynamodbCollection struct {
	pulumi.CustomResourceState

	// Text describing the collection.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrOutput `pulumi:"fieldMappingQuery"`
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrOutput `pulumi:"ingestTransformation"`
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrOutput `pulumi:"retentionSecs"`
	// Defines a source for this collection.
	Sources RocksetDynamodbCollectionSourceArrayOutput `pulumi:"sources"`
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrOutput `pulumi:"waitForCollection"`
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrOutput `pulumi:"waitForDocuments"`
	// The name of the workspace.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a collection with an DynamoDB source attached.

func GetRocksetDynamodbCollection 

func GetRocksetDynamodbCollection(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetDynamodbCollectionState, opts ...pulumi.ResourceOption) (*RocksetDynamodbCollection, error)

GetRocksetDynamodbCollection gets an existing RocksetDynamodbCollection 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 NewRocksetDynamodbCollection 

func NewRocksetDynamodbCollection(ctx *pulumi.Context,
	name string, args *RocksetDynamodbCollectionArgs, opts ...pulumi.ResourceOption) (*RocksetDynamodbCollection, error)

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

func (*RocksetDynamodbCollection) ElementType 

func (*RocksetDynamodbCollection) ElementType() reflect.Type

func (*RocksetDynamodbCollection) ToRocksetDynamodbCollectionOutput 

func (i *RocksetDynamodbCollection) ToRocksetDynamodbCollectionOutput() RocksetDynamodbCollectionOutput

func (*RocksetDynamodbCollection) ToRocksetDynamodbCollectionOutputWithContext 

func (i *RocksetDynamodbCollection) ToRocksetDynamodbCollectionOutputWithContext(ctx context.Context) RocksetDynamodbCollectionOutput

type RocksetDynamodbCollectionArgs 

type RocksetDynamodbCollectionArgs struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetDynamodbCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetDynamodbCollection resource.

func (RocksetDynamodbCollectionArgs) ElementType 

func (RocksetDynamodbCollectionArgs) ElementType() reflect.Type

type RocksetDynamodbCollectionArray 

type RocksetDynamodbCollectionArray []RocksetDynamodbCollectionInput

func (RocksetDynamodbCollectionArray) ElementType 

func (RocksetDynamodbCollectionArray) ElementType() reflect.Type

func (RocksetDynamodbCollectionArray) ToRocksetDynamodbCollectionArrayOutput 

func (i RocksetDynamodbCollectionArray) ToRocksetDynamodbCollectionArrayOutput() RocksetDynamodbCollectionArrayOutput

func (RocksetDynamodbCollectionArray) ToRocksetDynamodbCollectionArrayOutputWithContext 

func (i RocksetDynamodbCollectionArray) ToRocksetDynamodbCollectionArrayOutputWithContext(ctx context.Context) RocksetDynamodbCollectionArrayOutput

type RocksetDynamodbCollectionArrayInput 

type RocksetDynamodbCollectionArrayInput interface {
	pulumi.Input

	ToRocksetDynamodbCollectionArrayOutput() RocksetDynamodbCollectionArrayOutput
	ToRocksetDynamodbCollectionArrayOutputWithContext(context.Context) RocksetDynamodbCollectionArrayOutput
}

RocksetDynamodbCollectionArrayInput is an input type that accepts RocksetDynamodbCollectionArray and RocksetDynamodbCollectionArrayOutput values. You can construct a concrete instance of `RocksetDynamodbCollectionArrayInput` via: 

RocksetDynamodbCollectionArray{ RocksetDynamodbCollectionArgs{...} }

type RocksetDynamodbCollectionArrayOutput 

type RocksetDynamodbCollectionArrayOutput struct{ *pulumi.OutputState }

func (RocksetDynamodbCollectionArrayOutput) ElementType 

func (RocksetDynamodbCollectionArrayOutput) ElementType() reflect.Type

func (RocksetDynamodbCollectionArrayOutput) Index 

func (o RocksetDynamodbCollectionArrayOutput) Index(i pulumi.IntInput) RocksetDynamodbCollectionOutput

func (RocksetDynamodbCollectionArrayOutput) ToRocksetDynamodbCollectionArrayOutput 

func (o RocksetDynamodbCollectionArrayOutput) ToRocksetDynamodbCollectionArrayOutput() RocksetDynamodbCollectionArrayOutput

func (RocksetDynamodbCollectionArrayOutput) ToRocksetDynamodbCollectionArrayOutputWithContext 

func (o RocksetDynamodbCollectionArrayOutput) ToRocksetDynamodbCollectionArrayOutputWithContext(ctx context.Context) RocksetDynamodbCollectionArrayOutput

type RocksetDynamodbCollectionInput 

type RocksetDynamodbCollectionInput interface {
	pulumi.Input

	ToRocksetDynamodbCollectionOutput() RocksetDynamodbCollectionOutput
	ToRocksetDynamodbCollectionOutputWithContext(ctx context.Context) RocksetDynamodbCollectionOutput
}

type RocksetDynamodbCollectionMap 

type RocksetDynamodbCollectionMap map[string]RocksetDynamodbCollectionInput

func (RocksetDynamodbCollectionMap) ElementType 

func (RocksetDynamodbCollectionMap) ElementType() reflect.Type

func (RocksetDynamodbCollectionMap) ToRocksetDynamodbCollectionMapOutput 

func (i RocksetDynamodbCollectionMap) ToRocksetDynamodbCollectionMapOutput() RocksetDynamodbCollectionMapOutput

func (RocksetDynamodbCollectionMap) ToRocksetDynamodbCollectionMapOutputWithContext 

func (i RocksetDynamodbCollectionMap) ToRocksetDynamodbCollectionMapOutputWithContext(ctx context.Context) RocksetDynamodbCollectionMapOutput

type RocksetDynamodbCollectionMapInput 

type RocksetDynamodbCollectionMapInput interface {
	pulumi.Input

	ToRocksetDynamodbCollectionMapOutput() RocksetDynamodbCollectionMapOutput
	ToRocksetDynamodbCollectionMapOutputWithContext(context.Context) RocksetDynamodbCollectionMapOutput
}

RocksetDynamodbCollectionMapInput is an input type that accepts RocksetDynamodbCollectionMap and RocksetDynamodbCollectionMapOutput values. You can construct a concrete instance of `RocksetDynamodbCollectionMapInput` via: 

RocksetDynamodbCollectionMap{ "key": RocksetDynamodbCollectionArgs{...} }

type RocksetDynamodbCollectionMapOutput 

type RocksetDynamodbCollectionMapOutput struct{ *pulumi.OutputState }

func (RocksetDynamodbCollectionMapOutput) ElementType 

func (RocksetDynamodbCollectionMapOutput) ElementType() reflect.Type

func (RocksetDynamodbCollectionMapOutput) MapIndex 

func (o RocksetDynamodbCollectionMapOutput) MapIndex(k pulumi.StringInput) RocksetDynamodbCollectionOutput

func (RocksetDynamodbCollectionMapOutput) ToRocksetDynamodbCollectionMapOutput 

func (o RocksetDynamodbCollectionMapOutput) ToRocksetDynamodbCollectionMapOutput() RocksetDynamodbCollectionMapOutput

func (RocksetDynamodbCollectionMapOutput) ToRocksetDynamodbCollectionMapOutputWithContext 

func (o RocksetDynamodbCollectionMapOutput) ToRocksetDynamodbCollectionMapOutputWithContext(ctx context.Context) RocksetDynamodbCollectionMapOutput

type RocksetDynamodbCollectionOutput 

type RocksetDynamodbCollectionOutput struct{ *pulumi.OutputState }

func (RocksetDynamodbCollectionOutput) Description 

func (o RocksetDynamodbCollectionOutput) Description() pulumi.StringPtrOutput

Text describing the collection.

func (RocksetDynamodbCollectionOutput) ElementType 

func (RocksetDynamodbCollectionOutput) ElementType() reflect.Type

func (RocksetDynamodbCollectionOutput) FieldMappingQuery deprecated 

func (o RocksetDynamodbCollectionOutput) FieldMappingQuery() pulumi.StringPtrOutput

**Deprecated** use ingestTransformation instead

Deprecated: Use ingest_transformation instead

func (RocksetDynamodbCollectionOutput) IngestTransformation 

func (o RocksetDynamodbCollectionOutput) IngestTransformation() pulumi.StringPtrOutput

Ingest transformation SQL query. Turns the collection into insertOnly mode.

func (RocksetDynamodbCollectionOutput) Name 

func (o RocksetDynamodbCollectionOutput) Name() pulumi.StringOutput

Unique identifier for the collection. Can contain alphanumeric or dash characters.

func (RocksetDynamodbCollectionOutput) RetentionSecs 

func (o RocksetDynamodbCollectionOutput) RetentionSecs() pulumi.IntPtrOutput

Number of seconds after which data is purged. Based on event time.

func (RocksetDynamodbCollectionOutput) Sources 

func (o RocksetDynamodbCollectionOutput) Sources() RocksetDynamodbCollectionSourceArrayOutput

Defines a source for this collection.

func (RocksetDynamodbCollectionOutput) ToRocksetDynamodbCollectionOutput 

func (o RocksetDynamodbCollectionOutput) ToRocksetDynamodbCollectionOutput() RocksetDynamodbCollectionOutput

func (RocksetDynamodbCollectionOutput) ToRocksetDynamodbCollectionOutputWithContext 

func (o RocksetDynamodbCollectionOutput) ToRocksetDynamodbCollectionOutputWithContext(ctx context.Context) RocksetDynamodbCollectionOutput

func (RocksetDynamodbCollectionOutput) WaitForCollection 

func (o RocksetDynamodbCollectionOutput) WaitForCollection() pulumi.BoolPtrOutput

Wait until the collection is ready.

func (RocksetDynamodbCollectionOutput) WaitForDocuments 

func (o RocksetDynamodbCollectionOutput) WaitForDocuments() pulumi.IntPtrOutput

Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.

func (RocksetDynamodbCollectionOutput) Workspace 

func (o RocksetDynamodbCollectionOutput) Workspace() pulumi.StringOutput

The name of the workspace.

type RocksetDynamodbCollectionSource 

type RocksetDynamodbCollectionSource struct {
	// AWS region name of DynamoDB table, by default us-west-2 is used.
	AwsRegion *string `pulumi:"awsRegion"`
	// The name of the Rockset DynamoDB integration.
	IntegrationName string `pulumi:"integrationName"`
	// Max RCU usage for scan.
	Rcu *int `pulumi:"rcu"`
	// DynamoDB scan end time.
	ScanEndTime *string `pulumi:"scanEndTime"`
	// Number of records inserted using scan.
	ScanRecordsProcessed *int `pulumi:"scanRecordsProcessed"`
	// DynamoDB scan start time.
	ScanStartTime *string `pulumi:"scanStartTime"`
	// Number of records in DynamoDB table at time of scan.
	ScanTotalRecords *int `pulumi:"scanTotalRecords"`
	// State of current ingest for this table.
	State *string `pulumi:"state"`
	// ISO-8601 date when source was last processed.
	StreamLastProcessedAt *string `pulumi:"streamLastProcessedAt"`
	// Name of DynamoDB table containing data.
	TableName string `pulumi:"tableName"`
	// Whether the initial table scan should use the DynamoDB scan API. If false, export will be performed using an S3 bucket.
	UseScanApi *bool `pulumi:"useScanApi"`
}

type RocksetDynamodbCollectionSourceArgs 

type RocksetDynamodbCollectionSourceArgs struct {
	// AWS region name of DynamoDB table, by default us-west-2 is used.
	AwsRegion pulumi.StringPtrInput `pulumi:"awsRegion"`
	// The name of the Rockset DynamoDB integration.
	IntegrationName pulumi.StringInput `pulumi:"integrationName"`
	// Max RCU usage for scan.
	Rcu pulumi.IntPtrInput `pulumi:"rcu"`
	// DynamoDB scan end time.
	ScanEndTime pulumi.StringPtrInput `pulumi:"scanEndTime"`
	// Number of records inserted using scan.
	ScanRecordsProcessed pulumi.IntPtrInput `pulumi:"scanRecordsProcessed"`
	// DynamoDB scan start time.
	ScanStartTime pulumi.StringPtrInput `pulumi:"scanStartTime"`
	// Number of records in DynamoDB table at time of scan.
	ScanTotalRecords pulumi.IntPtrInput `pulumi:"scanTotalRecords"`
	// State of current ingest for this table.
	State pulumi.StringPtrInput `pulumi:"state"`
	// ISO-8601 date when source was last processed.
	StreamLastProcessedAt pulumi.StringPtrInput `pulumi:"streamLastProcessedAt"`
	// Name of DynamoDB table containing data.
	TableName pulumi.StringInput `pulumi:"tableName"`
	// Whether the initial table scan should use the DynamoDB scan API. If false, export will be performed using an S3 bucket.
	UseScanApi pulumi.BoolPtrInput `pulumi:"useScanApi"`
}

func (RocksetDynamodbCollectionSourceArgs) ElementType 

func (RocksetDynamodbCollectionSourceArgs) ElementType() reflect.Type

func (RocksetDynamodbCollectionSourceArgs) ToRocksetDynamodbCollectionSourceOutput 

func (i RocksetDynamodbCollectionSourceArgs) ToRocksetDynamodbCollectionSourceOutput() RocksetDynamodbCollectionSourceOutput

func (RocksetDynamodbCollectionSourceArgs) ToRocksetDynamodbCollectionSourceOutputWithContext 

func (i RocksetDynamodbCollectionSourceArgs) ToRocksetDynamodbCollectionSourceOutputWithContext(ctx context.Context) RocksetDynamodbCollectionSourceOutput

type RocksetDynamodbCollectionSourceArray 

type RocksetDynamodbCollectionSourceArray []RocksetDynamodbCollectionSourceInput

func (RocksetDynamodbCollectionSourceArray) ElementType 

func (RocksetDynamodbCollectionSourceArray) ElementType() reflect.Type

func (RocksetDynamodbCollectionSourceArray) ToRocksetDynamodbCollectionSourceArrayOutput 

func (i RocksetDynamodbCollectionSourceArray) ToRocksetDynamodbCollectionSourceArrayOutput() RocksetDynamodbCollectionSourceArrayOutput

func (RocksetDynamodbCollectionSourceArray) ToRocksetDynamodbCollectionSourceArrayOutputWithContext 

func (i RocksetDynamodbCollectionSourceArray) ToRocksetDynamodbCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetDynamodbCollectionSourceArrayOutput

type RocksetDynamodbCollectionSourceArrayInput 

type RocksetDynamodbCollectionSourceArrayInput interface {
	pulumi.Input

	ToRocksetDynamodbCollectionSourceArrayOutput() RocksetDynamodbCollectionSourceArrayOutput
	ToRocksetDynamodbCollectionSourceArrayOutputWithContext(context.Context) RocksetDynamodbCollectionSourceArrayOutput
}

RocksetDynamodbCollectionSourceArrayInput is an input type that accepts RocksetDynamodbCollectionSourceArray and RocksetDynamodbCollectionSourceArrayOutput values. You can construct a concrete instance of `RocksetDynamodbCollectionSourceArrayInput` via: 

RocksetDynamodbCollectionSourceArray{ RocksetDynamodbCollectionSourceArgs{...} }

type RocksetDynamodbCollectionSourceArrayOutput 

type RocksetDynamodbCollectionSourceArrayOutput struct{ *pulumi.OutputState }

func (RocksetDynamodbCollectionSourceArrayOutput) ElementType 

func (RocksetDynamodbCollectionSourceArrayOutput) ElementType() reflect.Type

func (RocksetDynamodbCollectionSourceArrayOutput) Index 

func (o RocksetDynamodbCollectionSourceArrayOutput) Index(i pulumi.IntInput) RocksetDynamodbCollectionSourceOutput

func (RocksetDynamodbCollectionSourceArrayOutput) ToRocksetDynamodbCollectionSourceArrayOutput 

func (o RocksetDynamodbCollectionSourceArrayOutput) ToRocksetDynamodbCollectionSourceArrayOutput() RocksetDynamodbCollectionSourceArrayOutput

func (RocksetDynamodbCollectionSourceArrayOutput) ToRocksetDynamodbCollectionSourceArrayOutputWithContext 

func (o RocksetDynamodbCollectionSourceArrayOutput) ToRocksetDynamodbCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetDynamodbCollectionSourceArrayOutput

type RocksetDynamodbCollectionSourceInput 

type RocksetDynamodbCollectionSourceInput interface {
	pulumi.Input

	ToRocksetDynamodbCollectionSourceOutput() RocksetDynamodbCollectionSourceOutput
	ToRocksetDynamodbCollectionSourceOutputWithContext(context.Context) RocksetDynamodbCollectionSourceOutput
}

RocksetDynamodbCollectionSourceInput is an input type that accepts RocksetDynamodbCollectionSourceArgs and RocksetDynamodbCollectionSourceOutput values. You can construct a concrete instance of `RocksetDynamodbCollectionSourceInput` via: 

RocksetDynamodbCollectionSourceArgs{...}

type RocksetDynamodbCollectionSourceOutput 

type RocksetDynamodbCollectionSourceOutput struct{ *pulumi.OutputState }

func (RocksetDynamodbCollectionSourceOutput) AwsRegion 

func (o RocksetDynamodbCollectionSourceOutput) AwsRegion() pulumi.StringPtrOutput

AWS region name of DynamoDB table, by default us-west-2 is used.

func (RocksetDynamodbCollectionSourceOutput) ElementType 

func (RocksetDynamodbCollectionSourceOutput) ElementType() reflect.Type

func (RocksetDynamodbCollectionSourceOutput) IntegrationName 

func (o RocksetDynamodbCollectionSourceOutput) IntegrationName() pulumi.StringOutput

The name of the Rockset DynamoDB integration.

func (RocksetDynamodbCollectionSourceOutput) Rcu 

func (o RocksetDynamodbCollectionSourceOutput) Rcu() pulumi.IntPtrOutput

Max RCU usage for scan.

func (RocksetDynamodbCollectionSourceOutput) ScanEndTime 

func (o RocksetDynamodbCollectionSourceOutput) ScanEndTime() pulumi.StringPtrOutput

DynamoDB scan end time.

func (RocksetDynamodbCollectionSourceOutput) ScanRecordsProcessed 

func (o RocksetDynamodbCollectionSourceOutput) ScanRecordsProcessed() pulumi.IntPtrOutput

Number of records inserted using scan.

func (RocksetDynamodbCollectionSourceOutput) ScanStartTime 

func (o RocksetDynamodbCollectionSourceOutput) ScanStartTime() pulumi.StringPtrOutput

DynamoDB scan start time.

func (RocksetDynamodbCollectionSourceOutput) ScanTotalRecords 

func (o RocksetDynamodbCollectionSourceOutput) ScanTotalRecords() pulumi.IntPtrOutput

Number of records in DynamoDB table at time of scan.

func (RocksetDynamodbCollectionSourceOutput) State 

func (o RocksetDynamodbCollectionSourceOutput) State() pulumi.StringPtrOutput

State of current ingest for this table.

func (RocksetDynamodbCollectionSourceOutput) StreamLastProcessedAt 

func (o RocksetDynamodbCollectionSourceOutput) StreamLastProcessedAt() pulumi.StringPtrOutput

ISO-8601 date when source was last processed.

func (RocksetDynamodbCollectionSourceOutput) TableName 

func (o RocksetDynamodbCollectionSourceOutput) TableName() pulumi.StringOutput

Name of DynamoDB table containing data.

func (RocksetDynamodbCollectionSourceOutput) ToRocksetDynamodbCollectionSourceOutput 

func (o RocksetDynamodbCollectionSourceOutput) ToRocksetDynamodbCollectionSourceOutput() RocksetDynamodbCollectionSourceOutput

func (RocksetDynamodbCollectionSourceOutput) ToRocksetDynamodbCollectionSourceOutputWithContext 

func (o RocksetDynamodbCollectionSourceOutput) ToRocksetDynamodbCollectionSourceOutputWithContext(ctx context.Context) RocksetDynamodbCollectionSourceOutput

func (RocksetDynamodbCollectionSourceOutput) UseScanApi 

func (o RocksetDynamodbCollectionSourceOutput) UseScanApi() pulumi.BoolPtrOutput

Whether the initial table scan should use the DynamoDB scan API. If false, export will be performed using an S3 bucket.

type RocksetDynamodbCollectionState 

type RocksetDynamodbCollectionState struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetDynamodbCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringPtrInput
}

func (RocksetDynamodbCollectionState) ElementType 

func (RocksetDynamodbCollectionState) ElementType() reflect.Type

type RocksetDynamodbIntegration 

type RocksetDynamodbIntegration struct {
	pulumi.CustomResourceState

	// The AWS Role Arn to use for this integration.
	AwsRoleArn pulumi.StringOutput `pulumi:"awsRoleArn"`
	// Text describing the integration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// AWS S3 bucket name used for exporting the DynamoDB tables.
	S3ExportBucketName pulumi.StringOutput `pulumi:"s3ExportBucketName"`
}

Manages a Rockset DynamoDB Integration.

func GetRocksetDynamodbIntegration 

func GetRocksetDynamodbIntegration(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetDynamodbIntegrationState, opts ...pulumi.ResourceOption) (*RocksetDynamodbIntegration, error)

GetRocksetDynamodbIntegration gets an existing RocksetDynamodbIntegration 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 NewRocksetDynamodbIntegration 

func NewRocksetDynamodbIntegration(ctx *pulumi.Context,
	name string, args *RocksetDynamodbIntegrationArgs, opts ...pulumi.ResourceOption) (*RocksetDynamodbIntegration, error)

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

func (*RocksetDynamodbIntegration) ElementType 

func (*RocksetDynamodbIntegration) ElementType() reflect.Type

func (*RocksetDynamodbIntegration) ToRocksetDynamodbIntegrationOutput 

func (i *RocksetDynamodbIntegration) ToRocksetDynamodbIntegrationOutput() RocksetDynamodbIntegrationOutput

func (*RocksetDynamodbIntegration) ToRocksetDynamodbIntegrationOutputWithContext 

func (i *RocksetDynamodbIntegration) ToRocksetDynamodbIntegrationOutputWithContext(ctx context.Context) RocksetDynamodbIntegrationOutput

type RocksetDynamodbIntegrationArgs 

type RocksetDynamodbIntegrationArgs struct {
	// The AWS Role Arn to use for this integration.
	AwsRoleArn pulumi.StringInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// AWS S3 bucket name used for exporting the DynamoDB tables.
	S3ExportBucketName pulumi.StringInput
}

The set of arguments for constructing a RocksetDynamodbIntegration resource.

func (RocksetDynamodbIntegrationArgs) ElementType 

func (RocksetDynamodbIntegrationArgs) ElementType() reflect.Type

type RocksetDynamodbIntegrationArray 

type RocksetDynamodbIntegrationArray []RocksetDynamodbIntegrationInput

func (RocksetDynamodbIntegrationArray) ElementType 

func (RocksetDynamodbIntegrationArray) ElementType() reflect.Type

func (RocksetDynamodbIntegrationArray) ToRocksetDynamodbIntegrationArrayOutput 

func (i RocksetDynamodbIntegrationArray) ToRocksetDynamodbIntegrationArrayOutput() RocksetDynamodbIntegrationArrayOutput

func (RocksetDynamodbIntegrationArray) ToRocksetDynamodbIntegrationArrayOutputWithContext 

func (i RocksetDynamodbIntegrationArray) ToRocksetDynamodbIntegrationArrayOutputWithContext(ctx context.Context) RocksetDynamodbIntegrationArrayOutput

type RocksetDynamodbIntegrationArrayInput 

type RocksetDynamodbIntegrationArrayInput interface {
	pulumi.Input

	ToRocksetDynamodbIntegrationArrayOutput() RocksetDynamodbIntegrationArrayOutput
	ToRocksetDynamodbIntegrationArrayOutputWithContext(context.Context) RocksetDynamodbIntegrationArrayOutput
}

RocksetDynamodbIntegrationArrayInput is an input type that accepts RocksetDynamodbIntegrationArray and RocksetDynamodbIntegrationArrayOutput values. You can construct a concrete instance of `RocksetDynamodbIntegrationArrayInput` via: 

RocksetDynamodbIntegrationArray{ RocksetDynamodbIntegrationArgs{...} }

type RocksetDynamodbIntegrationArrayOutput 

type RocksetDynamodbIntegrationArrayOutput struct{ *pulumi.OutputState }

func (RocksetDynamodbIntegrationArrayOutput) ElementType 

func (RocksetDynamodbIntegrationArrayOutput) ElementType() reflect.Type

func (RocksetDynamodbIntegrationArrayOutput) Index 

func (o RocksetDynamodbIntegrationArrayOutput) Index(i pulumi.IntInput) RocksetDynamodbIntegrationOutput

func (RocksetDynamodbIntegrationArrayOutput) ToRocksetDynamodbIntegrationArrayOutput 

func (o RocksetDynamodbIntegrationArrayOutput) ToRocksetDynamodbIntegrationArrayOutput() RocksetDynamodbIntegrationArrayOutput

func (RocksetDynamodbIntegrationArrayOutput) ToRocksetDynamodbIntegrationArrayOutputWithContext 

func (o RocksetDynamodbIntegrationArrayOutput) ToRocksetDynamodbIntegrationArrayOutputWithContext(ctx context.Context) RocksetDynamodbIntegrationArrayOutput

type RocksetDynamodbIntegrationInput 

type RocksetDynamodbIntegrationInput interface {
	pulumi.Input

	ToRocksetDynamodbIntegrationOutput() RocksetDynamodbIntegrationOutput
	ToRocksetDynamodbIntegrationOutputWithContext(ctx context.Context) RocksetDynamodbIntegrationOutput
}

type RocksetDynamodbIntegrationMap 

type RocksetDynamodbIntegrationMap map[string]RocksetDynamodbIntegrationInput

func (RocksetDynamodbIntegrationMap) ElementType 

func (RocksetDynamodbIntegrationMap) ElementType() reflect.Type

func (RocksetDynamodbIntegrationMap) ToRocksetDynamodbIntegrationMapOutput 

func (i RocksetDynamodbIntegrationMap) ToRocksetDynamodbIntegrationMapOutput() RocksetDynamodbIntegrationMapOutput

func (RocksetDynamodbIntegrationMap) ToRocksetDynamodbIntegrationMapOutputWithContext 

func (i RocksetDynamodbIntegrationMap) ToRocksetDynamodbIntegrationMapOutputWithContext(ctx context.Context) RocksetDynamodbIntegrationMapOutput

type RocksetDynamodbIntegrationMapInput 

type RocksetDynamodbIntegrationMapInput interface {
	pulumi.Input

	ToRocksetDynamodbIntegrationMapOutput() RocksetDynamodbIntegrationMapOutput
	ToRocksetDynamodbIntegrationMapOutputWithContext(context.Context) RocksetDynamodbIntegrationMapOutput
}

RocksetDynamodbIntegrationMapInput is an input type that accepts RocksetDynamodbIntegrationMap and RocksetDynamodbIntegrationMapOutput values. You can construct a concrete instance of `RocksetDynamodbIntegrationMapInput` via: 

RocksetDynamodbIntegrationMap{ "key": RocksetDynamodbIntegrationArgs{...} }

type RocksetDynamodbIntegrationMapOutput 

type RocksetDynamodbIntegrationMapOutput struct{ *pulumi.OutputState }

func (RocksetDynamodbIntegrationMapOutput) ElementType 

func (RocksetDynamodbIntegrationMapOutput) ElementType() reflect.Type

func (RocksetDynamodbIntegrationMapOutput) MapIndex 

func (o RocksetDynamodbIntegrationMapOutput) MapIndex(k pulumi.StringInput) RocksetDynamodbIntegrationOutput

func (RocksetDynamodbIntegrationMapOutput) ToRocksetDynamodbIntegrationMapOutput 

func (o RocksetDynamodbIntegrationMapOutput) ToRocksetDynamodbIntegrationMapOutput() RocksetDynamodbIntegrationMapOutput

func (RocksetDynamodbIntegrationMapOutput) ToRocksetDynamodbIntegrationMapOutputWithContext 

func (o RocksetDynamodbIntegrationMapOutput) ToRocksetDynamodbIntegrationMapOutputWithContext(ctx context.Context) RocksetDynamodbIntegrationMapOutput

type RocksetDynamodbIntegrationOutput 

type RocksetDynamodbIntegrationOutput struct{ *pulumi.OutputState }

func (RocksetDynamodbIntegrationOutput) AwsRoleArn 

func (o RocksetDynamodbIntegrationOutput) AwsRoleArn() pulumi.StringOutput

The AWS Role Arn to use for this integration.

func (RocksetDynamodbIntegrationOutput) Description 

func (o RocksetDynamodbIntegrationOutput) Description() pulumi.StringPtrOutput

Text describing the integration.

func (RocksetDynamodbIntegrationOutput) ElementType 

func (RocksetDynamodbIntegrationOutput) ElementType() reflect.Type

func (RocksetDynamodbIntegrationOutput) Name 

func (o RocksetDynamodbIntegrationOutput) Name() pulumi.StringOutput

Unique identifier for the integration. Can contain alphanumeric or dash characters.

func (RocksetDynamodbIntegrationOutput) S3ExportBucketName 

func (o RocksetDynamodbIntegrationOutput) S3ExportBucketName() pulumi.StringOutput

AWS S3 bucket name used for exporting the DynamoDB tables.

func (RocksetDynamodbIntegrationOutput) ToRocksetDynamodbIntegrationOutput 

func (o RocksetDynamodbIntegrationOutput) ToRocksetDynamodbIntegrationOutput() RocksetDynamodbIntegrationOutput

func (RocksetDynamodbIntegrationOutput) ToRocksetDynamodbIntegrationOutputWithContext 

func (o RocksetDynamodbIntegrationOutput) ToRocksetDynamodbIntegrationOutputWithContext(ctx context.Context) RocksetDynamodbIntegrationOutput

type RocksetDynamodbIntegrationState 

type RocksetDynamodbIntegrationState struct {
	// The AWS Role Arn to use for this integration.
	AwsRoleArn pulumi.StringPtrInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// AWS S3 bucket name used for exporting the DynamoDB tables.
	S3ExportBucketName pulumi.StringPtrInput
}

func (RocksetDynamodbIntegrationState) ElementType 

func (RocksetDynamodbIntegrationState) ElementType() reflect.Type

type RocksetGcsCollection 

type RocksetGcsCollection struct {
	pulumi.CustomResourceState

	// Text describing the collection.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrOutput `pulumi:"fieldMappingQuery"`
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrOutput `pulumi:"ingestTransformation"`
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrOutput `pulumi:"retentionSecs"`
	// Defines a source for this collection.
	Sources RocksetGcsCollectionSourceArrayOutput `pulumi:"sources"`
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrOutput `pulumi:"waitForCollection"`
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrOutput `pulumi:"waitForDocuments"`
	// The name of the workspace.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a collection with an GCS source attached.

func GetRocksetGcsCollection 

func GetRocksetGcsCollection(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetGcsCollectionState, opts ...pulumi.ResourceOption) (*RocksetGcsCollection, error)

GetRocksetGcsCollection gets an existing RocksetGcsCollection 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 NewRocksetGcsCollection 

func NewRocksetGcsCollection(ctx *pulumi.Context,
	name string, args *RocksetGcsCollectionArgs, opts ...pulumi.ResourceOption) (*RocksetGcsCollection, error)

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

func (*RocksetGcsCollection) ElementType 

func (*RocksetGcsCollection) ElementType() reflect.Type

func (*RocksetGcsCollection) ToRocksetGcsCollectionOutput 

func (i *RocksetGcsCollection) ToRocksetGcsCollectionOutput() RocksetGcsCollectionOutput

func (*RocksetGcsCollection) ToRocksetGcsCollectionOutputWithContext 

func (i *RocksetGcsCollection) ToRocksetGcsCollectionOutputWithContext(ctx context.Context) RocksetGcsCollectionOutput

type RocksetGcsCollectionArgs 

type RocksetGcsCollectionArgs struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetGcsCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetGcsCollection resource.

func (RocksetGcsCollectionArgs) ElementType 

func (RocksetGcsCollectionArgs) ElementType() reflect.Type

type RocksetGcsCollectionArray 

type RocksetGcsCollectionArray []RocksetGcsCollectionInput

func (RocksetGcsCollectionArray) ElementType 

func (RocksetGcsCollectionArray) ElementType() reflect.Type

func (RocksetGcsCollectionArray) ToRocksetGcsCollectionArrayOutput 

func (i RocksetGcsCollectionArray) ToRocksetGcsCollectionArrayOutput() RocksetGcsCollectionArrayOutput

func (RocksetGcsCollectionArray) ToRocksetGcsCollectionArrayOutputWithContext 

func (i RocksetGcsCollectionArray) ToRocksetGcsCollectionArrayOutputWithContext(ctx context.Context) RocksetGcsCollectionArrayOutput

type RocksetGcsCollectionArrayInput 

type RocksetGcsCollectionArrayInput interface {
	pulumi.Input

	ToRocksetGcsCollectionArrayOutput() RocksetGcsCollectionArrayOutput
	ToRocksetGcsCollectionArrayOutputWithContext(context.Context) RocksetGcsCollectionArrayOutput
}

RocksetGcsCollectionArrayInput is an input type that accepts RocksetGcsCollectionArray and RocksetGcsCollectionArrayOutput values. You can construct a concrete instance of `RocksetGcsCollectionArrayInput` via: 

RocksetGcsCollectionArray{ RocksetGcsCollectionArgs{...} }

type RocksetGcsCollectionArrayOutput 

type RocksetGcsCollectionArrayOutput struct{ *pulumi.OutputState }

func (RocksetGcsCollectionArrayOutput) ElementType 

func (RocksetGcsCollectionArrayOutput) ElementType() reflect.Type

func (RocksetGcsCollectionArrayOutput) Index 

func (o RocksetGcsCollectionArrayOutput) Index(i pulumi.IntInput) RocksetGcsCollectionOutput

func (RocksetGcsCollectionArrayOutput) ToRocksetGcsCollectionArrayOutput 

func (o RocksetGcsCollectionArrayOutput) ToRocksetGcsCollectionArrayOutput() RocksetGcsCollectionArrayOutput

func (RocksetGcsCollectionArrayOutput) ToRocksetGcsCollectionArrayOutputWithContext 

func (o RocksetGcsCollectionArrayOutput) ToRocksetGcsCollectionArrayOutputWithContext(ctx context.Context) RocksetGcsCollectionArrayOutput

type RocksetGcsCollectionInput 

type RocksetGcsCollectionInput interface {
	pulumi.Input

	ToRocksetGcsCollectionOutput() RocksetGcsCollectionOutput
	ToRocksetGcsCollectionOutputWithContext(ctx context.Context) RocksetGcsCollectionOutput
}

type RocksetGcsCollectionMap 

type RocksetGcsCollectionMap map[string]RocksetGcsCollectionInput

func (RocksetGcsCollectionMap) ElementType 

func (RocksetGcsCollectionMap) ElementType() reflect.Type

func (RocksetGcsCollectionMap) ToRocksetGcsCollectionMapOutput 

func (i RocksetGcsCollectionMap) ToRocksetGcsCollectionMapOutput() RocksetGcsCollectionMapOutput

func (RocksetGcsCollectionMap) ToRocksetGcsCollectionMapOutputWithContext 

func (i RocksetGcsCollectionMap) ToRocksetGcsCollectionMapOutputWithContext(ctx context.Context) RocksetGcsCollectionMapOutput

type RocksetGcsCollectionMapInput 

type RocksetGcsCollectionMapInput interface {
	pulumi.Input

	ToRocksetGcsCollectionMapOutput() RocksetGcsCollectionMapOutput
	ToRocksetGcsCollectionMapOutputWithContext(context.Context) RocksetGcsCollectionMapOutput
}

RocksetGcsCollectionMapInput is an input type that accepts RocksetGcsCollectionMap and RocksetGcsCollectionMapOutput values. You can construct a concrete instance of `RocksetGcsCollectionMapInput` via: 

RocksetGcsCollectionMap{ "key": RocksetGcsCollectionArgs{...} }

type RocksetGcsCollectionMapOutput 

type RocksetGcsCollectionMapOutput struct{ *pulumi.OutputState }

func (RocksetGcsCollectionMapOutput) ElementType 

func (RocksetGcsCollectionMapOutput) ElementType() reflect.Type

func (RocksetGcsCollectionMapOutput) MapIndex 

func (o RocksetGcsCollectionMapOutput) MapIndex(k pulumi.StringInput) RocksetGcsCollectionOutput

func (RocksetGcsCollectionMapOutput) ToRocksetGcsCollectionMapOutput 

func (o RocksetGcsCollectionMapOutput) ToRocksetGcsCollectionMapOutput() RocksetGcsCollectionMapOutput

func (RocksetGcsCollectionMapOutput) ToRocksetGcsCollectionMapOutputWithContext 

func (o RocksetGcsCollectionMapOutput) ToRocksetGcsCollectionMapOutputWithContext(ctx context.Context) RocksetGcsCollectionMapOutput

type RocksetGcsCollectionOutput 

type RocksetGcsCollectionOutput struct{ *pulumi.OutputState }

func (RocksetGcsCollectionOutput) Description 

func (o RocksetGcsCollectionOutput) Description() pulumi.StringPtrOutput

Text describing the collection.

func (RocksetGcsCollectionOutput) ElementType 

func (RocksetGcsCollectionOutput) ElementType() reflect.Type

func (RocksetGcsCollectionOutput) FieldMappingQuery deprecated 

func (o RocksetGcsCollectionOutput) FieldMappingQuery() pulumi.StringPtrOutput

**Deprecated** use ingestTransformation instead

Deprecated: Use ingest_transformation instead

func (RocksetGcsCollectionOutput) IngestTransformation 

func (o RocksetGcsCollectionOutput) IngestTransformation() pulumi.StringPtrOutput

Ingest transformation SQL query. Turns the collection into insertOnly mode.

func (RocksetGcsCollectionOutput) Name 

func (o RocksetGcsCollectionOutput) Name() pulumi.StringOutput

Unique identifier for the collection. Can contain alphanumeric or dash characters.

func (RocksetGcsCollectionOutput) RetentionSecs 

func (o RocksetGcsCollectionOutput) RetentionSecs() pulumi.IntPtrOutput

Number of seconds after which data is purged. Based on event time.

func (RocksetGcsCollectionOutput) Sources 

func (o RocksetGcsCollectionOutput) Sources() RocksetGcsCollectionSourceArrayOutput

Defines a source for this collection.

func (RocksetGcsCollectionOutput) ToRocksetGcsCollectionOutput 

func (o RocksetGcsCollectionOutput) ToRocksetGcsCollectionOutput() RocksetGcsCollectionOutput

func (RocksetGcsCollectionOutput) ToRocksetGcsCollectionOutputWithContext 

func (o RocksetGcsCollectionOutput) ToRocksetGcsCollectionOutputWithContext(ctx context.Context) RocksetGcsCollectionOutput

func (RocksetGcsCollectionOutput) WaitForCollection 

func (o RocksetGcsCollectionOutput) WaitForCollection() pulumi.BoolPtrOutput

Wait until the collection is ready.

func (RocksetGcsCollectionOutput) WaitForDocuments 

func (o RocksetGcsCollectionOutput) WaitForDocuments() pulumi.IntPtrOutput

Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.

func (RocksetGcsCollectionOutput) Workspace 

func (o RocksetGcsCollectionOutput) Workspace() pulumi.StringOutput

The name of the workspace.

type RocksetGcsCollectionSource 

type RocksetGcsCollectionSource struct {
	// GCS bucket containing the target data.
	Bucket string                         `pulumi:"bucket"`
	Csv    *RocksetGcsCollectionSourceCsv `pulumi:"csv"`
	// Format of the data. One of: json, csv, xml. xml and csv blocks can only be set for their respective formats.
	Format string `pulumi:"format"`
	// The name of the Rockset GCS integration.
	IntegrationName string `pulumi:"integrationName"`
	// Simple path prefix to GCS key.
	Prefix *string                        `pulumi:"prefix"`
	Xml    *RocksetGcsCollectionSourceXml `pulumi:"xml"`
}

type RocksetGcsCollectionSourceArgs 

type RocksetGcsCollectionSourceArgs struct {
	// GCS bucket containing the target data.
	Bucket pulumi.StringInput                    `pulumi:"bucket"`
	Csv    RocksetGcsCollectionSourceCsvPtrInput `pulumi:"csv"`
	// Format of the data. One of: json, csv, xml. xml and csv blocks can only be set for their respective formats.
	Format pulumi.StringInput `pulumi:"format"`
	// The name of the Rockset GCS integration.
	IntegrationName pulumi.StringInput `pulumi:"integrationName"`
	// Simple path prefix to GCS key.
	Prefix pulumi.StringPtrInput                 `pulumi:"prefix"`
	Xml    RocksetGcsCollectionSourceXmlPtrInput `pulumi:"xml"`
}

func (RocksetGcsCollectionSourceArgs) ElementType 

func (RocksetGcsCollectionSourceArgs) ElementType() reflect.Type

func (RocksetGcsCollectionSourceArgs) ToRocksetGcsCollectionSourceOutput 

func (i RocksetGcsCollectionSourceArgs) ToRocksetGcsCollectionSourceOutput() RocksetGcsCollectionSourceOutput

func (RocksetGcsCollectionSourceArgs) ToRocksetGcsCollectionSourceOutputWithContext 

func (i RocksetGcsCollectionSourceArgs) ToRocksetGcsCollectionSourceOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceOutput

type RocksetGcsCollectionSourceArray 

type RocksetGcsCollectionSourceArray []RocksetGcsCollectionSourceInput

func (RocksetGcsCollectionSourceArray) ElementType 

func (RocksetGcsCollectionSourceArray) ElementType() reflect.Type

func (RocksetGcsCollectionSourceArray) ToRocksetGcsCollectionSourceArrayOutput 

func (i RocksetGcsCollectionSourceArray) ToRocksetGcsCollectionSourceArrayOutput() RocksetGcsCollectionSourceArrayOutput

func (RocksetGcsCollectionSourceArray) ToRocksetGcsCollectionSourceArrayOutputWithContext 

func (i RocksetGcsCollectionSourceArray) ToRocksetGcsCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceArrayOutput

type RocksetGcsCollectionSourceArrayInput 

type RocksetGcsCollectionSourceArrayInput interface {
	pulumi.Input

	ToRocksetGcsCollectionSourceArrayOutput() RocksetGcsCollectionSourceArrayOutput
	ToRocksetGcsCollectionSourceArrayOutputWithContext(context.Context) RocksetGcsCollectionSourceArrayOutput
}

RocksetGcsCollectionSourceArrayInput is an input type that accepts RocksetGcsCollectionSourceArray and RocksetGcsCollectionSourceArrayOutput values. You can construct a concrete instance of `RocksetGcsCollectionSourceArrayInput` via: 

RocksetGcsCollectionSourceArray{ RocksetGcsCollectionSourceArgs{...} }

type RocksetGcsCollectionSourceArrayOutput 

type RocksetGcsCollectionSourceArrayOutput struct{ *pulumi.OutputState }

func (RocksetGcsCollectionSourceArrayOutput) ElementType 

func (RocksetGcsCollectionSourceArrayOutput) ElementType() reflect.Type

func (RocksetGcsCollectionSourceArrayOutput) Index 

func (o RocksetGcsCollectionSourceArrayOutput) Index(i pulumi.IntInput) RocksetGcsCollectionSourceOutput

func (RocksetGcsCollectionSourceArrayOutput) ToRocksetGcsCollectionSourceArrayOutput 

func (o RocksetGcsCollectionSourceArrayOutput) ToRocksetGcsCollectionSourceArrayOutput() RocksetGcsCollectionSourceArrayOutput

func (RocksetGcsCollectionSourceArrayOutput) ToRocksetGcsCollectionSourceArrayOutputWithContext 

func (o RocksetGcsCollectionSourceArrayOutput) ToRocksetGcsCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceArrayOutput

type RocksetGcsCollectionSourceCsv 

type RocksetGcsCollectionSourceCsv struct {
	ColumnNames            []string `pulumi:"columnNames"`
	ColumnTypes            []string `pulumi:"columnTypes"`
	Encoding               *string  `pulumi:"encoding"`
	EscapeChar             *string  `pulumi:"escapeChar"`
	FirstLineAsColumnNames *bool    `pulumi:"firstLineAsColumnNames"`
	QuoteChar              *string  `pulumi:"quoteChar"`
	Separator              *string  `pulumi:"separator"`
}

type RocksetGcsCollectionSourceCsvArgs 

type RocksetGcsCollectionSourceCsvArgs struct {
	ColumnNames            pulumi.StringArrayInput `pulumi:"columnNames"`
	ColumnTypes            pulumi.StringArrayInput `pulumi:"columnTypes"`
	Encoding               pulumi.StringPtrInput   `pulumi:"encoding"`
	EscapeChar             pulumi.StringPtrInput   `pulumi:"escapeChar"`
	FirstLineAsColumnNames pulumi.BoolPtrInput     `pulumi:"firstLineAsColumnNames"`
	QuoteChar              pulumi.StringPtrInput   `pulumi:"quoteChar"`
	Separator              pulumi.StringPtrInput   `pulumi:"separator"`
}

func (RocksetGcsCollectionSourceCsvArgs) ElementType 

func (RocksetGcsCollectionSourceCsvArgs) ElementType() reflect.Type

func (RocksetGcsCollectionSourceCsvArgs) ToRocksetGcsCollectionSourceCsvOutput 

func (i RocksetGcsCollectionSourceCsvArgs) ToRocksetGcsCollectionSourceCsvOutput() RocksetGcsCollectionSourceCsvOutput

func (RocksetGcsCollectionSourceCsvArgs) ToRocksetGcsCollectionSourceCsvOutputWithContext 

func (i RocksetGcsCollectionSourceCsvArgs) ToRocksetGcsCollectionSourceCsvOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceCsvOutput

func (RocksetGcsCollectionSourceCsvArgs) ToRocksetGcsCollectionSourceCsvPtrOutput 

func (i RocksetGcsCollectionSourceCsvArgs) ToRocksetGcsCollectionSourceCsvPtrOutput() RocksetGcsCollectionSourceCsvPtrOutput

func (RocksetGcsCollectionSourceCsvArgs) ToRocksetGcsCollectionSourceCsvPtrOutputWithContext 

func (i RocksetGcsCollectionSourceCsvArgs) ToRocksetGcsCollectionSourceCsvPtrOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceCsvPtrOutput

type RocksetGcsCollectionSourceCsvInput 

type RocksetGcsCollectionSourceCsvInput interface {
	pulumi.Input

	ToRocksetGcsCollectionSourceCsvOutput() RocksetGcsCollectionSourceCsvOutput
	ToRocksetGcsCollectionSourceCsvOutputWithContext(context.Context) RocksetGcsCollectionSourceCsvOutput
}

RocksetGcsCollectionSourceCsvInput is an input type that accepts RocksetGcsCollectionSourceCsvArgs and RocksetGcsCollectionSourceCsvOutput values. You can construct a concrete instance of `RocksetGcsCollectionSourceCsvInput` via: 

RocksetGcsCollectionSourceCsvArgs{...}

type RocksetGcsCollectionSourceCsvOutput 

type RocksetGcsCollectionSourceCsvOutput struct{ *pulumi.OutputState }

func (RocksetGcsCollectionSourceCsvOutput) ColumnNames 

func (o RocksetGcsCollectionSourceCsvOutput) ColumnNames() pulumi.StringArrayOutput

func (RocksetGcsCollectionSourceCsvOutput) ColumnTypes 

func (o RocksetGcsCollectionSourceCsvOutput) ColumnTypes() pulumi.StringArrayOutput

func (RocksetGcsCollectionSourceCsvOutput) ElementType 

func (RocksetGcsCollectionSourceCsvOutput) ElementType() reflect.Type

func (RocksetGcsCollectionSourceCsvOutput) Encoding 

func (o RocksetGcsCollectionSourceCsvOutput) Encoding() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceCsvOutput) EscapeChar 

func (o RocksetGcsCollectionSourceCsvOutput) EscapeChar() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceCsvOutput) FirstLineAsColumnNames 

func (o RocksetGcsCollectionSourceCsvOutput) FirstLineAsColumnNames() pulumi.BoolPtrOutput

func (RocksetGcsCollectionSourceCsvOutput) QuoteChar 

func (o RocksetGcsCollectionSourceCsvOutput) QuoteChar() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceCsvOutput) Separator 

func (o RocksetGcsCollectionSourceCsvOutput) Separator() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceCsvOutput) ToRocksetGcsCollectionSourceCsvOutput 

func (o RocksetGcsCollectionSourceCsvOutput) ToRocksetGcsCollectionSourceCsvOutput() RocksetGcsCollectionSourceCsvOutput

func (RocksetGcsCollectionSourceCsvOutput) ToRocksetGcsCollectionSourceCsvOutputWithContext 

func (o RocksetGcsCollectionSourceCsvOutput) ToRocksetGcsCollectionSourceCsvOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceCsvOutput

func (RocksetGcsCollectionSourceCsvOutput) ToRocksetGcsCollectionSourceCsvPtrOutput 

func (o RocksetGcsCollectionSourceCsvOutput) ToRocksetGcsCollectionSourceCsvPtrOutput() RocksetGcsCollectionSourceCsvPtrOutput

func (RocksetGcsCollectionSourceCsvOutput) ToRocksetGcsCollectionSourceCsvPtrOutputWithContext 

func (o RocksetGcsCollectionSourceCsvOutput) ToRocksetGcsCollectionSourceCsvPtrOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceCsvPtrOutput

type RocksetGcsCollectionSourceCsvPtrInput 

type RocksetGcsCollectionSourceCsvPtrInput interface {
	pulumi.Input

	ToRocksetGcsCollectionSourceCsvPtrOutput() RocksetGcsCollectionSourceCsvPtrOutput
	ToRocksetGcsCollectionSourceCsvPtrOutputWithContext(context.Context) RocksetGcsCollectionSourceCsvPtrOutput
}

RocksetGcsCollectionSourceCsvPtrInput is an input type that accepts RocksetGcsCollectionSourceCsvArgs, RocksetGcsCollectionSourceCsvPtr and RocksetGcsCollectionSourceCsvPtrOutput values. You can construct a concrete instance of `RocksetGcsCollectionSourceCsvPtrInput` via: 

        RocksetGcsCollectionSourceCsvArgs{...}

or:

        nil

func RocksetGcsCollectionSourceCsvPtr 

func RocksetGcsCollectionSourceCsvPtr(v *RocksetGcsCollectionSourceCsvArgs) RocksetGcsCollectionSourceCsvPtrInput

type RocksetGcsCollectionSourceCsvPtrOutput 

type RocksetGcsCollectionSourceCsvPtrOutput struct{ *pulumi.OutputState }

func (RocksetGcsCollectionSourceCsvPtrOutput) ColumnNames 

func (o RocksetGcsCollectionSourceCsvPtrOutput) ColumnNames() pulumi.StringArrayOutput

func (RocksetGcsCollectionSourceCsvPtrOutput) ColumnTypes 

func (o RocksetGcsCollectionSourceCsvPtrOutput) ColumnTypes() pulumi.StringArrayOutput

func (RocksetGcsCollectionSourceCsvPtrOutput) Elem 

func (o RocksetGcsCollectionSourceCsvPtrOutput) Elem() RocksetGcsCollectionSourceCsvOutput

func (RocksetGcsCollectionSourceCsvPtrOutput) ElementType 

func (RocksetGcsCollectionSourceCsvPtrOutput) ElementType() reflect.Type

func (RocksetGcsCollectionSourceCsvPtrOutput) Encoding 

func (o RocksetGcsCollectionSourceCsvPtrOutput) Encoding() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceCsvPtrOutput) EscapeChar 

func (o RocksetGcsCollectionSourceCsvPtrOutput) EscapeChar() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceCsvPtrOutput) FirstLineAsColumnNames 

func (o RocksetGcsCollectionSourceCsvPtrOutput) FirstLineAsColumnNames() pulumi.BoolPtrOutput

func (RocksetGcsCollectionSourceCsvPtrOutput) QuoteChar 

func (o RocksetGcsCollectionSourceCsvPtrOutput) QuoteChar() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceCsvPtrOutput) Separator 

func (o RocksetGcsCollectionSourceCsvPtrOutput) Separator() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceCsvPtrOutput) ToRocksetGcsCollectionSourceCsvPtrOutput 

func (o RocksetGcsCollectionSourceCsvPtrOutput) ToRocksetGcsCollectionSourceCsvPtrOutput() RocksetGcsCollectionSourceCsvPtrOutput

func (RocksetGcsCollectionSourceCsvPtrOutput) ToRocksetGcsCollectionSourceCsvPtrOutputWithContext 

func (o RocksetGcsCollectionSourceCsvPtrOutput) ToRocksetGcsCollectionSourceCsvPtrOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceCsvPtrOutput

type RocksetGcsCollectionSourceInput 

type RocksetGcsCollectionSourceInput interface {
	pulumi.Input

	ToRocksetGcsCollectionSourceOutput() RocksetGcsCollectionSourceOutput
	ToRocksetGcsCollectionSourceOutputWithContext(context.Context) RocksetGcsCollectionSourceOutput
}

RocksetGcsCollectionSourceInput is an input type that accepts RocksetGcsCollectionSourceArgs and RocksetGcsCollectionSourceOutput values. You can construct a concrete instance of `RocksetGcsCollectionSourceInput` via: 

RocksetGcsCollectionSourceArgs{...}

type RocksetGcsCollectionSourceOutput 

type RocksetGcsCollectionSourceOutput struct{ *pulumi.OutputState }

func (RocksetGcsCollectionSourceOutput) Bucket 

func (o RocksetGcsCollectionSourceOutput) Bucket() pulumi.StringOutput

GCS bucket containing the target data.

func (RocksetGcsCollectionSourceOutput) Csv 

func (o RocksetGcsCollectionSourceOutput) Csv() RocksetGcsCollectionSourceCsvPtrOutput

func (RocksetGcsCollectionSourceOutput) ElementType 

func (RocksetGcsCollectionSourceOutput) ElementType() reflect.Type

func (RocksetGcsCollectionSourceOutput) Format 

func (o RocksetGcsCollectionSourceOutput) Format() pulumi.StringOutput

Format of the data. One of: json, csv, xml. xml and csv blocks can only be set for their respective formats.

func (RocksetGcsCollectionSourceOutput) IntegrationName 

func (o RocksetGcsCollectionSourceOutput) IntegrationName() pulumi.StringOutput

The name of the Rockset GCS integration.

func (RocksetGcsCollectionSourceOutput) Prefix 

func (o RocksetGcsCollectionSourceOutput) Prefix() pulumi.StringPtrOutput

Simple path prefix to GCS key.

func (RocksetGcsCollectionSourceOutput) ToRocksetGcsCollectionSourceOutput 

func (o RocksetGcsCollectionSourceOutput) ToRocksetGcsCollectionSourceOutput() RocksetGcsCollectionSourceOutput

func (RocksetGcsCollectionSourceOutput) ToRocksetGcsCollectionSourceOutputWithContext 

func (o RocksetGcsCollectionSourceOutput) ToRocksetGcsCollectionSourceOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceOutput

func (RocksetGcsCollectionSourceOutput) Xml 

func (o RocksetGcsCollectionSourceOutput) Xml() RocksetGcsCollectionSourceXmlPtrOutput

type RocksetGcsCollectionSourceXml 

type RocksetGcsCollectionSourceXml struct {
	AttributePrefix *string `pulumi:"attributePrefix"`
	DocTag          *string `pulumi:"docTag"`
	Encoding        *string `pulumi:"encoding"`
	RootTag         *string `pulumi:"rootTag"`
	ValueTag        *string `pulumi:"valueTag"`
}

type RocksetGcsCollectionSourceXmlArgs 

type RocksetGcsCollectionSourceXmlArgs struct {
	AttributePrefix pulumi.StringPtrInput `pulumi:"attributePrefix"`
	DocTag          pulumi.StringPtrInput `pulumi:"docTag"`
	Encoding        pulumi.StringPtrInput `pulumi:"encoding"`
	RootTag         pulumi.StringPtrInput `pulumi:"rootTag"`
	ValueTag        pulumi.StringPtrInput `pulumi:"valueTag"`
}

func (RocksetGcsCollectionSourceXmlArgs) ElementType 

func (RocksetGcsCollectionSourceXmlArgs) ElementType() reflect.Type

func (RocksetGcsCollectionSourceXmlArgs) ToRocksetGcsCollectionSourceXmlOutput 

func (i RocksetGcsCollectionSourceXmlArgs) ToRocksetGcsCollectionSourceXmlOutput() RocksetGcsCollectionSourceXmlOutput

func (RocksetGcsCollectionSourceXmlArgs) ToRocksetGcsCollectionSourceXmlOutputWithContext 

func (i RocksetGcsCollectionSourceXmlArgs) ToRocksetGcsCollectionSourceXmlOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceXmlOutput

func (RocksetGcsCollectionSourceXmlArgs) ToRocksetGcsCollectionSourceXmlPtrOutput 

func (i RocksetGcsCollectionSourceXmlArgs) ToRocksetGcsCollectionSourceXmlPtrOutput() RocksetGcsCollectionSourceXmlPtrOutput

func (RocksetGcsCollectionSourceXmlArgs) ToRocksetGcsCollectionSourceXmlPtrOutputWithContext 

func (i RocksetGcsCollectionSourceXmlArgs) ToRocksetGcsCollectionSourceXmlPtrOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceXmlPtrOutput

type RocksetGcsCollectionSourceXmlInput 

type RocksetGcsCollectionSourceXmlInput interface {
	pulumi.Input

	ToRocksetGcsCollectionSourceXmlOutput() RocksetGcsCollectionSourceXmlOutput
	ToRocksetGcsCollectionSourceXmlOutputWithContext(context.Context) RocksetGcsCollectionSourceXmlOutput
}

RocksetGcsCollectionSourceXmlInput is an input type that accepts RocksetGcsCollectionSourceXmlArgs and RocksetGcsCollectionSourceXmlOutput values. You can construct a concrete instance of `RocksetGcsCollectionSourceXmlInput` via: 

RocksetGcsCollectionSourceXmlArgs{...}

type RocksetGcsCollectionSourceXmlOutput 

type RocksetGcsCollectionSourceXmlOutput struct{ *pulumi.OutputState }

func (RocksetGcsCollectionSourceXmlOutput) AttributePrefix 

func (o RocksetGcsCollectionSourceXmlOutput) AttributePrefix() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceXmlOutput) DocTag 

func (o RocksetGcsCollectionSourceXmlOutput) DocTag() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceXmlOutput) ElementType 

func (RocksetGcsCollectionSourceXmlOutput) ElementType() reflect.Type

func (RocksetGcsCollectionSourceXmlOutput) Encoding 

func (o RocksetGcsCollectionSourceXmlOutput) Encoding() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceXmlOutput) RootTag 

func (o RocksetGcsCollectionSourceXmlOutput) RootTag() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceXmlOutput) ToRocksetGcsCollectionSourceXmlOutput 

func (o RocksetGcsCollectionSourceXmlOutput) ToRocksetGcsCollectionSourceXmlOutput() RocksetGcsCollectionSourceXmlOutput

func (RocksetGcsCollectionSourceXmlOutput) ToRocksetGcsCollectionSourceXmlOutputWithContext 

func (o RocksetGcsCollectionSourceXmlOutput) ToRocksetGcsCollectionSourceXmlOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceXmlOutput

func (RocksetGcsCollectionSourceXmlOutput) ToRocksetGcsCollectionSourceXmlPtrOutput 

func (o RocksetGcsCollectionSourceXmlOutput) ToRocksetGcsCollectionSourceXmlPtrOutput() RocksetGcsCollectionSourceXmlPtrOutput

func (RocksetGcsCollectionSourceXmlOutput) ToRocksetGcsCollectionSourceXmlPtrOutputWithContext 

func (o RocksetGcsCollectionSourceXmlOutput) ToRocksetGcsCollectionSourceXmlPtrOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceXmlPtrOutput

func (RocksetGcsCollectionSourceXmlOutput) ValueTag 

func (o RocksetGcsCollectionSourceXmlOutput) ValueTag() pulumi.StringPtrOutput

type RocksetGcsCollectionSourceXmlPtrInput 

type RocksetGcsCollectionSourceXmlPtrInput interface {
	pulumi.Input

	ToRocksetGcsCollectionSourceXmlPtrOutput() RocksetGcsCollectionSourceXmlPtrOutput
	ToRocksetGcsCollectionSourceXmlPtrOutputWithContext(context.Context) RocksetGcsCollectionSourceXmlPtrOutput
}

RocksetGcsCollectionSourceXmlPtrInput is an input type that accepts RocksetGcsCollectionSourceXmlArgs, RocksetGcsCollectionSourceXmlPtr and RocksetGcsCollectionSourceXmlPtrOutput values. You can construct a concrete instance of `RocksetGcsCollectionSourceXmlPtrInput` via: 

        RocksetGcsCollectionSourceXmlArgs{...}

or:

        nil

func RocksetGcsCollectionSourceXmlPtr 

func RocksetGcsCollectionSourceXmlPtr(v *RocksetGcsCollectionSourceXmlArgs) RocksetGcsCollectionSourceXmlPtrInput

type RocksetGcsCollectionSourceXmlPtrOutput 

type RocksetGcsCollectionSourceXmlPtrOutput struct{ *pulumi.OutputState }

func (RocksetGcsCollectionSourceXmlPtrOutput) AttributePrefix 

func (o RocksetGcsCollectionSourceXmlPtrOutput) AttributePrefix() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceXmlPtrOutput) DocTag 

func (o RocksetGcsCollectionSourceXmlPtrOutput) DocTag() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceXmlPtrOutput) Elem 

func (o RocksetGcsCollectionSourceXmlPtrOutput) Elem() RocksetGcsCollectionSourceXmlOutput

func (RocksetGcsCollectionSourceXmlPtrOutput) ElementType 

func (RocksetGcsCollectionSourceXmlPtrOutput) ElementType() reflect.Type

func (RocksetGcsCollectionSourceXmlPtrOutput) Encoding 

func (o RocksetGcsCollectionSourceXmlPtrOutput) Encoding() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceXmlPtrOutput) RootTag 

func (o RocksetGcsCollectionSourceXmlPtrOutput) RootTag() pulumi.StringPtrOutput

func (RocksetGcsCollectionSourceXmlPtrOutput) ToRocksetGcsCollectionSourceXmlPtrOutput 

func (o RocksetGcsCollectionSourceXmlPtrOutput) ToRocksetGcsCollectionSourceXmlPtrOutput() RocksetGcsCollectionSourceXmlPtrOutput

func (RocksetGcsCollectionSourceXmlPtrOutput) ToRocksetGcsCollectionSourceXmlPtrOutputWithContext 

func (o RocksetGcsCollectionSourceXmlPtrOutput) ToRocksetGcsCollectionSourceXmlPtrOutputWithContext(ctx context.Context) RocksetGcsCollectionSourceXmlPtrOutput

func (RocksetGcsCollectionSourceXmlPtrOutput) ValueTag 

func (o RocksetGcsCollectionSourceXmlPtrOutput) ValueTag() pulumi.StringPtrOutput

type RocksetGcsCollectionState 

type RocksetGcsCollectionState struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetGcsCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringPtrInput
}

func (RocksetGcsCollectionState) ElementType 

func (RocksetGcsCollectionState) ElementType() reflect.Type

type RocksetGcsIntegration 

type RocksetGcsIntegration struct {
	pulumi.CustomResourceState

	// Text describing the integration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// The GCP service account key JSON.
	ServiceAccountKey pulumi.StringOutput `pulumi:"serviceAccountKey"`
}

Manages a Rockset GCS Integration.

func GetRocksetGcsIntegration 

func GetRocksetGcsIntegration(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetGcsIntegrationState, opts ...pulumi.ResourceOption) (*RocksetGcsIntegration, error)

GetRocksetGcsIntegration gets an existing RocksetGcsIntegration 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 NewRocksetGcsIntegration 

func NewRocksetGcsIntegration(ctx *pulumi.Context,
	name string, args *RocksetGcsIntegrationArgs, opts ...pulumi.ResourceOption) (*RocksetGcsIntegration, error)

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

func (*RocksetGcsIntegration) ElementType 

func (*RocksetGcsIntegration) ElementType() reflect.Type

func (*RocksetGcsIntegration) ToRocksetGcsIntegrationOutput 

func (i *RocksetGcsIntegration) ToRocksetGcsIntegrationOutput() RocksetGcsIntegrationOutput

func (*RocksetGcsIntegration) ToRocksetGcsIntegrationOutputWithContext 

func (i *RocksetGcsIntegration) ToRocksetGcsIntegrationOutputWithContext(ctx context.Context) RocksetGcsIntegrationOutput

type RocksetGcsIntegrationArgs 

type RocksetGcsIntegrationArgs struct {
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// The GCP service account key JSON.
	ServiceAccountKey pulumi.StringInput
}

The set of arguments for constructing a RocksetGcsIntegration resource.

func (RocksetGcsIntegrationArgs) ElementType 

func (RocksetGcsIntegrationArgs) ElementType() reflect.Type

type RocksetGcsIntegrationArray 

type RocksetGcsIntegrationArray []RocksetGcsIntegrationInput

func (RocksetGcsIntegrationArray) ElementType 

func (RocksetGcsIntegrationArray) ElementType() reflect.Type

func (RocksetGcsIntegrationArray) ToRocksetGcsIntegrationArrayOutput 

func (i RocksetGcsIntegrationArray) ToRocksetGcsIntegrationArrayOutput() RocksetGcsIntegrationArrayOutput

func (RocksetGcsIntegrationArray) ToRocksetGcsIntegrationArrayOutputWithContext 

func (i RocksetGcsIntegrationArray) ToRocksetGcsIntegrationArrayOutputWithContext(ctx context.Context) RocksetGcsIntegrationArrayOutput

type RocksetGcsIntegrationArrayInput 

type RocksetGcsIntegrationArrayInput interface {
	pulumi.Input

	ToRocksetGcsIntegrationArrayOutput() RocksetGcsIntegrationArrayOutput
	ToRocksetGcsIntegrationArrayOutputWithContext(context.Context) RocksetGcsIntegrationArrayOutput
}

RocksetGcsIntegrationArrayInput is an input type that accepts RocksetGcsIntegrationArray and RocksetGcsIntegrationArrayOutput values. You can construct a concrete instance of `RocksetGcsIntegrationArrayInput` via: 

RocksetGcsIntegrationArray{ RocksetGcsIntegrationArgs{...} }

type RocksetGcsIntegrationArrayOutput 

type RocksetGcsIntegrationArrayOutput struct{ *pulumi.OutputState }

func (RocksetGcsIntegrationArrayOutput) ElementType 

func (RocksetGcsIntegrationArrayOutput) ElementType() reflect.Type

func (RocksetGcsIntegrationArrayOutput) Index 

func (o RocksetGcsIntegrationArrayOutput) Index(i pulumi.IntInput) RocksetGcsIntegrationOutput

func (RocksetGcsIntegrationArrayOutput) ToRocksetGcsIntegrationArrayOutput 

func (o RocksetGcsIntegrationArrayOutput) ToRocksetGcsIntegrationArrayOutput() RocksetGcsIntegrationArrayOutput

func (RocksetGcsIntegrationArrayOutput) ToRocksetGcsIntegrationArrayOutputWithContext 

func (o RocksetGcsIntegrationArrayOutput) ToRocksetGcsIntegrationArrayOutputWithContext(ctx context.Context) RocksetGcsIntegrationArrayOutput

type RocksetGcsIntegrationInput 

type RocksetGcsIntegrationInput interface {
	pulumi.Input

	ToRocksetGcsIntegrationOutput() RocksetGcsIntegrationOutput
	ToRocksetGcsIntegrationOutputWithContext(ctx context.Context) RocksetGcsIntegrationOutput
}

type RocksetGcsIntegrationMap 

type RocksetGcsIntegrationMap map[string]RocksetGcsIntegrationInput

func (RocksetGcsIntegrationMap) ElementType 

func (RocksetGcsIntegrationMap) ElementType() reflect.Type

func (RocksetGcsIntegrationMap) ToRocksetGcsIntegrationMapOutput 

func (i RocksetGcsIntegrationMap) ToRocksetGcsIntegrationMapOutput() RocksetGcsIntegrationMapOutput

func (RocksetGcsIntegrationMap) ToRocksetGcsIntegrationMapOutputWithContext 

func (i RocksetGcsIntegrationMap) ToRocksetGcsIntegrationMapOutputWithContext(ctx context.Context) RocksetGcsIntegrationMapOutput

type RocksetGcsIntegrationMapInput 

type RocksetGcsIntegrationMapInput interface {
	pulumi.Input

	ToRocksetGcsIntegrationMapOutput() RocksetGcsIntegrationMapOutput
	ToRocksetGcsIntegrationMapOutputWithContext(context.Context) RocksetGcsIntegrationMapOutput
}

RocksetGcsIntegrationMapInput is an input type that accepts RocksetGcsIntegrationMap and RocksetGcsIntegrationMapOutput values. You can construct a concrete instance of `RocksetGcsIntegrationMapInput` via: 

RocksetGcsIntegrationMap{ "key": RocksetGcsIntegrationArgs{...} }

type RocksetGcsIntegrationMapOutput 

type RocksetGcsIntegrationMapOutput struct{ *pulumi.OutputState }

func (RocksetGcsIntegrationMapOutput) ElementType 

func (RocksetGcsIntegrationMapOutput) ElementType() reflect.Type

func (RocksetGcsIntegrationMapOutput) MapIndex 

func (o RocksetGcsIntegrationMapOutput) MapIndex(k pulumi.StringInput) RocksetGcsIntegrationOutput

func (RocksetGcsIntegrationMapOutput) ToRocksetGcsIntegrationMapOutput 

func (o RocksetGcsIntegrationMapOutput) ToRocksetGcsIntegrationMapOutput() RocksetGcsIntegrationMapOutput

func (RocksetGcsIntegrationMapOutput) ToRocksetGcsIntegrationMapOutputWithContext 

func (o RocksetGcsIntegrationMapOutput) ToRocksetGcsIntegrationMapOutputWithContext(ctx context.Context) RocksetGcsIntegrationMapOutput

type RocksetGcsIntegrationOutput 

type RocksetGcsIntegrationOutput struct{ *pulumi.OutputState }

func (RocksetGcsIntegrationOutput) Description 

func (o RocksetGcsIntegrationOutput) Description() pulumi.StringPtrOutput

Text describing the integration.

func (RocksetGcsIntegrationOutput) ElementType 

func (RocksetGcsIntegrationOutput) ElementType() reflect.Type

func (RocksetGcsIntegrationOutput) Name 

func (o RocksetGcsIntegrationOutput) Name() pulumi.StringOutput

Unique identifier for the integration. Can contain alphanumeric or dash characters.

func (RocksetGcsIntegrationOutput) ServiceAccountKey 

func (o RocksetGcsIntegrationOutput) ServiceAccountKey() pulumi.StringOutput

The GCP service account key JSON.

func (RocksetGcsIntegrationOutput) ToRocksetGcsIntegrationOutput 

func (o RocksetGcsIntegrationOutput) ToRocksetGcsIntegrationOutput() RocksetGcsIntegrationOutput

func (RocksetGcsIntegrationOutput) ToRocksetGcsIntegrationOutputWithContext 

func (o RocksetGcsIntegrationOutput) ToRocksetGcsIntegrationOutputWithContext(ctx context.Context) RocksetGcsIntegrationOutput

type RocksetGcsIntegrationState 

type RocksetGcsIntegrationState struct {
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// The GCP service account key JSON.
	ServiceAccountKey pulumi.StringPtrInput
}

func (RocksetGcsIntegrationState) ElementType 

func (RocksetGcsIntegrationState) ElementType() reflect.Type

type RocksetKafkaCollection 

type RocksetKafkaCollection struct {
	pulumi.CustomResourceState

	// Text describing the collection.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrOutput `pulumi:"fieldMappingQuery"`
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrOutput `pulumi:"ingestTransformation"`
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrOutput `pulumi:"retentionSecs"`
	// Defines a source for this collection.
	Sources RocksetKafkaCollectionSourceArrayOutput `pulumi:"sources"`
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrOutput `pulumi:"waitForCollection"`
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrOutput `pulumi:"waitForDocuments"`
	// The name of the workspace.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a collection created from a Kafka source. The `useV3` field must match the integration which the collection is created from.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"
"github.com/thomascollett/pulumi-rockset/sdk/go/rockset"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		bootstrapServers := cfg.RequireObject("bootstrapServers")
		apikey := cfg.RequireObject("apikey")
		secret := cfg.RequireObject("secret")
		confluentRocksetKafkaIntegration, err := rockset.NewRocksetKafkaIntegration(ctx, "confluentRocksetKafkaIntegration", &rockset.RocksetKafkaIntegrationArgs{
			Description:      pulumi.String("Integration to ingest documents from Confluent Cloud"),
			UseV3:            pulumi.Bool(true),
			BootstrapServers: pulumi.Any(bootstrapServers),
			SecurityConfig: pulumi.StringMap{
				"api_key": pulumi.Any(apikey),
				"secret":  pulumi.Any(secret),
			},
		})
		if err != nil {
			return err
		}
		confluentRocksetWorkspace, err := rockset.NewRocksetWorkspace(ctx, "confluentRocksetWorkspace", &rockset.RocksetWorkspaceArgs{
			Description: pulumi.String("Collections from Confluent Cloud topics."),
		})
		if err != nil {
			return err
		}
		_, err = rockset.NewRocksetKafkaCollection(ctx, "test", &rockset.RocksetKafkaCollectionArgs{
			Workspace:     confluentRocksetWorkspace.Name,
			Description:   pulumi.String("Collection from a Confluent Cloud topic."),
			RetentionSecs: pulumi.Int(3600),
			Sources: rockset.RocksetKafkaCollectionSourceArray{
				&rockset.RocksetKafkaCollectionSourceArgs{
					IntegrationName:   confluentRocksetKafkaIntegration.Name,
					UseV3:             pulumi.Bool(true),
					TopicName:         pulumi.String("test_json"),
					OffsetResetPolicy: pulumi.String("EARLIEST"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetRocksetKafkaCollection 

func GetRocksetKafkaCollection(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetKafkaCollectionState, opts ...pulumi.ResourceOption) (*RocksetKafkaCollection, error)

GetRocksetKafkaCollection gets an existing RocksetKafkaCollection 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 NewRocksetKafkaCollection 

func NewRocksetKafkaCollection(ctx *pulumi.Context,
	name string, args *RocksetKafkaCollectionArgs, opts ...pulumi.ResourceOption) (*RocksetKafkaCollection, error)

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

func (*RocksetKafkaCollection) ElementType 

func (*RocksetKafkaCollection) ElementType() reflect.Type

func (*RocksetKafkaCollection) ToRocksetKafkaCollectionOutput 

func (i *RocksetKafkaCollection) ToRocksetKafkaCollectionOutput() RocksetKafkaCollectionOutput

func (*RocksetKafkaCollection) ToRocksetKafkaCollectionOutputWithContext 

func (i *RocksetKafkaCollection) ToRocksetKafkaCollectionOutputWithContext(ctx context.Context) RocksetKafkaCollectionOutput

type RocksetKafkaCollectionArgs 

type RocksetKafkaCollectionArgs struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetKafkaCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetKafkaCollection resource.

func (RocksetKafkaCollectionArgs) ElementType 

func (RocksetKafkaCollectionArgs) ElementType() reflect.Type

type RocksetKafkaCollectionArray 

type RocksetKafkaCollectionArray []RocksetKafkaCollectionInput

func (RocksetKafkaCollectionArray) ElementType 

func (RocksetKafkaCollectionArray) ElementType() reflect.Type

func (RocksetKafkaCollectionArray) ToRocksetKafkaCollectionArrayOutput 

func (i RocksetKafkaCollectionArray) ToRocksetKafkaCollectionArrayOutput() RocksetKafkaCollectionArrayOutput

func (RocksetKafkaCollectionArray) ToRocksetKafkaCollectionArrayOutputWithContext 

func (i RocksetKafkaCollectionArray) ToRocksetKafkaCollectionArrayOutputWithContext(ctx context.Context) RocksetKafkaCollectionArrayOutput

type RocksetKafkaCollectionArrayInput 

type RocksetKafkaCollectionArrayInput interface {
	pulumi.Input

	ToRocksetKafkaCollectionArrayOutput() RocksetKafkaCollectionArrayOutput
	ToRocksetKafkaCollectionArrayOutputWithContext(context.Context) RocksetKafkaCollectionArrayOutput
}

RocksetKafkaCollectionArrayInput is an input type that accepts RocksetKafkaCollectionArray and RocksetKafkaCollectionArrayOutput values. You can construct a concrete instance of `RocksetKafkaCollectionArrayInput` via: 

RocksetKafkaCollectionArray{ RocksetKafkaCollectionArgs{...} }

type RocksetKafkaCollectionArrayOutput 

type RocksetKafkaCollectionArrayOutput struct{ *pulumi.OutputState }

func (RocksetKafkaCollectionArrayOutput) ElementType 

func (RocksetKafkaCollectionArrayOutput) ElementType() reflect.Type

func (RocksetKafkaCollectionArrayOutput) Index 

func (o RocksetKafkaCollectionArrayOutput) Index(i pulumi.IntInput) RocksetKafkaCollectionOutput

func (RocksetKafkaCollectionArrayOutput) ToRocksetKafkaCollectionArrayOutput 

func (o RocksetKafkaCollectionArrayOutput) ToRocksetKafkaCollectionArrayOutput() RocksetKafkaCollectionArrayOutput

func (RocksetKafkaCollectionArrayOutput) ToRocksetKafkaCollectionArrayOutputWithContext 

func (o RocksetKafkaCollectionArrayOutput) ToRocksetKafkaCollectionArrayOutputWithContext(ctx context.Context) RocksetKafkaCollectionArrayOutput

type RocksetKafkaCollectionInput 

type RocksetKafkaCollectionInput interface {
	pulumi.Input

	ToRocksetKafkaCollectionOutput() RocksetKafkaCollectionOutput
	ToRocksetKafkaCollectionOutputWithContext(ctx context.Context) RocksetKafkaCollectionOutput
}

type RocksetKafkaCollectionMap 

type RocksetKafkaCollectionMap map[string]RocksetKafkaCollectionInput

func (RocksetKafkaCollectionMap) ElementType 

func (RocksetKafkaCollectionMap) ElementType() reflect.Type

func (RocksetKafkaCollectionMap) ToRocksetKafkaCollectionMapOutput 

func (i RocksetKafkaCollectionMap) ToRocksetKafkaCollectionMapOutput() RocksetKafkaCollectionMapOutput

func (RocksetKafkaCollectionMap) ToRocksetKafkaCollectionMapOutputWithContext 

func (i RocksetKafkaCollectionMap) ToRocksetKafkaCollectionMapOutputWithContext(ctx context.Context) RocksetKafkaCollectionMapOutput

type RocksetKafkaCollectionMapInput 

type RocksetKafkaCollectionMapInput interface {
	pulumi.Input

	ToRocksetKafkaCollectionMapOutput() RocksetKafkaCollectionMapOutput
	ToRocksetKafkaCollectionMapOutputWithContext(context.Context) RocksetKafkaCollectionMapOutput
}

RocksetKafkaCollectionMapInput is an input type that accepts RocksetKafkaCollectionMap and RocksetKafkaCollectionMapOutput values. You can construct a concrete instance of `RocksetKafkaCollectionMapInput` via: 

RocksetKafkaCollectionMap{ "key": RocksetKafkaCollectionArgs{...} }

type RocksetKafkaCollectionMapOutput 

type RocksetKafkaCollectionMapOutput struct{ *pulumi.OutputState }

func (RocksetKafkaCollectionMapOutput) ElementType 

func (RocksetKafkaCollectionMapOutput) ElementType() reflect.Type

func (RocksetKafkaCollectionMapOutput) MapIndex 

func (o RocksetKafkaCollectionMapOutput) MapIndex(k pulumi.StringInput) RocksetKafkaCollectionOutput

func (RocksetKafkaCollectionMapOutput) ToRocksetKafkaCollectionMapOutput 

func (o RocksetKafkaCollectionMapOutput) ToRocksetKafkaCollectionMapOutput() RocksetKafkaCollectionMapOutput

func (RocksetKafkaCollectionMapOutput) ToRocksetKafkaCollectionMapOutputWithContext 

func (o RocksetKafkaCollectionMapOutput) ToRocksetKafkaCollectionMapOutputWithContext(ctx context.Context) RocksetKafkaCollectionMapOutput

type RocksetKafkaCollectionOutput 

type RocksetKafkaCollectionOutput struct{ *pulumi.OutputState }

func (RocksetKafkaCollectionOutput) Description 

func (o RocksetKafkaCollectionOutput) Description() pulumi.StringPtrOutput

Text describing the collection.

func (RocksetKafkaCollectionOutput) ElementType 

func (RocksetKafkaCollectionOutput) ElementType() reflect.Type

func (RocksetKafkaCollectionOutput) FieldMappingQuery deprecated 

func (o RocksetKafkaCollectionOutput) FieldMappingQuery() pulumi.StringPtrOutput

**Deprecated** use ingestTransformation instead

Deprecated: Use ingest_transformation instead

func (RocksetKafkaCollectionOutput) IngestTransformation 

func (o RocksetKafkaCollectionOutput) IngestTransformation() pulumi.StringPtrOutput

Ingest transformation SQL query. Turns the collection into insertOnly mode.

func (RocksetKafkaCollectionOutput) Name 

func (o RocksetKafkaCollectionOutput) Name() pulumi.StringOutput

Unique identifier for the collection. Can contain alphanumeric or dash characters.

func (RocksetKafkaCollectionOutput) RetentionSecs 

func (o RocksetKafkaCollectionOutput) RetentionSecs() pulumi.IntPtrOutput

Number of seconds after which data is purged. Based on event time.

func (RocksetKafkaCollectionOutput) Sources 

func (o RocksetKafkaCollectionOutput) Sources() RocksetKafkaCollectionSourceArrayOutput

Defines a source for this collection.

func (RocksetKafkaCollectionOutput) ToRocksetKafkaCollectionOutput 

func (o RocksetKafkaCollectionOutput) ToRocksetKafkaCollectionOutput() RocksetKafkaCollectionOutput

func (RocksetKafkaCollectionOutput) ToRocksetKafkaCollectionOutputWithContext 

func (o RocksetKafkaCollectionOutput) ToRocksetKafkaCollectionOutputWithContext(ctx context.Context) RocksetKafkaCollectionOutput

func (RocksetKafkaCollectionOutput) WaitForCollection 

func (o RocksetKafkaCollectionOutput) WaitForCollection() pulumi.BoolPtrOutput

Wait until the collection is ready.

func (RocksetKafkaCollectionOutput) WaitForDocuments 

func (o RocksetKafkaCollectionOutput) WaitForDocuments() pulumi.IntPtrOutput

Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.

func (RocksetKafkaCollectionOutput) Workspace 

func (o RocksetKafkaCollectionOutput) Workspace() pulumi.StringOutput

The name of the workspace.

type RocksetKafkaCollectionSource 

type RocksetKafkaCollectionSource struct {
	// The Kafka consumer group Id being used.
	ConsumerGroupId *string `pulumi:"consumerGroupId"`
	// The name of the Rockset Kafka integration.
	IntegrationName string `pulumi:"integrationName"`
	// The offset reset policy. Possible values: LATEST, EARLIEST. Only valid with v3 collections.
	OffsetResetPolicy *string                              `pulumi:"offsetResetPolicy"`
	Statuses          []RocksetKafkaCollectionSourceStatus `pulumi:"statuses"`
	// Name of Kafka topic to be tailed.
	TopicName string `pulumi:"topicName"`
	// Whether to use v3 integration. Required if the kafka integration uses v3.
	UseV3 *bool `pulumi:"useV3"`
}

type RocksetKafkaCollectionSourceArgs 

type RocksetKafkaCollectionSourceArgs struct {
	// The Kafka consumer group Id being used.
	ConsumerGroupId pulumi.StringPtrInput `pulumi:"consumerGroupId"`
	// The name of the Rockset Kafka integration.
	IntegrationName pulumi.StringInput `pulumi:"integrationName"`
	// The offset reset policy. Possible values: LATEST, EARLIEST. Only valid with v3 collections.
	OffsetResetPolicy pulumi.StringPtrInput                        `pulumi:"offsetResetPolicy"`
	Statuses          RocksetKafkaCollectionSourceStatusArrayInput `pulumi:"statuses"`
	// Name of Kafka topic to be tailed.
	TopicName pulumi.StringInput `pulumi:"topicName"`
	// Whether to use v3 integration. Required if the kafka integration uses v3.
	UseV3 pulumi.BoolPtrInput `pulumi:"useV3"`
}

func (RocksetKafkaCollectionSourceArgs) ElementType 

func (RocksetKafkaCollectionSourceArgs) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceArgs) ToRocksetKafkaCollectionSourceOutput 

func (i RocksetKafkaCollectionSourceArgs) ToRocksetKafkaCollectionSourceOutput() RocksetKafkaCollectionSourceOutput

func (RocksetKafkaCollectionSourceArgs) ToRocksetKafkaCollectionSourceOutputWithContext 

func (i RocksetKafkaCollectionSourceArgs) ToRocksetKafkaCollectionSourceOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceOutput

type RocksetKafkaCollectionSourceArray 

type RocksetKafkaCollectionSourceArray []RocksetKafkaCollectionSourceInput

func (RocksetKafkaCollectionSourceArray) ElementType 

func (RocksetKafkaCollectionSourceArray) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceArray) ToRocksetKafkaCollectionSourceArrayOutput 

func (i RocksetKafkaCollectionSourceArray) ToRocksetKafkaCollectionSourceArrayOutput() RocksetKafkaCollectionSourceArrayOutput

func (RocksetKafkaCollectionSourceArray) ToRocksetKafkaCollectionSourceArrayOutputWithContext 

func (i RocksetKafkaCollectionSourceArray) ToRocksetKafkaCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceArrayOutput

type RocksetKafkaCollectionSourceArrayInput 

type RocksetKafkaCollectionSourceArrayInput interface {
	pulumi.Input

	ToRocksetKafkaCollectionSourceArrayOutput() RocksetKafkaCollectionSourceArrayOutput
	ToRocksetKafkaCollectionSourceArrayOutputWithContext(context.Context) RocksetKafkaCollectionSourceArrayOutput
}

RocksetKafkaCollectionSourceArrayInput is an input type that accepts RocksetKafkaCollectionSourceArray and RocksetKafkaCollectionSourceArrayOutput values. You can construct a concrete instance of `RocksetKafkaCollectionSourceArrayInput` via: 

RocksetKafkaCollectionSourceArray{ RocksetKafkaCollectionSourceArgs{...} }

type RocksetKafkaCollectionSourceArrayOutput 

type RocksetKafkaCollectionSourceArrayOutput struct{ *pulumi.OutputState }

func (RocksetKafkaCollectionSourceArrayOutput) ElementType 

func (RocksetKafkaCollectionSourceArrayOutput) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceArrayOutput) Index 

func (o RocksetKafkaCollectionSourceArrayOutput) Index(i pulumi.IntInput) RocksetKafkaCollectionSourceOutput

func (RocksetKafkaCollectionSourceArrayOutput) ToRocksetKafkaCollectionSourceArrayOutput 

func (o RocksetKafkaCollectionSourceArrayOutput) ToRocksetKafkaCollectionSourceArrayOutput() RocksetKafkaCollectionSourceArrayOutput

func (RocksetKafkaCollectionSourceArrayOutput) ToRocksetKafkaCollectionSourceArrayOutputWithContext 

func (o RocksetKafkaCollectionSourceArrayOutput) ToRocksetKafkaCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceArrayOutput

type RocksetKafkaCollectionSourceInput 

type RocksetKafkaCollectionSourceInput interface {
	pulumi.Input

	ToRocksetKafkaCollectionSourceOutput() RocksetKafkaCollectionSourceOutput
	ToRocksetKafkaCollectionSourceOutputWithContext(context.Context) RocksetKafkaCollectionSourceOutput
}

RocksetKafkaCollectionSourceInput is an input type that accepts RocksetKafkaCollectionSourceArgs and RocksetKafkaCollectionSourceOutput values. You can construct a concrete instance of `RocksetKafkaCollectionSourceInput` via: 

RocksetKafkaCollectionSourceArgs{...}

type RocksetKafkaCollectionSourceOutput 

type RocksetKafkaCollectionSourceOutput struct{ *pulumi.OutputState }

func (RocksetKafkaCollectionSourceOutput) ConsumerGroupId 

func (o RocksetKafkaCollectionSourceOutput) ConsumerGroupId() pulumi.StringPtrOutput

The Kafka consumer group Id being used.

func (RocksetKafkaCollectionSourceOutput) ElementType 

func (RocksetKafkaCollectionSourceOutput) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceOutput) IntegrationName 

func (o RocksetKafkaCollectionSourceOutput) IntegrationName() pulumi.StringOutput

The name of the Rockset Kafka integration.

func (RocksetKafkaCollectionSourceOutput) OffsetResetPolicy 

func (o RocksetKafkaCollectionSourceOutput) OffsetResetPolicy() pulumi.StringPtrOutput

The offset reset policy. Possible values: LATEST, EARLIEST. Only valid with v3 collections.

func (RocksetKafkaCollectionSourceOutput) Statuses 

func (o RocksetKafkaCollectionSourceOutput) Statuses() RocksetKafkaCollectionSourceStatusArrayOutput

func (RocksetKafkaCollectionSourceOutput) ToRocksetKafkaCollectionSourceOutput 

func (o RocksetKafkaCollectionSourceOutput) ToRocksetKafkaCollectionSourceOutput() RocksetKafkaCollectionSourceOutput

func (RocksetKafkaCollectionSourceOutput) ToRocksetKafkaCollectionSourceOutputWithContext 

func (o RocksetKafkaCollectionSourceOutput) ToRocksetKafkaCollectionSourceOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceOutput

func (RocksetKafkaCollectionSourceOutput) TopicName 

func (o RocksetKafkaCollectionSourceOutput) TopicName() pulumi.StringOutput

Name of Kafka topic to be tailed.

func (RocksetKafkaCollectionSourceOutput) UseV3 

func (o RocksetKafkaCollectionSourceOutput) UseV3() pulumi.BoolPtrOutput

Whether to use v3 integration. Required if the kafka integration uses v3.

type RocksetKafkaCollectionSourceStatus 

type RocksetKafkaCollectionSourceStatus struct {
	DocumentsProcessed *int                                          `pulumi:"documentsProcessed"`
	LastConsumedTime   *string                                       `pulumi:"lastConsumedTime"`
	Partitions         []RocksetKafkaCollectionSourceStatusPartition `pulumi:"partitions"`
	State              *string                                       `pulumi:"state"`
}

type RocksetKafkaCollectionSourceStatusArgs 

type RocksetKafkaCollectionSourceStatusArgs struct {
	DocumentsProcessed pulumi.IntPtrInput                                    `pulumi:"documentsProcessed"`
	LastConsumedTime   pulumi.StringPtrInput                                 `pulumi:"lastConsumedTime"`
	Partitions         RocksetKafkaCollectionSourceStatusPartitionArrayInput `pulumi:"partitions"`
	State              pulumi.StringPtrInput                                 `pulumi:"state"`
}

func (RocksetKafkaCollectionSourceStatusArgs) ElementType 

func (RocksetKafkaCollectionSourceStatusArgs) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceStatusArgs) ToRocksetKafkaCollectionSourceStatusOutput 

func (i RocksetKafkaCollectionSourceStatusArgs) ToRocksetKafkaCollectionSourceStatusOutput() RocksetKafkaCollectionSourceStatusOutput

func (RocksetKafkaCollectionSourceStatusArgs) ToRocksetKafkaCollectionSourceStatusOutputWithContext 

func (i RocksetKafkaCollectionSourceStatusArgs) ToRocksetKafkaCollectionSourceStatusOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceStatusOutput

type RocksetKafkaCollectionSourceStatusArray 

type RocksetKafkaCollectionSourceStatusArray []RocksetKafkaCollectionSourceStatusInput

func (RocksetKafkaCollectionSourceStatusArray) ElementType 

func (RocksetKafkaCollectionSourceStatusArray) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceStatusArray) ToRocksetKafkaCollectionSourceStatusArrayOutput 

func (i RocksetKafkaCollectionSourceStatusArray) ToRocksetKafkaCollectionSourceStatusArrayOutput() RocksetKafkaCollectionSourceStatusArrayOutput

func (RocksetKafkaCollectionSourceStatusArray) ToRocksetKafkaCollectionSourceStatusArrayOutputWithContext 

func (i RocksetKafkaCollectionSourceStatusArray) ToRocksetKafkaCollectionSourceStatusArrayOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceStatusArrayOutput

type RocksetKafkaCollectionSourceStatusArrayInput 

type RocksetKafkaCollectionSourceStatusArrayInput interface {
	pulumi.Input

	ToRocksetKafkaCollectionSourceStatusArrayOutput() RocksetKafkaCollectionSourceStatusArrayOutput
	ToRocksetKafkaCollectionSourceStatusArrayOutputWithContext(context.Context) RocksetKafkaCollectionSourceStatusArrayOutput
}

RocksetKafkaCollectionSourceStatusArrayInput is an input type that accepts RocksetKafkaCollectionSourceStatusArray and RocksetKafkaCollectionSourceStatusArrayOutput values. You can construct a concrete instance of `RocksetKafkaCollectionSourceStatusArrayInput` via: 

RocksetKafkaCollectionSourceStatusArray{ RocksetKafkaCollectionSourceStatusArgs{...} }

type RocksetKafkaCollectionSourceStatusArrayOutput 

type RocksetKafkaCollectionSourceStatusArrayOutput struct{ *pulumi.OutputState }

func (RocksetKafkaCollectionSourceStatusArrayOutput) ElementType 

func (RocksetKafkaCollectionSourceStatusArrayOutput) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceStatusArrayOutput) Index 

func (o RocksetKafkaCollectionSourceStatusArrayOutput) Index(i pulumi.IntInput) RocksetKafkaCollectionSourceStatusOutput

func (RocksetKafkaCollectionSourceStatusArrayOutput) ToRocksetKafkaCollectionSourceStatusArrayOutput 

func (o RocksetKafkaCollectionSourceStatusArrayOutput) ToRocksetKafkaCollectionSourceStatusArrayOutput() RocksetKafkaCollectionSourceStatusArrayOutput

func (RocksetKafkaCollectionSourceStatusArrayOutput) ToRocksetKafkaCollectionSourceStatusArrayOutputWithContext 

func (o RocksetKafkaCollectionSourceStatusArrayOutput) ToRocksetKafkaCollectionSourceStatusArrayOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceStatusArrayOutput

type RocksetKafkaCollectionSourceStatusInput 

type RocksetKafkaCollectionSourceStatusInput interface {
	pulumi.Input

	ToRocksetKafkaCollectionSourceStatusOutput() RocksetKafkaCollectionSourceStatusOutput
	ToRocksetKafkaCollectionSourceStatusOutputWithContext(context.Context) RocksetKafkaCollectionSourceStatusOutput
}

RocksetKafkaCollectionSourceStatusInput is an input type that accepts RocksetKafkaCollectionSourceStatusArgs and RocksetKafkaCollectionSourceStatusOutput values. You can construct a concrete instance of `RocksetKafkaCollectionSourceStatusInput` via: 

RocksetKafkaCollectionSourceStatusArgs{...}

type RocksetKafkaCollectionSourceStatusOutput 

type RocksetKafkaCollectionSourceStatusOutput struct{ *pulumi.OutputState }

func (RocksetKafkaCollectionSourceStatusOutput) DocumentsProcessed 

func (o RocksetKafkaCollectionSourceStatusOutput) DocumentsProcessed() pulumi.IntPtrOutput

func (RocksetKafkaCollectionSourceStatusOutput) ElementType 

func (RocksetKafkaCollectionSourceStatusOutput) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceStatusOutput) LastConsumedTime 

func (o RocksetKafkaCollectionSourceStatusOutput) LastConsumedTime() pulumi.StringPtrOutput

func (RocksetKafkaCollectionSourceStatusOutput) Partitions 

func (o RocksetKafkaCollectionSourceStatusOutput) Partitions() RocksetKafkaCollectionSourceStatusPartitionArrayOutput

func (RocksetKafkaCollectionSourceStatusOutput) State 

func (o RocksetKafkaCollectionSourceStatusOutput) State() pulumi.StringPtrOutput

func (RocksetKafkaCollectionSourceStatusOutput) ToRocksetKafkaCollectionSourceStatusOutput 

func (o RocksetKafkaCollectionSourceStatusOutput) ToRocksetKafkaCollectionSourceStatusOutput() RocksetKafkaCollectionSourceStatusOutput

func (RocksetKafkaCollectionSourceStatusOutput) ToRocksetKafkaCollectionSourceStatusOutputWithContext 

func (o RocksetKafkaCollectionSourceStatusOutput) ToRocksetKafkaCollectionSourceStatusOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceStatusOutput

type RocksetKafkaCollectionSourceStatusPartition 

type RocksetKafkaCollectionSourceStatusPartition struct {
	OffsetLag       *int `pulumi:"offsetLag"`
	PartitionNumber *int `pulumi:"partitionNumber"`
	PartitionOffset *int `pulumi:"partitionOffset"`
}

type RocksetKafkaCollectionSourceStatusPartitionArgs 

type RocksetKafkaCollectionSourceStatusPartitionArgs struct {
	OffsetLag       pulumi.IntPtrInput `pulumi:"offsetLag"`
	PartitionNumber pulumi.IntPtrInput `pulumi:"partitionNumber"`
	PartitionOffset pulumi.IntPtrInput `pulumi:"partitionOffset"`
}

func (RocksetKafkaCollectionSourceStatusPartitionArgs) ElementType 

func (RocksetKafkaCollectionSourceStatusPartitionArgs) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceStatusPartitionArgs) ToRocksetKafkaCollectionSourceStatusPartitionOutput 

func (i RocksetKafkaCollectionSourceStatusPartitionArgs) ToRocksetKafkaCollectionSourceStatusPartitionOutput() RocksetKafkaCollectionSourceStatusPartitionOutput

func (RocksetKafkaCollectionSourceStatusPartitionArgs) ToRocksetKafkaCollectionSourceStatusPartitionOutputWithContext 

func (i RocksetKafkaCollectionSourceStatusPartitionArgs) ToRocksetKafkaCollectionSourceStatusPartitionOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceStatusPartitionOutput

type RocksetKafkaCollectionSourceStatusPartitionArray 

type RocksetKafkaCollectionSourceStatusPartitionArray []RocksetKafkaCollectionSourceStatusPartitionInput

func (RocksetKafkaCollectionSourceStatusPartitionArray) ElementType 

func (RocksetKafkaCollectionSourceStatusPartitionArray) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceStatusPartitionArray) ToRocksetKafkaCollectionSourceStatusPartitionArrayOutput 

func (i RocksetKafkaCollectionSourceStatusPartitionArray) ToRocksetKafkaCollectionSourceStatusPartitionArrayOutput() RocksetKafkaCollectionSourceStatusPartitionArrayOutput

func (RocksetKafkaCollectionSourceStatusPartitionArray) ToRocksetKafkaCollectionSourceStatusPartitionArrayOutputWithContext 

func (i RocksetKafkaCollectionSourceStatusPartitionArray) ToRocksetKafkaCollectionSourceStatusPartitionArrayOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceStatusPartitionArrayOutput

type RocksetKafkaCollectionSourceStatusPartitionArrayInput 

type RocksetKafkaCollectionSourceStatusPartitionArrayInput interface {
	pulumi.Input

	ToRocksetKafkaCollectionSourceStatusPartitionArrayOutput() RocksetKafkaCollectionSourceStatusPartitionArrayOutput
	ToRocksetKafkaCollectionSourceStatusPartitionArrayOutputWithContext(context.Context) RocksetKafkaCollectionSourceStatusPartitionArrayOutput
}

RocksetKafkaCollectionSourceStatusPartitionArrayInput is an input type that accepts RocksetKafkaCollectionSourceStatusPartitionArray and RocksetKafkaCollectionSourceStatusPartitionArrayOutput values. You can construct a concrete instance of `RocksetKafkaCollectionSourceStatusPartitionArrayInput` via: 

RocksetKafkaCollectionSourceStatusPartitionArray{ RocksetKafkaCollectionSourceStatusPartitionArgs{...} }

type RocksetKafkaCollectionSourceStatusPartitionArrayOutput 

type RocksetKafkaCollectionSourceStatusPartitionArrayOutput struct{ *pulumi.OutputState }

func (RocksetKafkaCollectionSourceStatusPartitionArrayOutput) ElementType 

func (RocksetKafkaCollectionSourceStatusPartitionArrayOutput) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceStatusPartitionArrayOutput) Index 

func (o RocksetKafkaCollectionSourceStatusPartitionArrayOutput) Index(i pulumi.IntInput) RocksetKafkaCollectionSourceStatusPartitionOutput

func (RocksetKafkaCollectionSourceStatusPartitionArrayOutput) ToRocksetKafkaCollectionSourceStatusPartitionArrayOutput 

func (o RocksetKafkaCollectionSourceStatusPartitionArrayOutput) ToRocksetKafkaCollectionSourceStatusPartitionArrayOutput() RocksetKafkaCollectionSourceStatusPartitionArrayOutput

func (RocksetKafkaCollectionSourceStatusPartitionArrayOutput) ToRocksetKafkaCollectionSourceStatusPartitionArrayOutputWithContext 

func (o RocksetKafkaCollectionSourceStatusPartitionArrayOutput) ToRocksetKafkaCollectionSourceStatusPartitionArrayOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceStatusPartitionArrayOutput

type RocksetKafkaCollectionSourceStatusPartitionInput 

type RocksetKafkaCollectionSourceStatusPartitionInput interface {
	pulumi.Input

	ToRocksetKafkaCollectionSourceStatusPartitionOutput() RocksetKafkaCollectionSourceStatusPartitionOutput
	ToRocksetKafkaCollectionSourceStatusPartitionOutputWithContext(context.Context) RocksetKafkaCollectionSourceStatusPartitionOutput
}

RocksetKafkaCollectionSourceStatusPartitionInput is an input type that accepts RocksetKafkaCollectionSourceStatusPartitionArgs and RocksetKafkaCollectionSourceStatusPartitionOutput values. You can construct a concrete instance of `RocksetKafkaCollectionSourceStatusPartitionInput` via: 

RocksetKafkaCollectionSourceStatusPartitionArgs{...}

type RocksetKafkaCollectionSourceStatusPartitionOutput 

type RocksetKafkaCollectionSourceStatusPartitionOutput struct{ *pulumi.OutputState }

func (RocksetKafkaCollectionSourceStatusPartitionOutput) ElementType 

func (RocksetKafkaCollectionSourceStatusPartitionOutput) ElementType() reflect.Type

func (RocksetKafkaCollectionSourceStatusPartitionOutput) OffsetLag 

func (o RocksetKafkaCollectionSourceStatusPartitionOutput) OffsetLag() pulumi.IntPtrOutput

func (RocksetKafkaCollectionSourceStatusPartitionOutput) PartitionNumber 

func (o RocksetKafkaCollectionSourceStatusPartitionOutput) PartitionNumber() pulumi.IntPtrOutput

func (RocksetKafkaCollectionSourceStatusPartitionOutput) PartitionOffset 

func (o RocksetKafkaCollectionSourceStatusPartitionOutput) PartitionOffset() pulumi.IntPtrOutput

func (RocksetKafkaCollectionSourceStatusPartitionOutput) ToRocksetKafkaCollectionSourceStatusPartitionOutput 

func (o RocksetKafkaCollectionSourceStatusPartitionOutput) ToRocksetKafkaCollectionSourceStatusPartitionOutput() RocksetKafkaCollectionSourceStatusPartitionOutput

func (RocksetKafkaCollectionSourceStatusPartitionOutput) ToRocksetKafkaCollectionSourceStatusPartitionOutputWithContext 

func (o RocksetKafkaCollectionSourceStatusPartitionOutput) ToRocksetKafkaCollectionSourceStatusPartitionOutputWithContext(ctx context.Context) RocksetKafkaCollectionSourceStatusPartitionOutput

type RocksetKafkaCollectionState 

type RocksetKafkaCollectionState struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetKafkaCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringPtrInput
}

func (RocksetKafkaCollectionState) ElementType 

func (RocksetKafkaCollectionState) ElementType() reflect.Type

type RocksetKafkaIntegration 

type RocksetKafkaIntegration struct {
	pulumi.CustomResourceState

	// The Kafka bootstrap server url(s). Required only for V3 integration.
	BootstrapServers pulumi.StringPtrOutput `pulumi:"bootstrapServers"`
	// Kafka connection string.
	ConnectionString pulumi.StringOutput `pulumi:"connectionString"`
	// Text describing the integration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// The format of the Kafka topics being tailed. Possible values: JSON, AVRO.
	KafkaDataFormat pulumi.StringPtrOutput `pulumi:"kafkaDataFormat"`
	// Kafka topics to tail.
	KafkaTopicNames pulumi.StringArrayOutput `pulumi:"kafkaTopicNames"`
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Kafka configuration for schema registry. Required only for V3 integration.
	SchemaRegistryConfig pulumi.StringMapOutput `pulumi:"schemaRegistryConfig"`
	// Kafka security configurations. Required only for V3 integration.
	SecurityConfig pulumi.StringMapOutput `pulumi:"securityConfig"`
	// Use v3 for Confluent Cloud.
	UseV3 pulumi.BoolPtrOutput `pulumi:"useV3"`
	// Wait until the integration is active.
	WaitForIntegration pulumi.BoolPtrOutput `pulumi:"waitForIntegration"`
}

func GetRocksetKafkaIntegration 

func GetRocksetKafkaIntegration(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetKafkaIntegrationState, opts ...pulumi.ResourceOption) (*RocksetKafkaIntegration, error)

GetRocksetKafkaIntegration gets an existing RocksetKafkaIntegration 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 NewRocksetKafkaIntegration 

func NewRocksetKafkaIntegration(ctx *pulumi.Context,
	name string, args *RocksetKafkaIntegrationArgs, opts ...pulumi.ResourceOption) (*RocksetKafkaIntegration, error)

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

func (*RocksetKafkaIntegration) ElementType 

func (*RocksetKafkaIntegration) ElementType() reflect.Type

func (*RocksetKafkaIntegration) ToRocksetKafkaIntegrationOutput 

func (i *RocksetKafkaIntegration) ToRocksetKafkaIntegrationOutput() RocksetKafkaIntegrationOutput

func (*RocksetKafkaIntegration) ToRocksetKafkaIntegrationOutputWithContext 

func (i *RocksetKafkaIntegration) ToRocksetKafkaIntegrationOutputWithContext(ctx context.Context) RocksetKafkaIntegrationOutput

type RocksetKafkaIntegrationArgs 

type RocksetKafkaIntegrationArgs struct {
	// The Kafka bootstrap server url(s). Required only for V3 integration.
	BootstrapServers pulumi.StringPtrInput
	// Kafka connection string.
	ConnectionString pulumi.StringPtrInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// The format of the Kafka topics being tailed. Possible values: JSON, AVRO.
	KafkaDataFormat pulumi.StringPtrInput
	// Kafka topics to tail.
	KafkaTopicNames pulumi.StringArrayInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Kafka configuration for schema registry. Required only for V3 integration.
	SchemaRegistryConfig pulumi.StringMapInput
	// Kafka security configurations. Required only for V3 integration.
	SecurityConfig pulumi.StringMapInput
	// Use v3 for Confluent Cloud.
	UseV3 pulumi.BoolPtrInput
	// Wait until the integration is active.
	WaitForIntegration pulumi.BoolPtrInput
}

The set of arguments for constructing a RocksetKafkaIntegration resource.

func (RocksetKafkaIntegrationArgs) ElementType 

func (RocksetKafkaIntegrationArgs) ElementType() reflect.Type

type RocksetKafkaIntegrationArray 

type RocksetKafkaIntegrationArray []RocksetKafkaIntegrationInput

func (RocksetKafkaIntegrationArray) ElementType 

func (RocksetKafkaIntegrationArray) ElementType() reflect.Type

func (RocksetKafkaIntegrationArray) ToRocksetKafkaIntegrationArrayOutput 

func (i RocksetKafkaIntegrationArray) ToRocksetKafkaIntegrationArrayOutput() RocksetKafkaIntegrationArrayOutput

func (RocksetKafkaIntegrationArray) ToRocksetKafkaIntegrationArrayOutputWithContext 

func (i RocksetKafkaIntegrationArray) ToRocksetKafkaIntegrationArrayOutputWithContext(ctx context.Context) RocksetKafkaIntegrationArrayOutput

type RocksetKafkaIntegrationArrayInput 

type RocksetKafkaIntegrationArrayInput interface {
	pulumi.Input

	ToRocksetKafkaIntegrationArrayOutput() RocksetKafkaIntegrationArrayOutput
	ToRocksetKafkaIntegrationArrayOutputWithContext(context.Context) RocksetKafkaIntegrationArrayOutput
}

RocksetKafkaIntegrationArrayInput is an input type that accepts RocksetKafkaIntegrationArray and RocksetKafkaIntegrationArrayOutput values. You can construct a concrete instance of `RocksetKafkaIntegrationArrayInput` via: 

RocksetKafkaIntegrationArray{ RocksetKafkaIntegrationArgs{...} }

type RocksetKafkaIntegrationArrayOutput 

type RocksetKafkaIntegrationArrayOutput struct{ *pulumi.OutputState }

func (RocksetKafkaIntegrationArrayOutput) ElementType 

func (RocksetKafkaIntegrationArrayOutput) ElementType() reflect.Type

func (RocksetKafkaIntegrationArrayOutput) Index 

func (o RocksetKafkaIntegrationArrayOutput) Index(i pulumi.IntInput) RocksetKafkaIntegrationOutput

func (RocksetKafkaIntegrationArrayOutput) ToRocksetKafkaIntegrationArrayOutput 

func (o RocksetKafkaIntegrationArrayOutput) ToRocksetKafkaIntegrationArrayOutput() RocksetKafkaIntegrationArrayOutput

func (RocksetKafkaIntegrationArrayOutput) ToRocksetKafkaIntegrationArrayOutputWithContext 

func (o RocksetKafkaIntegrationArrayOutput) ToRocksetKafkaIntegrationArrayOutputWithContext(ctx context.Context) RocksetKafkaIntegrationArrayOutput

type RocksetKafkaIntegrationInput 

type RocksetKafkaIntegrationInput interface {
	pulumi.Input

	ToRocksetKafkaIntegrationOutput() RocksetKafkaIntegrationOutput
	ToRocksetKafkaIntegrationOutputWithContext(ctx context.Context) RocksetKafkaIntegrationOutput
}

type RocksetKafkaIntegrationMap 

type RocksetKafkaIntegrationMap map[string]RocksetKafkaIntegrationInput

func (RocksetKafkaIntegrationMap) ElementType 

func (RocksetKafkaIntegrationMap) ElementType() reflect.Type

func (RocksetKafkaIntegrationMap) ToRocksetKafkaIntegrationMapOutput 

func (i RocksetKafkaIntegrationMap) ToRocksetKafkaIntegrationMapOutput() RocksetKafkaIntegrationMapOutput

func (RocksetKafkaIntegrationMap) ToRocksetKafkaIntegrationMapOutputWithContext 

func (i RocksetKafkaIntegrationMap) ToRocksetKafkaIntegrationMapOutputWithContext(ctx context.Context) RocksetKafkaIntegrationMapOutput

type RocksetKafkaIntegrationMapInput 

type RocksetKafkaIntegrationMapInput interface {
	pulumi.Input

	ToRocksetKafkaIntegrationMapOutput() RocksetKafkaIntegrationMapOutput
	ToRocksetKafkaIntegrationMapOutputWithContext(context.Context) RocksetKafkaIntegrationMapOutput
}

RocksetKafkaIntegrationMapInput is an input type that accepts RocksetKafkaIntegrationMap and RocksetKafkaIntegrationMapOutput values. You can construct a concrete instance of `RocksetKafkaIntegrationMapInput` via: 

RocksetKafkaIntegrationMap{ "key": RocksetKafkaIntegrationArgs{...} }

type RocksetKafkaIntegrationMapOutput 

type RocksetKafkaIntegrationMapOutput struct{ *pulumi.OutputState }

func (RocksetKafkaIntegrationMapOutput) ElementType 

func (RocksetKafkaIntegrationMapOutput) ElementType() reflect.Type

func (RocksetKafkaIntegrationMapOutput) MapIndex 

func (o RocksetKafkaIntegrationMapOutput) MapIndex(k pulumi.StringInput) RocksetKafkaIntegrationOutput

func (RocksetKafkaIntegrationMapOutput) ToRocksetKafkaIntegrationMapOutput 

func (o RocksetKafkaIntegrationMapOutput) ToRocksetKafkaIntegrationMapOutput() RocksetKafkaIntegrationMapOutput

func (RocksetKafkaIntegrationMapOutput) ToRocksetKafkaIntegrationMapOutputWithContext 

func (o RocksetKafkaIntegrationMapOutput) ToRocksetKafkaIntegrationMapOutputWithContext(ctx context.Context) RocksetKafkaIntegrationMapOutput

type RocksetKafkaIntegrationOutput 

type RocksetKafkaIntegrationOutput struct{ *pulumi.OutputState }

func (RocksetKafkaIntegrationOutput) BootstrapServers 

func (o RocksetKafkaIntegrationOutput) BootstrapServers() pulumi.StringPtrOutput

The Kafka bootstrap server url(s). Required only for V3 integration.

func (RocksetKafkaIntegrationOutput) ConnectionString 

func (o RocksetKafkaIntegrationOutput) ConnectionString() pulumi.StringOutput

Kafka connection string.

func (RocksetKafkaIntegrationOutput) Description 

func (o RocksetKafkaIntegrationOutput) Description() pulumi.StringPtrOutput

Text describing the integration.

func (RocksetKafkaIntegrationOutput) ElementType 

func (RocksetKafkaIntegrationOutput) ElementType() reflect.Type

func (RocksetKafkaIntegrationOutput) KafkaDataFormat 

func (o RocksetKafkaIntegrationOutput) KafkaDataFormat() pulumi.StringPtrOutput

The format of the Kafka topics being tailed. Possible values: JSON, AVRO.

func (RocksetKafkaIntegrationOutput) KafkaTopicNames 

func (o RocksetKafkaIntegrationOutput) KafkaTopicNames() pulumi.StringArrayOutput

Kafka topics to tail.

func (RocksetKafkaIntegrationOutput) Name 

func (o RocksetKafkaIntegrationOutput) Name() pulumi.StringOutput

Unique identifier for the integration. Can contain alphanumeric or dash characters.

func (RocksetKafkaIntegrationOutput) SchemaRegistryConfig 

func (o RocksetKafkaIntegrationOutput) SchemaRegistryConfig() pulumi.StringMapOutput

Kafka configuration for schema registry. Required only for V3 integration.

func (RocksetKafkaIntegrationOutput) SecurityConfig 

func (o RocksetKafkaIntegrationOutput) SecurityConfig() pulumi.StringMapOutput

Kafka security configurations. Required only for V3 integration.

func (RocksetKafkaIntegrationOutput) ToRocksetKafkaIntegrationOutput 

func (o RocksetKafkaIntegrationOutput) ToRocksetKafkaIntegrationOutput() RocksetKafkaIntegrationOutput

func (RocksetKafkaIntegrationOutput) ToRocksetKafkaIntegrationOutputWithContext 

func (o RocksetKafkaIntegrationOutput) ToRocksetKafkaIntegrationOutputWithContext(ctx context.Context) RocksetKafkaIntegrationOutput

func (RocksetKafkaIntegrationOutput) UseV3 

func (o RocksetKafkaIntegrationOutput) UseV3() pulumi.BoolPtrOutput

Use v3 for Confluent Cloud.

func (RocksetKafkaIntegrationOutput) WaitForIntegration 

func (o RocksetKafkaIntegrationOutput) WaitForIntegration() pulumi.BoolPtrOutput

Wait until the integration is active.

type RocksetKafkaIntegrationState 

type RocksetKafkaIntegrationState struct {
	// The Kafka bootstrap server url(s). Required only for V3 integration.
	BootstrapServers pulumi.StringPtrInput
	// Kafka connection string.
	ConnectionString pulumi.StringPtrInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// The format of the Kafka topics being tailed. Possible values: JSON, AVRO.
	KafkaDataFormat pulumi.StringPtrInput
	// Kafka topics to tail.
	KafkaTopicNames pulumi.StringArrayInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Kafka configuration for schema registry. Required only for V3 integration.
	SchemaRegistryConfig pulumi.StringMapInput
	// Kafka security configurations. Required only for V3 integration.
	SecurityConfig pulumi.StringMapInput
	// Use v3 for Confluent Cloud.
	UseV3 pulumi.BoolPtrInput
	// Wait until the integration is active.
	WaitForIntegration pulumi.BoolPtrInput
}

func (RocksetKafkaIntegrationState) ElementType 

func (RocksetKafkaIntegrationState) ElementType() reflect.Type

type RocksetKinesisCollection 

type RocksetKinesisCollection struct {
	pulumi.CustomResourceState

	// Text describing the collection.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrOutput `pulumi:"fieldMappingQuery"`
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrOutput `pulumi:"ingestTransformation"`
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrOutput `pulumi:"retentionSecs"`
	// Defines a source for this collection.
	Sources RocksetKinesisCollectionSourceArrayOutput `pulumi:"sources"`
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrOutput `pulumi:"waitForCollection"`
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrOutput `pulumi:"waitForDocuments"`
	// The name of the workspace.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a collection with an Kinesis source attached.

func GetRocksetKinesisCollection 

func GetRocksetKinesisCollection(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetKinesisCollectionState, opts ...pulumi.ResourceOption) (*RocksetKinesisCollection, error)

GetRocksetKinesisCollection gets an existing RocksetKinesisCollection 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 NewRocksetKinesisCollection 

func NewRocksetKinesisCollection(ctx *pulumi.Context,
	name string, args *RocksetKinesisCollectionArgs, opts ...pulumi.ResourceOption) (*RocksetKinesisCollection, error)

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

func (*RocksetKinesisCollection) ElementType 

func (*RocksetKinesisCollection) ElementType() reflect.Type

func (*RocksetKinesisCollection) ToRocksetKinesisCollectionOutput 

func (i *RocksetKinesisCollection) ToRocksetKinesisCollectionOutput() RocksetKinesisCollectionOutput

func (*RocksetKinesisCollection) ToRocksetKinesisCollectionOutputWithContext 

func (i *RocksetKinesisCollection) ToRocksetKinesisCollectionOutputWithContext(ctx context.Context) RocksetKinesisCollectionOutput

type RocksetKinesisCollectionArgs 

type RocksetKinesisCollectionArgs struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetKinesisCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetKinesisCollection resource.

func (RocksetKinesisCollectionArgs) ElementType 

func (RocksetKinesisCollectionArgs) ElementType() reflect.Type

type RocksetKinesisCollectionArray 

type RocksetKinesisCollectionArray []RocksetKinesisCollectionInput

func (RocksetKinesisCollectionArray) ElementType 

func (RocksetKinesisCollectionArray) ElementType() reflect.Type

func (RocksetKinesisCollectionArray) ToRocksetKinesisCollectionArrayOutput 

func (i RocksetKinesisCollectionArray) ToRocksetKinesisCollectionArrayOutput() RocksetKinesisCollectionArrayOutput

func (RocksetKinesisCollectionArray) ToRocksetKinesisCollectionArrayOutputWithContext 

func (i RocksetKinesisCollectionArray) ToRocksetKinesisCollectionArrayOutputWithContext(ctx context.Context) RocksetKinesisCollectionArrayOutput

type RocksetKinesisCollectionArrayInput 

type RocksetKinesisCollectionArrayInput interface {
	pulumi.Input

	ToRocksetKinesisCollectionArrayOutput() RocksetKinesisCollectionArrayOutput
	ToRocksetKinesisCollectionArrayOutputWithContext(context.Context) RocksetKinesisCollectionArrayOutput
}

RocksetKinesisCollectionArrayInput is an input type that accepts RocksetKinesisCollectionArray and RocksetKinesisCollectionArrayOutput values. You can construct a concrete instance of `RocksetKinesisCollectionArrayInput` via: 

RocksetKinesisCollectionArray{ RocksetKinesisCollectionArgs{...} }

type RocksetKinesisCollectionArrayOutput 

type RocksetKinesisCollectionArrayOutput struct{ *pulumi.OutputState }

func (RocksetKinesisCollectionArrayOutput) ElementType 

func (RocksetKinesisCollectionArrayOutput) ElementType() reflect.Type

func (RocksetKinesisCollectionArrayOutput) Index 

func (o RocksetKinesisCollectionArrayOutput) Index(i pulumi.IntInput) RocksetKinesisCollectionOutput

func (RocksetKinesisCollectionArrayOutput) ToRocksetKinesisCollectionArrayOutput 

func (o RocksetKinesisCollectionArrayOutput) ToRocksetKinesisCollectionArrayOutput() RocksetKinesisCollectionArrayOutput

func (RocksetKinesisCollectionArrayOutput) ToRocksetKinesisCollectionArrayOutputWithContext 

func (o RocksetKinesisCollectionArrayOutput) ToRocksetKinesisCollectionArrayOutputWithContext(ctx context.Context) RocksetKinesisCollectionArrayOutput

type RocksetKinesisCollectionInput 

type RocksetKinesisCollectionInput interface {
	pulumi.Input

	ToRocksetKinesisCollectionOutput() RocksetKinesisCollectionOutput
	ToRocksetKinesisCollectionOutputWithContext(ctx context.Context) RocksetKinesisCollectionOutput
}

type RocksetKinesisCollectionMap 

type RocksetKinesisCollectionMap map[string]RocksetKinesisCollectionInput

func (RocksetKinesisCollectionMap) ElementType 

func (RocksetKinesisCollectionMap) ElementType() reflect.Type

func (RocksetKinesisCollectionMap) ToRocksetKinesisCollectionMapOutput 

func (i RocksetKinesisCollectionMap) ToRocksetKinesisCollectionMapOutput() RocksetKinesisCollectionMapOutput

func (RocksetKinesisCollectionMap) ToRocksetKinesisCollectionMapOutputWithContext 

func (i RocksetKinesisCollectionMap) ToRocksetKinesisCollectionMapOutputWithContext(ctx context.Context) RocksetKinesisCollectionMapOutput

type RocksetKinesisCollectionMapInput 

type RocksetKinesisCollectionMapInput interface {
	pulumi.Input

	ToRocksetKinesisCollectionMapOutput() RocksetKinesisCollectionMapOutput
	ToRocksetKinesisCollectionMapOutputWithContext(context.Context) RocksetKinesisCollectionMapOutput
}

RocksetKinesisCollectionMapInput is an input type that accepts RocksetKinesisCollectionMap and RocksetKinesisCollectionMapOutput values. You can construct a concrete instance of `RocksetKinesisCollectionMapInput` via: 

RocksetKinesisCollectionMap{ "key": RocksetKinesisCollectionArgs{...} }

type RocksetKinesisCollectionMapOutput 

type RocksetKinesisCollectionMapOutput struct{ *pulumi.OutputState }

func (RocksetKinesisCollectionMapOutput) ElementType 

func (RocksetKinesisCollectionMapOutput) ElementType() reflect.Type

func (RocksetKinesisCollectionMapOutput) MapIndex 

func (o RocksetKinesisCollectionMapOutput) MapIndex(k pulumi.StringInput) RocksetKinesisCollectionOutput

func (RocksetKinesisCollectionMapOutput) ToRocksetKinesisCollectionMapOutput 

func (o RocksetKinesisCollectionMapOutput) ToRocksetKinesisCollectionMapOutput() RocksetKinesisCollectionMapOutput

func (RocksetKinesisCollectionMapOutput) ToRocksetKinesisCollectionMapOutputWithContext 

func (o RocksetKinesisCollectionMapOutput) ToRocksetKinesisCollectionMapOutputWithContext(ctx context.Context) RocksetKinesisCollectionMapOutput

type RocksetKinesisCollectionOutput 

type RocksetKinesisCollectionOutput struct{ *pulumi.OutputState }

func (RocksetKinesisCollectionOutput) Description 

func (o RocksetKinesisCollectionOutput) Description() pulumi.StringPtrOutput

Text describing the collection.

func (RocksetKinesisCollectionOutput) ElementType 

func (RocksetKinesisCollectionOutput) ElementType() reflect.Type

func (RocksetKinesisCollectionOutput) FieldMappingQuery deprecated 

func (o RocksetKinesisCollectionOutput) FieldMappingQuery() pulumi.StringPtrOutput

**Deprecated** use ingestTransformation instead

Deprecated: Use ingest_transformation instead

func (RocksetKinesisCollectionOutput) IngestTransformation 

func (o RocksetKinesisCollectionOutput) IngestTransformation() pulumi.StringPtrOutput

Ingest transformation SQL query. Turns the collection into insertOnly mode.

func (RocksetKinesisCollectionOutput) Name 

func (o RocksetKinesisCollectionOutput) Name() pulumi.StringOutput

Unique identifier for the collection. Can contain alphanumeric or dash characters.

func (RocksetKinesisCollectionOutput) RetentionSecs 

func (o RocksetKinesisCollectionOutput) RetentionSecs() pulumi.IntPtrOutput

Number of seconds after which data is purged. Based on event time.

func (RocksetKinesisCollectionOutput) Sources 

func (o RocksetKinesisCollectionOutput) Sources() RocksetKinesisCollectionSourceArrayOutput

Defines a source for this collection.

func (RocksetKinesisCollectionOutput) ToRocksetKinesisCollectionOutput 

func (o RocksetKinesisCollectionOutput) ToRocksetKinesisCollectionOutput() RocksetKinesisCollectionOutput

func (RocksetKinesisCollectionOutput) ToRocksetKinesisCollectionOutputWithContext 

func (o RocksetKinesisCollectionOutput) ToRocksetKinesisCollectionOutputWithContext(ctx context.Context) RocksetKinesisCollectionOutput

func (RocksetKinesisCollectionOutput) WaitForCollection 

func (o RocksetKinesisCollectionOutput) WaitForCollection() pulumi.BoolPtrOutput

Wait until the collection is ready.

func (RocksetKinesisCollectionOutput) WaitForDocuments 

func (o RocksetKinesisCollectionOutput) WaitForDocuments() pulumi.IntPtrOutput

Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.

func (RocksetKinesisCollectionOutput) Workspace 

func (o RocksetKinesisCollectionOutput) Workspace() pulumi.StringOutput

The name of the workspace.

type RocksetKinesisCollectionSource 

type RocksetKinesisCollectionSource struct {
	// AWS region name for the Kinesis stream, by default us-west-2 is used
	AwsRegion *string `pulumi:"awsRegion"`
	// Set of fields that correspond to a DMS primary key. Can only be set if format is mysql or postgres.
	DmsPrimaryKeys []string `pulumi:"dmsPrimaryKeys"`
	// Format of the data. One of: json, mysql, postgres. dms*primary*keys list can only be set for mysql or postgres.
	Format string `pulumi:"format"`
	// The name of the Rockset Kinesis integration.
	IntegrationName string `pulumi:"integrationName"`
	// Name of Kinesis stream.
	StreamName string `pulumi:"streamName"`
}

type RocksetKinesisCollectionSourceArgs 

type RocksetKinesisCollectionSourceArgs struct {
	// AWS region name for the Kinesis stream, by default us-west-2 is used
	AwsRegion pulumi.StringPtrInput `pulumi:"awsRegion"`
	// Set of fields that correspond to a DMS primary key. Can only be set if format is mysql or postgres.
	DmsPrimaryKeys pulumi.StringArrayInput `pulumi:"dmsPrimaryKeys"`
	// Format of the data. One of: json, mysql, postgres. dms*primary*keys list can only be set for mysql or postgres.
	Format pulumi.StringInput `pulumi:"format"`
	// The name of the Rockset Kinesis integration.
	IntegrationName pulumi.StringInput `pulumi:"integrationName"`
	// Name of Kinesis stream.
	StreamName pulumi.StringInput `pulumi:"streamName"`
}

func (RocksetKinesisCollectionSourceArgs) ElementType 

func (RocksetKinesisCollectionSourceArgs) ElementType() reflect.Type

func (RocksetKinesisCollectionSourceArgs) ToRocksetKinesisCollectionSourceOutput 

func (i RocksetKinesisCollectionSourceArgs) ToRocksetKinesisCollectionSourceOutput() RocksetKinesisCollectionSourceOutput

func (RocksetKinesisCollectionSourceArgs) ToRocksetKinesisCollectionSourceOutputWithContext 

func (i RocksetKinesisCollectionSourceArgs) ToRocksetKinesisCollectionSourceOutputWithContext(ctx context.Context) RocksetKinesisCollectionSourceOutput

type RocksetKinesisCollectionSourceArray 

type RocksetKinesisCollectionSourceArray []RocksetKinesisCollectionSourceInput

func (RocksetKinesisCollectionSourceArray) ElementType 

func (RocksetKinesisCollectionSourceArray) ElementType() reflect.Type

func (RocksetKinesisCollectionSourceArray) ToRocksetKinesisCollectionSourceArrayOutput 

func (i RocksetKinesisCollectionSourceArray) ToRocksetKinesisCollectionSourceArrayOutput() RocksetKinesisCollectionSourceArrayOutput

func (RocksetKinesisCollectionSourceArray) ToRocksetKinesisCollectionSourceArrayOutputWithContext 

func (i RocksetKinesisCollectionSourceArray) ToRocksetKinesisCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetKinesisCollectionSourceArrayOutput

type RocksetKinesisCollectionSourceArrayInput 

type RocksetKinesisCollectionSourceArrayInput interface {
	pulumi.Input

	ToRocksetKinesisCollectionSourceArrayOutput() RocksetKinesisCollectionSourceArrayOutput
	ToRocksetKinesisCollectionSourceArrayOutputWithContext(context.Context) RocksetKinesisCollectionSourceArrayOutput
}

RocksetKinesisCollectionSourceArrayInput is an input type that accepts RocksetKinesisCollectionSourceArray and RocksetKinesisCollectionSourceArrayOutput values. You can construct a concrete instance of `RocksetKinesisCollectionSourceArrayInput` via: 

RocksetKinesisCollectionSourceArray{ RocksetKinesisCollectionSourceArgs{...} }

type RocksetKinesisCollectionSourceArrayOutput 

type RocksetKinesisCollectionSourceArrayOutput struct{ *pulumi.OutputState }

func (RocksetKinesisCollectionSourceArrayOutput) ElementType 

func (RocksetKinesisCollectionSourceArrayOutput) ElementType() reflect.Type

func (RocksetKinesisCollectionSourceArrayOutput) Index 

func (o RocksetKinesisCollectionSourceArrayOutput) Index(i pulumi.IntInput) RocksetKinesisCollectionSourceOutput

func (RocksetKinesisCollectionSourceArrayOutput) ToRocksetKinesisCollectionSourceArrayOutput 

func (o RocksetKinesisCollectionSourceArrayOutput) ToRocksetKinesisCollectionSourceArrayOutput() RocksetKinesisCollectionSourceArrayOutput

func (RocksetKinesisCollectionSourceArrayOutput) ToRocksetKinesisCollectionSourceArrayOutputWithContext 

func (o RocksetKinesisCollectionSourceArrayOutput) ToRocksetKinesisCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetKinesisCollectionSourceArrayOutput

type RocksetKinesisCollectionSourceInput 

type RocksetKinesisCollectionSourceInput interface {
	pulumi.Input

	ToRocksetKinesisCollectionSourceOutput() RocksetKinesisCollectionSourceOutput
	ToRocksetKinesisCollectionSourceOutputWithContext(context.Context) RocksetKinesisCollectionSourceOutput
}

RocksetKinesisCollectionSourceInput is an input type that accepts RocksetKinesisCollectionSourceArgs and RocksetKinesisCollectionSourceOutput values. You can construct a concrete instance of `RocksetKinesisCollectionSourceInput` via: 

RocksetKinesisCollectionSourceArgs{...}

type RocksetKinesisCollectionSourceOutput 

type RocksetKinesisCollectionSourceOutput struct{ *pulumi.OutputState }

func (RocksetKinesisCollectionSourceOutput) AwsRegion 

func (o RocksetKinesisCollectionSourceOutput) AwsRegion() pulumi.StringPtrOutput

AWS region name for the Kinesis stream, by default us-west-2 is used

func (RocksetKinesisCollectionSourceOutput) DmsPrimaryKeys 

func (o RocksetKinesisCollectionSourceOutput) DmsPrimaryKeys() pulumi.StringArrayOutput

Set of fields that correspond to a DMS primary key. Can only be set if format is mysql or postgres.

func (RocksetKinesisCollectionSourceOutput) ElementType 

func (RocksetKinesisCollectionSourceOutput) ElementType() reflect.Type

func (RocksetKinesisCollectionSourceOutput) Format 

func (o RocksetKinesisCollectionSourceOutput) Format() pulumi.StringOutput

Format of the data. One of: json, mysql, postgres. dms*primary*keys list can only be set for mysql or postgres.

func (RocksetKinesisCollectionSourceOutput) IntegrationName 

func (o RocksetKinesisCollectionSourceOutput) IntegrationName() pulumi.StringOutput

The name of the Rockset Kinesis integration.

func (RocksetKinesisCollectionSourceOutput) StreamName 

func (o RocksetKinesisCollectionSourceOutput) StreamName() pulumi.StringOutput

Name of Kinesis stream.

func (RocksetKinesisCollectionSourceOutput) ToRocksetKinesisCollectionSourceOutput 

func (o RocksetKinesisCollectionSourceOutput) ToRocksetKinesisCollectionSourceOutput() RocksetKinesisCollectionSourceOutput

func (RocksetKinesisCollectionSourceOutput) ToRocksetKinesisCollectionSourceOutputWithContext 

func (o RocksetKinesisCollectionSourceOutput) ToRocksetKinesisCollectionSourceOutputWithContext(ctx context.Context) RocksetKinesisCollectionSourceOutput

type RocksetKinesisCollectionState 

type RocksetKinesisCollectionState struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetKinesisCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringPtrInput
}

func (RocksetKinesisCollectionState) ElementType 

func (RocksetKinesisCollectionState) ElementType() reflect.Type

type RocksetKinesisIntegration 

type RocksetKinesisIntegration struct {
	pulumi.CustomResourceState

	// The AWS Role Arn to use for this integration.
	AwsRoleArn pulumi.StringOutput `pulumi:"awsRoleArn"`
	// Text describing the integration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
}

Manages a Rockset Kinesis Integration.

func GetRocksetKinesisIntegration 

func GetRocksetKinesisIntegration(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetKinesisIntegrationState, opts ...pulumi.ResourceOption) (*RocksetKinesisIntegration, error)

GetRocksetKinesisIntegration gets an existing RocksetKinesisIntegration 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 NewRocksetKinesisIntegration 

func NewRocksetKinesisIntegration(ctx *pulumi.Context,
	name string, args *RocksetKinesisIntegrationArgs, opts ...pulumi.ResourceOption) (*RocksetKinesisIntegration, error)

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

func (*RocksetKinesisIntegration) ElementType 

func (*RocksetKinesisIntegration) ElementType() reflect.Type

func (*RocksetKinesisIntegration) ToRocksetKinesisIntegrationOutput 

func (i *RocksetKinesisIntegration) ToRocksetKinesisIntegrationOutput() RocksetKinesisIntegrationOutput

func (*RocksetKinesisIntegration) ToRocksetKinesisIntegrationOutputWithContext 

func (i *RocksetKinesisIntegration) ToRocksetKinesisIntegrationOutputWithContext(ctx context.Context) RocksetKinesisIntegrationOutput

type RocksetKinesisIntegrationArgs 

type RocksetKinesisIntegrationArgs struct {
	// The AWS Role Arn to use for this integration.
	AwsRoleArn pulumi.StringInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
}

The set of arguments for constructing a RocksetKinesisIntegration resource.

func (RocksetKinesisIntegrationArgs) ElementType 

func (RocksetKinesisIntegrationArgs) ElementType() reflect.Type

type RocksetKinesisIntegrationArray 

type RocksetKinesisIntegrationArray []RocksetKinesisIntegrationInput

func (RocksetKinesisIntegrationArray) ElementType 

func (RocksetKinesisIntegrationArray) ElementType() reflect.Type

func (RocksetKinesisIntegrationArray) ToRocksetKinesisIntegrationArrayOutput 

func (i RocksetKinesisIntegrationArray) ToRocksetKinesisIntegrationArrayOutput() RocksetKinesisIntegrationArrayOutput

func (RocksetKinesisIntegrationArray) ToRocksetKinesisIntegrationArrayOutputWithContext 

func (i RocksetKinesisIntegrationArray) ToRocksetKinesisIntegrationArrayOutputWithContext(ctx context.Context) RocksetKinesisIntegrationArrayOutput

type RocksetKinesisIntegrationArrayInput 

type RocksetKinesisIntegrationArrayInput interface {
	pulumi.Input

	ToRocksetKinesisIntegrationArrayOutput() RocksetKinesisIntegrationArrayOutput
	ToRocksetKinesisIntegrationArrayOutputWithContext(context.Context) RocksetKinesisIntegrationArrayOutput
}

RocksetKinesisIntegrationArrayInput is an input type that accepts RocksetKinesisIntegrationArray and RocksetKinesisIntegrationArrayOutput values. You can construct a concrete instance of `RocksetKinesisIntegrationArrayInput` via: 

RocksetKinesisIntegrationArray{ RocksetKinesisIntegrationArgs{...} }

type RocksetKinesisIntegrationArrayOutput 

type RocksetKinesisIntegrationArrayOutput struct{ *pulumi.OutputState }

func (RocksetKinesisIntegrationArrayOutput) ElementType 

func (RocksetKinesisIntegrationArrayOutput) ElementType() reflect.Type

func (RocksetKinesisIntegrationArrayOutput) Index 

func (o RocksetKinesisIntegrationArrayOutput) Index(i pulumi.IntInput) RocksetKinesisIntegrationOutput

func (RocksetKinesisIntegrationArrayOutput) ToRocksetKinesisIntegrationArrayOutput 

func (o RocksetKinesisIntegrationArrayOutput) ToRocksetKinesisIntegrationArrayOutput() RocksetKinesisIntegrationArrayOutput

func (RocksetKinesisIntegrationArrayOutput) ToRocksetKinesisIntegrationArrayOutputWithContext 

func (o RocksetKinesisIntegrationArrayOutput) ToRocksetKinesisIntegrationArrayOutputWithContext(ctx context.Context) RocksetKinesisIntegrationArrayOutput

type RocksetKinesisIntegrationInput 

type RocksetKinesisIntegrationInput interface {
	pulumi.Input

	ToRocksetKinesisIntegrationOutput() RocksetKinesisIntegrationOutput
	ToRocksetKinesisIntegrationOutputWithContext(ctx context.Context) RocksetKinesisIntegrationOutput
}

type RocksetKinesisIntegrationMap 

type RocksetKinesisIntegrationMap map[string]RocksetKinesisIntegrationInput

func (RocksetKinesisIntegrationMap) ElementType 

func (RocksetKinesisIntegrationMap) ElementType() reflect.Type

func (RocksetKinesisIntegrationMap) ToRocksetKinesisIntegrationMapOutput 

func (i RocksetKinesisIntegrationMap) ToRocksetKinesisIntegrationMapOutput() RocksetKinesisIntegrationMapOutput

func (RocksetKinesisIntegrationMap) ToRocksetKinesisIntegrationMapOutputWithContext 

func (i RocksetKinesisIntegrationMap) ToRocksetKinesisIntegrationMapOutputWithContext(ctx context.Context) RocksetKinesisIntegrationMapOutput

type RocksetKinesisIntegrationMapInput 

type RocksetKinesisIntegrationMapInput interface {
	pulumi.Input

	ToRocksetKinesisIntegrationMapOutput() RocksetKinesisIntegrationMapOutput
	ToRocksetKinesisIntegrationMapOutputWithContext(context.Context) RocksetKinesisIntegrationMapOutput
}

RocksetKinesisIntegrationMapInput is an input type that accepts RocksetKinesisIntegrationMap and RocksetKinesisIntegrationMapOutput values. You can construct a concrete instance of `RocksetKinesisIntegrationMapInput` via: 

RocksetKinesisIntegrationMap{ "key": RocksetKinesisIntegrationArgs{...} }

type RocksetKinesisIntegrationMapOutput 

type RocksetKinesisIntegrationMapOutput struct{ *pulumi.OutputState }

func (RocksetKinesisIntegrationMapOutput) ElementType 

func (RocksetKinesisIntegrationMapOutput) ElementType() reflect.Type

func (RocksetKinesisIntegrationMapOutput) MapIndex 

func (o RocksetKinesisIntegrationMapOutput) MapIndex(k pulumi.StringInput) RocksetKinesisIntegrationOutput

func (RocksetKinesisIntegrationMapOutput) ToRocksetKinesisIntegrationMapOutput 

func (o RocksetKinesisIntegrationMapOutput) ToRocksetKinesisIntegrationMapOutput() RocksetKinesisIntegrationMapOutput

func (RocksetKinesisIntegrationMapOutput) ToRocksetKinesisIntegrationMapOutputWithContext 

func (o RocksetKinesisIntegrationMapOutput) ToRocksetKinesisIntegrationMapOutputWithContext(ctx context.Context) RocksetKinesisIntegrationMapOutput

type RocksetKinesisIntegrationOutput 

type RocksetKinesisIntegrationOutput struct{ *pulumi.OutputState }

func (RocksetKinesisIntegrationOutput) AwsRoleArn 

func (o RocksetKinesisIntegrationOutput) AwsRoleArn() pulumi.StringOutput

The AWS Role Arn to use for this integration.

func (RocksetKinesisIntegrationOutput) Description 

func (o RocksetKinesisIntegrationOutput) Description() pulumi.StringPtrOutput

Text describing the integration.

func (RocksetKinesisIntegrationOutput) ElementType 

func (RocksetKinesisIntegrationOutput) ElementType() reflect.Type

func (RocksetKinesisIntegrationOutput) Name 

func (o RocksetKinesisIntegrationOutput) Name() pulumi.StringOutput

Unique identifier for the integration. Can contain alphanumeric or dash characters.

func (RocksetKinesisIntegrationOutput) ToRocksetKinesisIntegrationOutput 

func (o RocksetKinesisIntegrationOutput) ToRocksetKinesisIntegrationOutput() RocksetKinesisIntegrationOutput

func (RocksetKinesisIntegrationOutput) ToRocksetKinesisIntegrationOutputWithContext 

func (o RocksetKinesisIntegrationOutput) ToRocksetKinesisIntegrationOutputWithContext(ctx context.Context) RocksetKinesisIntegrationOutput

type RocksetKinesisIntegrationState 

type RocksetKinesisIntegrationState struct {
	// The AWS Role Arn to use for this integration.
	AwsRoleArn pulumi.StringPtrInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
}

func (RocksetKinesisIntegrationState) ElementType 

func (RocksetKinesisIntegrationState) ElementType() reflect.Type

type RocksetMongodbCollection 

type RocksetMongodbCollection struct {
	pulumi.CustomResourceState

	// Text describing the collection.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrOutput `pulumi:"fieldMappingQuery"`
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrOutput `pulumi:"ingestTransformation"`
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrOutput `pulumi:"retentionSecs"`
	// Defines a source for this collection.
	Sources RocksetMongodbCollectionSourceArrayOutput `pulumi:"sources"`
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrOutput `pulumi:"waitForCollection"`
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrOutput `pulumi:"waitForDocuments"`
	// The name of the workspace.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a collection with an MongoDB source attached.

func GetRocksetMongodbCollection 

func GetRocksetMongodbCollection(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetMongodbCollectionState, opts ...pulumi.ResourceOption) (*RocksetMongodbCollection, error)

GetRocksetMongodbCollection gets an existing RocksetMongodbCollection 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 NewRocksetMongodbCollection 

func NewRocksetMongodbCollection(ctx *pulumi.Context,
	name string, args *RocksetMongodbCollectionArgs, opts ...pulumi.ResourceOption) (*RocksetMongodbCollection, error)

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

func (*RocksetMongodbCollection) ElementType 

func (*RocksetMongodbCollection) ElementType() reflect.Type

func (*RocksetMongodbCollection) ToRocksetMongodbCollectionOutput 

func (i *RocksetMongodbCollection) ToRocksetMongodbCollectionOutput() RocksetMongodbCollectionOutput

func (*RocksetMongodbCollection) ToRocksetMongodbCollectionOutputWithContext 

func (i *RocksetMongodbCollection) ToRocksetMongodbCollectionOutputWithContext(ctx context.Context) RocksetMongodbCollectionOutput

type RocksetMongodbCollectionArgs 

type RocksetMongodbCollectionArgs struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetMongodbCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetMongodbCollection resource.

func (RocksetMongodbCollectionArgs) ElementType 

func (RocksetMongodbCollectionArgs) ElementType() reflect.Type

type RocksetMongodbCollectionArray 

type RocksetMongodbCollectionArray []RocksetMongodbCollectionInput

func (RocksetMongodbCollectionArray) ElementType 

func (RocksetMongodbCollectionArray) ElementType() reflect.Type

func (RocksetMongodbCollectionArray) ToRocksetMongodbCollectionArrayOutput 

func (i RocksetMongodbCollectionArray) ToRocksetMongodbCollectionArrayOutput() RocksetMongodbCollectionArrayOutput

func (RocksetMongodbCollectionArray) ToRocksetMongodbCollectionArrayOutputWithContext 

func (i RocksetMongodbCollectionArray) ToRocksetMongodbCollectionArrayOutputWithContext(ctx context.Context) RocksetMongodbCollectionArrayOutput

type RocksetMongodbCollectionArrayInput 

type RocksetMongodbCollectionArrayInput interface {
	pulumi.Input

	ToRocksetMongodbCollectionArrayOutput() RocksetMongodbCollectionArrayOutput
	ToRocksetMongodbCollectionArrayOutputWithContext(context.Context) RocksetMongodbCollectionArrayOutput
}

RocksetMongodbCollectionArrayInput is an input type that accepts RocksetMongodbCollectionArray and RocksetMongodbCollectionArrayOutput values. You can construct a concrete instance of `RocksetMongodbCollectionArrayInput` via: 

RocksetMongodbCollectionArray{ RocksetMongodbCollectionArgs{...} }

type RocksetMongodbCollectionArrayOutput 

type RocksetMongodbCollectionArrayOutput struct{ *pulumi.OutputState }

func (RocksetMongodbCollectionArrayOutput) ElementType 

func (RocksetMongodbCollectionArrayOutput) ElementType() reflect.Type

func (RocksetMongodbCollectionArrayOutput) Index 

func (o RocksetMongodbCollectionArrayOutput) Index(i pulumi.IntInput) RocksetMongodbCollectionOutput

func (RocksetMongodbCollectionArrayOutput) ToRocksetMongodbCollectionArrayOutput 

func (o RocksetMongodbCollectionArrayOutput) ToRocksetMongodbCollectionArrayOutput() RocksetMongodbCollectionArrayOutput

func (RocksetMongodbCollectionArrayOutput) ToRocksetMongodbCollectionArrayOutputWithContext 

func (o RocksetMongodbCollectionArrayOutput) ToRocksetMongodbCollectionArrayOutputWithContext(ctx context.Context) RocksetMongodbCollectionArrayOutput

type RocksetMongodbCollectionInput 

type RocksetMongodbCollectionInput interface {
	pulumi.Input

	ToRocksetMongodbCollectionOutput() RocksetMongodbCollectionOutput
	ToRocksetMongodbCollectionOutputWithContext(ctx context.Context) RocksetMongodbCollectionOutput
}

type RocksetMongodbCollectionMap 

type RocksetMongodbCollectionMap map[string]RocksetMongodbCollectionInput

func (RocksetMongodbCollectionMap) ElementType 

func (RocksetMongodbCollectionMap) ElementType() reflect.Type

func (RocksetMongodbCollectionMap) ToRocksetMongodbCollectionMapOutput 

func (i RocksetMongodbCollectionMap) ToRocksetMongodbCollectionMapOutput() RocksetMongodbCollectionMapOutput

func (RocksetMongodbCollectionMap) ToRocksetMongodbCollectionMapOutputWithContext 

func (i RocksetMongodbCollectionMap) ToRocksetMongodbCollectionMapOutputWithContext(ctx context.Context) RocksetMongodbCollectionMapOutput

type RocksetMongodbCollectionMapInput 

type RocksetMongodbCollectionMapInput interface {
	pulumi.Input

	ToRocksetMongodbCollectionMapOutput() RocksetMongodbCollectionMapOutput
	ToRocksetMongodbCollectionMapOutputWithContext(context.Context) RocksetMongodbCollectionMapOutput
}

RocksetMongodbCollectionMapInput is an input type that accepts RocksetMongodbCollectionMap and RocksetMongodbCollectionMapOutput values. You can construct a concrete instance of `RocksetMongodbCollectionMapInput` via: 

RocksetMongodbCollectionMap{ "key": RocksetMongodbCollectionArgs{...} }

type RocksetMongodbCollectionMapOutput 

type RocksetMongodbCollectionMapOutput struct{ *pulumi.OutputState }

func (RocksetMongodbCollectionMapOutput) ElementType 

func (RocksetMongodbCollectionMapOutput) ElementType() reflect.Type

func (RocksetMongodbCollectionMapOutput) MapIndex 

func (o RocksetMongodbCollectionMapOutput) MapIndex(k pulumi.StringInput) RocksetMongodbCollectionOutput

func (RocksetMongodbCollectionMapOutput) ToRocksetMongodbCollectionMapOutput 

func (o RocksetMongodbCollectionMapOutput) ToRocksetMongodbCollectionMapOutput() RocksetMongodbCollectionMapOutput

func (RocksetMongodbCollectionMapOutput) ToRocksetMongodbCollectionMapOutputWithContext 

func (o RocksetMongodbCollectionMapOutput) ToRocksetMongodbCollectionMapOutputWithContext(ctx context.Context) RocksetMongodbCollectionMapOutput

type RocksetMongodbCollectionOutput 

type RocksetMongodbCollectionOutput struct{ *pulumi.OutputState }

func (RocksetMongodbCollectionOutput) Description 

func (o RocksetMongodbCollectionOutput) Description() pulumi.StringPtrOutput

Text describing the collection.

func (RocksetMongodbCollectionOutput) ElementType 

func (RocksetMongodbCollectionOutput) ElementType() reflect.Type

func (RocksetMongodbCollectionOutput) FieldMappingQuery deprecated 

func (o RocksetMongodbCollectionOutput) FieldMappingQuery() pulumi.StringPtrOutput

**Deprecated** use ingestTransformation instead

Deprecated: Use ingest_transformation instead

func (RocksetMongodbCollectionOutput) IngestTransformation 

func (o RocksetMongodbCollectionOutput) IngestTransformation() pulumi.StringPtrOutput

Ingest transformation SQL query. Turns the collection into insertOnly mode.

func (RocksetMongodbCollectionOutput) Name 

func (o RocksetMongodbCollectionOutput) Name() pulumi.StringOutput

Unique identifier for the collection. Can contain alphanumeric or dash characters.

func (RocksetMongodbCollectionOutput) RetentionSecs 

func (o RocksetMongodbCollectionOutput) RetentionSecs() pulumi.IntPtrOutput

Number of seconds after which data is purged. Based on event time.

func (RocksetMongodbCollectionOutput) Sources 

func (o RocksetMongodbCollectionOutput) Sources() RocksetMongodbCollectionSourceArrayOutput

Defines a source for this collection.

func (RocksetMongodbCollectionOutput) ToRocksetMongodbCollectionOutput 

func (o RocksetMongodbCollectionOutput) ToRocksetMongodbCollectionOutput() RocksetMongodbCollectionOutput

func (RocksetMongodbCollectionOutput) ToRocksetMongodbCollectionOutputWithContext 

func (o RocksetMongodbCollectionOutput) ToRocksetMongodbCollectionOutputWithContext(ctx context.Context) RocksetMongodbCollectionOutput

func (RocksetMongodbCollectionOutput) WaitForCollection 

func (o RocksetMongodbCollectionOutput) WaitForCollection() pulumi.BoolPtrOutput

Wait until the collection is ready.

func (RocksetMongodbCollectionOutput) WaitForDocuments 

func (o RocksetMongodbCollectionOutput) WaitForDocuments() pulumi.IntPtrOutput

Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.

func (RocksetMongodbCollectionOutput) Workspace 

func (o RocksetMongodbCollectionOutput) Workspace() pulumi.StringOutput

The name of the workspace.

type RocksetMongodbCollectionSource 

type RocksetMongodbCollectionSource struct {
	// MongoDB collection name of the target collection.
	CollectionName string `pulumi:"collectionName"`
	// MongoDB database name containing the target collection.
	DatabaseName string `pulumi:"databaseName"`
	// The name of the Rockset MongoDB integration.
	IntegrationName string `pulumi:"integrationName"`
	// MongoDB scan end time.
	ScanEndTime *string `pulumi:"scanEndTime"`
	// Number of records inserted using scan.
	ScanRecordsProcessed *int `pulumi:"scanRecordsProcessed"`
	// MongoDB scan start time.
	ScanStartTime *string `pulumi:"scanStartTime"`
	// Number of records in MongoDB table at time of scan.
	ScanTotalRecords *int `pulumi:"scanTotalRecords"`
	// State of current ingest for this table.
	State *string `pulumi:"state"`
	// ISO-8601 date when delete from source was last processed.
	StreamLastDeleteProcessedAt *string `pulumi:"streamLastDeleteProcessedAt"`
	// ISO-8601 date when new insert from source was last processed.
	StreamLastInsertProcessedAt *string `pulumi:"streamLastInsertProcessedAt"`
	// ISO-8601 date when update from source was last processed.
	StreamLastUpdateProcessedAt *string `pulumi:"streamLastUpdateProcessedAt"`
	// Number of new records deleted using stream.
	StreamRecordsDeleted *int `pulumi:"streamRecordsDeleted"`
	// Number of new records inserted using stream.
	StreamRecordsInserted *int `pulumi:"streamRecordsInserted"`
	// Number of new records updated using stream.
	StreamRecordsUpdated *int `pulumi:"streamRecordsUpdated"`
}

type RocksetMongodbCollectionSourceArgs 

type RocksetMongodbCollectionSourceArgs struct {
	// MongoDB collection name of the target collection.
	CollectionName pulumi.StringInput `pulumi:"collectionName"`
	// MongoDB database name containing the target collection.
	DatabaseName pulumi.StringInput `pulumi:"databaseName"`
	// The name of the Rockset MongoDB integration.
	IntegrationName pulumi.StringInput `pulumi:"integrationName"`
	// MongoDB scan end time.
	ScanEndTime pulumi.StringPtrInput `pulumi:"scanEndTime"`
	// Number of records inserted using scan.
	ScanRecordsProcessed pulumi.IntPtrInput `pulumi:"scanRecordsProcessed"`
	// MongoDB scan start time.
	ScanStartTime pulumi.StringPtrInput `pulumi:"scanStartTime"`
	// Number of records in MongoDB table at time of scan.
	ScanTotalRecords pulumi.IntPtrInput `pulumi:"scanTotalRecords"`
	// State of current ingest for this table.
	State pulumi.StringPtrInput `pulumi:"state"`
	// ISO-8601 date when delete from source was last processed.
	StreamLastDeleteProcessedAt pulumi.StringPtrInput `pulumi:"streamLastDeleteProcessedAt"`
	// ISO-8601 date when new insert from source was last processed.
	StreamLastInsertProcessedAt pulumi.StringPtrInput `pulumi:"streamLastInsertProcessedAt"`
	// ISO-8601 date when update from source was last processed.
	StreamLastUpdateProcessedAt pulumi.StringPtrInput `pulumi:"streamLastUpdateProcessedAt"`
	// Number of new records deleted using stream.
	StreamRecordsDeleted pulumi.IntPtrInput `pulumi:"streamRecordsDeleted"`
	// Number of new records inserted using stream.
	StreamRecordsInserted pulumi.IntPtrInput `pulumi:"streamRecordsInserted"`
	// Number of new records updated using stream.
	StreamRecordsUpdated pulumi.IntPtrInput `pulumi:"streamRecordsUpdated"`
}

func (RocksetMongodbCollectionSourceArgs) ElementType 

func (RocksetMongodbCollectionSourceArgs) ElementType() reflect.Type

func (RocksetMongodbCollectionSourceArgs) ToRocksetMongodbCollectionSourceOutput 

func (i RocksetMongodbCollectionSourceArgs) ToRocksetMongodbCollectionSourceOutput() RocksetMongodbCollectionSourceOutput

func (RocksetMongodbCollectionSourceArgs) ToRocksetMongodbCollectionSourceOutputWithContext 

func (i RocksetMongodbCollectionSourceArgs) ToRocksetMongodbCollectionSourceOutputWithContext(ctx context.Context) RocksetMongodbCollectionSourceOutput

type RocksetMongodbCollectionSourceArray 

type RocksetMongodbCollectionSourceArray []RocksetMongodbCollectionSourceInput

func (RocksetMongodbCollectionSourceArray) ElementType 

func (RocksetMongodbCollectionSourceArray) ElementType() reflect.Type

func (RocksetMongodbCollectionSourceArray) ToRocksetMongodbCollectionSourceArrayOutput 

func (i RocksetMongodbCollectionSourceArray) ToRocksetMongodbCollectionSourceArrayOutput() RocksetMongodbCollectionSourceArrayOutput

func (RocksetMongodbCollectionSourceArray) ToRocksetMongodbCollectionSourceArrayOutputWithContext 

func (i RocksetMongodbCollectionSourceArray) ToRocksetMongodbCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetMongodbCollectionSourceArrayOutput

type RocksetMongodbCollectionSourceArrayInput 

type RocksetMongodbCollectionSourceArrayInput interface {
	pulumi.Input

	ToRocksetMongodbCollectionSourceArrayOutput() RocksetMongodbCollectionSourceArrayOutput
	ToRocksetMongodbCollectionSourceArrayOutputWithContext(context.Context) RocksetMongodbCollectionSourceArrayOutput
}

RocksetMongodbCollectionSourceArrayInput is an input type that accepts RocksetMongodbCollectionSourceArray and RocksetMongodbCollectionSourceArrayOutput values. You can construct a concrete instance of `RocksetMongodbCollectionSourceArrayInput` via: 

RocksetMongodbCollectionSourceArray{ RocksetMongodbCollectionSourceArgs{...} }

type RocksetMongodbCollectionSourceArrayOutput 

type RocksetMongodbCollectionSourceArrayOutput struct{ *pulumi.OutputState }

func (RocksetMongodbCollectionSourceArrayOutput) ElementType 

func (RocksetMongodbCollectionSourceArrayOutput) ElementType() reflect.Type

func (RocksetMongodbCollectionSourceArrayOutput) Index 

func (o RocksetMongodbCollectionSourceArrayOutput) Index(i pulumi.IntInput) RocksetMongodbCollectionSourceOutput

func (RocksetMongodbCollectionSourceArrayOutput) ToRocksetMongodbCollectionSourceArrayOutput 

func (o RocksetMongodbCollectionSourceArrayOutput) ToRocksetMongodbCollectionSourceArrayOutput() RocksetMongodbCollectionSourceArrayOutput

func (RocksetMongodbCollectionSourceArrayOutput) ToRocksetMongodbCollectionSourceArrayOutputWithContext 

func (o RocksetMongodbCollectionSourceArrayOutput) ToRocksetMongodbCollectionSourceArrayOutputWithContext(ctx context.Context) RocksetMongodbCollectionSourceArrayOutput

type RocksetMongodbCollectionSourceInput 

type RocksetMongodbCollectionSourceInput interface {
	pulumi.Input

	ToRocksetMongodbCollectionSourceOutput() RocksetMongodbCollectionSourceOutput
	ToRocksetMongodbCollectionSourceOutputWithContext(context.Context) RocksetMongodbCollectionSourceOutput
}

RocksetMongodbCollectionSourceInput is an input type that accepts RocksetMongodbCollectionSourceArgs and RocksetMongodbCollectionSourceOutput values. You can construct a concrete instance of `RocksetMongodbCollectionSourceInput` via: 

RocksetMongodbCollectionSourceArgs{...}

type RocksetMongodbCollectionSourceOutput 

type RocksetMongodbCollectionSourceOutput struct{ *pulumi.OutputState }

func (RocksetMongodbCollectionSourceOutput) CollectionName 

func (o RocksetMongodbCollectionSourceOutput) CollectionName() pulumi.StringOutput

MongoDB collection name of the target collection.

func (RocksetMongodbCollectionSourceOutput) DatabaseName 

func (o RocksetMongodbCollectionSourceOutput) DatabaseName() pulumi.StringOutput

MongoDB database name containing the target collection.

func (RocksetMongodbCollectionSourceOutput) ElementType 

func (RocksetMongodbCollectionSourceOutput) ElementType() reflect.Type

func (RocksetMongodbCollectionSourceOutput) IntegrationName 

func (o RocksetMongodbCollectionSourceOutput) IntegrationName() pulumi.StringOutput

The name of the Rockset MongoDB integration.

func (RocksetMongodbCollectionSourceOutput) ScanEndTime 

func (o RocksetMongodbCollectionSourceOutput) ScanEndTime() pulumi.StringPtrOutput

MongoDB scan end time.

func (RocksetMongodbCollectionSourceOutput) ScanRecordsProcessed 

func (o RocksetMongodbCollectionSourceOutput) ScanRecordsProcessed() pulumi.IntPtrOutput

Number of records inserted using scan.

func (RocksetMongodbCollectionSourceOutput) ScanStartTime 

func (o RocksetMongodbCollectionSourceOutput) ScanStartTime() pulumi.StringPtrOutput

MongoDB scan start time.

func (RocksetMongodbCollectionSourceOutput) ScanTotalRecords 

func (o RocksetMongodbCollectionSourceOutput) ScanTotalRecords() pulumi.IntPtrOutput

Number of records in MongoDB table at time of scan.

func (RocksetMongodbCollectionSourceOutput) State 

func (o RocksetMongodbCollectionSourceOutput) State() pulumi.StringPtrOutput

State of current ingest for this table.

func (RocksetMongodbCollectionSourceOutput) StreamLastDeleteProcessedAt 

func (o RocksetMongodbCollectionSourceOutput) StreamLastDeleteProcessedAt() pulumi.StringPtrOutput

ISO-8601 date when delete from source was last processed.

func (RocksetMongodbCollectionSourceOutput) StreamLastInsertProcessedAt 

func (o RocksetMongodbCollectionSourceOutput) StreamLastInsertProcessedAt() pulumi.StringPtrOutput

ISO-8601 date when new insert from source was last processed.

func (RocksetMongodbCollectionSourceOutput) StreamLastUpdateProcessedAt 

func (o RocksetMongodbCollectionSourceOutput) StreamLastUpdateProcessedAt() pulumi.StringPtrOutput

ISO-8601 date when update from source was last processed.

func (RocksetMongodbCollectionSourceOutput) StreamRecordsDeleted 

func (o RocksetMongodbCollectionSourceOutput) StreamRecordsDeleted() pulumi.IntPtrOutput

Number of new records deleted using stream.

func (RocksetMongodbCollectionSourceOutput) StreamRecordsInserted 

func (o RocksetMongodbCollectionSourceOutput) StreamRecordsInserted() pulumi.IntPtrOutput

Number of new records inserted using stream.

func (RocksetMongodbCollectionSourceOutput) StreamRecordsUpdated 

func (o RocksetMongodbCollectionSourceOutput) StreamRecordsUpdated() pulumi.IntPtrOutput

Number of new records updated using stream.

func (RocksetMongodbCollectionSourceOutput) ToRocksetMongodbCollectionSourceOutput 

func (o RocksetMongodbCollectionSourceOutput) ToRocksetMongodbCollectionSourceOutput() RocksetMongodbCollectionSourceOutput

func (RocksetMongodbCollectionSourceOutput) ToRocksetMongodbCollectionSourceOutputWithContext 

func (o RocksetMongodbCollectionSourceOutput) ToRocksetMongodbCollectionSourceOutputWithContext(ctx context.Context) RocksetMongodbCollectionSourceOutput

type RocksetMongodbCollectionState 

type RocksetMongodbCollectionState struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetMongodbCollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringPtrInput
}

func (RocksetMongodbCollectionState) ElementType 

func (RocksetMongodbCollectionState) ElementType() reflect.Type

type RocksetMongodbIntegration 

type RocksetMongodbIntegration struct {
	pulumi.CustomResourceState

	// MongoDB connection URI string. The password is scrubbed from the URI when fetched by the API so this field is NOT set on imports and reads.
	ConnectionUri pulumi.StringOutput `pulumi:"connectionUri"`
	// Text describing the integration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
}

Manages a Rockset MongoDB Integration.

func GetRocksetMongodbIntegration 

func GetRocksetMongodbIntegration(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetMongodbIntegrationState, opts ...pulumi.ResourceOption) (*RocksetMongodbIntegration, error)

GetRocksetMongodbIntegration gets an existing RocksetMongodbIntegration 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 NewRocksetMongodbIntegration 

func NewRocksetMongodbIntegration(ctx *pulumi.Context,
	name string, args *RocksetMongodbIntegrationArgs, opts ...pulumi.ResourceOption) (*RocksetMongodbIntegration, error)

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

func (*RocksetMongodbIntegration) ElementType 

func (*RocksetMongodbIntegration) ElementType() reflect.Type

func (*RocksetMongodbIntegration) ToRocksetMongodbIntegrationOutput 

func (i *RocksetMongodbIntegration) ToRocksetMongodbIntegrationOutput() RocksetMongodbIntegrationOutput

func (*RocksetMongodbIntegration) ToRocksetMongodbIntegrationOutputWithContext 

func (i *RocksetMongodbIntegration) ToRocksetMongodbIntegrationOutputWithContext(ctx context.Context) RocksetMongodbIntegrationOutput

type RocksetMongodbIntegrationArgs 

type RocksetMongodbIntegrationArgs struct {
	// MongoDB connection URI string. The password is scrubbed from the URI when fetched by the API so this field is NOT set on imports and reads.
	ConnectionUri pulumi.StringInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
}

The set of arguments for constructing a RocksetMongodbIntegration resource.

func (RocksetMongodbIntegrationArgs) ElementType 

func (RocksetMongodbIntegrationArgs) ElementType() reflect.Type

type RocksetMongodbIntegrationArray 

type RocksetMongodbIntegrationArray []RocksetMongodbIntegrationInput

func (RocksetMongodbIntegrationArray) ElementType 

func (RocksetMongodbIntegrationArray) ElementType() reflect.Type

func (RocksetMongodbIntegrationArray) ToRocksetMongodbIntegrationArrayOutput 

func (i RocksetMongodbIntegrationArray) ToRocksetMongodbIntegrationArrayOutput() RocksetMongodbIntegrationArrayOutput

func (RocksetMongodbIntegrationArray) ToRocksetMongodbIntegrationArrayOutputWithContext 

func (i RocksetMongodbIntegrationArray) ToRocksetMongodbIntegrationArrayOutputWithContext(ctx context.Context) RocksetMongodbIntegrationArrayOutput

type RocksetMongodbIntegrationArrayInput 

type RocksetMongodbIntegrationArrayInput interface {
	pulumi.Input

	ToRocksetMongodbIntegrationArrayOutput() RocksetMongodbIntegrationArrayOutput
	ToRocksetMongodbIntegrationArrayOutputWithContext(context.Context) RocksetMongodbIntegrationArrayOutput
}

RocksetMongodbIntegrationArrayInput is an input type that accepts RocksetMongodbIntegrationArray and RocksetMongodbIntegrationArrayOutput values. You can construct a concrete instance of `RocksetMongodbIntegrationArrayInput` via: 

RocksetMongodbIntegrationArray{ RocksetMongodbIntegrationArgs{...} }

type RocksetMongodbIntegrationArrayOutput 

type RocksetMongodbIntegrationArrayOutput struct{ *pulumi.OutputState }

func (RocksetMongodbIntegrationArrayOutput) ElementType 

func (RocksetMongodbIntegrationArrayOutput) ElementType() reflect.Type

func (RocksetMongodbIntegrationArrayOutput) Index 

func (o RocksetMongodbIntegrationArrayOutput) Index(i pulumi.IntInput) RocksetMongodbIntegrationOutput

func (RocksetMongodbIntegrationArrayOutput) ToRocksetMongodbIntegrationArrayOutput 

func (o RocksetMongodbIntegrationArrayOutput) ToRocksetMongodbIntegrationArrayOutput() RocksetMongodbIntegrationArrayOutput

func (RocksetMongodbIntegrationArrayOutput) ToRocksetMongodbIntegrationArrayOutputWithContext 

func (o RocksetMongodbIntegrationArrayOutput) ToRocksetMongodbIntegrationArrayOutputWithContext(ctx context.Context) RocksetMongodbIntegrationArrayOutput

type RocksetMongodbIntegrationInput 

type RocksetMongodbIntegrationInput interface {
	pulumi.Input

	ToRocksetMongodbIntegrationOutput() RocksetMongodbIntegrationOutput
	ToRocksetMongodbIntegrationOutputWithContext(ctx context.Context) RocksetMongodbIntegrationOutput
}

type RocksetMongodbIntegrationMap 

type RocksetMongodbIntegrationMap map[string]RocksetMongodbIntegrationInput

func (RocksetMongodbIntegrationMap) ElementType 

func (RocksetMongodbIntegrationMap) ElementType() reflect.Type

func (RocksetMongodbIntegrationMap) ToRocksetMongodbIntegrationMapOutput 

func (i RocksetMongodbIntegrationMap) ToRocksetMongodbIntegrationMapOutput() RocksetMongodbIntegrationMapOutput

func (RocksetMongodbIntegrationMap) ToRocksetMongodbIntegrationMapOutputWithContext 

func (i RocksetMongodbIntegrationMap) ToRocksetMongodbIntegrationMapOutputWithContext(ctx context.Context) RocksetMongodbIntegrationMapOutput

type RocksetMongodbIntegrationMapInput 

type RocksetMongodbIntegrationMapInput interface {
	pulumi.Input

	ToRocksetMongodbIntegrationMapOutput() RocksetMongodbIntegrationMapOutput
	ToRocksetMongodbIntegrationMapOutputWithContext(context.Context) RocksetMongodbIntegrationMapOutput
}

RocksetMongodbIntegrationMapInput is an input type that accepts RocksetMongodbIntegrationMap and RocksetMongodbIntegrationMapOutput values. You can construct a concrete instance of `RocksetMongodbIntegrationMapInput` via: 

RocksetMongodbIntegrationMap{ "key": RocksetMongodbIntegrationArgs{...} }

type RocksetMongodbIntegrationMapOutput 

type RocksetMongodbIntegrationMapOutput struct{ *pulumi.OutputState }

func (RocksetMongodbIntegrationMapOutput) ElementType 

func (RocksetMongodbIntegrationMapOutput) ElementType() reflect.Type

func (RocksetMongodbIntegrationMapOutput) MapIndex 

func (o RocksetMongodbIntegrationMapOutput) MapIndex(k pulumi.StringInput) RocksetMongodbIntegrationOutput

func (RocksetMongodbIntegrationMapOutput) ToRocksetMongodbIntegrationMapOutput 

func (o RocksetMongodbIntegrationMapOutput) ToRocksetMongodbIntegrationMapOutput() RocksetMongodbIntegrationMapOutput

func (RocksetMongodbIntegrationMapOutput) ToRocksetMongodbIntegrationMapOutputWithContext 

func (o RocksetMongodbIntegrationMapOutput) ToRocksetMongodbIntegrationMapOutputWithContext(ctx context.Context) RocksetMongodbIntegrationMapOutput

type RocksetMongodbIntegrationOutput 

type RocksetMongodbIntegrationOutput struct{ *pulumi.OutputState }

func (RocksetMongodbIntegrationOutput) ConnectionUri 

func (o RocksetMongodbIntegrationOutput) ConnectionUri() pulumi.StringOutput

MongoDB connection URI string. The password is scrubbed from the URI when fetched by the API so this field is NOT set on imports and reads.

func (RocksetMongodbIntegrationOutput) Description 

func (o RocksetMongodbIntegrationOutput) Description() pulumi.StringPtrOutput

Text describing the integration.

func (RocksetMongodbIntegrationOutput) ElementType 

func (RocksetMongodbIntegrationOutput) ElementType() reflect.Type

func (RocksetMongodbIntegrationOutput) Name 

func (o RocksetMongodbIntegrationOutput) Name() pulumi.StringOutput

Unique identifier for the integration. Can contain alphanumeric or dash characters.

func (RocksetMongodbIntegrationOutput) ToRocksetMongodbIntegrationOutput 

func (o RocksetMongodbIntegrationOutput) ToRocksetMongodbIntegrationOutput() RocksetMongodbIntegrationOutput

func (RocksetMongodbIntegrationOutput) ToRocksetMongodbIntegrationOutputWithContext 

func (o RocksetMongodbIntegrationOutput) ToRocksetMongodbIntegrationOutputWithContext(ctx context.Context) RocksetMongodbIntegrationOutput

type RocksetMongodbIntegrationState 

type RocksetMongodbIntegrationState struct {
	// MongoDB connection URI string. The password is scrubbed from the URI when fetched by the API so this field is NOT set on imports and reads.
	ConnectionUri pulumi.StringPtrInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
}

func (RocksetMongodbIntegrationState) ElementType 

func (RocksetMongodbIntegrationState) ElementType() reflect.Type

type RocksetQueryLambda 

type RocksetQueryLambda struct {
	pulumi.CustomResourceState

	// Text describing the query lambda.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Unique identifier for the query lambda. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput              `pulumi:"name"`
	Sqls RocksetQueryLambdaSqlArrayOutput `pulumi:"sqls"`
	// The latest state of this query lambda.
	State pulumi.StringOutput `pulumi:"state"`
	// The latest version string of this query lambda.
	Version pulumi.StringOutput `pulumi:"version"`
	// The name of the workspace.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a Rockset Query Lambda.

func GetRocksetQueryLambda 

func GetRocksetQueryLambda(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetQueryLambdaState, opts ...pulumi.ResourceOption) (*RocksetQueryLambda, error)

GetRocksetQueryLambda gets an existing RocksetQueryLambda 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 NewRocksetQueryLambda 

func NewRocksetQueryLambda(ctx *pulumi.Context,
	name string, args *RocksetQueryLambdaArgs, opts ...pulumi.ResourceOption) (*RocksetQueryLambda, error)

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

func (*RocksetQueryLambda) ElementType 

func (*RocksetQueryLambda) ElementType() reflect.Type

func (*RocksetQueryLambda) ToRocksetQueryLambdaOutput 

func (i *RocksetQueryLambda) ToRocksetQueryLambdaOutput() RocksetQueryLambdaOutput

func (*RocksetQueryLambda) ToRocksetQueryLambdaOutputWithContext 

func (i *RocksetQueryLambda) ToRocksetQueryLambdaOutputWithContext(ctx context.Context) RocksetQueryLambdaOutput

type RocksetQueryLambdaArgs 

type RocksetQueryLambdaArgs struct {
	// Text describing the query lambda.
	Description pulumi.StringPtrInput
	// Unique identifier for the query lambda. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	Sqls RocksetQueryLambdaSqlArrayInput
	// The name of the workspace.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetQueryLambda resource.

func (RocksetQueryLambdaArgs) ElementType 

func (RocksetQueryLambdaArgs) ElementType() reflect.Type

type RocksetQueryLambdaArray 

type RocksetQueryLambdaArray []RocksetQueryLambdaInput

func (RocksetQueryLambdaArray) ElementType 

func (RocksetQueryLambdaArray) ElementType() reflect.Type

func (RocksetQueryLambdaArray) ToRocksetQueryLambdaArrayOutput 

func (i RocksetQueryLambdaArray) ToRocksetQueryLambdaArrayOutput() RocksetQueryLambdaArrayOutput

func (RocksetQueryLambdaArray) ToRocksetQueryLambdaArrayOutputWithContext 

func (i RocksetQueryLambdaArray) ToRocksetQueryLambdaArrayOutputWithContext(ctx context.Context) RocksetQueryLambdaArrayOutput

type RocksetQueryLambdaArrayInput 

type RocksetQueryLambdaArrayInput interface {
	pulumi.Input

	ToRocksetQueryLambdaArrayOutput() RocksetQueryLambdaArrayOutput
	ToRocksetQueryLambdaArrayOutputWithContext(context.Context) RocksetQueryLambdaArrayOutput
}

RocksetQueryLambdaArrayInput is an input type that accepts RocksetQueryLambdaArray and RocksetQueryLambdaArrayOutput values. You can construct a concrete instance of `RocksetQueryLambdaArrayInput` via: 

RocksetQueryLambdaArray{ RocksetQueryLambdaArgs{...} }

type RocksetQueryLambdaArrayOutput 

type RocksetQueryLambdaArrayOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaArrayOutput) ElementType 

func (RocksetQueryLambdaArrayOutput) ElementType() reflect.Type

func (RocksetQueryLambdaArrayOutput) Index 

func (o RocksetQueryLambdaArrayOutput) Index(i pulumi.IntInput) RocksetQueryLambdaOutput

func (RocksetQueryLambdaArrayOutput) ToRocksetQueryLambdaArrayOutput 

func (o RocksetQueryLambdaArrayOutput) ToRocksetQueryLambdaArrayOutput() RocksetQueryLambdaArrayOutput

func (RocksetQueryLambdaArrayOutput) ToRocksetQueryLambdaArrayOutputWithContext 

func (o RocksetQueryLambdaArrayOutput) ToRocksetQueryLambdaArrayOutputWithContext(ctx context.Context) RocksetQueryLambdaArrayOutput

type RocksetQueryLambdaInput 

type RocksetQueryLambdaInput interface {
	pulumi.Input

	ToRocksetQueryLambdaOutput() RocksetQueryLambdaOutput
	ToRocksetQueryLambdaOutputWithContext(ctx context.Context) RocksetQueryLambdaOutput
}

type RocksetQueryLambdaMap 

type RocksetQueryLambdaMap map[string]RocksetQueryLambdaInput

func (RocksetQueryLambdaMap) ElementType 

func (RocksetQueryLambdaMap) ElementType() reflect.Type

func (RocksetQueryLambdaMap) ToRocksetQueryLambdaMapOutput 

func (i RocksetQueryLambdaMap) ToRocksetQueryLambdaMapOutput() RocksetQueryLambdaMapOutput

func (RocksetQueryLambdaMap) ToRocksetQueryLambdaMapOutputWithContext 

func (i RocksetQueryLambdaMap) ToRocksetQueryLambdaMapOutputWithContext(ctx context.Context) RocksetQueryLambdaMapOutput

type RocksetQueryLambdaMapInput 

type RocksetQueryLambdaMapInput interface {
	pulumi.Input

	ToRocksetQueryLambdaMapOutput() RocksetQueryLambdaMapOutput
	ToRocksetQueryLambdaMapOutputWithContext(context.Context) RocksetQueryLambdaMapOutput
}

RocksetQueryLambdaMapInput is an input type that accepts RocksetQueryLambdaMap and RocksetQueryLambdaMapOutput values. You can construct a concrete instance of `RocksetQueryLambdaMapInput` via: 

RocksetQueryLambdaMap{ "key": RocksetQueryLambdaArgs{...} }

type RocksetQueryLambdaMapOutput 

type RocksetQueryLambdaMapOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaMapOutput) ElementType 

func (RocksetQueryLambdaMapOutput) ElementType() reflect.Type

func (RocksetQueryLambdaMapOutput) MapIndex 

func (o RocksetQueryLambdaMapOutput) MapIndex(k pulumi.StringInput) RocksetQueryLambdaOutput

func (RocksetQueryLambdaMapOutput) ToRocksetQueryLambdaMapOutput 

func (o RocksetQueryLambdaMapOutput) ToRocksetQueryLambdaMapOutput() RocksetQueryLambdaMapOutput

func (RocksetQueryLambdaMapOutput) ToRocksetQueryLambdaMapOutputWithContext 

func (o RocksetQueryLambdaMapOutput) ToRocksetQueryLambdaMapOutputWithContext(ctx context.Context) RocksetQueryLambdaMapOutput

type RocksetQueryLambdaOutput 

type RocksetQueryLambdaOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaOutput) Description 

func (o RocksetQueryLambdaOutput) Description() pulumi.StringPtrOutput

Text describing the query lambda.

func (RocksetQueryLambdaOutput) ElementType 

func (RocksetQueryLambdaOutput) ElementType() reflect.Type

func (RocksetQueryLambdaOutput) Name 

func (o RocksetQueryLambdaOutput) Name() pulumi.StringOutput

Unique identifier for the query lambda. Can contain alphanumeric or dash characters.

func (RocksetQueryLambdaOutput) Sqls 

func (o RocksetQueryLambdaOutput) Sqls() RocksetQueryLambdaSqlArrayOutput

func (RocksetQueryLambdaOutput) State 

func (o RocksetQueryLambdaOutput) State() pulumi.StringOutput

The latest state of this query lambda.

func (RocksetQueryLambdaOutput) ToRocksetQueryLambdaOutput 

func (o RocksetQueryLambdaOutput) ToRocksetQueryLambdaOutput() RocksetQueryLambdaOutput

func (RocksetQueryLambdaOutput) ToRocksetQueryLambdaOutputWithContext 

func (o RocksetQueryLambdaOutput) ToRocksetQueryLambdaOutputWithContext(ctx context.Context) RocksetQueryLambdaOutput

func (RocksetQueryLambdaOutput) Version 

func (o RocksetQueryLambdaOutput) Version() pulumi.StringOutput

The latest version string of this query lambda.

func (RocksetQueryLambdaOutput) Workspace 

func (o RocksetQueryLambdaOutput) Workspace() pulumi.StringOutput

The name of the workspace.

type RocksetQueryLambdaSql 

type RocksetQueryLambdaSql struct {
	DefaultParameters []RocksetQueryLambdaSqlDefaultParameter `pulumi:"defaultParameters"`
	Query             string                                  `pulumi:"query"`
}

type RocksetQueryLambdaSqlArgs 

type RocksetQueryLambdaSqlArgs struct {
	DefaultParameters RocksetQueryLambdaSqlDefaultParameterArrayInput `pulumi:"defaultParameters"`
	Query             pulumi.StringInput                              `pulumi:"query"`
}

func (RocksetQueryLambdaSqlArgs) ElementType 

func (RocksetQueryLambdaSqlArgs) ElementType() reflect.Type

func (RocksetQueryLambdaSqlArgs) ToRocksetQueryLambdaSqlOutput 

func (i RocksetQueryLambdaSqlArgs) ToRocksetQueryLambdaSqlOutput() RocksetQueryLambdaSqlOutput

func (RocksetQueryLambdaSqlArgs) ToRocksetQueryLambdaSqlOutputWithContext 

func (i RocksetQueryLambdaSqlArgs) ToRocksetQueryLambdaSqlOutputWithContext(ctx context.Context) RocksetQueryLambdaSqlOutput

type RocksetQueryLambdaSqlArray 

type RocksetQueryLambdaSqlArray []RocksetQueryLambdaSqlInput

func (RocksetQueryLambdaSqlArray) ElementType 

func (RocksetQueryLambdaSqlArray) ElementType() reflect.Type

func (RocksetQueryLambdaSqlArray) ToRocksetQueryLambdaSqlArrayOutput 

func (i RocksetQueryLambdaSqlArray) ToRocksetQueryLambdaSqlArrayOutput() RocksetQueryLambdaSqlArrayOutput

func (RocksetQueryLambdaSqlArray) ToRocksetQueryLambdaSqlArrayOutputWithContext 

func (i RocksetQueryLambdaSqlArray) ToRocksetQueryLambdaSqlArrayOutputWithContext(ctx context.Context) RocksetQueryLambdaSqlArrayOutput

type RocksetQueryLambdaSqlArrayInput 

type RocksetQueryLambdaSqlArrayInput interface {
	pulumi.Input

	ToRocksetQueryLambdaSqlArrayOutput() RocksetQueryLambdaSqlArrayOutput
	ToRocksetQueryLambdaSqlArrayOutputWithContext(context.Context) RocksetQueryLambdaSqlArrayOutput
}

RocksetQueryLambdaSqlArrayInput is an input type that accepts RocksetQueryLambdaSqlArray and RocksetQueryLambdaSqlArrayOutput values. You can construct a concrete instance of `RocksetQueryLambdaSqlArrayInput` via: 

RocksetQueryLambdaSqlArray{ RocksetQueryLambdaSqlArgs{...} }

type RocksetQueryLambdaSqlArrayOutput 

type RocksetQueryLambdaSqlArrayOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaSqlArrayOutput) ElementType 

func (RocksetQueryLambdaSqlArrayOutput) ElementType() reflect.Type

func (RocksetQueryLambdaSqlArrayOutput) Index 

func (o RocksetQueryLambdaSqlArrayOutput) Index(i pulumi.IntInput) RocksetQueryLambdaSqlOutput

func (RocksetQueryLambdaSqlArrayOutput) ToRocksetQueryLambdaSqlArrayOutput 

func (o RocksetQueryLambdaSqlArrayOutput) ToRocksetQueryLambdaSqlArrayOutput() RocksetQueryLambdaSqlArrayOutput

func (RocksetQueryLambdaSqlArrayOutput) ToRocksetQueryLambdaSqlArrayOutputWithContext 

func (o RocksetQueryLambdaSqlArrayOutput) ToRocksetQueryLambdaSqlArrayOutputWithContext(ctx context.Context) RocksetQueryLambdaSqlArrayOutput

type RocksetQueryLambdaSqlDefaultParameter 

type RocksetQueryLambdaSqlDefaultParameter struct {
	// Unique identifier for the query lambda. Can contain alphanumeric or dash characters.
	Name  string `pulumi:"name"`
	Type  string `pulumi:"type"`
	Value string `pulumi:"value"`
}

type RocksetQueryLambdaSqlDefaultParameterArgs 

type RocksetQueryLambdaSqlDefaultParameterArgs struct {
	// Unique identifier for the query lambda. Can contain alphanumeric or dash characters.
	Name  pulumi.StringInput `pulumi:"name"`
	Type  pulumi.StringInput `pulumi:"type"`
	Value pulumi.StringInput `pulumi:"value"`
}

func (RocksetQueryLambdaSqlDefaultParameterArgs) ElementType 

func (RocksetQueryLambdaSqlDefaultParameterArgs) ElementType() reflect.Type

func (RocksetQueryLambdaSqlDefaultParameterArgs) ToRocksetQueryLambdaSqlDefaultParameterOutput 

func (i RocksetQueryLambdaSqlDefaultParameterArgs) ToRocksetQueryLambdaSqlDefaultParameterOutput() RocksetQueryLambdaSqlDefaultParameterOutput

func (RocksetQueryLambdaSqlDefaultParameterArgs) ToRocksetQueryLambdaSqlDefaultParameterOutputWithContext 

func (i RocksetQueryLambdaSqlDefaultParameterArgs) ToRocksetQueryLambdaSqlDefaultParameterOutputWithContext(ctx context.Context) RocksetQueryLambdaSqlDefaultParameterOutput

type RocksetQueryLambdaSqlDefaultParameterArray 

type RocksetQueryLambdaSqlDefaultParameterArray []RocksetQueryLambdaSqlDefaultParameterInput

func (RocksetQueryLambdaSqlDefaultParameterArray) ElementType 

func (RocksetQueryLambdaSqlDefaultParameterArray) ElementType() reflect.Type

func (RocksetQueryLambdaSqlDefaultParameterArray) ToRocksetQueryLambdaSqlDefaultParameterArrayOutput 

func (i RocksetQueryLambdaSqlDefaultParameterArray) ToRocksetQueryLambdaSqlDefaultParameterArrayOutput() RocksetQueryLambdaSqlDefaultParameterArrayOutput

func (RocksetQueryLambdaSqlDefaultParameterArray) ToRocksetQueryLambdaSqlDefaultParameterArrayOutputWithContext 

func (i RocksetQueryLambdaSqlDefaultParameterArray) ToRocksetQueryLambdaSqlDefaultParameterArrayOutputWithContext(ctx context.Context) RocksetQueryLambdaSqlDefaultParameterArrayOutput

type RocksetQueryLambdaSqlDefaultParameterArrayInput 

type RocksetQueryLambdaSqlDefaultParameterArrayInput interface {
	pulumi.Input

	ToRocksetQueryLambdaSqlDefaultParameterArrayOutput() RocksetQueryLambdaSqlDefaultParameterArrayOutput
	ToRocksetQueryLambdaSqlDefaultParameterArrayOutputWithContext(context.Context) RocksetQueryLambdaSqlDefaultParameterArrayOutput
}

RocksetQueryLambdaSqlDefaultParameterArrayInput is an input type that accepts RocksetQueryLambdaSqlDefaultParameterArray and RocksetQueryLambdaSqlDefaultParameterArrayOutput values. You can construct a concrete instance of `RocksetQueryLambdaSqlDefaultParameterArrayInput` via: 

RocksetQueryLambdaSqlDefaultParameterArray{ RocksetQueryLambdaSqlDefaultParameterArgs{...} }

type RocksetQueryLambdaSqlDefaultParameterArrayOutput 

type RocksetQueryLambdaSqlDefaultParameterArrayOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaSqlDefaultParameterArrayOutput) ElementType 

func (RocksetQueryLambdaSqlDefaultParameterArrayOutput) ElementType() reflect.Type

func (RocksetQueryLambdaSqlDefaultParameterArrayOutput) Index 

func (o RocksetQueryLambdaSqlDefaultParameterArrayOutput) Index(i pulumi.IntInput) RocksetQueryLambdaSqlDefaultParameterOutput

func (RocksetQueryLambdaSqlDefaultParameterArrayOutput) ToRocksetQueryLambdaSqlDefaultParameterArrayOutput 

func (o RocksetQueryLambdaSqlDefaultParameterArrayOutput) ToRocksetQueryLambdaSqlDefaultParameterArrayOutput() RocksetQueryLambdaSqlDefaultParameterArrayOutput

func (RocksetQueryLambdaSqlDefaultParameterArrayOutput) ToRocksetQueryLambdaSqlDefaultParameterArrayOutputWithContext 

func (o RocksetQueryLambdaSqlDefaultParameterArrayOutput) ToRocksetQueryLambdaSqlDefaultParameterArrayOutputWithContext(ctx context.Context) RocksetQueryLambdaSqlDefaultParameterArrayOutput

type RocksetQueryLambdaSqlDefaultParameterInput 

type RocksetQueryLambdaSqlDefaultParameterInput interface {
	pulumi.Input

	ToRocksetQueryLambdaSqlDefaultParameterOutput() RocksetQueryLambdaSqlDefaultParameterOutput
	ToRocksetQueryLambdaSqlDefaultParameterOutputWithContext(context.Context) RocksetQueryLambdaSqlDefaultParameterOutput
}

RocksetQueryLambdaSqlDefaultParameterInput is an input type that accepts RocksetQueryLambdaSqlDefaultParameterArgs and RocksetQueryLambdaSqlDefaultParameterOutput values. You can construct a concrete instance of `RocksetQueryLambdaSqlDefaultParameterInput` via: 

RocksetQueryLambdaSqlDefaultParameterArgs{...}

type RocksetQueryLambdaSqlDefaultParameterOutput 

type RocksetQueryLambdaSqlDefaultParameterOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaSqlDefaultParameterOutput) ElementType 

func (RocksetQueryLambdaSqlDefaultParameterOutput) ElementType() reflect.Type

func (RocksetQueryLambdaSqlDefaultParameterOutput) Name 

func (o RocksetQueryLambdaSqlDefaultParameterOutput) Name() pulumi.StringOutput

Unique identifier for the query lambda. Can contain alphanumeric or dash characters.

func (RocksetQueryLambdaSqlDefaultParameterOutput) ToRocksetQueryLambdaSqlDefaultParameterOutput 

func (o RocksetQueryLambdaSqlDefaultParameterOutput) ToRocksetQueryLambdaSqlDefaultParameterOutput() RocksetQueryLambdaSqlDefaultParameterOutput

func (RocksetQueryLambdaSqlDefaultParameterOutput) ToRocksetQueryLambdaSqlDefaultParameterOutputWithContext 

func (o RocksetQueryLambdaSqlDefaultParameterOutput) ToRocksetQueryLambdaSqlDefaultParameterOutputWithContext(ctx context.Context) RocksetQueryLambdaSqlDefaultParameterOutput

func (RocksetQueryLambdaSqlDefaultParameterOutput) Type 

func (o RocksetQueryLambdaSqlDefaultParameterOutput) Type() pulumi.StringOutput

func (RocksetQueryLambdaSqlDefaultParameterOutput) Value 

func (o RocksetQueryLambdaSqlDefaultParameterOutput) Value() pulumi.StringOutput

type RocksetQueryLambdaSqlInput 

type RocksetQueryLambdaSqlInput interface {
	pulumi.Input

	ToRocksetQueryLambdaSqlOutput() RocksetQueryLambdaSqlOutput
	ToRocksetQueryLambdaSqlOutputWithContext(context.Context) RocksetQueryLambdaSqlOutput
}

RocksetQueryLambdaSqlInput is an input type that accepts RocksetQueryLambdaSqlArgs and RocksetQueryLambdaSqlOutput values. You can construct a concrete instance of `RocksetQueryLambdaSqlInput` via: 

RocksetQueryLambdaSqlArgs{...}

type RocksetQueryLambdaSqlOutput 

type RocksetQueryLambdaSqlOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaSqlOutput) DefaultParameters 

func (o RocksetQueryLambdaSqlOutput) DefaultParameters() RocksetQueryLambdaSqlDefaultParameterArrayOutput

func (RocksetQueryLambdaSqlOutput) ElementType 

func (RocksetQueryLambdaSqlOutput) ElementType() reflect.Type

func (RocksetQueryLambdaSqlOutput) Query 

func (o RocksetQueryLambdaSqlOutput) Query() pulumi.StringOutput

func (RocksetQueryLambdaSqlOutput) ToRocksetQueryLambdaSqlOutput 

func (o RocksetQueryLambdaSqlOutput) ToRocksetQueryLambdaSqlOutput() RocksetQueryLambdaSqlOutput

func (RocksetQueryLambdaSqlOutput) ToRocksetQueryLambdaSqlOutputWithContext 

func (o RocksetQueryLambdaSqlOutput) ToRocksetQueryLambdaSqlOutputWithContext(ctx context.Context) RocksetQueryLambdaSqlOutput

type RocksetQueryLambdaState 

type RocksetQueryLambdaState struct {
	// Text describing the query lambda.
	Description pulumi.StringPtrInput
	// Unique identifier for the query lambda. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	Sqls RocksetQueryLambdaSqlArrayInput
	// The latest state of this query lambda.
	State pulumi.StringPtrInput
	// The latest version string of this query lambda.
	Version pulumi.StringPtrInput
	// The name of the workspace.
	Workspace pulumi.StringPtrInput
}

func (RocksetQueryLambdaState) ElementType 

func (RocksetQueryLambdaState) ElementType() reflect.Type

type RocksetQueryLambdaTag 

type RocksetQueryLambdaTag struct {
	pulumi.CustomResourceState

	// Unique identifier for the tag. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Unique identifier for the query lambda. Can contain alphanumeric or dash characters.
	QueryLambda pulumi.StringOutput `pulumi:"queryLambda"`
	// Version of the query lambda this tag should point to.
	Version pulumi.StringOutput `pulumi:"version"`
	// The name of the workspace the query lambda is in.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a Rockset Query Lambda Tag.

func GetRocksetQueryLambdaTag 

func GetRocksetQueryLambdaTag(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetQueryLambdaTagState, opts ...pulumi.ResourceOption) (*RocksetQueryLambdaTag, error)

GetRocksetQueryLambdaTag gets an existing RocksetQueryLambdaTag 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 NewRocksetQueryLambdaTag 

func NewRocksetQueryLambdaTag(ctx *pulumi.Context,
	name string, args *RocksetQueryLambdaTagArgs, opts ...pulumi.ResourceOption) (*RocksetQueryLambdaTag, error)

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

func (*RocksetQueryLambdaTag) ElementType 

func (*RocksetQueryLambdaTag) ElementType() reflect.Type

func (*RocksetQueryLambdaTag) ToRocksetQueryLambdaTagOutput 

func (i *RocksetQueryLambdaTag) ToRocksetQueryLambdaTagOutput() RocksetQueryLambdaTagOutput

func (*RocksetQueryLambdaTag) ToRocksetQueryLambdaTagOutputWithContext 

func (i *RocksetQueryLambdaTag) ToRocksetQueryLambdaTagOutputWithContext(ctx context.Context) RocksetQueryLambdaTagOutput

type RocksetQueryLambdaTagArgs 

type RocksetQueryLambdaTagArgs struct {
	// Unique identifier for the tag. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Unique identifier for the query lambda. Can contain alphanumeric or dash characters.
	QueryLambda pulumi.StringInput
	// Version of the query lambda this tag should point to.
	Version pulumi.StringInput
	// The name of the workspace the query lambda is in.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetQueryLambdaTag resource.

func (RocksetQueryLambdaTagArgs) ElementType 

func (RocksetQueryLambdaTagArgs) ElementType() reflect.Type

type RocksetQueryLambdaTagArray 

type RocksetQueryLambdaTagArray []RocksetQueryLambdaTagInput

func (RocksetQueryLambdaTagArray) ElementType 

func (RocksetQueryLambdaTagArray) ElementType() reflect.Type

func (RocksetQueryLambdaTagArray) ToRocksetQueryLambdaTagArrayOutput 

func (i RocksetQueryLambdaTagArray) ToRocksetQueryLambdaTagArrayOutput() RocksetQueryLambdaTagArrayOutput

func (RocksetQueryLambdaTagArray) ToRocksetQueryLambdaTagArrayOutputWithContext 

func (i RocksetQueryLambdaTagArray) ToRocksetQueryLambdaTagArrayOutputWithContext(ctx context.Context) RocksetQueryLambdaTagArrayOutput

type RocksetQueryLambdaTagArrayInput 

type RocksetQueryLambdaTagArrayInput interface {
	pulumi.Input

	ToRocksetQueryLambdaTagArrayOutput() RocksetQueryLambdaTagArrayOutput
	ToRocksetQueryLambdaTagArrayOutputWithContext(context.Context) RocksetQueryLambdaTagArrayOutput
}

RocksetQueryLambdaTagArrayInput is an input type that accepts RocksetQueryLambdaTagArray and RocksetQueryLambdaTagArrayOutput values. You can construct a concrete instance of `RocksetQueryLambdaTagArrayInput` via: 

RocksetQueryLambdaTagArray{ RocksetQueryLambdaTagArgs{...} }

type RocksetQueryLambdaTagArrayOutput 

type RocksetQueryLambdaTagArrayOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaTagArrayOutput) ElementType 

func (RocksetQueryLambdaTagArrayOutput) ElementType() reflect.Type

func (RocksetQueryLambdaTagArrayOutput) Index 

func (o RocksetQueryLambdaTagArrayOutput) Index(i pulumi.IntInput) RocksetQueryLambdaTagOutput

func (RocksetQueryLambdaTagArrayOutput) ToRocksetQueryLambdaTagArrayOutput 

func (o RocksetQueryLambdaTagArrayOutput) ToRocksetQueryLambdaTagArrayOutput() RocksetQueryLambdaTagArrayOutput

func (RocksetQueryLambdaTagArrayOutput) ToRocksetQueryLambdaTagArrayOutputWithContext 

func (o RocksetQueryLambdaTagArrayOutput) ToRocksetQueryLambdaTagArrayOutputWithContext(ctx context.Context) RocksetQueryLambdaTagArrayOutput

type RocksetQueryLambdaTagInput 

type RocksetQueryLambdaTagInput interface {
	pulumi.Input

	ToRocksetQueryLambdaTagOutput() RocksetQueryLambdaTagOutput
	ToRocksetQueryLambdaTagOutputWithContext(ctx context.Context) RocksetQueryLambdaTagOutput
}

type RocksetQueryLambdaTagMap 

type RocksetQueryLambdaTagMap map[string]RocksetQueryLambdaTagInput

func (RocksetQueryLambdaTagMap) ElementType 

func (RocksetQueryLambdaTagMap) ElementType() reflect.Type

func (RocksetQueryLambdaTagMap) ToRocksetQueryLambdaTagMapOutput 

func (i RocksetQueryLambdaTagMap) ToRocksetQueryLambdaTagMapOutput() RocksetQueryLambdaTagMapOutput

func (RocksetQueryLambdaTagMap) ToRocksetQueryLambdaTagMapOutputWithContext 

func (i RocksetQueryLambdaTagMap) ToRocksetQueryLambdaTagMapOutputWithContext(ctx context.Context) RocksetQueryLambdaTagMapOutput

type RocksetQueryLambdaTagMapInput 

type RocksetQueryLambdaTagMapInput interface {
	pulumi.Input

	ToRocksetQueryLambdaTagMapOutput() RocksetQueryLambdaTagMapOutput
	ToRocksetQueryLambdaTagMapOutputWithContext(context.Context) RocksetQueryLambdaTagMapOutput
}

RocksetQueryLambdaTagMapInput is an input type that accepts RocksetQueryLambdaTagMap and RocksetQueryLambdaTagMapOutput values. You can construct a concrete instance of `RocksetQueryLambdaTagMapInput` via: 

RocksetQueryLambdaTagMap{ "key": RocksetQueryLambdaTagArgs{...} }

type RocksetQueryLambdaTagMapOutput 

type RocksetQueryLambdaTagMapOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaTagMapOutput) ElementType 

func (RocksetQueryLambdaTagMapOutput) ElementType() reflect.Type

func (RocksetQueryLambdaTagMapOutput) MapIndex 

func (o RocksetQueryLambdaTagMapOutput) MapIndex(k pulumi.StringInput) RocksetQueryLambdaTagOutput

func (RocksetQueryLambdaTagMapOutput) ToRocksetQueryLambdaTagMapOutput 

func (o RocksetQueryLambdaTagMapOutput) ToRocksetQueryLambdaTagMapOutput() RocksetQueryLambdaTagMapOutput

func (RocksetQueryLambdaTagMapOutput) ToRocksetQueryLambdaTagMapOutputWithContext 

func (o RocksetQueryLambdaTagMapOutput) ToRocksetQueryLambdaTagMapOutputWithContext(ctx context.Context) RocksetQueryLambdaTagMapOutput

type RocksetQueryLambdaTagOutput 

type RocksetQueryLambdaTagOutput struct{ *pulumi.OutputState }

func (RocksetQueryLambdaTagOutput) ElementType 

func (RocksetQueryLambdaTagOutput) ElementType() reflect.Type

func (RocksetQueryLambdaTagOutput) Name 

func (o RocksetQueryLambdaTagOutput) Name() pulumi.StringOutput

Unique identifier for the tag. Can contain alphanumeric or dash characters.

func (RocksetQueryLambdaTagOutput) QueryLambda 

func (o RocksetQueryLambdaTagOutput) QueryLambda() pulumi.StringOutput

Unique identifier for the query lambda. Can contain alphanumeric or dash characters.

func (RocksetQueryLambdaTagOutput) ToRocksetQueryLambdaTagOutput 

func (o RocksetQueryLambdaTagOutput) ToRocksetQueryLambdaTagOutput() RocksetQueryLambdaTagOutput

func (RocksetQueryLambdaTagOutput) ToRocksetQueryLambdaTagOutputWithContext 

func (o RocksetQueryLambdaTagOutput) ToRocksetQueryLambdaTagOutputWithContext(ctx context.Context) RocksetQueryLambdaTagOutput

func (RocksetQueryLambdaTagOutput) Version 

func (o RocksetQueryLambdaTagOutput) Version() pulumi.StringOutput

Version of the query lambda this tag should point to.

func (RocksetQueryLambdaTagOutput) Workspace 

func (o RocksetQueryLambdaTagOutput) Workspace() pulumi.StringOutput

The name of the workspace the query lambda is in.

type RocksetQueryLambdaTagState 

type RocksetQueryLambdaTagState struct {
	// Unique identifier for the tag. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Unique identifier for the query lambda. Can contain alphanumeric or dash characters.
	QueryLambda pulumi.StringPtrInput
	// Version of the query lambda this tag should point to.
	Version pulumi.StringPtrInput
	// The name of the workspace the query lambda is in.
	Workspace pulumi.StringPtrInput
}

func (RocksetQueryLambdaTagState) ElementType 

func (RocksetQueryLambdaTagState) ElementType() reflect.Type

type RocksetRole 

type RocksetRole struct {
	pulumi.CustomResourceState

	// When the role was created.
	CreatedAt pulumi.StringOutput `pulumi:"createdAt"`
	// Who created the role.
	CreatedBy pulumi.StringOutput `pulumi:"createdBy"`
	// Role description.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Role name.
	Name pulumi.StringOutput `pulumi:"name"`
	// The email of the user who currently owns the role.
	OwnerEmail pulumi.StringOutput `pulumi:"ownerEmail"`
	// Privileges associated with the role. For a full list see [API documentation](https://rockset.com/docs/iam/#supported-privileges)
	Privileges RocksetRolePrivilegeArrayOutput `pulumi:"privileges"`
}

Manages a Rockset [Role](https://rockset.com/docs/iam/).

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/thomascollett/pulumi-rockset/sdk/go/rockset"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := rockset.NewRocksetRole(ctx, "query-onlyRocksetRole", &rockset.RocksetRoleArgs{
			Description: pulumi.String("This role can only query collections in the prod workspace in the usw2a1 cluster"),
			Privileges: rockset.RocksetRolePrivilegeArray{
				&rockset.RocksetRolePrivilegeArgs{
					Action:       pulumi.String("QUERY_DATA_WS"),
					ResourceName: pulumi.String("prod"),
					Cluster:      pulumi.String("usw2a1"),
				},
				&rockset.RocksetRolePrivilegeArgs{
					Action:       pulumi.String("EXECUTE_QUERY_LAMBDA_WS"),
					ResourceName: pulumi.String("prod"),
					Cluster:      pulumi.String("usw2a1"),
				},
			},
		})
		if err != nil {
			return err
		}
		_, err = rockset.NewRocksetApiKey(ctx, "query-onlyRocksetApiKey", &rockset.RocksetApiKeyArgs{
			Role: query_onlyRocksetRole.Name,
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetRocksetRole 

func GetRocksetRole(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetRoleState, opts ...pulumi.ResourceOption) (*RocksetRole, error)

GetRocksetRole gets an existing RocksetRole 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 NewRocksetRole 

func NewRocksetRole(ctx *pulumi.Context,
	name string, args *RocksetRoleArgs, opts ...pulumi.ResourceOption) (*RocksetRole, error)

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

func (*RocksetRole) ElementType 

func (*RocksetRole) ElementType() reflect.Type

func (*RocksetRole) ToRocksetRoleOutput 

func (i *RocksetRole) ToRocksetRoleOutput() RocksetRoleOutput

func (*RocksetRole) ToRocksetRoleOutputWithContext 

func (i *RocksetRole) ToRocksetRoleOutputWithContext(ctx context.Context) RocksetRoleOutput

type RocksetRoleArgs 

type RocksetRoleArgs struct {
	// Role description.
	Description pulumi.StringPtrInput
	// Role name.
	Name pulumi.StringPtrInput
	// Privileges associated with the role. For a full list see [API documentation](https://rockset.com/docs/iam/#supported-privileges)
	Privileges RocksetRolePrivilegeArrayInput
}

The set of arguments for constructing a RocksetRole resource.

func (RocksetRoleArgs) ElementType 

func (RocksetRoleArgs) ElementType() reflect.Type

type RocksetRoleArray 

type RocksetRoleArray []RocksetRoleInput

func (RocksetRoleArray) ElementType 

func (RocksetRoleArray) ElementType() reflect.Type

func (RocksetRoleArray) ToRocksetRoleArrayOutput 

func (i RocksetRoleArray) ToRocksetRoleArrayOutput() RocksetRoleArrayOutput

func (RocksetRoleArray) ToRocksetRoleArrayOutputWithContext 

func (i RocksetRoleArray) ToRocksetRoleArrayOutputWithContext(ctx context.Context) RocksetRoleArrayOutput

type RocksetRoleArrayInput 

type RocksetRoleArrayInput interface {
	pulumi.Input

	ToRocksetRoleArrayOutput() RocksetRoleArrayOutput
	ToRocksetRoleArrayOutputWithContext(context.Context) RocksetRoleArrayOutput
}

RocksetRoleArrayInput is an input type that accepts RocksetRoleArray and RocksetRoleArrayOutput values. You can construct a concrete instance of `RocksetRoleArrayInput` via: 

RocksetRoleArray{ RocksetRoleArgs{...} }

type RocksetRoleArrayOutput 

type RocksetRoleArrayOutput struct{ *pulumi.OutputState }

func (RocksetRoleArrayOutput) ElementType 

func (RocksetRoleArrayOutput) ElementType() reflect.Type

func (RocksetRoleArrayOutput) Index 

func (o RocksetRoleArrayOutput) Index(i pulumi.IntInput) RocksetRoleOutput

func (RocksetRoleArrayOutput) ToRocksetRoleArrayOutput 

func (o RocksetRoleArrayOutput) ToRocksetRoleArrayOutput() RocksetRoleArrayOutput

func (RocksetRoleArrayOutput) ToRocksetRoleArrayOutputWithContext 

func (o RocksetRoleArrayOutput) ToRocksetRoleArrayOutputWithContext(ctx context.Context) RocksetRoleArrayOutput

type RocksetRoleInput 

type RocksetRoleInput interface {
	pulumi.Input

	ToRocksetRoleOutput() RocksetRoleOutput
	ToRocksetRoleOutputWithContext(ctx context.Context) RocksetRoleOutput
}

type RocksetRoleMap 

type RocksetRoleMap map[string]RocksetRoleInput

func (RocksetRoleMap) ElementType 

func (RocksetRoleMap) ElementType() reflect.Type

func (RocksetRoleMap) ToRocksetRoleMapOutput 

func (i RocksetRoleMap) ToRocksetRoleMapOutput() RocksetRoleMapOutput

func (RocksetRoleMap) ToRocksetRoleMapOutputWithContext 

func (i RocksetRoleMap) ToRocksetRoleMapOutputWithContext(ctx context.Context) RocksetRoleMapOutput

type RocksetRoleMapInput 

type RocksetRoleMapInput interface {
	pulumi.Input

	ToRocksetRoleMapOutput() RocksetRoleMapOutput
	ToRocksetRoleMapOutputWithContext(context.Context) RocksetRoleMapOutput
}

RocksetRoleMapInput is an input type that accepts RocksetRoleMap and RocksetRoleMapOutput values. You can construct a concrete instance of `RocksetRoleMapInput` via: 

RocksetRoleMap{ "key": RocksetRoleArgs{...} }

type RocksetRoleMapOutput 

type RocksetRoleMapOutput struct{ *pulumi.OutputState }

func (RocksetRoleMapOutput) ElementType 

func (RocksetRoleMapOutput) ElementType() reflect.Type

func (RocksetRoleMapOutput) MapIndex 

func (o RocksetRoleMapOutput) MapIndex(k pulumi.StringInput) RocksetRoleOutput

func (RocksetRoleMapOutput) ToRocksetRoleMapOutput 

func (o RocksetRoleMapOutput) ToRocksetRoleMapOutput() RocksetRoleMapOutput

func (RocksetRoleMapOutput) ToRocksetRoleMapOutputWithContext 

func (o RocksetRoleMapOutput) ToRocksetRoleMapOutputWithContext(ctx context.Context) RocksetRoleMapOutput

type RocksetRoleOutput 

type RocksetRoleOutput struct{ *pulumi.OutputState }

func (RocksetRoleOutput) CreatedAt 

func (o RocksetRoleOutput) CreatedAt() pulumi.StringOutput

When the role was created.

func (RocksetRoleOutput) CreatedBy 

func (o RocksetRoleOutput) CreatedBy() pulumi.StringOutput

Who created the role.

func (RocksetRoleOutput) Description 

func (o RocksetRoleOutput) Description() pulumi.StringPtrOutput

Role description.

func (RocksetRoleOutput) ElementType 

func (RocksetRoleOutput) ElementType() reflect.Type

func (RocksetRoleOutput) Name 

func (o RocksetRoleOutput) Name() pulumi.StringOutput

Role name.

func (RocksetRoleOutput) OwnerEmail 

func (o RocksetRoleOutput) OwnerEmail() pulumi.StringOutput

The email of the user who currently owns the role.

func (RocksetRoleOutput) Privileges 

func (o RocksetRoleOutput) Privileges() RocksetRolePrivilegeArrayOutput

Privileges associated with the role. For a full list see [API documentation](https://rockset.com/docs/iam/#supported-privileges)

func (RocksetRoleOutput) ToRocksetRoleOutput 

func (o RocksetRoleOutput) ToRocksetRoleOutput() RocksetRoleOutput

func (RocksetRoleOutput) ToRocksetRoleOutputWithContext 

func (o RocksetRoleOutput) ToRocksetRoleOutputWithContext(ctx context.Context) RocksetRoleOutput

type RocksetRolePrivilege 

type RocksetRolePrivilege struct {
	// The action allowed by this privilege.
	Action string `pulumi:"action"`
	// Rockset cluster ID for which this action is allowed. Only valid for Workspace actions. Use '*ALL*' for actions which apply to all clusters.
	Cluster *string `pulumi:"cluster"`
	// The resource on which this action is allowed. Defaults to 'All' if not specified.
	ResourceName *string `pulumi:"resourceName"`
}

type RocksetRolePrivilegeArgs 

type RocksetRolePrivilegeArgs struct {
	// The action allowed by this privilege.
	Action pulumi.StringInput `pulumi:"action"`
	// Rockset cluster ID for which this action is allowed. Only valid for Workspace actions. Use '*ALL*' for actions which apply to all clusters.
	Cluster pulumi.StringPtrInput `pulumi:"cluster"`
	// The resource on which this action is allowed. Defaults to 'All' if not specified.
	ResourceName pulumi.StringPtrInput `pulumi:"resourceName"`
}

func (RocksetRolePrivilegeArgs) ElementType 

func (RocksetRolePrivilegeArgs) ElementType() reflect.Type

func (RocksetRolePrivilegeArgs) ToRocksetRolePrivilegeOutput 

func (i RocksetRolePrivilegeArgs) ToRocksetRolePrivilegeOutput() RocksetRolePrivilegeOutput

func (RocksetRolePrivilegeArgs) ToRocksetRolePrivilegeOutputWithContext 

func (i RocksetRolePrivilegeArgs) ToRocksetRolePrivilegeOutputWithContext(ctx context.Context) RocksetRolePrivilegeOutput

type RocksetRolePrivilegeArray 

type RocksetRolePrivilegeArray []RocksetRolePrivilegeInput

func (RocksetRolePrivilegeArray) ElementType 

func (RocksetRolePrivilegeArray) ElementType() reflect.Type

func (RocksetRolePrivilegeArray) ToRocksetRolePrivilegeArrayOutput 

func (i RocksetRolePrivilegeArray) ToRocksetRolePrivilegeArrayOutput() RocksetRolePrivilegeArrayOutput

func (RocksetRolePrivilegeArray) ToRocksetRolePrivilegeArrayOutputWithContext 

func (i RocksetRolePrivilegeArray) ToRocksetRolePrivilegeArrayOutputWithContext(ctx context.Context) RocksetRolePrivilegeArrayOutput

type RocksetRolePrivilegeArrayInput 

type RocksetRolePrivilegeArrayInput interface {
	pulumi.Input

	ToRocksetRolePrivilegeArrayOutput() RocksetRolePrivilegeArrayOutput
	ToRocksetRolePrivilegeArrayOutputWithContext(context.Context) RocksetRolePrivilegeArrayOutput
}

RocksetRolePrivilegeArrayInput is an input type that accepts RocksetRolePrivilegeArray and RocksetRolePrivilegeArrayOutput values. You can construct a concrete instance of `RocksetRolePrivilegeArrayInput` via: 

RocksetRolePrivilegeArray{ RocksetRolePrivilegeArgs{...} }

type RocksetRolePrivilegeArrayOutput 

type RocksetRolePrivilegeArrayOutput struct{ *pulumi.OutputState }

func (RocksetRolePrivilegeArrayOutput) ElementType 

func (RocksetRolePrivilegeArrayOutput) ElementType() reflect.Type

func (RocksetRolePrivilegeArrayOutput) Index 

func (o RocksetRolePrivilegeArrayOutput) Index(i pulumi.IntInput) RocksetRolePrivilegeOutput

func (RocksetRolePrivilegeArrayOutput) ToRocksetRolePrivilegeArrayOutput 

func (o RocksetRolePrivilegeArrayOutput) ToRocksetRolePrivilegeArrayOutput() RocksetRolePrivilegeArrayOutput

func (RocksetRolePrivilegeArrayOutput) ToRocksetRolePrivilegeArrayOutputWithContext 

func (o RocksetRolePrivilegeArrayOutput) ToRocksetRolePrivilegeArrayOutputWithContext(ctx context.Context) RocksetRolePrivilegeArrayOutput

type RocksetRolePrivilegeInput 

type RocksetRolePrivilegeInput interface {
	pulumi.Input

	ToRocksetRolePrivilegeOutput() RocksetRolePrivilegeOutput
	ToRocksetRolePrivilegeOutputWithContext(context.Context) RocksetRolePrivilegeOutput
}

RocksetRolePrivilegeInput is an input type that accepts RocksetRolePrivilegeArgs and RocksetRolePrivilegeOutput values. You can construct a concrete instance of `RocksetRolePrivilegeInput` via: 

RocksetRolePrivilegeArgs{...}

type RocksetRolePrivilegeOutput 

type RocksetRolePrivilegeOutput struct{ *pulumi.OutputState }

func (RocksetRolePrivilegeOutput) Action 

func (o RocksetRolePrivilegeOutput) Action() pulumi.StringOutput

The action allowed by this privilege.

func (RocksetRolePrivilegeOutput) Cluster 

func (o RocksetRolePrivilegeOutput) Cluster() pulumi.StringPtrOutput

Rockset cluster ID for which this action is allowed. Only valid for Workspace actions. Use '*ALL*' for actions which apply to all clusters.

func (RocksetRolePrivilegeOutput) ElementType 

func (RocksetRolePrivilegeOutput) ElementType() reflect.Type

func (RocksetRolePrivilegeOutput) ResourceName 

func (o RocksetRolePrivilegeOutput) ResourceName() pulumi.StringPtrOutput

The resource on which this action is allowed. Defaults to 'All' if not specified.

func (RocksetRolePrivilegeOutput) ToRocksetRolePrivilegeOutput 

func (o RocksetRolePrivilegeOutput) ToRocksetRolePrivilegeOutput() RocksetRolePrivilegeOutput

func (RocksetRolePrivilegeOutput) ToRocksetRolePrivilegeOutputWithContext 

func (o RocksetRolePrivilegeOutput) ToRocksetRolePrivilegeOutputWithContext(ctx context.Context) RocksetRolePrivilegeOutput

type RocksetRoleState 

type RocksetRoleState struct {
	// When the role was created.
	CreatedAt pulumi.StringPtrInput
	// Who created the role.
	CreatedBy pulumi.StringPtrInput
	// Role description.
	Description pulumi.StringPtrInput
	// Role name.
	Name pulumi.StringPtrInput
	// The email of the user who currently owns the role.
	OwnerEmail pulumi.StringPtrInput
	// Privileges associated with the role. For a full list see [API documentation](https://rockset.com/docs/iam/#supported-privileges)
	Privileges RocksetRolePrivilegeArrayInput
}

func (RocksetRoleState) ElementType 

func (RocksetRoleState) ElementType() reflect.Type

type RocksetS3Collection 

type RocksetS3Collection struct {
	pulumi.CustomResourceState

	// Text describing the collection.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrOutput `pulumi:"fieldMappingQuery"`
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrOutput `pulumi:"ingestTransformation"`
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrOutput `pulumi:"retentionSecs"`
	// Defines a source for this collection.
	Sources RocksetS3CollectionSourceArrayOutput `pulumi:"sources"`
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrOutput `pulumi:"waitForCollection"`
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrOutput `pulumi:"waitForDocuments"`
	// The name of the workspace.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a collection with on or more S3 sources attached. Uses an S3 integration to access the S3 bucket. If no integration is provided, only data in public buckets are accessible.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/thomascollett/pulumi-rockset/sdk/go/rockset"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		sample, err := rockset.NewRocksetWorkspace(ctx, "sample", &rockset.RocksetWorkspaceArgs{
			Description: pulumi.String("sample datasets"),
		})
		if err != nil {
			return err
		}
		public, err := rockset.NewRocksetS3Integration(ctx, "public", &rockset.RocksetS3IntegrationArgs{
			Description: pulumi.String("Integration to access Rockset's public datasets"),
			AwsRoleArn:  pulumi.String("arn:aws:iam::469279130686:role/rockset-public-datasets"),
		})
		if err != nil {
			return err
		}
		_, err = rockset.NewRocksetS3Collection(ctx, "cities", &rockset.RocksetS3CollectionArgs{
			Workspace: sample.Name,
			Sources: rockset.RocksetS3CollectionSourceArray{
				&rockset.RocksetS3CollectionSourceArgs{
					Bucket:          pulumi.String("rockset-public-datasets"),
					IntegrationName: public.Name,
					Pattern:         pulumi.String("cities/*.json"),
					Format:          pulumi.String("json"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetRocksetS3Collection 

func GetRocksetS3Collection(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetS3CollectionState, opts ...pulumi.ResourceOption) (*RocksetS3Collection, error)

GetRocksetS3Collection gets an existing RocksetS3Collection 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 NewRocksetS3Collection 

func NewRocksetS3Collection(ctx *pulumi.Context,
	name string, args *RocksetS3CollectionArgs, opts ...pulumi.ResourceOption) (*RocksetS3Collection, error)

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

func (*RocksetS3Collection) ElementType 

func (*RocksetS3Collection) ElementType() reflect.Type

func (*RocksetS3Collection) ToRocksetS3CollectionOutput 

func (i *RocksetS3Collection) ToRocksetS3CollectionOutput() RocksetS3CollectionOutput

func (*RocksetS3Collection) ToRocksetS3CollectionOutputWithContext 

func (i *RocksetS3Collection) ToRocksetS3CollectionOutputWithContext(ctx context.Context) RocksetS3CollectionOutput

type RocksetS3CollectionArgs 

type RocksetS3CollectionArgs struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetS3CollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetS3Collection resource.

func (RocksetS3CollectionArgs) ElementType 

func (RocksetS3CollectionArgs) ElementType() reflect.Type

type RocksetS3CollectionArray 

type RocksetS3CollectionArray []RocksetS3CollectionInput

func (RocksetS3CollectionArray) ElementType 

func (RocksetS3CollectionArray) ElementType() reflect.Type

func (RocksetS3CollectionArray) ToRocksetS3CollectionArrayOutput 

func (i RocksetS3CollectionArray) ToRocksetS3CollectionArrayOutput() RocksetS3CollectionArrayOutput

func (RocksetS3CollectionArray) ToRocksetS3CollectionArrayOutputWithContext 

func (i RocksetS3CollectionArray) ToRocksetS3CollectionArrayOutputWithContext(ctx context.Context) RocksetS3CollectionArrayOutput

type RocksetS3CollectionArrayInput 

type RocksetS3CollectionArrayInput interface {
	pulumi.Input

	ToRocksetS3CollectionArrayOutput() RocksetS3CollectionArrayOutput
	ToRocksetS3CollectionArrayOutputWithContext(context.Context) RocksetS3CollectionArrayOutput
}

RocksetS3CollectionArrayInput is an input type that accepts RocksetS3CollectionArray and RocksetS3CollectionArrayOutput values. You can construct a concrete instance of `RocksetS3CollectionArrayInput` via: 

RocksetS3CollectionArray{ RocksetS3CollectionArgs{...} }

type RocksetS3CollectionArrayOutput 

type RocksetS3CollectionArrayOutput struct{ *pulumi.OutputState }

func (RocksetS3CollectionArrayOutput) ElementType 

func (RocksetS3CollectionArrayOutput) ElementType() reflect.Type

func (RocksetS3CollectionArrayOutput) Index 

func (o RocksetS3CollectionArrayOutput) Index(i pulumi.IntInput) RocksetS3CollectionOutput

func (RocksetS3CollectionArrayOutput) ToRocksetS3CollectionArrayOutput 

func (o RocksetS3CollectionArrayOutput) ToRocksetS3CollectionArrayOutput() RocksetS3CollectionArrayOutput

func (RocksetS3CollectionArrayOutput) ToRocksetS3CollectionArrayOutputWithContext 

func (o RocksetS3CollectionArrayOutput) ToRocksetS3CollectionArrayOutputWithContext(ctx context.Context) RocksetS3CollectionArrayOutput

type RocksetS3CollectionInput 

type RocksetS3CollectionInput interface {
	pulumi.Input

	ToRocksetS3CollectionOutput() RocksetS3CollectionOutput
	ToRocksetS3CollectionOutputWithContext(ctx context.Context) RocksetS3CollectionOutput
}

type RocksetS3CollectionMap 

type RocksetS3CollectionMap map[string]RocksetS3CollectionInput

func (RocksetS3CollectionMap) ElementType 

func (RocksetS3CollectionMap) ElementType() reflect.Type

func (RocksetS3CollectionMap) ToRocksetS3CollectionMapOutput 

func (i RocksetS3CollectionMap) ToRocksetS3CollectionMapOutput() RocksetS3CollectionMapOutput

func (RocksetS3CollectionMap) ToRocksetS3CollectionMapOutputWithContext 

func (i RocksetS3CollectionMap) ToRocksetS3CollectionMapOutputWithContext(ctx context.Context) RocksetS3CollectionMapOutput

type RocksetS3CollectionMapInput 

type RocksetS3CollectionMapInput interface {
	pulumi.Input

	ToRocksetS3CollectionMapOutput() RocksetS3CollectionMapOutput
	ToRocksetS3CollectionMapOutputWithContext(context.Context) RocksetS3CollectionMapOutput
}

RocksetS3CollectionMapInput is an input type that accepts RocksetS3CollectionMap and RocksetS3CollectionMapOutput values. You can construct a concrete instance of `RocksetS3CollectionMapInput` via: 

RocksetS3CollectionMap{ "key": RocksetS3CollectionArgs{...} }

type RocksetS3CollectionMapOutput 

type RocksetS3CollectionMapOutput struct{ *pulumi.OutputState }

func (RocksetS3CollectionMapOutput) ElementType 

func (RocksetS3CollectionMapOutput) ElementType() reflect.Type

func (RocksetS3CollectionMapOutput) MapIndex 

func (o RocksetS3CollectionMapOutput) MapIndex(k pulumi.StringInput) RocksetS3CollectionOutput

func (RocksetS3CollectionMapOutput) ToRocksetS3CollectionMapOutput 

func (o RocksetS3CollectionMapOutput) ToRocksetS3CollectionMapOutput() RocksetS3CollectionMapOutput

func (RocksetS3CollectionMapOutput) ToRocksetS3CollectionMapOutputWithContext 

func (o RocksetS3CollectionMapOutput) ToRocksetS3CollectionMapOutputWithContext(ctx context.Context) RocksetS3CollectionMapOutput

type RocksetS3CollectionOutput 

type RocksetS3CollectionOutput struct{ *pulumi.OutputState }

func (RocksetS3CollectionOutput) Description 

func (o RocksetS3CollectionOutput) Description() pulumi.StringPtrOutput

Text describing the collection.

func (RocksetS3CollectionOutput) ElementType 

func (RocksetS3CollectionOutput) ElementType() reflect.Type

func (RocksetS3CollectionOutput) FieldMappingQuery deprecated 

func (o RocksetS3CollectionOutput) FieldMappingQuery() pulumi.StringPtrOutput

**Deprecated** use ingestTransformation instead

Deprecated: Use ingest_transformation instead

func (RocksetS3CollectionOutput) IngestTransformation 

func (o RocksetS3CollectionOutput) IngestTransformation() pulumi.StringPtrOutput

Ingest transformation SQL query. Turns the collection into insertOnly mode.

func (RocksetS3CollectionOutput) Name 

func (o RocksetS3CollectionOutput) Name() pulumi.StringOutput

Unique identifier for the collection. Can contain alphanumeric or dash characters.

func (RocksetS3CollectionOutput) RetentionSecs 

func (o RocksetS3CollectionOutput) RetentionSecs() pulumi.IntPtrOutput

Number of seconds after which data is purged. Based on event time.

func (RocksetS3CollectionOutput) Sources 

func (o RocksetS3CollectionOutput) Sources() RocksetS3CollectionSourceArrayOutput

Defines a source for this collection.

func (RocksetS3CollectionOutput) ToRocksetS3CollectionOutput 

func (o RocksetS3CollectionOutput) ToRocksetS3CollectionOutput() RocksetS3CollectionOutput

func (RocksetS3CollectionOutput) ToRocksetS3CollectionOutputWithContext 

func (o RocksetS3CollectionOutput) ToRocksetS3CollectionOutputWithContext(ctx context.Context) RocksetS3CollectionOutput

func (RocksetS3CollectionOutput) WaitForCollection 

func (o RocksetS3CollectionOutput) WaitForCollection() pulumi.BoolPtrOutput

Wait until the collection is ready.

func (RocksetS3CollectionOutput) WaitForDocuments 

func (o RocksetS3CollectionOutput) WaitForDocuments() pulumi.IntPtrOutput

Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.

func (RocksetS3CollectionOutput) Workspace 

func (o RocksetS3CollectionOutput) Workspace() pulumi.StringOutput

The name of the workspace.

type RocksetS3CollectionSource 

type RocksetS3CollectionSource struct {
	// S3 bucket containing the target data.
	Bucket string                        `pulumi:"bucket"`
	Csv    *RocksetS3CollectionSourceCsv `pulumi:"csv"`
	// Format of the data. One of: json, csv, xml. xml and csv blocks can only be set for their respective formats.
	Format string `pulumi:"format"`
	// The name of the Rockset S3 integration. If no S3 integration is provided only data in public S3 buckets are accessible.
	IntegrationName string `pulumi:"integrationName"`
	// Regex path pattern to S3 keys.
	Pattern *string `pulumi:"pattern"`
	// Simple path prefix to S3 keys.
	//
	// Deprecated: use pattern instead
	Prefix *string                       `pulumi:"prefix"`
	Xml    *RocksetS3CollectionSourceXml `pulumi:"xml"`
}

type RocksetS3CollectionSourceArgs 

type RocksetS3CollectionSourceArgs struct {
	// S3 bucket containing the target data.
	Bucket pulumi.StringInput                   `pulumi:"bucket"`
	Csv    RocksetS3CollectionSourceCsvPtrInput `pulumi:"csv"`
	// Format of the data. One of: json, csv, xml. xml and csv blocks can only be set for their respective formats.
	Format pulumi.StringInput `pulumi:"format"`
	// The name of the Rockset S3 integration. If no S3 integration is provided only data in public S3 buckets are accessible.
	IntegrationName pulumi.StringInput `pulumi:"integrationName"`
	// Regex path pattern to S3 keys.
	Pattern pulumi.StringPtrInput `pulumi:"pattern"`
	// Simple path prefix to S3 keys.
	//
	// Deprecated: use pattern instead
	Prefix pulumi.StringPtrInput                `pulumi:"prefix"`
	Xml    RocksetS3CollectionSourceXmlPtrInput `pulumi:"xml"`
}

func (RocksetS3CollectionSourceArgs) ElementType 

func (RocksetS3CollectionSourceArgs) ElementType() reflect.Type

func (RocksetS3CollectionSourceArgs) ToRocksetS3CollectionSourceOutput 

func (i RocksetS3CollectionSourceArgs) ToRocksetS3CollectionSourceOutput() RocksetS3CollectionSourceOutput

func (RocksetS3CollectionSourceArgs) ToRocksetS3CollectionSourceOutputWithContext 

func (i RocksetS3CollectionSourceArgs) ToRocksetS3CollectionSourceOutputWithContext(ctx context.Context) RocksetS3CollectionSourceOutput

type RocksetS3CollectionSourceArray 

type RocksetS3CollectionSourceArray []RocksetS3CollectionSourceInput

func (RocksetS3CollectionSourceArray) ElementType 

func (RocksetS3CollectionSourceArray) ElementType() reflect.Type

func (RocksetS3CollectionSourceArray) ToRocksetS3CollectionSourceArrayOutput 

func (i RocksetS3CollectionSourceArray) ToRocksetS3CollectionSourceArrayOutput() RocksetS3CollectionSourceArrayOutput

func (RocksetS3CollectionSourceArray) ToRocksetS3CollectionSourceArrayOutputWithContext 

func (i RocksetS3CollectionSourceArray) ToRocksetS3CollectionSourceArrayOutputWithContext(ctx context.Context) RocksetS3CollectionSourceArrayOutput

type RocksetS3CollectionSourceArrayInput 

type RocksetS3CollectionSourceArrayInput interface {
	pulumi.Input

	ToRocksetS3CollectionSourceArrayOutput() RocksetS3CollectionSourceArrayOutput
	ToRocksetS3CollectionSourceArrayOutputWithContext(context.Context) RocksetS3CollectionSourceArrayOutput
}

RocksetS3CollectionSourceArrayInput is an input type that accepts RocksetS3CollectionSourceArray and RocksetS3CollectionSourceArrayOutput values. You can construct a concrete instance of `RocksetS3CollectionSourceArrayInput` via: 

RocksetS3CollectionSourceArray{ RocksetS3CollectionSourceArgs{...} }

type RocksetS3CollectionSourceArrayOutput 

type RocksetS3CollectionSourceArrayOutput struct{ *pulumi.OutputState }

func (RocksetS3CollectionSourceArrayOutput) ElementType 

func (RocksetS3CollectionSourceArrayOutput) ElementType() reflect.Type

func (RocksetS3CollectionSourceArrayOutput) Index 

func (o RocksetS3CollectionSourceArrayOutput) Index(i pulumi.IntInput) RocksetS3CollectionSourceOutput

func (RocksetS3CollectionSourceArrayOutput) ToRocksetS3CollectionSourceArrayOutput 

func (o RocksetS3CollectionSourceArrayOutput) ToRocksetS3CollectionSourceArrayOutput() RocksetS3CollectionSourceArrayOutput

func (RocksetS3CollectionSourceArrayOutput) ToRocksetS3CollectionSourceArrayOutputWithContext 

func (o RocksetS3CollectionSourceArrayOutput) ToRocksetS3CollectionSourceArrayOutputWithContext(ctx context.Context) RocksetS3CollectionSourceArrayOutput

type RocksetS3CollectionSourceCsv 

type RocksetS3CollectionSourceCsv struct {
	ColumnNames            []string `pulumi:"columnNames"`
	ColumnTypes            []string `pulumi:"columnTypes"`
	Encoding               *string  `pulumi:"encoding"`
	EscapeChar             *string  `pulumi:"escapeChar"`
	FirstLineAsColumnNames *bool    `pulumi:"firstLineAsColumnNames"`
	QuoteChar              *string  `pulumi:"quoteChar"`
	Separator              *string  `pulumi:"separator"`
}

type RocksetS3CollectionSourceCsvArgs 

type RocksetS3CollectionSourceCsvArgs struct {
	ColumnNames            pulumi.StringArrayInput `pulumi:"columnNames"`
	ColumnTypes            pulumi.StringArrayInput `pulumi:"columnTypes"`
	Encoding               pulumi.StringPtrInput   `pulumi:"encoding"`
	EscapeChar             pulumi.StringPtrInput   `pulumi:"escapeChar"`
	FirstLineAsColumnNames pulumi.BoolPtrInput     `pulumi:"firstLineAsColumnNames"`
	QuoteChar              pulumi.StringPtrInput   `pulumi:"quoteChar"`
	Separator              pulumi.StringPtrInput   `pulumi:"separator"`
}

func (RocksetS3CollectionSourceCsvArgs) ElementType 

func (RocksetS3CollectionSourceCsvArgs) ElementType() reflect.Type

func (RocksetS3CollectionSourceCsvArgs) ToRocksetS3CollectionSourceCsvOutput 

func (i RocksetS3CollectionSourceCsvArgs) ToRocksetS3CollectionSourceCsvOutput() RocksetS3CollectionSourceCsvOutput

func (RocksetS3CollectionSourceCsvArgs) ToRocksetS3CollectionSourceCsvOutputWithContext 

func (i RocksetS3CollectionSourceCsvArgs) ToRocksetS3CollectionSourceCsvOutputWithContext(ctx context.Context) RocksetS3CollectionSourceCsvOutput

func (RocksetS3CollectionSourceCsvArgs) ToRocksetS3CollectionSourceCsvPtrOutput 

func (i RocksetS3CollectionSourceCsvArgs) ToRocksetS3CollectionSourceCsvPtrOutput() RocksetS3CollectionSourceCsvPtrOutput

func (RocksetS3CollectionSourceCsvArgs) ToRocksetS3CollectionSourceCsvPtrOutputWithContext 

func (i RocksetS3CollectionSourceCsvArgs) ToRocksetS3CollectionSourceCsvPtrOutputWithContext(ctx context.Context) RocksetS3CollectionSourceCsvPtrOutput

type RocksetS3CollectionSourceCsvInput 

type RocksetS3CollectionSourceCsvInput interface {
	pulumi.Input

	ToRocksetS3CollectionSourceCsvOutput() RocksetS3CollectionSourceCsvOutput
	ToRocksetS3CollectionSourceCsvOutputWithContext(context.Context) RocksetS3CollectionSourceCsvOutput
}

RocksetS3CollectionSourceCsvInput is an input type that accepts RocksetS3CollectionSourceCsvArgs and RocksetS3CollectionSourceCsvOutput values. You can construct a concrete instance of `RocksetS3CollectionSourceCsvInput` via: 

RocksetS3CollectionSourceCsvArgs{...}

type RocksetS3CollectionSourceCsvOutput 

type RocksetS3CollectionSourceCsvOutput struct{ *pulumi.OutputState }

func (RocksetS3CollectionSourceCsvOutput) ColumnNames 

func (o RocksetS3CollectionSourceCsvOutput) ColumnNames() pulumi.StringArrayOutput

func (RocksetS3CollectionSourceCsvOutput) ColumnTypes 

func (o RocksetS3CollectionSourceCsvOutput) ColumnTypes() pulumi.StringArrayOutput

func (RocksetS3CollectionSourceCsvOutput) ElementType 

func (RocksetS3CollectionSourceCsvOutput) ElementType() reflect.Type

func (RocksetS3CollectionSourceCsvOutput) Encoding 

func (o RocksetS3CollectionSourceCsvOutput) Encoding() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceCsvOutput) EscapeChar 

func (o RocksetS3CollectionSourceCsvOutput) EscapeChar() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceCsvOutput) FirstLineAsColumnNames 

func (o RocksetS3CollectionSourceCsvOutput) FirstLineAsColumnNames() pulumi.BoolPtrOutput

func (RocksetS3CollectionSourceCsvOutput) QuoteChar 

func (o RocksetS3CollectionSourceCsvOutput) QuoteChar() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceCsvOutput) Separator 

func (o RocksetS3CollectionSourceCsvOutput) Separator() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceCsvOutput) ToRocksetS3CollectionSourceCsvOutput 

func (o RocksetS3CollectionSourceCsvOutput) ToRocksetS3CollectionSourceCsvOutput() RocksetS3CollectionSourceCsvOutput

func (RocksetS3CollectionSourceCsvOutput) ToRocksetS3CollectionSourceCsvOutputWithContext 

func (o RocksetS3CollectionSourceCsvOutput) ToRocksetS3CollectionSourceCsvOutputWithContext(ctx context.Context) RocksetS3CollectionSourceCsvOutput

func (RocksetS3CollectionSourceCsvOutput) ToRocksetS3CollectionSourceCsvPtrOutput 

func (o RocksetS3CollectionSourceCsvOutput) ToRocksetS3CollectionSourceCsvPtrOutput() RocksetS3CollectionSourceCsvPtrOutput

func (RocksetS3CollectionSourceCsvOutput) ToRocksetS3CollectionSourceCsvPtrOutputWithContext 

func (o RocksetS3CollectionSourceCsvOutput) ToRocksetS3CollectionSourceCsvPtrOutputWithContext(ctx context.Context) RocksetS3CollectionSourceCsvPtrOutput

type RocksetS3CollectionSourceCsvPtrInput 

type RocksetS3CollectionSourceCsvPtrInput interface {
	pulumi.Input

	ToRocksetS3CollectionSourceCsvPtrOutput() RocksetS3CollectionSourceCsvPtrOutput
	ToRocksetS3CollectionSourceCsvPtrOutputWithContext(context.Context) RocksetS3CollectionSourceCsvPtrOutput
}

RocksetS3CollectionSourceCsvPtrInput is an input type that accepts RocksetS3CollectionSourceCsvArgs, RocksetS3CollectionSourceCsvPtr and RocksetS3CollectionSourceCsvPtrOutput values. You can construct a concrete instance of `RocksetS3CollectionSourceCsvPtrInput` via: 

        RocksetS3CollectionSourceCsvArgs{...}

or:

        nil

func RocksetS3CollectionSourceCsvPtr 

func RocksetS3CollectionSourceCsvPtr(v *RocksetS3CollectionSourceCsvArgs) RocksetS3CollectionSourceCsvPtrInput

type RocksetS3CollectionSourceCsvPtrOutput 

type RocksetS3CollectionSourceCsvPtrOutput struct{ *pulumi.OutputState }

func (RocksetS3CollectionSourceCsvPtrOutput) ColumnNames 

func (o RocksetS3CollectionSourceCsvPtrOutput) ColumnNames() pulumi.StringArrayOutput

func (RocksetS3CollectionSourceCsvPtrOutput) ColumnTypes 

func (o RocksetS3CollectionSourceCsvPtrOutput) ColumnTypes() pulumi.StringArrayOutput

func (RocksetS3CollectionSourceCsvPtrOutput) Elem 

func (o RocksetS3CollectionSourceCsvPtrOutput) Elem() RocksetS3CollectionSourceCsvOutput

func (RocksetS3CollectionSourceCsvPtrOutput) ElementType 

func (RocksetS3CollectionSourceCsvPtrOutput) ElementType() reflect.Type

func (RocksetS3CollectionSourceCsvPtrOutput) Encoding 

func (o RocksetS3CollectionSourceCsvPtrOutput) Encoding() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceCsvPtrOutput) EscapeChar 

func (o RocksetS3CollectionSourceCsvPtrOutput) EscapeChar() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceCsvPtrOutput) FirstLineAsColumnNames 

func (o RocksetS3CollectionSourceCsvPtrOutput) FirstLineAsColumnNames() pulumi.BoolPtrOutput

func (RocksetS3CollectionSourceCsvPtrOutput) QuoteChar 

func (o RocksetS3CollectionSourceCsvPtrOutput) QuoteChar() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceCsvPtrOutput) Separator 

func (o RocksetS3CollectionSourceCsvPtrOutput) Separator() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceCsvPtrOutput) ToRocksetS3CollectionSourceCsvPtrOutput 

func (o RocksetS3CollectionSourceCsvPtrOutput) ToRocksetS3CollectionSourceCsvPtrOutput() RocksetS3CollectionSourceCsvPtrOutput

func (RocksetS3CollectionSourceCsvPtrOutput) ToRocksetS3CollectionSourceCsvPtrOutputWithContext 

func (o RocksetS3CollectionSourceCsvPtrOutput) ToRocksetS3CollectionSourceCsvPtrOutputWithContext(ctx context.Context) RocksetS3CollectionSourceCsvPtrOutput

type RocksetS3CollectionSourceInput 

type RocksetS3CollectionSourceInput interface {
	pulumi.Input

	ToRocksetS3CollectionSourceOutput() RocksetS3CollectionSourceOutput
	ToRocksetS3CollectionSourceOutputWithContext(context.Context) RocksetS3CollectionSourceOutput
}

RocksetS3CollectionSourceInput is an input type that accepts RocksetS3CollectionSourceArgs and RocksetS3CollectionSourceOutput values. You can construct a concrete instance of `RocksetS3CollectionSourceInput` via: 

RocksetS3CollectionSourceArgs{...}

type RocksetS3CollectionSourceOutput 

type RocksetS3CollectionSourceOutput struct{ *pulumi.OutputState }

func (RocksetS3CollectionSourceOutput) Bucket 

func (o RocksetS3CollectionSourceOutput) Bucket() pulumi.StringOutput

S3 bucket containing the target data.

func (RocksetS3CollectionSourceOutput) Csv 

func (o RocksetS3CollectionSourceOutput) Csv() RocksetS3CollectionSourceCsvPtrOutput

func (RocksetS3CollectionSourceOutput) ElementType 

func (RocksetS3CollectionSourceOutput) ElementType() reflect.Type

func (RocksetS3CollectionSourceOutput) Format 

func (o RocksetS3CollectionSourceOutput) Format() pulumi.StringOutput

Format of the data. One of: json, csv, xml. xml and csv blocks can only be set for their respective formats.

func (RocksetS3CollectionSourceOutput) IntegrationName 

func (o RocksetS3CollectionSourceOutput) IntegrationName() pulumi.StringOutput

The name of the Rockset S3 integration. If no S3 integration is provided only data in public S3 buckets are accessible.

func (RocksetS3CollectionSourceOutput) Pattern 

func (o RocksetS3CollectionSourceOutput) Pattern() pulumi.StringPtrOutput

Regex path pattern to S3 keys.

func (RocksetS3CollectionSourceOutput) Prefix deprecated 

func (o RocksetS3CollectionSourceOutput) Prefix() pulumi.StringPtrOutput

Simple path prefix to S3 keys.

Deprecated: use pattern instead

func (RocksetS3CollectionSourceOutput) ToRocksetS3CollectionSourceOutput 

func (o RocksetS3CollectionSourceOutput) ToRocksetS3CollectionSourceOutput() RocksetS3CollectionSourceOutput

func (RocksetS3CollectionSourceOutput) ToRocksetS3CollectionSourceOutputWithContext 

func (o RocksetS3CollectionSourceOutput) ToRocksetS3CollectionSourceOutputWithContext(ctx context.Context) RocksetS3CollectionSourceOutput

func (RocksetS3CollectionSourceOutput) Xml 

func (o RocksetS3CollectionSourceOutput) Xml() RocksetS3CollectionSourceXmlPtrOutput

type RocksetS3CollectionSourceXml 

type RocksetS3CollectionSourceXml struct {
	AttributePrefix *string `pulumi:"attributePrefix"`
	DocTag          *string `pulumi:"docTag"`
	Encoding        *string `pulumi:"encoding"`
	RootTag         *string `pulumi:"rootTag"`
	ValueTag        *string `pulumi:"valueTag"`
}

type RocksetS3CollectionSourceXmlArgs 

type RocksetS3CollectionSourceXmlArgs struct {
	AttributePrefix pulumi.StringPtrInput `pulumi:"attributePrefix"`
	DocTag          pulumi.StringPtrInput `pulumi:"docTag"`
	Encoding        pulumi.StringPtrInput `pulumi:"encoding"`
	RootTag         pulumi.StringPtrInput `pulumi:"rootTag"`
	ValueTag        pulumi.StringPtrInput `pulumi:"valueTag"`
}

func (RocksetS3CollectionSourceXmlArgs) ElementType 

func (RocksetS3CollectionSourceXmlArgs) ElementType() reflect.Type

func (RocksetS3CollectionSourceXmlArgs) ToRocksetS3CollectionSourceXmlOutput 

func (i RocksetS3CollectionSourceXmlArgs) ToRocksetS3CollectionSourceXmlOutput() RocksetS3CollectionSourceXmlOutput

func (RocksetS3CollectionSourceXmlArgs) ToRocksetS3CollectionSourceXmlOutputWithContext 

func (i RocksetS3CollectionSourceXmlArgs) ToRocksetS3CollectionSourceXmlOutputWithContext(ctx context.Context) RocksetS3CollectionSourceXmlOutput

func (RocksetS3CollectionSourceXmlArgs) ToRocksetS3CollectionSourceXmlPtrOutput 

func (i RocksetS3CollectionSourceXmlArgs) ToRocksetS3CollectionSourceXmlPtrOutput() RocksetS3CollectionSourceXmlPtrOutput

func (RocksetS3CollectionSourceXmlArgs) ToRocksetS3CollectionSourceXmlPtrOutputWithContext 

func (i RocksetS3CollectionSourceXmlArgs) ToRocksetS3CollectionSourceXmlPtrOutputWithContext(ctx context.Context) RocksetS3CollectionSourceXmlPtrOutput

type RocksetS3CollectionSourceXmlInput 

type RocksetS3CollectionSourceXmlInput interface {
	pulumi.Input

	ToRocksetS3CollectionSourceXmlOutput() RocksetS3CollectionSourceXmlOutput
	ToRocksetS3CollectionSourceXmlOutputWithContext(context.Context) RocksetS3CollectionSourceXmlOutput
}

RocksetS3CollectionSourceXmlInput is an input type that accepts RocksetS3CollectionSourceXmlArgs and RocksetS3CollectionSourceXmlOutput values. You can construct a concrete instance of `RocksetS3CollectionSourceXmlInput` via: 

RocksetS3CollectionSourceXmlArgs{...}

type RocksetS3CollectionSourceXmlOutput 

type RocksetS3CollectionSourceXmlOutput struct{ *pulumi.OutputState }

func (RocksetS3CollectionSourceXmlOutput) AttributePrefix 

func (o RocksetS3CollectionSourceXmlOutput) AttributePrefix() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceXmlOutput) DocTag 

func (o RocksetS3CollectionSourceXmlOutput) DocTag() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceXmlOutput) ElementType 

func (RocksetS3CollectionSourceXmlOutput) ElementType() reflect.Type

func (RocksetS3CollectionSourceXmlOutput) Encoding 

func (o RocksetS3CollectionSourceXmlOutput) Encoding() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceXmlOutput) RootTag 

func (o RocksetS3CollectionSourceXmlOutput) RootTag() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceXmlOutput) ToRocksetS3CollectionSourceXmlOutput 

func (o RocksetS3CollectionSourceXmlOutput) ToRocksetS3CollectionSourceXmlOutput() RocksetS3CollectionSourceXmlOutput

func (RocksetS3CollectionSourceXmlOutput) ToRocksetS3CollectionSourceXmlOutputWithContext 

func (o RocksetS3CollectionSourceXmlOutput) ToRocksetS3CollectionSourceXmlOutputWithContext(ctx context.Context) RocksetS3CollectionSourceXmlOutput

func (RocksetS3CollectionSourceXmlOutput) ToRocksetS3CollectionSourceXmlPtrOutput 

func (o RocksetS3CollectionSourceXmlOutput) ToRocksetS3CollectionSourceXmlPtrOutput() RocksetS3CollectionSourceXmlPtrOutput

func (RocksetS3CollectionSourceXmlOutput) ToRocksetS3CollectionSourceXmlPtrOutputWithContext 

func (o RocksetS3CollectionSourceXmlOutput) ToRocksetS3CollectionSourceXmlPtrOutputWithContext(ctx context.Context) RocksetS3CollectionSourceXmlPtrOutput

func (RocksetS3CollectionSourceXmlOutput) ValueTag 

func (o RocksetS3CollectionSourceXmlOutput) ValueTag() pulumi.StringPtrOutput

type RocksetS3CollectionSourceXmlPtrInput 

type RocksetS3CollectionSourceXmlPtrInput interface {
	pulumi.Input

	ToRocksetS3CollectionSourceXmlPtrOutput() RocksetS3CollectionSourceXmlPtrOutput
	ToRocksetS3CollectionSourceXmlPtrOutputWithContext(context.Context) RocksetS3CollectionSourceXmlPtrOutput
}

RocksetS3CollectionSourceXmlPtrInput is an input type that accepts RocksetS3CollectionSourceXmlArgs, RocksetS3CollectionSourceXmlPtr and RocksetS3CollectionSourceXmlPtrOutput values. You can construct a concrete instance of `RocksetS3CollectionSourceXmlPtrInput` via: 

        RocksetS3CollectionSourceXmlArgs{...}

or:

        nil

func RocksetS3CollectionSourceXmlPtr 

func RocksetS3CollectionSourceXmlPtr(v *RocksetS3CollectionSourceXmlArgs) RocksetS3CollectionSourceXmlPtrInput

type RocksetS3CollectionSourceXmlPtrOutput 

type RocksetS3CollectionSourceXmlPtrOutput struct{ *pulumi.OutputState }

func (RocksetS3CollectionSourceXmlPtrOutput) AttributePrefix 

func (o RocksetS3CollectionSourceXmlPtrOutput) AttributePrefix() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceXmlPtrOutput) DocTag 

func (o RocksetS3CollectionSourceXmlPtrOutput) DocTag() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceXmlPtrOutput) Elem 

func (o RocksetS3CollectionSourceXmlPtrOutput) Elem() RocksetS3CollectionSourceXmlOutput

func (RocksetS3CollectionSourceXmlPtrOutput) ElementType 

func (RocksetS3CollectionSourceXmlPtrOutput) ElementType() reflect.Type

func (RocksetS3CollectionSourceXmlPtrOutput) Encoding 

func (o RocksetS3CollectionSourceXmlPtrOutput) Encoding() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceXmlPtrOutput) RootTag 

func (o RocksetS3CollectionSourceXmlPtrOutput) RootTag() pulumi.StringPtrOutput

func (RocksetS3CollectionSourceXmlPtrOutput) ToRocksetS3CollectionSourceXmlPtrOutput 

func (o RocksetS3CollectionSourceXmlPtrOutput) ToRocksetS3CollectionSourceXmlPtrOutput() RocksetS3CollectionSourceXmlPtrOutput

func (RocksetS3CollectionSourceXmlPtrOutput) ToRocksetS3CollectionSourceXmlPtrOutputWithContext 

func (o RocksetS3CollectionSourceXmlPtrOutput) ToRocksetS3CollectionSourceXmlPtrOutputWithContext(ctx context.Context) RocksetS3CollectionSourceXmlPtrOutput

func (RocksetS3CollectionSourceXmlPtrOutput) ValueTag 

func (o RocksetS3CollectionSourceXmlPtrOutput) ValueTag() pulumi.StringPtrOutput

type RocksetS3CollectionState 

type RocksetS3CollectionState struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// **Deprecated** use ingestTransformation instead
	//
	// Deprecated: Use ingest_transformation instead
	FieldMappingQuery pulumi.StringPtrInput
	// Ingest transformation SQL query. Turns the collection into insertOnly mode.
	IngestTransformation pulumi.StringPtrInput
	// Unique identifier for the collection. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// Number of seconds after which data is purged. Based on event time.
	RetentionSecs pulumi.IntPtrInput
	// Defines a source for this collection.
	Sources RocksetS3CollectionSourceArrayInput
	// Wait until the collection is ready.
	WaitForCollection pulumi.BoolPtrInput
	// Wait until the collection has documents. The default is to wait for 0 documents, which means it doesn't wait.
	WaitForDocuments pulumi.IntPtrInput
	// The name of the workspace.
	Workspace pulumi.StringPtrInput
}

func (RocksetS3CollectionState) ElementType 

func (RocksetS3CollectionState) ElementType() reflect.Type

type RocksetS3Integration 

type RocksetS3Integration struct {
	pulumi.CustomResourceState

	// The AWS Role Arn to use for this integration.
	AwsRoleArn pulumi.StringOutput `pulumi:"awsRoleArn"`
	// Text describing the integration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
}

Manages a Rockset S3 Integration.

func GetRocksetS3Integration 

func GetRocksetS3Integration(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetS3IntegrationState, opts ...pulumi.ResourceOption) (*RocksetS3Integration, error)

GetRocksetS3Integration gets an existing RocksetS3Integration 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 NewRocksetS3Integration 

func NewRocksetS3Integration(ctx *pulumi.Context,
	name string, args *RocksetS3IntegrationArgs, opts ...pulumi.ResourceOption) (*RocksetS3Integration, error)

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

func (*RocksetS3Integration) ElementType 

func (*RocksetS3Integration) ElementType() reflect.Type

func (*RocksetS3Integration) ToRocksetS3IntegrationOutput 

func (i *RocksetS3Integration) ToRocksetS3IntegrationOutput() RocksetS3IntegrationOutput

func (*RocksetS3Integration) ToRocksetS3IntegrationOutputWithContext 

func (i *RocksetS3Integration) ToRocksetS3IntegrationOutputWithContext(ctx context.Context) RocksetS3IntegrationOutput

type RocksetS3IntegrationArgs 

type RocksetS3IntegrationArgs struct {
	// The AWS Role Arn to use for this integration.
	AwsRoleArn pulumi.StringInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
}

The set of arguments for constructing a RocksetS3Integration resource.

func (RocksetS3IntegrationArgs) ElementType 

func (RocksetS3IntegrationArgs) ElementType() reflect.Type

type RocksetS3IntegrationArray 

type RocksetS3IntegrationArray []RocksetS3IntegrationInput

func (RocksetS3IntegrationArray) ElementType 

func (RocksetS3IntegrationArray) ElementType() reflect.Type

func (RocksetS3IntegrationArray) ToRocksetS3IntegrationArrayOutput 

func (i RocksetS3IntegrationArray) ToRocksetS3IntegrationArrayOutput() RocksetS3IntegrationArrayOutput

func (RocksetS3IntegrationArray) ToRocksetS3IntegrationArrayOutputWithContext 

func (i RocksetS3IntegrationArray) ToRocksetS3IntegrationArrayOutputWithContext(ctx context.Context) RocksetS3IntegrationArrayOutput

type RocksetS3IntegrationArrayInput 

type RocksetS3IntegrationArrayInput interface {
	pulumi.Input

	ToRocksetS3IntegrationArrayOutput() RocksetS3IntegrationArrayOutput
	ToRocksetS3IntegrationArrayOutputWithContext(context.Context) RocksetS3IntegrationArrayOutput
}

RocksetS3IntegrationArrayInput is an input type that accepts RocksetS3IntegrationArray and RocksetS3IntegrationArrayOutput values. You can construct a concrete instance of `RocksetS3IntegrationArrayInput` via: 

RocksetS3IntegrationArray{ RocksetS3IntegrationArgs{...} }

type RocksetS3IntegrationArrayOutput 

type RocksetS3IntegrationArrayOutput struct{ *pulumi.OutputState }

func (RocksetS3IntegrationArrayOutput) ElementType 

func (RocksetS3IntegrationArrayOutput) ElementType() reflect.Type

func (RocksetS3IntegrationArrayOutput) Index 

func (o RocksetS3IntegrationArrayOutput) Index(i pulumi.IntInput) RocksetS3IntegrationOutput

func (RocksetS3IntegrationArrayOutput) ToRocksetS3IntegrationArrayOutput 

func (o RocksetS3IntegrationArrayOutput) ToRocksetS3IntegrationArrayOutput() RocksetS3IntegrationArrayOutput

func (RocksetS3IntegrationArrayOutput) ToRocksetS3IntegrationArrayOutputWithContext 

func (o RocksetS3IntegrationArrayOutput) ToRocksetS3IntegrationArrayOutputWithContext(ctx context.Context) RocksetS3IntegrationArrayOutput

type RocksetS3IntegrationInput 

type RocksetS3IntegrationInput interface {
	pulumi.Input

	ToRocksetS3IntegrationOutput() RocksetS3IntegrationOutput
	ToRocksetS3IntegrationOutputWithContext(ctx context.Context) RocksetS3IntegrationOutput
}

type RocksetS3IntegrationMap 

type RocksetS3IntegrationMap map[string]RocksetS3IntegrationInput

func (RocksetS3IntegrationMap) ElementType 

func (RocksetS3IntegrationMap) ElementType() reflect.Type

func (RocksetS3IntegrationMap) ToRocksetS3IntegrationMapOutput 

func (i RocksetS3IntegrationMap) ToRocksetS3IntegrationMapOutput() RocksetS3IntegrationMapOutput

func (RocksetS3IntegrationMap) ToRocksetS3IntegrationMapOutputWithContext 

func (i RocksetS3IntegrationMap) ToRocksetS3IntegrationMapOutputWithContext(ctx context.Context) RocksetS3IntegrationMapOutput

type RocksetS3IntegrationMapInput 

type RocksetS3IntegrationMapInput interface {
	pulumi.Input

	ToRocksetS3IntegrationMapOutput() RocksetS3IntegrationMapOutput
	ToRocksetS3IntegrationMapOutputWithContext(context.Context) RocksetS3IntegrationMapOutput
}

RocksetS3IntegrationMapInput is an input type that accepts RocksetS3IntegrationMap and RocksetS3IntegrationMapOutput values. You can construct a concrete instance of `RocksetS3IntegrationMapInput` via: 

RocksetS3IntegrationMap{ "key": RocksetS3IntegrationArgs{...} }

type RocksetS3IntegrationMapOutput 

type RocksetS3IntegrationMapOutput struct{ *pulumi.OutputState }

func (RocksetS3IntegrationMapOutput) ElementType 

func (RocksetS3IntegrationMapOutput) ElementType() reflect.Type

func (RocksetS3IntegrationMapOutput) MapIndex 

func (o RocksetS3IntegrationMapOutput) MapIndex(k pulumi.StringInput) RocksetS3IntegrationOutput

func (RocksetS3IntegrationMapOutput) ToRocksetS3IntegrationMapOutput 

func (o RocksetS3IntegrationMapOutput) ToRocksetS3IntegrationMapOutput() RocksetS3IntegrationMapOutput

func (RocksetS3IntegrationMapOutput) ToRocksetS3IntegrationMapOutputWithContext 

func (o RocksetS3IntegrationMapOutput) ToRocksetS3IntegrationMapOutputWithContext(ctx context.Context) RocksetS3IntegrationMapOutput

type RocksetS3IntegrationOutput 

type RocksetS3IntegrationOutput struct{ *pulumi.OutputState }

func (RocksetS3IntegrationOutput) AwsRoleArn 

func (o RocksetS3IntegrationOutput) AwsRoleArn() pulumi.StringOutput

The AWS Role Arn to use for this integration.

func (RocksetS3IntegrationOutput) Description 

func (o RocksetS3IntegrationOutput) Description() pulumi.StringPtrOutput

Text describing the integration.

func (RocksetS3IntegrationOutput) ElementType 

func (RocksetS3IntegrationOutput) ElementType() reflect.Type

func (RocksetS3IntegrationOutput) Name 

func (o RocksetS3IntegrationOutput) Name() pulumi.StringOutput

Unique identifier for the integration. Can contain alphanumeric or dash characters.

func (RocksetS3IntegrationOutput) ToRocksetS3IntegrationOutput 

func (o RocksetS3IntegrationOutput) ToRocksetS3IntegrationOutput() RocksetS3IntegrationOutput

func (RocksetS3IntegrationOutput) ToRocksetS3IntegrationOutputWithContext 

func (o RocksetS3IntegrationOutput) ToRocksetS3IntegrationOutputWithContext(ctx context.Context) RocksetS3IntegrationOutput

type RocksetS3IntegrationState 

type RocksetS3IntegrationState struct {
	// The AWS Role Arn to use for this integration.
	AwsRoleArn pulumi.StringPtrInput
	// Text describing the integration.
	Description pulumi.StringPtrInput
	// Unique identifier for the integration. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
}

func (RocksetS3IntegrationState) ElementType 

func (RocksetS3IntegrationState) ElementType() reflect.Type

type RocksetUser 

type RocksetUser struct {
	pulumi.CustomResourceState

	// The ISO-8601 time of when the user was created.
	CreatedAt pulumi.StringOutput `pulumi:"createdAt"`
	// Email address of the user. Also used to identify the user.
	Email pulumi.StringOutput `pulumi:"email"`
	// User's first name. This can only be set once the state is ACTIVE, i.e after the user has accepted the invite.
	FirstName pulumi.StringPtrOutput `pulumi:"firstName"`
	// User's last name. This can only be set once the state is ACTIVE, i.e after the user has accepted the invite.
	LastName pulumi.StringPtrOutput `pulumi:"lastName"`
	// List of roles for the user. E.g. 'admin', 'member', 'read-only'.
	Roles pulumi.StringArrayOutput `pulumi:"roles"`
	// State of the user, either NEW or ACTIVE.
	State pulumi.StringOutput `pulumi:"state"`
}

Manages a Rockset User.

First and last name can only be managed for users who have accepted the invite, i.e. when the state is ACCEPTED.

func GetRocksetUser 

func GetRocksetUser(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetUserState, opts ...pulumi.ResourceOption) (*RocksetUser, error)

GetRocksetUser gets an existing RocksetUser 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 NewRocksetUser 

func NewRocksetUser(ctx *pulumi.Context,
	name string, args *RocksetUserArgs, opts ...pulumi.ResourceOption) (*RocksetUser, error)

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

func (*RocksetUser) ElementType 

func (*RocksetUser) ElementType() reflect.Type

func (*RocksetUser) ToRocksetUserOutput 

func (i *RocksetUser) ToRocksetUserOutput() RocksetUserOutput

func (*RocksetUser) ToRocksetUserOutputWithContext 

func (i *RocksetUser) ToRocksetUserOutputWithContext(ctx context.Context) RocksetUserOutput

type RocksetUserArgs 

type RocksetUserArgs struct {
	// Email address of the user. Also used to identify the user.
	Email pulumi.StringInput
	// User's first name. This can only be set once the state is ACTIVE, i.e after the user has accepted the invite.
	FirstName pulumi.StringPtrInput
	// User's last name. This can only be set once the state is ACTIVE, i.e after the user has accepted the invite.
	LastName pulumi.StringPtrInput
	// List of roles for the user. E.g. 'admin', 'member', 'read-only'.
	Roles pulumi.StringArrayInput
}

The set of arguments for constructing a RocksetUser resource.

func (RocksetUserArgs) ElementType 

func (RocksetUserArgs) ElementType() reflect.Type

type RocksetUserArray 

type RocksetUserArray []RocksetUserInput

func (RocksetUserArray) ElementType 

func (RocksetUserArray) ElementType() reflect.Type

func (RocksetUserArray) ToRocksetUserArrayOutput 

func (i RocksetUserArray) ToRocksetUserArrayOutput() RocksetUserArrayOutput

func (RocksetUserArray) ToRocksetUserArrayOutputWithContext 

func (i RocksetUserArray) ToRocksetUserArrayOutputWithContext(ctx context.Context) RocksetUserArrayOutput

type RocksetUserArrayInput 

type RocksetUserArrayInput interface {
	pulumi.Input

	ToRocksetUserArrayOutput() RocksetUserArrayOutput
	ToRocksetUserArrayOutputWithContext(context.Context) RocksetUserArrayOutput
}

RocksetUserArrayInput is an input type that accepts RocksetUserArray and RocksetUserArrayOutput values. You can construct a concrete instance of `RocksetUserArrayInput` via: 

RocksetUserArray{ RocksetUserArgs{...} }

type RocksetUserArrayOutput 

type RocksetUserArrayOutput struct{ *pulumi.OutputState }

func (RocksetUserArrayOutput) ElementType 

func (RocksetUserArrayOutput) ElementType() reflect.Type

func (RocksetUserArrayOutput) Index 

func (o RocksetUserArrayOutput) Index(i pulumi.IntInput) RocksetUserOutput

func (RocksetUserArrayOutput) ToRocksetUserArrayOutput 

func (o RocksetUserArrayOutput) ToRocksetUserArrayOutput() RocksetUserArrayOutput

func (RocksetUserArrayOutput) ToRocksetUserArrayOutputWithContext 

func (o RocksetUserArrayOutput) ToRocksetUserArrayOutputWithContext(ctx context.Context) RocksetUserArrayOutput

type RocksetUserInput 

type RocksetUserInput interface {
	pulumi.Input

	ToRocksetUserOutput() RocksetUserOutput
	ToRocksetUserOutputWithContext(ctx context.Context) RocksetUserOutput
}

type RocksetUserMap 

type RocksetUserMap map[string]RocksetUserInput

func (RocksetUserMap) ElementType 

func (RocksetUserMap) ElementType() reflect.Type

func (RocksetUserMap) ToRocksetUserMapOutput 

func (i RocksetUserMap) ToRocksetUserMapOutput() RocksetUserMapOutput

func (RocksetUserMap) ToRocksetUserMapOutputWithContext 

func (i RocksetUserMap) ToRocksetUserMapOutputWithContext(ctx context.Context) RocksetUserMapOutput

type RocksetUserMapInput 

type RocksetUserMapInput interface {
	pulumi.Input

	ToRocksetUserMapOutput() RocksetUserMapOutput
	ToRocksetUserMapOutputWithContext(context.Context) RocksetUserMapOutput
}

RocksetUserMapInput is an input type that accepts RocksetUserMap and RocksetUserMapOutput values. You can construct a concrete instance of `RocksetUserMapInput` via: 

RocksetUserMap{ "key": RocksetUserArgs{...} }

type RocksetUserMapOutput 

type RocksetUserMapOutput struct{ *pulumi.OutputState }

func (RocksetUserMapOutput) ElementType 

func (RocksetUserMapOutput) ElementType() reflect.Type

func (RocksetUserMapOutput) MapIndex 

func (o RocksetUserMapOutput) MapIndex(k pulumi.StringInput) RocksetUserOutput

func (RocksetUserMapOutput) ToRocksetUserMapOutput 

func (o RocksetUserMapOutput) ToRocksetUserMapOutput() RocksetUserMapOutput

func (RocksetUserMapOutput) ToRocksetUserMapOutputWithContext 

func (o RocksetUserMapOutput) ToRocksetUserMapOutputWithContext(ctx context.Context) RocksetUserMapOutput

type RocksetUserOutput 

type RocksetUserOutput struct{ *pulumi.OutputState }

func (RocksetUserOutput) CreatedAt 

func (o RocksetUserOutput) CreatedAt() pulumi.StringOutput

The ISO-8601 time of when the user was created.

func (RocksetUserOutput) ElementType 

func (RocksetUserOutput) ElementType() reflect.Type

func (RocksetUserOutput) Email 

func (o RocksetUserOutput) Email() pulumi.StringOutput

Email address of the user. Also used to identify the user.

func (RocksetUserOutput) FirstName 

func (o RocksetUserOutput) FirstName() pulumi.StringPtrOutput

User's first name. This can only be set once the state is ACTIVE, i.e after the user has accepted the invite.

func (RocksetUserOutput) LastName 

func (o RocksetUserOutput) LastName() pulumi.StringPtrOutput

User's last name. This can only be set once the state is ACTIVE, i.e after the user has accepted the invite.

func (RocksetUserOutput) Roles 

func (o RocksetUserOutput) Roles() pulumi.StringArrayOutput

List of roles for the user. E.g. 'admin', 'member', 'read-only'.

func (RocksetUserOutput) State 

func (o RocksetUserOutput) State() pulumi.StringOutput

State of the user, either NEW or ACTIVE.

func (RocksetUserOutput) ToRocksetUserOutput 

func (o RocksetUserOutput) ToRocksetUserOutput() RocksetUserOutput

func (RocksetUserOutput) ToRocksetUserOutputWithContext 

func (o RocksetUserOutput) ToRocksetUserOutputWithContext(ctx context.Context) RocksetUserOutput

type RocksetUserState 

type RocksetUserState struct {
	// The ISO-8601 time of when the user was created.
	CreatedAt pulumi.StringPtrInput
	// Email address of the user. Also used to identify the user.
	Email pulumi.StringPtrInput
	// User's first name. This can only be set once the state is ACTIVE, i.e after the user has accepted the invite.
	FirstName pulumi.StringPtrInput
	// User's last name. This can only be set once the state is ACTIVE, i.e after the user has accepted the invite.
	LastName pulumi.StringPtrInput
	// List of roles for the user. E.g. 'admin', 'member', 'read-only'.
	Roles pulumi.StringArrayInput
	// State of the user, either NEW or ACTIVE.
	State pulumi.StringPtrInput
}

func (RocksetUserState) ElementType 

func (RocksetUserState) ElementType() reflect.Type

type RocksetView 

type RocksetView struct {
	pulumi.CustomResourceState

	// The user who created the view.
	CreatedBy pulumi.StringOutput `pulumi:"createdBy"`
	// Text describing the collection.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Unique name for the view in the workspace. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// SQL query used for thw view.
	Query pulumi.StringOutput `pulumi:"query"`
	// Workspace name.
	Workspace pulumi.StringOutput `pulumi:"workspace"`
}

Manages a Rockset view.

func GetRocksetView 

func GetRocksetView(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetViewState, opts ...pulumi.ResourceOption) (*RocksetView, error)

GetRocksetView gets an existing RocksetView 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 NewRocksetView 

func NewRocksetView(ctx *pulumi.Context,
	name string, args *RocksetViewArgs, opts ...pulumi.ResourceOption) (*RocksetView, error)

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

func (*RocksetView) ElementType 

func (*RocksetView) ElementType() reflect.Type

func (*RocksetView) ToRocksetViewOutput 

func (i *RocksetView) ToRocksetViewOutput() RocksetViewOutput

func (*RocksetView) ToRocksetViewOutputWithContext 

func (i *RocksetView) ToRocksetViewOutputWithContext(ctx context.Context) RocksetViewOutput

type RocksetViewArgs 

type RocksetViewArgs struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// Unique name for the view in the workspace. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// SQL query used for thw view.
	Query pulumi.StringInput
	// Workspace name.
	Workspace pulumi.StringInput
}

The set of arguments for constructing a RocksetView resource.

func (RocksetViewArgs) ElementType 

func (RocksetViewArgs) ElementType() reflect.Type

type RocksetViewArray 

type RocksetViewArray []RocksetViewInput

func (RocksetViewArray) ElementType 

func (RocksetViewArray) ElementType() reflect.Type

func (RocksetViewArray) ToRocksetViewArrayOutput 

func (i RocksetViewArray) ToRocksetViewArrayOutput() RocksetViewArrayOutput

func (RocksetViewArray) ToRocksetViewArrayOutputWithContext 

func (i RocksetViewArray) ToRocksetViewArrayOutputWithContext(ctx context.Context) RocksetViewArrayOutput

type RocksetViewArrayInput 

type RocksetViewArrayInput interface {
	pulumi.Input

	ToRocksetViewArrayOutput() RocksetViewArrayOutput
	ToRocksetViewArrayOutputWithContext(context.Context) RocksetViewArrayOutput
}

RocksetViewArrayInput is an input type that accepts RocksetViewArray and RocksetViewArrayOutput values. You can construct a concrete instance of `RocksetViewArrayInput` via: 

RocksetViewArray{ RocksetViewArgs{...} }

type RocksetViewArrayOutput 

type RocksetViewArrayOutput struct{ *pulumi.OutputState }

func (RocksetViewArrayOutput) ElementType 

func (RocksetViewArrayOutput) ElementType() reflect.Type

func (RocksetViewArrayOutput) Index 

func (o RocksetViewArrayOutput) Index(i pulumi.IntInput) RocksetViewOutput

func (RocksetViewArrayOutput) ToRocksetViewArrayOutput 

func (o RocksetViewArrayOutput) ToRocksetViewArrayOutput() RocksetViewArrayOutput

func (RocksetViewArrayOutput) ToRocksetViewArrayOutputWithContext 

func (o RocksetViewArrayOutput) ToRocksetViewArrayOutputWithContext(ctx context.Context) RocksetViewArrayOutput

type RocksetViewInput 

type RocksetViewInput interface {
	pulumi.Input

	ToRocksetViewOutput() RocksetViewOutput
	ToRocksetViewOutputWithContext(ctx context.Context) RocksetViewOutput
}

type RocksetViewMap 

type RocksetViewMap map[string]RocksetViewInput

func (RocksetViewMap) ElementType 

func (RocksetViewMap) ElementType() reflect.Type

func (RocksetViewMap) ToRocksetViewMapOutput 

func (i RocksetViewMap) ToRocksetViewMapOutput() RocksetViewMapOutput

func (RocksetViewMap) ToRocksetViewMapOutputWithContext 

func (i RocksetViewMap) ToRocksetViewMapOutputWithContext(ctx context.Context) RocksetViewMapOutput

type RocksetViewMapInput 

type RocksetViewMapInput interface {
	pulumi.Input

	ToRocksetViewMapOutput() RocksetViewMapOutput
	ToRocksetViewMapOutputWithContext(context.Context) RocksetViewMapOutput
}

RocksetViewMapInput is an input type that accepts RocksetViewMap and RocksetViewMapOutput values. You can construct a concrete instance of `RocksetViewMapInput` via: 

RocksetViewMap{ "key": RocksetViewArgs{...} }

type RocksetViewMapOutput 

type RocksetViewMapOutput struct{ *pulumi.OutputState }

func (RocksetViewMapOutput) ElementType 

func (RocksetViewMapOutput) ElementType() reflect.Type

func (RocksetViewMapOutput) MapIndex 

func (o RocksetViewMapOutput) MapIndex(k pulumi.StringInput) RocksetViewOutput

func (RocksetViewMapOutput) ToRocksetViewMapOutput 

func (o RocksetViewMapOutput) ToRocksetViewMapOutput() RocksetViewMapOutput

func (RocksetViewMapOutput) ToRocksetViewMapOutputWithContext 

func (o RocksetViewMapOutput) ToRocksetViewMapOutputWithContext(ctx context.Context) RocksetViewMapOutput

type RocksetViewOutput 

type RocksetViewOutput struct{ *pulumi.OutputState }

func (RocksetViewOutput) CreatedBy 

func (o RocksetViewOutput) CreatedBy() pulumi.StringOutput

The user who created the view.

func (RocksetViewOutput) Description 

func (o RocksetViewOutput) Description() pulumi.StringPtrOutput

Text describing the collection.

func (RocksetViewOutput) ElementType 

func (RocksetViewOutput) ElementType() reflect.Type

func (RocksetViewOutput) Name 

func (o RocksetViewOutput) Name() pulumi.StringOutput

Unique name for the view in the workspace. Can contain alphanumeric or dash characters.

func (RocksetViewOutput) Query 

func (o RocksetViewOutput) Query() pulumi.StringOutput

SQL query used for thw view.

func (RocksetViewOutput) ToRocksetViewOutput 

func (o RocksetViewOutput) ToRocksetViewOutput() RocksetViewOutput

func (RocksetViewOutput) ToRocksetViewOutputWithContext 

func (o RocksetViewOutput) ToRocksetViewOutputWithContext(ctx context.Context) RocksetViewOutput

func (RocksetViewOutput) Workspace 

func (o RocksetViewOutput) Workspace() pulumi.StringOutput

Workspace name.

type RocksetViewState 

type RocksetViewState struct {
	// The user who created the view.
	CreatedBy pulumi.StringPtrInput
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// Unique name for the view in the workspace. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
	// SQL query used for thw view.
	Query pulumi.StringPtrInput
	// Workspace name.
	Workspace pulumi.StringPtrInput
}

func (RocksetViewState) ElementType 

func (RocksetViewState) ElementType() reflect.Type

type RocksetWorkspace 

type RocksetWorkspace struct {
	pulumi.CustomResourceState

	// The user who created the workspace.
	CreatedBy pulumi.StringOutput `pulumi:"createdBy"`
	// Text describing the collection.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Unique identifier for workspace. Can contain alphanumeric or dash characters.
	Name pulumi.StringOutput `pulumi:"name"`
}

Manages a Rockset workspace.

func GetRocksetWorkspace 

func GetRocksetWorkspace(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RocksetWorkspaceState, opts ...pulumi.ResourceOption) (*RocksetWorkspace, error)

GetRocksetWorkspace gets an existing RocksetWorkspace 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 NewRocksetWorkspace 

func NewRocksetWorkspace(ctx *pulumi.Context,
	name string, args *RocksetWorkspaceArgs, opts ...pulumi.ResourceOption) (*RocksetWorkspace, error)

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

func (*RocksetWorkspace) ElementType 

func (*RocksetWorkspace) ElementType() reflect.Type

func (*RocksetWorkspace) ToRocksetWorkspaceOutput 

func (i *RocksetWorkspace) ToRocksetWorkspaceOutput() RocksetWorkspaceOutput

func (*RocksetWorkspace) ToRocksetWorkspaceOutputWithContext 

func (i *RocksetWorkspace) ToRocksetWorkspaceOutputWithContext(ctx context.Context) RocksetWorkspaceOutput

type RocksetWorkspaceArgs 

type RocksetWorkspaceArgs struct {
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// Unique identifier for workspace. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
}

The set of arguments for constructing a RocksetWorkspace resource.

func (RocksetWorkspaceArgs) ElementType 

func (RocksetWorkspaceArgs) ElementType() reflect.Type

type RocksetWorkspaceArray 

type RocksetWorkspaceArray []RocksetWorkspaceInput

func (RocksetWorkspaceArray) ElementType 

func (RocksetWorkspaceArray) ElementType() reflect.Type

func (RocksetWorkspaceArray) ToRocksetWorkspaceArrayOutput 

func (i RocksetWorkspaceArray) ToRocksetWorkspaceArrayOutput() RocksetWorkspaceArrayOutput

func (RocksetWorkspaceArray) ToRocksetWorkspaceArrayOutputWithContext 

func (i RocksetWorkspaceArray) ToRocksetWorkspaceArrayOutputWithContext(ctx context.Context) RocksetWorkspaceArrayOutput

type RocksetWorkspaceArrayInput 

type RocksetWorkspaceArrayInput interface {
	pulumi.Input

	ToRocksetWorkspaceArrayOutput() RocksetWorkspaceArrayOutput
	ToRocksetWorkspaceArrayOutputWithContext(context.Context) RocksetWorkspaceArrayOutput
}

RocksetWorkspaceArrayInput is an input type that accepts RocksetWorkspaceArray and RocksetWorkspaceArrayOutput values. You can construct a concrete instance of `RocksetWorkspaceArrayInput` via: 

RocksetWorkspaceArray{ RocksetWorkspaceArgs{...} }

type RocksetWorkspaceArrayOutput 

type RocksetWorkspaceArrayOutput struct{ *pulumi.OutputState }

func (RocksetWorkspaceArrayOutput) ElementType 

func (RocksetWorkspaceArrayOutput) ElementType() reflect.Type

func (RocksetWorkspaceArrayOutput) Index 

func (o RocksetWorkspaceArrayOutput) Index(i pulumi.IntInput) RocksetWorkspaceOutput

func (RocksetWorkspaceArrayOutput) ToRocksetWorkspaceArrayOutput 

func (o RocksetWorkspaceArrayOutput) ToRocksetWorkspaceArrayOutput() RocksetWorkspaceArrayOutput

func (RocksetWorkspaceArrayOutput) ToRocksetWorkspaceArrayOutputWithContext 

func (o RocksetWorkspaceArrayOutput) ToRocksetWorkspaceArrayOutputWithContext(ctx context.Context) RocksetWorkspaceArrayOutput

type RocksetWorkspaceInput 

type RocksetWorkspaceInput interface {
	pulumi.Input

	ToRocksetWorkspaceOutput() RocksetWorkspaceOutput
	ToRocksetWorkspaceOutputWithContext(ctx context.Context) RocksetWorkspaceOutput
}

type RocksetWorkspaceMap 

type RocksetWorkspaceMap map[string]RocksetWorkspaceInput

func (RocksetWorkspaceMap) ElementType 

func (RocksetWorkspaceMap) ElementType() reflect.Type

func (RocksetWorkspaceMap) ToRocksetWorkspaceMapOutput 

func (i RocksetWorkspaceMap) ToRocksetWorkspaceMapOutput() RocksetWorkspaceMapOutput

func (RocksetWorkspaceMap) ToRocksetWorkspaceMapOutputWithContext 

func (i RocksetWorkspaceMap) ToRocksetWorkspaceMapOutputWithContext(ctx context.Context) RocksetWorkspaceMapOutput

type RocksetWorkspaceMapInput 

type RocksetWorkspaceMapInput interface {
	pulumi.Input

	ToRocksetWorkspaceMapOutput() RocksetWorkspaceMapOutput
	ToRocksetWorkspaceMapOutputWithContext(context.Context) RocksetWorkspaceMapOutput
}

RocksetWorkspaceMapInput is an input type that accepts RocksetWorkspaceMap and RocksetWorkspaceMapOutput values. You can construct a concrete instance of `RocksetWorkspaceMapInput` via: 

RocksetWorkspaceMap{ "key": RocksetWorkspaceArgs{...} }

type RocksetWorkspaceMapOutput 

type RocksetWorkspaceMapOutput struct{ *pulumi.OutputState }

func (RocksetWorkspaceMapOutput) ElementType 

func (RocksetWorkspaceMapOutput) ElementType() reflect.Type

func (RocksetWorkspaceMapOutput) MapIndex 

func (o RocksetWorkspaceMapOutput) MapIndex(k pulumi.StringInput) RocksetWorkspaceOutput

func (RocksetWorkspaceMapOutput) ToRocksetWorkspaceMapOutput 

func (o RocksetWorkspaceMapOutput) ToRocksetWorkspaceMapOutput() RocksetWorkspaceMapOutput

func (RocksetWorkspaceMapOutput) ToRocksetWorkspaceMapOutputWithContext 

func (o RocksetWorkspaceMapOutput) ToRocksetWorkspaceMapOutputWithContext(ctx context.Context) RocksetWorkspaceMapOutput

type RocksetWorkspaceOutput 

type RocksetWorkspaceOutput struct{ *pulumi.OutputState }

func (RocksetWorkspaceOutput) CreatedBy 

func (o RocksetWorkspaceOutput) CreatedBy() pulumi.StringOutput

The user who created the workspace.

func (RocksetWorkspaceOutput) Description 

func (o RocksetWorkspaceOutput) Description() pulumi.StringPtrOutput

Text describing the collection.

func (RocksetWorkspaceOutput) ElementType 

func (RocksetWorkspaceOutput) ElementType() reflect.Type

func (RocksetWorkspaceOutput) Name 

func (o RocksetWorkspaceOutput) Name() pulumi.StringOutput

Unique identifier for workspace. Can contain alphanumeric or dash characters.

func (RocksetWorkspaceOutput) ToRocksetWorkspaceOutput 

func (o RocksetWorkspaceOutput) ToRocksetWorkspaceOutput() RocksetWorkspaceOutput

func (RocksetWorkspaceOutput) ToRocksetWorkspaceOutputWithContext 

func (o RocksetWorkspaceOutput) ToRocksetWorkspaceOutputWithContext(ctx context.Context) RocksetWorkspaceOutput

type RocksetWorkspaceState 

type RocksetWorkspaceState struct {
	// The user who created the workspace.
	CreatedBy pulumi.StringPtrInput
	// Text describing the collection.
	Description pulumi.StringPtrInput
	// Unique identifier for workspace. Can contain alphanumeric or dash characters.
	Name pulumi.StringPtrInput
}

func (RocksetWorkspaceState) ElementType 

func (RocksetWorkspaceState) ElementType() reflect.Type

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.