import * as pulumi from "@pulumi/pulumi"; import * as inputs from "../types/input"; export interface ClusterScheduling { /** * Configuration for refreshing the cluster. */ onRefresh?: pulumi.Input; } export interface ClusterSchedulingOnRefresh { /** * Enable scheduling to refresh the cluster. */ enabled?: pulumi.Input; /** * Estimated time to hydrate the cluster during refresh. */ hydrationTimeEstimate?: pulumi.Input; /** * Estimated time to rehydrate the cluster during refresh. This field is deprecated and will be removed in a future release. Use `hydration_time_estimate` instead. * * @deprecated Deprecated */ rehydrationTimeEstimate?: pulumi.Input; } export interface ClusterWaitUntilReady { /** * Enable wait_until_ready. */ enabled?: pulumi.Input; /** * Action to take on timeout: COMMIT|ROLLBACK */ onTimeout?: pulumi.Input; /** * Max duration to wait for the new replicas to be ready. */ timeout?: pulumi.Input; } export interface ConnectionAwsAccessKeyId { /** * The `access_key_id` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `access_key_id` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionAwsAccessKeyIdSecret { /** * The access_key_id database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The access_key_id name. */ name: pulumi.Input; /** * The access_key_id schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionAwsSecretAccessKey { /** * The secret_access_key database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The secret_access_key name. */ name: pulumi.Input; /** * The secret_access_key schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionAwsSessionToken { /** * The `session_token` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `session_token` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionAwsSessionTokenSecret { /** * The session_token database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The session_token name. */ name: pulumi.Input; /** * The session_token schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistryAwsPrivatelink { /** * The aws_privatelink database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The aws_privatelink name. */ name: pulumi.Input; /** * The aws_privatelink schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistryPassword { /** * The password database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The password name. */ name: pulumi.Input; /** * The password schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistrySshTunnel { /** * The ssh_tunnel database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssh_tunnel name. */ name: pulumi.Input; /** * The ssh_tunnel schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistrySslCertificate { /** * The `ssl_certificate` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `ssl_certificate` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistrySslCertificateAuthority { /** * The `ssl_certificate_authority` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `ssl_certificate_authority` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistrySslCertificateAuthoritySecret { /** * The ssl_certificate_authority database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_certificate_authority name. */ name: pulumi.Input; /** * The ssl_certificate_authority schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistrySslCertificateSecret { /** * The ssl_certificate database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_certificate name. */ name: pulumi.Input; /** * The ssl_certificate schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistrySslKey { /** * The ssl_key database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_key name. */ name: pulumi.Input; /** * The ssl_key schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistryUsername { /** * The `username` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `username` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionConfluentSchemaRegistryUsernameSecret { /** * The username database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The username name. */ name: pulumi.Input; /** * The username schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaAwsConnection { /** * The aws_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The aws_connection name. */ name: pulumi.Input; /** * The aws_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaAwsPrivatelink { /** * The AWS PrivateLink connection name in Materialize. */ privatelinkConnection: pulumi.Input; /** * The port of the AWS PrivateLink connection. */ privatelinkConnectionPort: pulumi.Input; } export interface ConnectionKafkaAwsPrivatelinkPrivatelinkConnection { /** * The privatelink_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The privatelink_connection name. */ name: pulumi.Input; /** * The privatelink_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaKafkaBroker { /** * The availability zone of the Kafka broker. */ availabilityZone?: pulumi.Input; /** * The Kafka broker, in the form of `host:port`. */ broker: pulumi.Input; /** * The AWS PrivateLink connection name in Materialize. */ privatelinkConnection?: pulumi.Input; /** * The name of an SSH tunnel connection to route network traffic through by default. */ sshTunnel?: pulumi.Input; /** * The port of the target group associated with the Kafka broker. */ targetGroupPort?: pulumi.Input; } export interface ConnectionKafkaKafkaBrokerPrivatelinkConnection { /** * The privatelink_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The privatelink_connection name. */ name: pulumi.Input; /** * The privatelink_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaKafkaBrokerSshTunnel { /** * The ssh_tunnel database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssh_tunnel name. */ name: pulumi.Input; /** * The ssh_tunnel schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaSaslPassword { /** * The sasl_password database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The sasl_password name. */ name: pulumi.Input; /** * The sasl_password schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaSaslUsername { /** * The `sasl_username` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `sasl_username` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionKafkaSaslUsernameSecret { /** * The sasl_username database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The sasl_username name. */ name: pulumi.Input; /** * The sasl_username schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaSshTunnel { /** * The ssh_tunnel database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssh_tunnel name. */ name: pulumi.Input; /** * The ssh_tunnel schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaSslCertificate { /** * The `ssl_certificate` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `ssl_certificate` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionKafkaSslCertificateAuthority { /** * The `ssl_certificate_authority` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `ssl_certificate_authority` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionKafkaSslCertificateAuthoritySecret { /** * The ssl_certificate_authority database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_certificate_authority name. */ name: pulumi.Input; /** * The ssl_certificate_authority schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaSslCertificateSecret { /** * The ssl_certificate database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_certificate name. */ name: pulumi.Input; /** * The ssl_certificate schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionKafkaSslKey { /** * The ssl_key database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_key name. */ name: pulumi.Input; /** * The ssl_key schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionMysqlAwsPrivatelink { /** * The aws_privatelink database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The aws_privatelink name. */ name: pulumi.Input; /** * The aws_privatelink schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionMysqlPassword { /** * The password database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The password name. */ name: pulumi.Input; /** * The password schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionMysqlSshTunnel { /** * The ssh_tunnel database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssh_tunnel name. */ name: pulumi.Input; /** * The ssh_tunnel schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionMysqlSslCertificate { /** * The `ssl_certificate` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `ssl_certificate` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionMysqlSslCertificateAuthority { /** * The `ssl_certificate_authority` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `ssl_certificate_authority` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionMysqlSslCertificateAuthoritySecret { /** * The ssl_certificate_authority database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_certificate_authority name. */ name: pulumi.Input; /** * The ssl_certificate_authority schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionMysqlSslCertificateSecret { /** * The ssl_certificate database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_certificate name. */ name: pulumi.Input; /** * The ssl_certificate schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionMysqlSslKey { /** * The ssl_key database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_key name. */ name: pulumi.Input; /** * The ssl_key schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionMysqlUser { /** * The `user` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `user` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionMysqlUserSecret { /** * The user database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The user name. */ name: pulumi.Input; /** * The user schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionPostgresAwsPrivatelink { /** * The aws_privatelink database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The aws_privatelink name. */ name: pulumi.Input; /** * The aws_privatelink schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionPostgresPassword { /** * The password database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The password name. */ name: pulumi.Input; /** * The password schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionPostgresSshTunnel { /** * The ssh_tunnel database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssh_tunnel name. */ name: pulumi.Input; /** * The ssh_tunnel schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionPostgresSslCertificate { /** * The `ssl_certificate` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `ssl_certificate` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionPostgresSslCertificateAuthority { /** * The `ssl_certificate_authority` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `ssl_certificate_authority` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionPostgresSslCertificateAuthoritySecret { /** * The ssl_certificate_authority database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_certificate_authority name. */ name: pulumi.Input; /** * The ssl_certificate_authority schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionPostgresSslCertificateSecret { /** * The ssl_certificate database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_certificate name. */ name: pulumi.Input; /** * The ssl_certificate schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionPostgresSslKey { /** * The ssl_key database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_key name. */ name: pulumi.Input; /** * The ssl_key schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionPostgresUser { /** * The `user` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `user` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionPostgresUserSecret { /** * The user database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The user name. */ name: pulumi.Input; /** * The user schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionSqlserverAwsPrivatelink { /** * The aws_privatelink database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The aws_privatelink name. */ name: pulumi.Input; /** * The aws_privatelink schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionSqlserverPassword { /** * The password database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The password name. */ name: pulumi.Input; /** * The password schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionSqlserverSshTunnel { /** * The ssh_tunnel database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssh_tunnel name. */ name: pulumi.Input; /** * The ssh_tunnel schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionSqlserverSslCertificateAuthority { /** * The `ssl_certificate_authority` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `ssl_certificate_authority` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionSqlserverSslCertificateAuthoritySecret { /** * The ssl_certificate_authority database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The ssl_certificate_authority name. */ name: pulumi.Input; /** * The ssl_certificate_authority schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface ConnectionSqlserverUser { /** * The `user` secret value. Conflicts with `text` within this block. */ secret?: pulumi.Input; /** * The `user` text value. Conflicts with `secret` within this block */ text?: pulumi.Input; } export interface ConnectionSqlserverUserSecret { /** * The user database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The user name. */ name: pulumi.Input; /** * The user schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface IndexColExpr { /** * The name of the option you want to set. */ field: pulumi.Input; } export interface IndexObjName { /** * The obj_name database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The obj_name name. */ name: pulumi.Input; /** * The obj_name schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface NetworkPolicyRule { /** * The action to take for this rule. Currently only 'allow' is supported. */ action: pulumi.Input; /** * The CIDR block the rule will be applied to. */ address: pulumi.Input; /** * The direction of traffic the rule applies to. Currently only 'ingress' is supported. */ direction: pulumi.Input; /** * The name of the rule. */ name: pulumi.Input; } export interface SinkKafkaEnvelope { /** * The generated schemas have a Debezium-style diff envelope to capture changes in the input view or source. */ debezium?: pulumi.Input; /** * The sink emits data with upsert semantics: updates and inserts for the given key are expressed as a value, and deletes are expressed as a null value payload in Kafka. */ upsert?: pulumi.Input; } export interface SinkKafkaFormat { /** * Avro format. */ avro?: pulumi.Input; /** * JSON format. */ json?: pulumi.Input; } export interface SinkKafkaFormatAvro { /** * Add column level documentation comment to the generated Avro schemas. */ avroDocColumns?: pulumi.Input[]>; /** * Add top level documentation comment to the generated Avro schemas. */ avroDocType?: pulumi.Input; /** * The full name of the Avro key schema. */ avroKeyFullname?: pulumi.Input; /** * The full name of the Avro value schema. */ avroValueFullname?: pulumi.Input; /** * If specified, set the Compatibility Level for the generated key schema. */ keyCompatibilityLevel?: pulumi.Input; /** * The name of a schema registry connection. */ schemaRegistryConnection: pulumi.Input; /** * If specified, set the Compatibility Level for the generated value schema. */ valueCompatibilityLevel?: pulumi.Input; } export interface SinkKafkaFormatAvroAvroDocColumn { /** * Name of the column in the Avro schema to apply to. */ column: pulumi.Input; /** * Documentation string. */ doc: pulumi.Input; /** * Applies to the key schema. */ key?: pulumi.Input; /** * The object to apply the Avro documentation. */ object: pulumi.Input; /** * Applies to the value schema. */ value?: pulumi.Input; } export interface SinkKafkaFormatAvroAvroDocColumnObject { /** * The object database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The object name. */ name: pulumi.Input; /** * The object schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SinkKafkaFormatAvroAvroDocType { /** * Documentation string. */ doc: pulumi.Input; /** * Applies to the key schema. */ key?: pulumi.Input; /** * The object to apply the Avro documentation. */ object: pulumi.Input; /** * Applies to the value schema. */ value?: pulumi.Input; } export interface SinkKafkaFormatAvroAvroDocTypeObject { /** * The object database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The object name. */ name: pulumi.Input; /** * The object schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SinkKafkaFormatAvroSchemaRegistryConnection { /** * The schema_registry_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The schema_registry_connection name. */ name: pulumi.Input; /** * The schema_registry_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SinkKafkaFrom { /** * The from database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The from name. */ name: pulumi.Input; /** * The from schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SinkKafkaKafkaConnection { /** * The kafka_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The kafka_connection name. */ name: pulumi.Input; /** * The kafka_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceKafkaEnvelope { /** * Use the Debezium envelope, which uses a diff envelope to handle CRUD operations. */ debezium?: pulumi.Input; /** * Use an append-only envelope. This means that records will only be appended and cannot be updated or deleted. */ none?: pulumi.Input; /** * Use the upsert envelope, which uses message keys to handle CRUD operations. */ upsert?: pulumi.Input; /** * Options for the upsert envelope. */ upsertOptions?: pulumi.Input; } export interface SourceKafkaEnvelopeUpsertOptions { /** * Specify how to handle value decoding errors in the upsert envelope. */ valueDecodingErrors?: pulumi.Input; } export interface SourceKafkaEnvelopeUpsertOptionsValueDecodingErrors { /** * Configuration for inline value decoding errors. */ inline?: pulumi.Input; } export interface SourceKafkaEnvelopeUpsertOptionsValueDecodingErrorsInline { /** * Specify an alias for the value decoding errors column, to use an alternative name for the error column. If not specified, the column name will be `error`. */ alias?: pulumi.Input; /** * Enable inline value decoding errors. */ enabled?: pulumi.Input; } export interface SourceKafkaExposeProgress { /** * The expose_progress database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The expose_progress name. */ name: pulumi.Input; /** * The expose_progress schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceKafkaFormat { /** * Avro format. */ avro?: pulumi.Input; /** * BYTES format. */ bytes?: pulumi.Input; /** * CSV format. */ csvs?: pulumi.Input[]>; /** * JSON format. */ json?: pulumi.Input; /** * Protobuf format. */ protobuf?: pulumi.Input; /** * Text format. */ text?: pulumi.Input; } export interface SourceKafkaFormatAvro { /** * How Materialize will define the Avro schema reader key strategy. */ keyStrategy?: pulumi.Input; /** * The name of a schema registry connection. */ schemaRegistryConnection: pulumi.Input; /** * How Materialize will define the Avro schema reader value strategy. */ valueStrategy?: pulumi.Input; } export interface SourceKafkaFormatAvroSchemaRegistryConnection { /** * The schema_registry_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The schema_registry_connection name. */ name: pulumi.Input; /** * The schema_registry_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceKafkaFormatCsv { /** * The columns to use for the source. */ column?: pulumi.Input; /** * The delimiter to use for the source. */ delimitedBy?: pulumi.Input; /** * The number of columns and the name of each column using the header row. */ headers?: pulumi.Input[]>; } export interface SourceKafkaFormatProtobuf { /** * The name of the Protobuf message to use for the source. */ message: pulumi.Input; /** * The name of a schema registry connection. */ schemaRegistryConnection: pulumi.Input; } export interface SourceKafkaFormatProtobufSchemaRegistryConnection { /** * The schema_registry_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The schema_registry_connection name. */ name: pulumi.Input; /** * The schema_registry_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceKafkaKafkaConnection { /** * The kafka_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The kafka_connection name. */ name: pulumi.Input; /** * The kafka_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceKafkaKeyFormat { /** * Avro format. */ avro?: pulumi.Input; /** * BYTES format. */ bytes?: pulumi.Input; /** * CSV format. */ csvs?: pulumi.Input[]>; /** * JSON format. */ json?: pulumi.Input; /** * Protobuf format. */ protobuf?: pulumi.Input; /** * Text format. */ text?: pulumi.Input; } export interface SourceKafkaKeyFormatAvro { /** * How Materialize will define the Avro schema reader key strategy. */ keyStrategy?: pulumi.Input; /** * The name of a schema registry connection. */ schemaRegistryConnection: pulumi.Input; /** * How Materialize will define the Avro schema reader value strategy. */ valueStrategy?: pulumi.Input; } export interface SourceKafkaKeyFormatAvroSchemaRegistryConnection { /** * The schema_registry_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The schema_registry_connection name. */ name: pulumi.Input; /** * The schema_registry_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceKafkaKeyFormatCsv { /** * The columns to use for the source. */ column?: pulumi.Input; /** * The delimiter to use for the source. */ delimitedBy?: pulumi.Input; /** * The number of columns and the name of each column using the header row. */ headers?: pulumi.Input[]>; } export interface SourceKafkaKeyFormatProtobuf { /** * The name of the Protobuf message to use for the source. */ message: pulumi.Input; /** * The name of a schema registry connection. */ schemaRegistryConnection: pulumi.Input; } export interface SourceKafkaKeyFormatProtobufSchemaRegistryConnection { /** * The schema_registry_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The schema_registry_connection name. */ name: pulumi.Input; /** * The schema_registry_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceKafkaValueFormat { /** * Avro format. */ avro?: pulumi.Input; /** * BYTES format. */ bytes?: pulumi.Input; /** * CSV format. */ csvs?: pulumi.Input[]>; /** * JSON format. */ json?: pulumi.Input; /** * Protobuf format. */ protobuf?: pulumi.Input; /** * Text format. */ text?: pulumi.Input; } export interface SourceKafkaValueFormatAvro { /** * How Materialize will define the Avro schema reader key strategy. */ keyStrategy?: pulumi.Input; /** * The name of a schema registry connection. */ schemaRegistryConnection: pulumi.Input; /** * How Materialize will define the Avro schema reader value strategy. */ valueStrategy?: pulumi.Input; } export interface SourceKafkaValueFormatAvroSchemaRegistryConnection { /** * The schema_registry_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The schema_registry_connection name. */ name: pulumi.Input; /** * The schema_registry_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceKafkaValueFormatCsv { /** * The columns to use for the source. */ column?: pulumi.Input; /** * The delimiter to use for the source. */ delimitedBy?: pulumi.Input; /** * The number of columns and the name of each column using the header row. */ headers?: pulumi.Input[]>; } export interface SourceKafkaValueFormatProtobuf { /** * The name of the Protobuf message to use for the source. */ message: pulumi.Input; /** * The name of a schema registry connection. */ schemaRegistryConnection: pulumi.Input; } export interface SourceKafkaValueFormatProtobufSchemaRegistryConnection { /** * The schema_registry_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The schema_registry_connection name. */ name: pulumi.Input; /** * The schema_registry_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceLoadGeneratorAuctionOptions { /** * (Deprecated) The scale factor for the generator. Defaults to 0.01 (~ 10MB). * * @deprecated Deprecated */ scaleFactor?: pulumi.Input; /** * The interval at which the next datum should be emitted. Defaults to one second. */ tickInterval?: pulumi.Input; } export interface SourceLoadGeneratorExposeProgress { /** * The expose_progress database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The expose_progress name. */ name: pulumi.Input; /** * The expose_progress schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceLoadGeneratorMarketingOptions { /** * (Deprecated) The scale factor for the generator. Defaults to 0.01 (~ 10MB). * * @deprecated Deprecated */ scaleFactor?: pulumi.Input; /** * The interval at which the next datum should be emitted. Defaults to one second. */ tickInterval?: pulumi.Input; } export interface SourceLoadGeneratorTpchOptions { /** * The scale factor for the generator. Defaults to 0.01 (~ 10MB). */ scaleFactor?: pulumi.Input; /** * The interval at which the next datum should be emitted. Defaults to one second. */ tickInterval?: pulumi.Input; } export interface SourceMysqlExposeProgress { /** * The expose_progress database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The expose_progress name. */ name: pulumi.Input; /** * The expose_progress schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceMysqlMysqlConnection { /** * The mysql_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The mysql_connection name. */ name: pulumi.Input; /** * The mysql_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceMysqlTable { /** * The database of the table in Materialize. */ databaseName?: pulumi.Input; /** * The name for the table, used in Materialize. */ name?: pulumi.Input; /** * The schema of the table in Materialize. */ schemaName?: pulumi.Input; /** * The name of the table in the upstream MySQL database. */ upstreamName: pulumi.Input; /** * The schema of the table in the upstream MySQL database. */ upstreamSchemaName?: pulumi.Input; } export interface SourcePostgresExposeProgress { /** * The expose_progress database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The expose_progress name. */ name: pulumi.Input; /** * The expose_progress schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourcePostgresPostgresConnection { /** * The postgres_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The postgres_connection name. */ name: pulumi.Input; /** * The postgres_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourcePostgresTable { /** * The database of the table in Materialize. */ databaseName?: pulumi.Input; /** * The name of the table in Materialize. */ name?: pulumi.Input; /** * The schema of the table in Materialize. */ schemaName?: pulumi.Input; /** * The name of the table in the upstream Postgres database. */ upstreamName: pulumi.Input; /** * The schema of the table in the upstream Postgres database. */ upstreamSchemaName?: pulumi.Input; } export interface SourceSqlserverAwsPrivatelink { /** * The aws_privatelink database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The aws_privatelink name. */ name: pulumi.Input; /** * The aws_privatelink schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceSqlserverExposeProgress { /** * The expose_progress database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The expose_progress name. */ name: pulumi.Input; /** * The expose_progress schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceSqlserverSqlserverConnection { /** * The sqlserver_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The sqlserver_connection name. */ name: pulumi.Input; /** * The sqlserver_connection schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceSqlserverTable { /** * The database of the table in Materialize. */ databaseName?: pulumi.Input; /** * The name for the table, used in Materialize. */ name?: pulumi.Input; /** * The schema of the table in Materialize. */ schemaName?: pulumi.Input; /** * The name of the table in the upstream SQL Server database. */ upstreamName: pulumi.Input; /** * The schema of the table in the upstream SQL Server database. */ upstreamSchemaName?: pulumi.Input; } export interface SourceWebhookCheckOption { /** * The alias for the check options. */ alias?: pulumi.Input; /** * Change type to `bytea`. */ bytes?: pulumi.Input; /** * The field for the check options. */ field: pulumi.Input; } export interface SourceWebhookCheckOptionField { /** * The body for the check options. */ body?: pulumi.Input; /** * The headers for the check options. */ headers?: pulumi.Input; /** * The secret for the check options. */ secret?: pulumi.Input; } export interface SourceWebhookCheckOptionFieldSecret { /** * The secret database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The secret name. */ name: pulumi.Input; /** * The secret schema name. Defaults to `public`. */ schemaName?: pulumi.Input; } export interface SourceWebhookIncludeHeader { /** * The alias for the header. */ alias?: pulumi.Input; /** * Change type to `bytea`. */ bytes?: pulumi.Input; /** * The name for the header. */ header: pulumi.Input; } export interface SourceWebhookIncludeHeaders { /** * Include all headers. */ all?: pulumi.Input; /** * Headers that should be excluded. */ nots?: pulumi.Input[]>; /** * Headers that should be included. */ onlies?: pulumi.Input[]>; } export interface TableColumn { /** * Comment on an object in the database. */ comment?: pulumi.Input; /** * A default value to use for the column in an INSERT statement if an explicit value is not provided. If not specified, `NULL` is assumed.. */ default?: pulumi.Input; /** * The name of the column to be created in the table. */ name: pulumi.Input; /** * Do not allow the column to contain `NULL` values. Columns without this constraint can contain `NULL` values. */ nullable?: pulumi.Input; /** * The data type of the column indicated by name. */ type: pulumi.Input; } export interface TypeListProperties { /** * Creates a custom list whose elements are of `ELEMENT TYPE` */ elementType: pulumi.Input; } export interface TypeMapProperties { /** * Creates a custom map whose keys are of `KEY TYPE`. `KEY TYPE` must resolve to text. */ keyType: pulumi.Input; /** * Creates a custom map whose values are of `VALUE TYPE`. */ valueType: pulumi.Input; } export interface TypeRowProperty { /** * The name of a field in a row type. */ fieldName: pulumi.Input; /** * The data type of a field indicated by `FIELD NAME`. */ fieldType: pulumi.Input; }