This page documents the language specification for the aiven package. If you're looking for help working with the inputs, outputs, or functions of aiven resources in a Pulumi program, please see the resource documentation for examples and API reference.

Pulumi Aiven

class pulumi_aiven.Account(resource_name, opts=None, create_time=None, name=None, owner_team_id=None, tenant_id=None, update_time=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

account1 = aiven.Account("account1")
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • create_time (pulumi.Input[str]) – Time of creation

  • name (pulumi.Input[str]) – Account name

  • owner_team_id (pulumi.Input[str]) – Owner team id

  • tenant_id (pulumi.Input[str]) – Tenant id

  • update_time (pulumi.Input[str]) – Time of last update

account_id: pulumi.Output[str] = None

Account id

create_time: pulumi.Output[str] = None

Time of creation

name: pulumi.Output[str] = None

Account name

owner_team_id: pulumi.Output[str] = None

Owner team id

tenant_id: pulumi.Output[str] = None

Tenant id

update_time: pulumi.Output[str] = None

Time of last update

static get(resource_name, id, opts=None, account_id=None, create_time=None, name=None, owner_team_id=None, tenant_id=None, update_time=None)

Get an existing Account resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • account_id (pulumi.Input[str]) – Account id

  • create_time (pulumi.Input[str]) – Time of creation

  • name (pulumi.Input[str]) – Account name

  • owner_team_id (pulumi.Input[str]) – Owner team id

  • tenant_id (pulumi.Input[str]) – Tenant id

  • update_time (pulumi.Input[str]) – Time of last update

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.AccountAuthentication(resource_name, opts=None, account_id=None, authentication_id=None, create_time=None, enabled=None, name=None, saml_acs_url=None, saml_certificate=None, saml_entity_id=None, saml_idp_url=None, saml_metadata_url=None, type=None, update_time=None, __props__=None, __name__=None, __opts__=None)

Create a AccountAuthentication resource with the given unique name, props, and options. :param str resource_name: The name of the resource. :param pulumi.ResourceOptions opts: Options for the resource. :param pulumi.Input[str] account_id: Account id :param pulumi.Input[str] authentication_id: Account authentication id :param pulumi.Input[str] create_time: Time of creation :param pulumi.Input[bool] enabled: Status of account authentication method :param pulumi.Input[str] name: Account team name :param pulumi.Input[str] saml_acs_url: SAML Assertion Consumer Service URL :param pulumi.Input[str] saml_certificate: SAML Certificate :param pulumi.Input[str] saml_entity_id: SAML Entity id :param pulumi.Input[str] saml_idp_url: SAML Idp URL :param pulumi.Input[str] saml_metadata_url: SAML Metadata URL :param pulumi.Input[str] type: Account authentication id :param pulumi.Input[str] update_time: Time of last update

account_id: pulumi.Output[str] = None

Account id

authentication_id: pulumi.Output[str] = None

Account authentication id

create_time: pulumi.Output[str] = None

Time of creation

enabled: pulumi.Output[bool] = None

Status of account authentication method

name: pulumi.Output[str] = None

Account team name

saml_acs_url: pulumi.Output[str] = None

SAML Assertion Consumer Service URL

saml_certificate: pulumi.Output[str] = None

SAML Certificate

saml_entity_id: pulumi.Output[str] = None

SAML Entity id

saml_idp_url: pulumi.Output[str] = None

SAML Idp URL

saml_metadata_url: pulumi.Output[str] = None

SAML Metadata URL

type: pulumi.Output[str] = None

Account authentication id

update_time: pulumi.Output[str] = None

Time of last update

static get(resource_name, id, opts=None, account_id=None, authentication_id=None, create_time=None, enabled=None, name=None, saml_acs_url=None, saml_certificate=None, saml_entity_id=None, saml_idp_url=None, saml_metadata_url=None, type=None, update_time=None)

Get an existing AccountAuthentication resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • account_id (pulumi.Input[str]) – Account id

  • authentication_id (pulumi.Input[str]) – Account authentication id

  • create_time (pulumi.Input[str]) – Time of creation

  • enabled (pulumi.Input[bool]) – Status of account authentication method

  • name (pulumi.Input[str]) – Account team name

  • saml_acs_url (pulumi.Input[str]) – SAML Assertion Consumer Service URL

  • saml_certificate (pulumi.Input[str]) – SAML Certificate

  • saml_entity_id (pulumi.Input[str]) – SAML Entity id

  • saml_idp_url (pulumi.Input[str]) – SAML Idp URL

  • saml_metadata_url (pulumi.Input[str]) – SAML Metadata URL

  • type (pulumi.Input[str]) – Account authentication id

  • update_time (pulumi.Input[str]) – Time of last update

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.AccountTeam(resource_name, opts=None, account_id=None, create_time=None, name=None, update_time=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

account_team1 = aiven.AccountTeam("accountTeam1", account_id=aiven_account["team"]["account_id"])
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • account_id (pulumi.Input[str]) – Account id

  • create_time (pulumi.Input[str]) – Time of creation

  • name (pulumi.Input[str]) – Account team name

  • update_time (pulumi.Input[str]) – Time of last update

account_id: pulumi.Output[str] = None

Account id

create_time: pulumi.Output[str] = None

Time of creation

name: pulumi.Output[str] = None

Account team name

team_id: pulumi.Output[str] = None

Account team id

update_time: pulumi.Output[str] = None

Time of last update

static get(resource_name, id, opts=None, account_id=None, create_time=None, name=None, team_id=None, update_time=None)

Get an existing AccountTeam resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • account_id (pulumi.Input[str]) – Account id

  • create_time (pulumi.Input[str]) – Time of creation

  • name (pulumi.Input[str]) – Account team name

  • team_id (pulumi.Input[str]) – Account team id

  • update_time (pulumi.Input[str]) – Time of last update

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.AccountTeamMember(resource_name, opts=None, accepted=None, account_id=None, create_time=None, invited_by_user_email=None, team_id=None, user_email=None, __props__=None, __name__=None, __opts__=None)

During the creation of .AccountTeamMember resource, an email invitation will be sent to a user using user_email address. If the user accepts an invitation, he or she will become a member of the account team. The deletion of .AccountTeamMember will not only delete invitation if one was sent but not yet accepted by the user, and it will also eliminate an account team member if one has accepted an invitation previously.

import pulumi
import pulumi_aiven as aiven

foo = aiven.AccountTeamMember("foo",
    account_id=aiven_account["developers"]["account_id"],
    team_id=aiven_account["developers"]["account_id"],
    user_email="user+1@example.com")
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • accepted (pulumi.Input[bool]) – Team member invitation status

  • account_id (pulumi.Input[str]) – Account id

  • create_time (pulumi.Input[str]) – Time of creation

  • invited_by_user_email (pulumi.Input[str]) – Team invited by user email

  • team_id (pulumi.Input[str]) – Account team id

  • user_email (pulumi.Input[str]) – Team invite user email

accepted: pulumi.Output[bool] = None

Team member invitation status

account_id: pulumi.Output[str] = None

Account id

create_time: pulumi.Output[str] = None

Time of creation

invited_by_user_email: pulumi.Output[str] = None

Team invited by user email

team_id: pulumi.Output[str] = None

Account team id

user_email: pulumi.Output[str] = None

Team invite user email

static get(resource_name, id, opts=None, accepted=None, account_id=None, create_time=None, invited_by_user_email=None, team_id=None, user_email=None)

Get an existing AccountTeamMember resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • accepted (pulumi.Input[bool]) – Team member invitation status

  • account_id (pulumi.Input[str]) – Account id

  • create_time (pulumi.Input[str]) – Time of creation

  • invited_by_user_email (pulumi.Input[str]) – Team invited by user email

  • team_id (pulumi.Input[str]) – Account team id

  • user_email (pulumi.Input[str]) – Team invite user email

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.AccountTeamProject(resource_name, opts=None, account_id=None, project_name=None, team_id=None, team_type=None, __props__=None, __name__=None, __opts__=None)

The account team project is intended to link and existing project to the existing account team. It is important to note that the project should have an account_id property set and equal to account team you are trying to link this project.

import pulumi
import pulumi_aiven as aiven

project1 = aiven.Project("project1",
    account_id=aiven_account_team["developers"]["account_id"],
    project="project-1")
account_team_project1 = aiven.AccountTeamProject("accountTeamProject1",
    account_id=aiven_account_team["developers"]["account_id"],
    project_name=project1.project,
    team_id=aiven_account_team["developers"]["team_id"],
    team_type="admin")
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • account_id (pulumi.Input[str]) – Account id

  • project_name (pulumi.Input[str]) – Account team project name

  • team_id (pulumi.Input[str]) – Account team id

  • team_type (pulumi.Input[str]) – Account team project type, can one of the following values: admin, developer, operator and read_only

account_id: pulumi.Output[str] = None

Account id

project_name: pulumi.Output[str] = None

Account team project name

team_id: pulumi.Output[str] = None

Account team id

team_type: pulumi.Output[str] = None

Account team project type, can one of the following values: admin, developer, operator and read_only

static get(resource_name, id, opts=None, account_id=None, project_name=None, team_id=None, team_type=None)

Get an existing AccountTeamProject resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • account_id (pulumi.Input[str]) – Account id

  • project_name (pulumi.Input[str]) – Account team project name

  • team_id (pulumi.Input[str]) – Account team id

  • team_type (pulumi.Input[str]) – Account team project type, can one of the following values: admin, developer, operator and read_only

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.AwaitableGetAccountAuthenticationResult(account_id=None, authentication_id=None, create_time=None, enabled=None, id=None, name=None, saml_acs_url=None, saml_certificate=None, saml_entity_id=None, saml_idp_url=None, saml_metadata_url=None, type=None, update_time=None)
class pulumi_aiven.AwaitableGetAccountResult(account_id=None, create_time=None, id=None, name=None, owner_team_id=None, tenant_id=None, update_time=None)
class pulumi_aiven.AwaitableGetAccountTeamMemberResult(accepted=None, account_id=None, create_time=None, id=None, invited_by_user_email=None, team_id=None, user_email=None)
class pulumi_aiven.AwaitableGetAccountTeamProjectResult(account_id=None, id=None, project_name=None, team_id=None, team_type=None)
class pulumi_aiven.AwaitableGetAccountTeamResult(account_id=None, create_time=None, id=None, name=None, team_id=None, update_time=None)
class pulumi_aiven.AwaitableGetConnectionPoolResult(connection_uri=None, database_name=None, id=None, pool_mode=None, pool_name=None, pool_size=None, project=None, service_name=None, username=None)
class pulumi_aiven.AwaitableGetDatabaseResult(database_name=None, id=None, lc_collate=None, lc_ctype=None, project=None, service_name=None, termination_protection=None)
class pulumi_aiven.AwaitableGetElasticSearchAclResult(acls=None, enabled=None, extended_acl=None, id=None, project=None, service_name=None)
class pulumi_aiven.AwaitableGetKafkaAclResult(id=None, permission=None, project=None, service_name=None, topic=None, username=None)
class pulumi_aiven.AwaitableGetKafkaConnectorResult(config=None, connector_name=None, id=None, plugin_author=None, plugin_class=None, plugin_doc_url=None, plugin_title=None, plugin_type=None, plugin_version=None, project=None, service_name=None, tasks=None)
class pulumi_aiven.AwaitableGetKafkaSchemaConfigurationResult(id=None, project=None, schema=None, service_name=None, subject_name=None, version=None)
class pulumi_aiven.AwaitableGetKafkaSchemaResult(id=None, project=None, schema=None, service_name=None, subject_name=None, version=None)
class pulumi_aiven.AwaitableGetKafkaTopicResult(cleanup_policy=None, client_timeout=None, id=None, minimum_in_sync_replicas=None, partitions=None, project=None, replication=None, retention_bytes=None, retention_hours=None, service_name=None, termination_protection=None, topic_name=None)
class pulumi_aiven.AwaitableGetMirrorMakerReplicationFlowResult(enable=None, id=None, project=None, service_name=None, source_cluster=None, target_cluster=None, topics=None, topics_blacklists=None)
class pulumi_aiven.AwaitableGetProjectResult(account_id=None, billing_address=None, billing_emails=None, ca_cert=None, card_id=None, copy_from_project=None, country_code=None, id=None, project=None, technical_emails=None)
class pulumi_aiven.AwaitableGetProjectUserResult(accepted=None, email=None, id=None, member_type=None, project=None)
class pulumi_aiven.AwaitableGetProjectVpcResult(client_timeout=None, cloud_name=None, id=None, network_cidr=None, project=None, state=None)
class pulumi_aiven.AwaitableGetServiceIntegrationEndpointResult(datadog_user_config=None, endpoint_config=None, endpoint_name=None, endpoint_type=None, external_elasticsearch_logs_user_config=None, id=None, project=None, prometheus_user_config=None, rsyslog_user_config=None)
class pulumi_aiven.AwaitableGetServiceIntegrationResult(destination_endpoint_id=None, destination_service_name=None, id=None, integration_type=None, kafka_connect_user_config=None, kafka_mirrormaker_user_config=None, logs_user_config=None, mirrormaker_user_config=None, project=None, source_endpoint_id=None, source_service_name=None)
class pulumi_aiven.AwaitableGetServiceResult(cassandra=None, cassandra_user_config=None, client_timeout=None, cloud_name=None, components=None, elasticsearch=None, elasticsearch_user_config=None, grafana=None, grafana_user_config=None, id=None, influxdb=None, influxdb_user_config=None, kafka=None, kafka_connect=None, kafka_connect_user_config=None, kafka_mirrormaker=None, kafka_mirrormaker_user_config=None, kafka_user_config=None, maintenance_window_dow=None, maintenance_window_time=None, mysql=None, mysql_user_config=None, pg=None, pg_user_config=None, plan=None, project=None, project_vpc_id=None, redis=None, redis_user_config=None, service_host=None, service_integrations=None, service_name=None, service_password=None, service_port=None, service_type=None, service_uri=None, service_username=None, state=None, termination_protection=None)
class pulumi_aiven.AwaitableGetServiceUserResult(access_cert=None, access_key=None, id=None, password=None, project=None, service_name=None, type=None, username=None)
class pulumi_aiven.AwaitableGetVpcPeeringConnectionResult(client_timeout=None, id=None, peer_cloud_account=None, peer_region=None, peer_vpc=None, peering_connection_id=None, state=None, state_info=None, vpc_id=None)
class pulumi_aiven.ConnectionPool(resource_name, opts=None, database_name=None, pool_mode=None, pool_name=None, pool_size=None, project=None, service_name=None, username=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

mytestpool = aiven.ConnectionPool("mytestpool",
    database_name=aiven_database["mydatabase"]["database_name"],
    pool_mode="transaction",
    pool_name="mypool",
    pool_size=10,
    project=aiven_project["myproject"]["project"],
    service_name=aiven_service["myservice"]["service_name"],
    username=aiven_service_user["myserviceuser"]["username"])
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • database_name (pulumi.Input[str]) – Name of the database the pool connects to

  • pool_mode (pulumi.Input[str]) – Mode the pool operates in (session, transaction, statement)

  • pool_name (pulumi.Input[str]) – Name of the pool

  • pool_size (pulumi.Input[float]) – Number of connections the pool may create towards the backend server

  • project (pulumi.Input[str]) – Project to link the connection pool to

  • service_name (pulumi.Input[str]) – Service to link the connection pool to

  • username (pulumi.Input[str]) – Name of the service user used to connect to the database

connection_uri: pulumi.Output[str] = None

URI for connecting to the pool

database_name: pulumi.Output[str] = None

Name of the database the pool connects to

pool_mode: pulumi.Output[str] = None

Mode the pool operates in (session, transaction, statement)

pool_name: pulumi.Output[str] = None

Name of the pool

pool_size: pulumi.Output[float] = None

Number of connections the pool may create towards the backend server

project: pulumi.Output[str] = None

Project to link the connection pool to

service_name: pulumi.Output[str] = None

Service to link the connection pool to

username: pulumi.Output[str] = None

Name of the service user used to connect to the database

static get(resource_name, id, opts=None, connection_uri=None, database_name=None, pool_mode=None, pool_name=None, pool_size=None, project=None, service_name=None, username=None)

Get an existing ConnectionPool resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • connection_uri (pulumi.Input[str]) – URI for connecting to the pool

  • database_name (pulumi.Input[str]) – Name of the database the pool connects to

  • pool_mode (pulumi.Input[str]) – Mode the pool operates in (session, transaction, statement)

  • pool_name (pulumi.Input[str]) – Name of the pool

  • pool_size (pulumi.Input[float]) – Number of connections the pool may create towards the backend server

  • project (pulumi.Input[str]) – Project to link the connection pool to

  • service_name (pulumi.Input[str]) – Service to link the connection pool to

  • username (pulumi.Input[str]) – Name of the service user used to connect to the database

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.Database(resource_name, opts=None, database_name=None, lc_collate=None, lc_ctype=None, project=None, service_name=None, termination_protection=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

mydatabase = aiven.Database("mydatabase",
    database_name="<DATABASE_NAME>",
    project=aiven_project["myproject"]["project"],
    service_name=aiven_service["myservice"]["service_name"])
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • database_name (pulumi.Input[str]) – Service database name

  • lc_collate (pulumi.Input[str]) – Default string sort order (LC_COLLATE) of the database. Default value: en_US.UTF-8

  • lc_ctype (pulumi.Input[str]) – Default character classification (LC_CTYPE) of the database. Default value: en_US.UTF-8

  • project (pulumi.Input[str]) – Project to link the database to

  • service_name (pulumi.Input[str]) – Service to link the database to

  • termination_protection (pulumi.Input[bool]) – It is a Terraform client-side deletion protections, which prevents the database from being deleted by Terraform. It is recommended to enable this for any production databases containing critical data.

database_name: pulumi.Output[str] = None

Service database name

lc_collate: pulumi.Output[str] = None

Default string sort order (LC_COLLATE) of the database. Default value: en_US.UTF-8

lc_ctype: pulumi.Output[str] = None

Default character classification (LC_CTYPE) of the database. Default value: en_US.UTF-8

project: pulumi.Output[str] = None

Project to link the database to

service_name: pulumi.Output[str] = None

Service to link the database to

termination_protection: pulumi.Output[bool] = None

It is a Terraform client-side deletion protections, which prevents the database from being deleted by Terraform. It is recommended to enable this for any production databases containing critical data.

static get(resource_name, id, opts=None, database_name=None, lc_collate=None, lc_ctype=None, project=None, service_name=None, termination_protection=None)

Get an existing Database resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • database_name (pulumi.Input[str]) – Service database name

  • lc_collate (pulumi.Input[str]) – Default string sort order (LC_COLLATE) of the database. Default value: en_US.UTF-8

  • lc_ctype (pulumi.Input[str]) – Default character classification (LC_CTYPE) of the database. Default value: en_US.UTF-8

  • project (pulumi.Input[str]) – Project to link the database to

  • service_name (pulumi.Input[str]) – Service to link the database to

  • termination_protection (pulumi.Input[bool]) – It is a Terraform client-side deletion protections, which prevents the database from being deleted by Terraform. It is recommended to enable this for any production databases containing critical data.

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.ElasticSearchAcl(resource_name, opts=None, acls=None, enabled=None, extended_acl=None, project=None, service_name=None, __props__=None, __name__=None, __opts__=None)

Create a ElasticSearchAcl resource with the given unique name, props, and options. :param str resource_name: The name of the resource. :param pulumi.ResourceOptions opts: Options for the resource. :param pulumi.Input[list] acls: List of Elasticsearch ACLs :param pulumi.Input[bool] enabled: Enable Elasticsearch ACLs. When disabled authenticated service users have unrestricted access :param pulumi.Input[bool] extended_acl: Index rules can be applied in a limited fashion to the _mget, _msearch and _bulk APIs (and only those) by enabling the

ExtendedAcl option for the service. When it is enabled, users can use these APIs as long as all operations only target indexes they have been granted access to

Parameters
  • project (pulumi.Input[str]) – Project to link the Elasticsearch ACLs to

  • service_name (pulumi.Input[str]) – Service to link the Elasticsearch ACLs to

The acls object supports the following:

  • rules (pulumi.Input[list])

    • index (pulumi.Input[str])

    • permission (pulumi.Input[str])

  • username (pulumi.Input[str])

acls: pulumi.Output[list] = None

List of Elasticsearch ACLs

  • rules (list)

    • index (str)

    • permission (str)

  • username (str)

enabled: pulumi.Output[bool] = None

Enable Elasticsearch ACLs. When disabled authenticated service users have unrestricted access

extended_acl: pulumi.Output[bool] = None

Index rules can be applied in a limited fashion to the _mget, _msearch and _bulk APIs (and only those) by enabling the ExtendedAcl option for the service. When it is enabled, users can use these APIs as long as all operations only target indexes they have been granted access to

project: pulumi.Output[str] = None

Project to link the Elasticsearch ACLs to

service_name: pulumi.Output[str] = None

Service to link the Elasticsearch ACLs to

static get(resource_name, id, opts=None, acls=None, enabled=None, extended_acl=None, project=None, service_name=None)

Get an existing ElasticSearchAcl resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • acls (pulumi.Input[list]) – List of Elasticsearch ACLs

  • enabled (pulumi.Input[bool]) – Enable Elasticsearch ACLs. When disabled authenticated service users have unrestricted access

  • extended_acl (pulumi.Input[bool]) – Index rules can be applied in a limited fashion to the _mget, _msearch and _bulk APIs (and only those) by enabling the ExtendedAcl option for the service. When it is enabled, users can use these APIs as long as all operations only target indexes they have been granted access to

  • project (pulumi.Input[str]) – Project to link the Elasticsearch ACLs to

  • service_name (pulumi.Input[str]) – Service to link the Elasticsearch ACLs to

The acls object supports the following:

  • rules (pulumi.Input[list])

    • index (pulumi.Input[str])

    • permission (pulumi.Input[str])

  • username (pulumi.Input[str])

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.GetAccountAuthenticationResult(account_id=None, authentication_id=None, create_time=None, enabled=None, id=None, name=None, saml_acs_url=None, saml_certificate=None, saml_entity_id=None, saml_idp_url=None, saml_metadata_url=None, type=None, update_time=None)

A collection of values returned by getAccountAuthentication.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetAccountResult(account_id=None, create_time=None, id=None, name=None, owner_team_id=None, tenant_id=None, update_time=None)

A collection of values returned by getAccount.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetAccountTeamMemberResult(accepted=None, account_id=None, create_time=None, id=None, invited_by_user_email=None, team_id=None, user_email=None)

A collection of values returned by getAccountTeamMember.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetAccountTeamProjectResult(account_id=None, id=None, project_name=None, team_id=None, team_type=None)

A collection of values returned by getAccountTeamProject.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetAccountTeamResult(account_id=None, create_time=None, id=None, name=None, team_id=None, update_time=None)

A collection of values returned by getAccountTeam.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetConnectionPoolResult(connection_uri=None, database_name=None, id=None, pool_mode=None, pool_name=None, pool_size=None, project=None, service_name=None, username=None)

A collection of values returned by getConnectionPool.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetDatabaseResult(database_name=None, id=None, lc_collate=None, lc_ctype=None, project=None, service_name=None, termination_protection=None)

A collection of values returned by getDatabase.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetElasticSearchAclResult(acls=None, enabled=None, extended_acl=None, id=None, project=None, service_name=None)

A collection of values returned by getElasticSearchAcl.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetKafkaAclResult(id=None, permission=None, project=None, service_name=None, topic=None, username=None)

A collection of values returned by getKafkaAcl.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetKafkaConnectorResult(config=None, connector_name=None, id=None, plugin_author=None, plugin_class=None, plugin_doc_url=None, plugin_title=None, plugin_type=None, plugin_version=None, project=None, service_name=None, tasks=None)

A collection of values returned by getKafkaConnector.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetKafkaSchemaConfigurationResult(id=None, project=None, schema=None, service_name=None, subject_name=None, version=None)

A collection of values returned by getKafkaSchemaConfiguration.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetKafkaSchemaResult(id=None, project=None, schema=None, service_name=None, subject_name=None, version=None)

A collection of values returned by getKafkaSchema.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetKafkaTopicResult(cleanup_policy=None, client_timeout=None, id=None, minimum_in_sync_replicas=None, partitions=None, project=None, replication=None, retention_bytes=None, retention_hours=None, service_name=None, termination_protection=None, topic_name=None)

A collection of values returned by getKafkaTopic.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetMirrorMakerReplicationFlowResult(enable=None, id=None, project=None, service_name=None, source_cluster=None, target_cluster=None, topics=None, topics_blacklists=None)

A collection of values returned by getMirrorMakerReplicationFlow.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetProjectResult(account_id=None, billing_address=None, billing_emails=None, ca_cert=None, card_id=None, copy_from_project=None, country_code=None, id=None, project=None, technical_emails=None)

A collection of values returned by getProject.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetProjectUserResult(accepted=None, email=None, id=None, member_type=None, project=None)

A collection of values returned by getProjectUser.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetProjectVpcResult(client_timeout=None, cloud_name=None, id=None, network_cidr=None, project=None, state=None)

A collection of values returned by getProjectVpc.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetServiceIntegrationEndpointResult(datadog_user_config=None, endpoint_config=None, endpoint_name=None, endpoint_type=None, external_elasticsearch_logs_user_config=None, id=None, project=None, prometheus_user_config=None, rsyslog_user_config=None)

A collection of values returned by getServiceIntegrationEndpoint.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetServiceIntegrationResult(destination_endpoint_id=None, destination_service_name=None, id=None, integration_type=None, kafka_connect_user_config=None, kafka_mirrormaker_user_config=None, logs_user_config=None, mirrormaker_user_config=None, project=None, source_endpoint_id=None, source_service_name=None)

A collection of values returned by getServiceIntegration.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetServiceResult(cassandra=None, cassandra_user_config=None, client_timeout=None, cloud_name=None, components=None, elasticsearch=None, elasticsearch_user_config=None, grafana=None, grafana_user_config=None, id=None, influxdb=None, influxdb_user_config=None, kafka=None, kafka_connect=None, kafka_connect_user_config=None, kafka_mirrormaker=None, kafka_mirrormaker_user_config=None, kafka_user_config=None, maintenance_window_dow=None, maintenance_window_time=None, mysql=None, mysql_user_config=None, pg=None, pg_user_config=None, plan=None, project=None, project_vpc_id=None, redis=None, redis_user_config=None, service_host=None, service_integrations=None, service_name=None, service_password=None, service_port=None, service_type=None, service_uri=None, service_username=None, state=None, termination_protection=None)

A collection of values returned by getService.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetServiceUserResult(access_cert=None, access_key=None, id=None, password=None, project=None, service_name=None, type=None, username=None)

A collection of values returned by getServiceUser.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.GetVpcPeeringConnectionResult(client_timeout=None, id=None, peer_cloud_account=None, peer_region=None, peer_vpc=None, peering_connection_id=None, state=None, state_info=None, vpc_id=None)

A collection of values returned by getVpcPeeringConnection.

id = None

The provider-assigned unique ID for this managed resource.

class pulumi_aiven.KafkaAcl(resource_name, opts=None, permission=None, project=None, service_name=None, topic=None, username=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

mytestacl = aiven.KafkaAcl("mytestacl",
    permission="admin",
    project=aiven_project["myproject"]["project"],
    service_name=aiven_service["myservice"]["service_name"],
    topic="<TOPIC_NAME_PATTERN>",
    username="<USERNAME_PATTERN>")
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • permission (pulumi.Input[str]) – Kafka permission to grant (admin, read, readwrite, write)

  • project (pulumi.Input[str]) – Project to link the Kafka ACL to

  • service_name (pulumi.Input[str]) – Service to link the Kafka ACL to

  • topic (pulumi.Input[str]) – Topic name pattern for the ACL entry

  • username (pulumi.Input[str]) – Username pattern for the ACL entry

permission: pulumi.Output[str] = None

Kafka permission to grant (admin, read, readwrite, write)

project: pulumi.Output[str] = None

Project to link the Kafka ACL to

service_name: pulumi.Output[str] = None

Service to link the Kafka ACL to

topic: pulumi.Output[str] = None

Topic name pattern for the ACL entry

username: pulumi.Output[str] = None

Username pattern for the ACL entry

static get(resource_name, id, opts=None, permission=None, project=None, service_name=None, topic=None, username=None)

Get an existing KafkaAcl resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • permission (pulumi.Input[str]) – Kafka permission to grant (admin, read, readwrite, write)

  • project (pulumi.Input[str]) – Project to link the Kafka ACL to

  • service_name (pulumi.Input[str]) – Service to link the Kafka ACL to

  • topic (pulumi.Input[str]) – Topic name pattern for the ACL entry

  • username (pulumi.Input[str]) – Username pattern for the ACL entry

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.KafkaConnector(resource_name, opts=None, config=None, connector_name=None, project=None, service_name=None, __props__=None, __name__=None, __opts__=None)

Create a KafkaConnector resource with the given unique name, props, and options. :param str resource_name: The name of the resource. :param pulumi.ResourceOptions opts: Options for the resource. :param pulumi.Input[dict] config: Kafka Connector configuration parameters :param pulumi.Input[str] connector_name: Kafka connector name :param pulumi.Input[str] project: Project to link the kafka connector to :param pulumi.Input[str] service_name: Service to link the kafka connector to

config: pulumi.Output[dict] = None

Kafka Connector configuration parameters

connector_name: pulumi.Output[str] = None

Kafka connector name

plugin_author: pulumi.Output[str] = None

Kafka connector author

plugin_class: pulumi.Output[str] = None

Kafka connector Java class

plugin_doc_url: pulumi.Output[str] = None

Kafka connector documentation URL

plugin_title: pulumi.Output[str] = None

Kafka connector title

plugin_type: pulumi.Output[str] = None

Kafka connector type

plugin_version: pulumi.Output[str] = None

Kafka connector version

project: pulumi.Output[str] = None

Project to link the kafka connector to

service_name: pulumi.Output[str] = None

Service to link the kafka connector to

tasks: pulumi.Output[list] = None

List of tasks of a connector

  • connector (str)

  • task (float)

static get(resource_name, id, opts=None, config=None, connector_name=None, plugin_author=None, plugin_class=None, plugin_doc_url=None, plugin_title=None, plugin_type=None, plugin_version=None, project=None, service_name=None, tasks=None)

Get an existing KafkaConnector resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • config (pulumi.Input[dict]) – Kafka Connector configuration parameters

  • connector_name (pulumi.Input[str]) – Kafka connector name

  • plugin_author (pulumi.Input[str]) – Kafka connector author

  • plugin_class (pulumi.Input[str]) – Kafka connector Java class

  • plugin_doc_url (pulumi.Input[str]) – Kafka connector documentation URL

  • plugin_title (pulumi.Input[str]) – Kafka connector title

  • plugin_type (pulumi.Input[str]) – Kafka connector type

  • plugin_version (pulumi.Input[str]) – Kafka connector version

  • project (pulumi.Input[str]) – Project to link the kafka connector to

  • service_name (pulumi.Input[str]) – Service to link the kafka connector to

  • tasks (pulumi.Input[list]) – List of tasks of a connector

The tasks object supports the following:

  • connector (pulumi.Input[str])

  • task (pulumi.Input[float])

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.KafkaSchema(resource_name, opts=None, project=None, schema=None, service_name=None, subject_name=None, __props__=None, __name__=None, __opts__=None)

Create a KafkaSchema resource with the given unique name, props, and options. :param str resource_name: The name of the resource. :param pulumi.ResourceOptions opts: Options for the resource. :param pulumi.Input[str] project: Project to link the Kafka Schema to :param pulumi.Input[str] schema: Kafka Schema configuration should be a valid Avro Schema JSON format :param pulumi.Input[str] service_name: Service to link the Kafka Schema to :param pulumi.Input[str] subject_name: Kafka Schema Subject name

project: pulumi.Output[str] = None

Project to link the Kafka Schema to

schema: pulumi.Output[str] = None

Kafka Schema configuration should be a valid Avro Schema JSON format

service_name: pulumi.Output[str] = None

Service to link the Kafka Schema to

subject_name: pulumi.Output[str] = None

Kafka Schema Subject name

version: pulumi.Output[float] = None

Kafka Schema configuration version

static get(resource_name, id, opts=None, project=None, schema=None, service_name=None, subject_name=None, version=None)

Get an existing KafkaSchema resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • project (pulumi.Input[str]) – Project to link the Kafka Schema to

  • schema (pulumi.Input[str]) – Kafka Schema configuration should be a valid Avro Schema JSON format

  • service_name (pulumi.Input[str]) – Service to link the Kafka Schema to

  • subject_name (pulumi.Input[str]) – Kafka Schema Subject name

  • version (pulumi.Input[float]) – Kafka Schema configuration version

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.KafkaSchemaConfiguration(resource_name, opts=None, compatibility_level=None, project=None, service_name=None, __props__=None, __name__=None, __opts__=None)

Create a KafkaSchemaConfiguration resource with the given unique name, props, and options. :param str resource_name: The name of the resource. :param pulumi.ResourceOptions opts: Options for the resource. :param pulumi.Input[str] compatibility_level: Kafka Schemas compatibility level :param pulumi.Input[str] project: Project to link the Kafka Schemas Configuration to :param pulumi.Input[str] service_name: Service to link the Kafka Schemas Configuration to

compatibility_level: pulumi.Output[str] = None

Kafka Schemas compatibility level

project: pulumi.Output[str] = None

Project to link the Kafka Schemas Configuration to

service_name: pulumi.Output[str] = None

Service to link the Kafka Schemas Configuration to

static get(resource_name, id, opts=None, compatibility_level=None, project=None, service_name=None)

Get an existing KafkaSchemaConfiguration resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • compatibility_level (pulumi.Input[str]) – Kafka Schemas compatibility level

  • project (pulumi.Input[str]) – Project to link the Kafka Schemas Configuration to

  • service_name (pulumi.Input[str]) – Service to link the Kafka Schemas Configuration to

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.KafkaTopic(resource_name, opts=None, cleanup_policy=None, client_timeout=None, minimum_in_sync_replicas=None, partitions=None, project=None, replication=None, retention_bytes=None, retention_hours=None, service_name=None, termination_protection=None, topic_name=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

mytesttopic = aiven.KafkaTopic("mytesttopic",
    cleanup_policy="delete",
    minimum_in_sync_replicas=2,
    partitions=5,
    project=aiven_project["myproject"]["project"],
    replication=3,
    retention_bytes=-1,
    retention_hours=72,
    service_name=aiven_service["myservice"]["service_name"],
    topic_name="<TOPIC_NAME>")
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • cleanup_policy (pulumi.Input[str]) – Topic cleanup policy. Allowed values: delete, compact

  • client_timeout (pulumi.Input[dict]) – Custom Terraform Client timeouts

  • minimum_in_sync_replicas (pulumi.Input[float]) – Minimum required nodes in-sync replicas (ISR) to produce to a partition

  • partitions (pulumi.Input[float]) – Number of partitions to create in the topic

  • project (pulumi.Input[str]) – Project to link the kafka topic to

  • replication (pulumi.Input[float]) – Replication factor for the topic

  • retention_bytes (pulumi.Input[float]) – Retention bytes

  • retention_hours (pulumi.Input[float]) – Retention period (hours)

  • service_name (pulumi.Input[str]) – Service to link the kafka topic to

  • termination_protection (pulumi.Input[bool]) – It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.

  • topic_name (pulumi.Input[str]) – Topic name

The client_timeout object supports the following:

  • create (pulumi.Input[str])

  • read (pulumi.Input[str])

cleanup_policy: pulumi.Output[str] = None

Topic cleanup policy. Allowed values: delete, compact

client_timeout: pulumi.Output[dict] = None

Custom Terraform Client timeouts

  • create (str)

  • read (str)

minimum_in_sync_replicas: pulumi.Output[float] = None

Minimum required nodes in-sync replicas (ISR) to produce to a partition

partitions: pulumi.Output[float] = None

Number of partitions to create in the topic

project: pulumi.Output[str] = None

Project to link the kafka topic to

replication: pulumi.Output[float] = None

Replication factor for the topic

retention_bytes: pulumi.Output[float] = None

Retention bytes

retention_hours: pulumi.Output[float] = None

Retention period (hours)

service_name: pulumi.Output[str] = None

Service to link the kafka topic to

termination_protection: pulumi.Output[bool] = None

It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.

topic_name: pulumi.Output[str] = None

Topic name

static get(resource_name, id, opts=None, cleanup_policy=None, client_timeout=None, minimum_in_sync_replicas=None, partitions=None, project=None, replication=None, retention_bytes=None, retention_hours=None, service_name=None, termination_protection=None, topic_name=None)

Get an existing KafkaTopic resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • cleanup_policy (pulumi.Input[str]) – Topic cleanup policy. Allowed values: delete, compact

  • client_timeout (pulumi.Input[dict]) – Custom Terraform Client timeouts

  • minimum_in_sync_replicas (pulumi.Input[float]) – Minimum required nodes in-sync replicas (ISR) to produce to a partition

  • partitions (pulumi.Input[float]) – Number of partitions to create in the topic

  • project (pulumi.Input[str]) – Project to link the kafka topic to

  • replication (pulumi.Input[float]) – Replication factor for the topic

  • retention_bytes (pulumi.Input[float]) – Retention bytes

  • retention_hours (pulumi.Input[float]) – Retention period (hours)

  • service_name (pulumi.Input[str]) – Service to link the kafka topic to

  • termination_protection (pulumi.Input[bool]) – It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.

  • topic_name (pulumi.Input[str]) – Topic name

The client_timeout object supports the following:

  • create (pulumi.Input[str])

  • read (pulumi.Input[str])

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.MirrorMakerReplicationFlow(resource_name, opts=None, enable=None, project=None, service_name=None, source_cluster=None, target_cluster=None, topics=None, topics_blacklists=None, __props__=None, __name__=None, __opts__=None)

Create a MirrorMakerReplicationFlow resource with the given unique name, props, and options. :param str resource_name: The name of the resource. :param pulumi.ResourceOptions opts: Options for the resource. :param pulumi.Input[bool] enable: Enable of disable replication flows for a service :param pulumi.Input[str] project: Project to link the kafka topic to :param pulumi.Input[str] service_name: Service to link the kafka topic to :param pulumi.Input[str] source_cluster: Source cluster alias :param pulumi.Input[str] target_cluster: Target cluster alias :param pulumi.Input[list] topics: List of topics and/or regular expressions to replicate :param pulumi.Input[list] topics_blacklists: List of topics and/or regular expressions to not replicate.

enable: pulumi.Output[bool] = None

Enable of disable replication flows for a service

project: pulumi.Output[str] = None

Project to link the kafka topic to

service_name: pulumi.Output[str] = None

Service to link the kafka topic to

source_cluster: pulumi.Output[str] = None

Source cluster alias

target_cluster: pulumi.Output[str] = None

Target cluster alias

topics: pulumi.Output[list] = None

List of topics and/or regular expressions to replicate

topics_blacklists: pulumi.Output[list] = None

List of topics and/or regular expressions to not replicate.

static get(resource_name, id, opts=None, enable=None, project=None, service_name=None, source_cluster=None, target_cluster=None, topics=None, topics_blacklists=None)

Get an existing MirrorMakerReplicationFlow resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • enable (pulumi.Input[bool]) – Enable of disable replication flows for a service

  • project (pulumi.Input[str]) – Project to link the kafka topic to

  • service_name (pulumi.Input[str]) – Service to link the kafka topic to

  • source_cluster (pulumi.Input[str]) – Source cluster alias

  • target_cluster (pulumi.Input[str]) – Target cluster alias

  • topics (pulumi.Input[list]) – List of topics and/or regular expressions to replicate

  • topics_blacklists (pulumi.Input[list]) – List of topics and/or regular expressions to not replicate.

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.Project(resource_name, opts=None, account_id=None, billing_address=None, billing_emails=None, ca_cert=None, card_id=None, copy_from_project=None, country_code=None, project=None, technical_emails=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

myproject = aiven.Project("myproject",
    card_id="<FULL_CARD_ID/LAST4_DIGITS>",
    project="<PROJECT_NAME>")
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • account_id (pulumi.Input[str]) – Account ID

  • billing_address (pulumi.Input[str]) – Billing name and address of the project

  • billing_emails (pulumi.Input[list]) – Billing contact emails of the project

  • ca_cert (pulumi.Input[str]) – Project root CA. This is used by some services like Kafka to sign service certificate

  • card_id (pulumi.Input[str]) – Credit card ID

  • copy_from_project (pulumi.Input[str]) – Copy properties from another project. Only has effect when a new project is created.

  • country_code (pulumi.Input[str]) – Billing country code of the project

  • project (pulumi.Input[str]) – Project name

  • technical_emails (pulumi.Input[list]) – Technical contact emails of the project

account_id: pulumi.Output[str] = None

Account ID

billing_address: pulumi.Output[str] = None

Billing name and address of the project

billing_emails: pulumi.Output[list] = None

Billing contact emails of the project

ca_cert: pulumi.Output[str] = None

Project root CA. This is used by some services like Kafka to sign service certificate

card_id: pulumi.Output[str] = None

Credit card ID

copy_from_project: pulumi.Output[str] = None

Copy properties from another project. Only has effect when a new project is created.

country_code: pulumi.Output[str] = None

Billing country code of the project

project: pulumi.Output[str] = None

Project name

technical_emails: pulumi.Output[list] = None

Technical contact emails of the project

static get(resource_name, id, opts=None, account_id=None, billing_address=None, billing_emails=None, ca_cert=None, card_id=None, copy_from_project=None, country_code=None, project=None, technical_emails=None)

Get an existing Project resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • account_id (pulumi.Input[str]) – Account ID

  • billing_address (pulumi.Input[str]) – Billing name and address of the project

  • billing_emails (pulumi.Input[list]) – Billing contact emails of the project

  • ca_cert (pulumi.Input[str]) – Project root CA. This is used by some services like Kafka to sign service certificate

  • card_id (pulumi.Input[str]) – Credit card ID

  • copy_from_project (pulumi.Input[str]) – Copy properties from another project. Only has effect when a new project is created.

  • country_code (pulumi.Input[str]) – Billing country code of the project

  • project (pulumi.Input[str]) – Project name

  • technical_emails (pulumi.Input[list]) – Technical contact emails of the project

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.ProjectUser(resource_name, opts=None, email=None, member_type=None, project=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

mytestuser = aiven.ProjectUser("mytestuser",
    email="john.doe@example.com",
    member_type="admin",
    project=aiven_project["myproject"]["project"])
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • email (pulumi.Input[str]) – Email address of the user

  • member_type (pulumi.Input[str]) – Project membership type. One of: admin, developer, operator

  • project (pulumi.Input[str]) – The project the user belongs to

accepted: pulumi.Output[bool] = None

Whether the user has accepted project membership or not

email: pulumi.Output[str] = None

Email address of the user

member_type: pulumi.Output[str] = None

Project membership type. One of: admin, developer, operator

project: pulumi.Output[str] = None

The project the user belongs to

static get(resource_name, id, opts=None, accepted=None, email=None, member_type=None, project=None)

Get an existing ProjectUser resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • accepted (pulumi.Input[bool]) – Whether the user has accepted project membership or not

  • email (pulumi.Input[str]) – Email address of the user

  • member_type (pulumi.Input[str]) – Project membership type. One of: admin, developer, operator

  • project (pulumi.Input[str]) – The project the user belongs to

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.ProjectVpc(resource_name, opts=None, client_timeout=None, cloud_name=None, network_cidr=None, project=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

myvpc = aiven.ProjectVpc("myvpc",
    cloud_name="google-europe-west1",
    network_cidr="192.168.0.1/24",
    project=aiven_project["myproject"]["project"])
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • client_timeout (pulumi.Input[dict]) – Custom Terraform Client timeouts

  • cloud_name (pulumi.Input[str]) – Cloud the VPC is in

  • network_cidr (pulumi.Input[str]) – Network address range used by the VPC like 192.168.0.0/24

  • project (pulumi.Input[str]) – The project the VPC belongs to

The client_timeout object supports the following:

  • create (pulumi.Input[str])

  • delete (pulumi.Input[str])

client_timeout: pulumi.Output[dict] = None

Custom Terraform Client timeouts

  • create (str)

  • delete (str)

cloud_name: pulumi.Output[str] = None

Cloud the VPC is in

network_cidr: pulumi.Output[str] = None

Network address range used by the VPC like 192.168.0.0/24

project: pulumi.Output[str] = None

The project the VPC belongs to

state: pulumi.Output[str] = None

State of the VPC (APPROVED, ACTIVE, DELETING, DELETED)

static get(resource_name, id, opts=None, client_timeout=None, cloud_name=None, network_cidr=None, project=None, state=None)

Get an existing ProjectVpc resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • client_timeout (pulumi.Input[dict]) – Custom Terraform Client timeouts

  • cloud_name (pulumi.Input[str]) – Cloud the VPC is in

  • network_cidr (pulumi.Input[str]) – Network address range used by the VPC like 192.168.0.0/24

  • project (pulumi.Input[str]) – The project the VPC belongs to

  • state (pulumi.Input[str]) – State of the VPC (APPROVED, ACTIVE, DELETING, DELETED)

The client_timeout object supports the following:

  • create (pulumi.Input[str])

  • delete (pulumi.Input[str])

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.Provider(resource_name, opts=None, api_token=None, __props__=None, __name__=None, __opts__=None)

The provider type for the aiven 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 for more information.

Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • api_token (pulumi.Input[str]) – Aiven Authentication Token

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.Service(resource_name, opts=None, cassandra=None, cassandra_user_config=None, client_timeout=None, cloud_name=None, elasticsearch=None, elasticsearch_user_config=None, grafana=None, grafana_user_config=None, influxdb=None, influxdb_user_config=None, kafka=None, kafka_connect=None, kafka_connect_user_config=None, kafka_mirrormaker=None, kafka_mirrormaker_user_config=None, kafka_user_config=None, maintenance_window_dow=None, maintenance_window_time=None, mysql=None, mysql_user_config=None, pg=None, pg_user_config=None, plan=None, project=None, project_vpc_id=None, redis=None, redis_user_config=None, service_integrations=None, service_name=None, service_type=None, termination_protection=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

myservice = aiven.Service("myservice",
    cloud_name="google-europe-west1",
    pg_user_config={
        "ipFilter": ["0.0.0.0/0"],
        "pgVersion": "10",
    },
    plan="business-8",
    project=aiven_project["myproject"]["project"],
    project_vpc_id=aiven_project_vpc["vpc_gcp_europe_west1"]["id"],
    service_name="<SERVICE_NAME>",
    service_type="pg",
    termination_protection=True)
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • cassandra (pulumi.Input[dict]) – Cassandra specific server provided values

  • cassandra_user_config (pulumi.Input[dict]) – Cassandra specific user configurable settings

  • client_timeout (pulumi.Input[dict]) – Custom Terraform Client timeouts

  • cloud_name (pulumi.Input[str]) – Cloud the service runs in

  • elasticsearch (pulumi.Input[dict]) – Elasticsearch specific server provided values

  • elasticsearch_user_config (pulumi.Input[dict]) – Elasticsearch specific user configurable settings

  • grafana (pulumi.Input[dict]) – Grafana specific server provided values

  • grafana_user_config (pulumi.Input[dict]) – Grafana specific user configurable settings

  • influxdb (pulumi.Input[dict]) – InfluxDB specific server provided values

  • influxdb_user_config (pulumi.Input[dict]) – InfluxDB specific user configurable settings

  • kafka (pulumi.Input[dict]) – Kafka specific server provided values

  • kafka_connect (pulumi.Input[dict]) – Kafka Connect specific server provided values

  • kafka_connect_user_config (pulumi.Input[dict]) – Kafka Connect specific user configurable settings

  • kafka_mirrormaker (pulumi.Input[dict]) – Kafka MirrorMaker 2 specific server provided values

  • kafka_mirrormaker_user_config (pulumi.Input[dict]) – Kafka MirrorMaker 2 specific user configurable settings

  • kafka_user_config (pulumi.Input[dict]) – Kafka specific user configurable settings

  • maintenance_window_dow (pulumi.Input[str]) – Day of week when maintenance operations should be performed. One monday, tuesday, wednesday, etc.

  • maintenance_window_time (pulumi.Input[str]) – Time of day when maintenance operations should be performed. UTC time in HH:mm:ss format.

  • mysql (pulumi.Input[dict]) – MySQL specific server provided values

  • mysql_user_config (pulumi.Input[dict]) – MySQL specific user configurable settings

  • pg (pulumi.Input[dict]) – PostgreSQL specific server provided values

  • pg_user_config (pulumi.Input[dict]) – PostgreSQL specific user configurable settings

  • plan (pulumi.Input[str]) – Subscription plan

  • project (pulumi.Input[str]) – Target project

  • project_vpc_id (pulumi.Input[str]) – Identifier of the VPC the service should be in, if any

  • redis (pulumi.Input[dict]) – Redis specific server provided values

  • redis_user_config (pulumi.Input[dict]) – Redis specific user configurable settings

  • service_integrations (pulumi.Input[list]) – Service integrations to specify when creating a service. Not applied after initial service creation

  • service_name (pulumi.Input[str]) – Service name

  • service_type (pulumi.Input[str]) – Service type code

  • termination_protection (pulumi.Input[bool]) – Prevent service from being deleted. It is recommended to have this enabled for all services.

The cassandra_user_config object supports the following:

  • ipFilters (pulumi.Input[list])

  • migrateSstableloader (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

The client_timeout object supports the following:

  • create (pulumi.Input[str])

  • update (pulumi.Input[str])

The elasticsearch object supports the following:

  • kibanaUri (pulumi.Input[str])

The elasticsearch_user_config object supports the following:

  • customDomain (pulumi.Input[str])

  • disableReplicationFactorAdjustment (pulumi.Input[str])

  • elasticsearch (pulumi.Input[dict])

    • actionAutoCreateIndexEnabled (pulumi.Input[str])

    • actionDestructiveRequiresName (pulumi.Input[str])

    • httpMaxContentLength (pulumi.Input[str])

    • httpMaxHeaderSize (pulumi.Input[str])

    • httpMaxInitialLineLength (pulumi.Input[str])

    • indicesFielddataCacheSize (pulumi.Input[str])

    • indicesMemoryIndexBufferSize (pulumi.Input[str])

    • indicesQueriesCacheSize (pulumi.Input[str])

    • indicesQueryBoolMaxClauseCount (pulumi.Input[str])

    • reindexRemoteWhitelists (pulumi.Input[list])

    • threadPoolAnalyzeQueueSize (pulumi.Input[str])

    • threadPoolAnalyzeSize (pulumi.Input[str])

    • threadPoolForceMergeSize (pulumi.Input[str])

    • threadPoolGetQueueSize (pulumi.Input[str])

    • threadPoolGetSize (pulumi.Input[str])

    • threadPoolIndexQueueSize (pulumi.Input[str])

    • threadPoolIndexSize (pulumi.Input[str])

    • threadPoolSearchQueueSize (pulumi.Input[str])

    • threadPoolSearchSize (pulumi.Input[str])

    • threadPoolSearchThrottledQueueSize (pulumi.Input[str])

    • threadPoolSearchThrottledSize (pulumi.Input[str])

    • threadPoolWriteQueueSize (pulumi.Input[str])

    • threadPoolWriteSize (pulumi.Input[str])

  • elasticsearchVersion (pulumi.Input[str])

  • indexPatterns (pulumi.Input[list])

    • maxIndexCount (pulumi.Input[str])

    • pattern (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • kibana (pulumi.Input[dict])

    • elasticsearchRequestTimeout (pulumi.Input[str])

    • enabled (pulumi.Input[str])

    • maxOldSpaceSize (pulumi.Input[str])

  • maxIndexCount (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • elasticsearch (pulumi.Input[str])

    • kibana (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • elasticsearch (pulumi.Input[str])

    • kibana (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • recoveryBasebackupName (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

The grafana_user_config object supports the following:

  • alertingEnabled (pulumi.Input[str])

  • alertingErrorOrTimeout (pulumi.Input[str])

  • alertingNodataOrNullvalues (pulumi.Input[str])

  • allowEmbedding (pulumi.Input[str])

  • authBasicEnabled (pulumi.Input[str])

  • authGenericOauth (pulumi.Input[dict])

    • allowSignUp (pulumi.Input[str])

    • allowedDomains (pulumi.Input[list])

    • allowedOrganizations (pulumi.Input[list])

    • apiUrl (pulumi.Input[str])

    • authUrl (pulumi.Input[str])

    • clientId (pulumi.Input[str])

    • clientSecret (pulumi.Input[str])

    • name (pulumi.Input[str])

    • scopes (pulumi.Input[list])

    • tokenUrl (pulumi.Input[str])

  • authGithub (pulumi.Input[dict])

    • allowSignUp (pulumi.Input[str])

    • allowedOrganizations (pulumi.Input[list])

    • clientId (pulumi.Input[str])

    • clientSecret (pulumi.Input[str])

    • teamIds (pulumi.Input[list])

  • authGitlab (pulumi.Input[dict])

    • allowSignUp (pulumi.Input[str])

    • allowedGroups (pulumi.Input[list])

    • apiUrl (pulumi.Input[str])

    • authUrl (pulumi.Input[str])

    • clientId (pulumi.Input[str])

    • clientSecret (pulumi.Input[str])

    • tokenUrl (pulumi.Input[str])

  • authGoogle (pulumi.Input[dict])

    • allowSignUp (pulumi.Input[str])

    • allowedDomains (pulumi.Input[list])

    • clientId (pulumi.Input[str])

    • clientSecret (pulumi.Input[str])

  • cookieSamesite (pulumi.Input[str])

  • customDomain (pulumi.Input[str])

  • dashboardsVersionsToKeep (pulumi.Input[str])

  • dataproxySendUserHeader (pulumi.Input[str])

  • dataproxyTimeout (pulumi.Input[str])

  • disableGravatar (pulumi.Input[str])

  • editorsCanAdmin (pulumi.Input[str])

  • externalImageStorage (pulumi.Input[dict])

    • access_key (pulumi.Input[str])

    • bucketUrl (pulumi.Input[str])

    • provider (pulumi.Input[str])

    • secretKey (pulumi.Input[str])

  • googleAnalyticsUaId (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • metricsEnabled (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • grafana (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • grafana (pulumi.Input[str])

  • smtpServer (pulumi.Input[dict])

    • fromAddress (pulumi.Input[str])

    • fromName (pulumi.Input[str])

    • host (pulumi.Input[str])

    • password (pulumi.Input[str])

    • port (pulumi.Input[str])

    • skipVerify (pulumi.Input[str])

    • username (pulumi.Input[str])

  • userAutoAssignOrg (pulumi.Input[str])

  • userAutoAssignOrgRole (pulumi.Input[str])

  • viewersCanEdit (pulumi.Input[str])

The influxdb object supports the following:

  • database_name (pulumi.Input[str])

The influxdb_user_config object supports the following:

  • customDomain (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • privateAccess (pulumi.Input[dict])

    • influxdb (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • influxdb (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

The kafka object supports the following:

  • access_cert (pulumi.Input[str])

  • access_key (pulumi.Input[str])

  • connectUri (pulumi.Input[str])

  • restUri (pulumi.Input[str])

  • schemaRegistryUri (pulumi.Input[str])

The kafka_connect_user_config object supports the following:

  • ipFilters (pulumi.Input[list])

  • kafka_connect (pulumi.Input[dict])

    • consumerIsolationLevel (pulumi.Input[str])

    • consumerMaxPollRecords (pulumi.Input[str])

    • offsetFlushIntervalMs (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • kafka_connect (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • kafka_connect (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

The kafka_mirrormaker_user_config object supports the following:

  • ipFilters (pulumi.Input[list])

  • kafka_mirrormaker (pulumi.Input[dict])

    • refreshGroupsEnabled (pulumi.Input[str])

    • refreshGroupsIntervalSeconds (pulumi.Input[str])

    • refreshTopicsEnabled (pulumi.Input[str])

    • refreshTopicsIntervalSeconds (pulumi.Input[str])

The kafka_user_config object supports the following:

  • customDomain (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • kafka (pulumi.Input[dict])

    • autoCreateTopicsEnable (pulumi.Input[str])

    • compressionType (pulumi.Input[str])

    • connectionsMaxIdleMs (pulumi.Input[str])

    • defaultReplicationFactor (pulumi.Input[str])

    • groupMaxSessionTimeoutMs (pulumi.Input[str])

    • groupMinSessionTimeoutMs (pulumi.Input[str])

    • logCleanerMaxCompactionLagMs (pulumi.Input[str])

    • logCleanerMinCleanableRatio (pulumi.Input[str])

    • logCleanerMinCompactionLagMs (pulumi.Input[str])

    • logCleanupPolicy (pulumi.Input[str])

    • logMessageTimestampDifferenceMaxMs (pulumi.Input[str])

    • logMessageTimestampType (pulumi.Input[str])

    • logRetentionBytes (pulumi.Input[str])

    • logRetentionHours (pulumi.Input[str])

    • logSegmentBytes (pulumi.Input[str])

    • maxConnectionsPerIp (pulumi.Input[str])

    • messageMaxBytes (pulumi.Input[str])

    • numPartitions (pulumi.Input[str])

    • offsetsRetentionMinutes (pulumi.Input[str])

    • producerPurgatoryPurgeIntervalRequests (pulumi.Input[str])

    • replicaFetchMaxBytes (pulumi.Input[str])

    • replicaFetchResponseMaxBytes (pulumi.Input[str])

    • socketRequestMaxBytes (pulumi.Input[str])

  • kafkaAuthenticationMethods (pulumi.Input[dict])

    • certificate (pulumi.Input[str])

    • sasl (pulumi.Input[str])

  • kafka_connect (pulumi.Input[str])

  • kafkaConnectConfig (pulumi.Input[dict])

    • consumerIsolationLevel (pulumi.Input[str])

    • consumerMaxPollRecords (pulumi.Input[str])

    • offsetFlushIntervalMs (pulumi.Input[str])

  • kafkaRest (pulumi.Input[str])

  • kafkaRestConfig (pulumi.Input[dict])

    • consumerEnableAutoCommit (pulumi.Input[str])

    • consumerRequestMaxBytes (pulumi.Input[str])

    • consumerRequestTimeoutMs (pulumi.Input[str])

    • producerAcks (pulumi.Input[str])

    • producerLingerMs (pulumi.Input[str])

    • simpleconsumerPoolSizeMax (pulumi.Input[str])

  • kafkaVersion (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • kafka (pulumi.Input[str])

    • kafka_connect (pulumi.Input[str])

    • kafkaRest (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

    • schemaRegistry (pulumi.Input[str])

  • schemaRegistry (pulumi.Input[str])

The mysql_user_config object supports the following:

  • adminPassword (pulumi.Input[str])

  • adminUsername (pulumi.Input[str])

  • backupHour (pulumi.Input[str])

  • backupMinute (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • mysql (pulumi.Input[dict])

    • connectTimeout (pulumi.Input[str])

    • defaultTimeZone (pulumi.Input[str])

    • groupConcatMaxLen (pulumi.Input[str])

    • informationSchemaStatsExpiry (pulumi.Input[str])

    • innodbFtMinTokenSize (pulumi.Input[str])

    • innodbFtServerStopwordTable (pulumi.Input[str])

    • innodbLockWaitTimeout (pulumi.Input[str])

    • innodbLogBufferSize (pulumi.Input[str])

    • innodbOnlineAlterLogMaxSize (pulumi.Input[str])

    • innodbRollbackOnTimeout (pulumi.Input[str])

    • interactiveTimeout (pulumi.Input[str])

    • maxAllowedPacket (pulumi.Input[str])

    • maxHeapTableSize (pulumi.Input[str])

    • netReadTimeout (pulumi.Input[str])

    • netWriteTimeout (pulumi.Input[str])

    • sortBufferSize (pulumi.Input[str])

    • sqlMode (pulumi.Input[str])

    • sqlRequirePrimaryKey (pulumi.Input[str])

    • tmpTableSize (pulumi.Input[str])

    • waitTimeout (pulumi.Input[str])

  • mysqlVersion (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • mysql (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • mysql (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • recoveryTargetTime (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

The pg object supports the following:

  • dbname (pulumi.Input[str])

  • host (pulumi.Input[str])

  • password (pulumi.Input[str])

  • port (pulumi.Input[float])

  • replicaUri (pulumi.Input[str])

  • sslmode (pulumi.Input[str])

  • uri (pulumi.Input[str])

  • user (pulumi.Input[str])

The pg_user_config object supports the following:

  • adminPassword (pulumi.Input[str])

  • adminUsername (pulumi.Input[str])

  • backupHour (pulumi.Input[str])

  • backupMinute (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • pg (pulumi.Input[dict])

    • autovacuumAnalyzeScaleFactor (pulumi.Input[str])

    • autovacuumAnalyzeThreshold (pulumi.Input[str])

    • autovacuumFreezeMaxAge (pulumi.Input[str])

    • autovacuumMaxWorkers (pulumi.Input[str])

    • autovacuumNaptime (pulumi.Input[str])

    • autovacuumVacuumCostDelay (pulumi.Input[str])

    • autovacuumVacuumCostLimit (pulumi.Input[str])

    • autovacuumVacuumScaleFactor (pulumi.Input[str])

    • autovacuumVacuumThreshold (pulumi.Input[str])

    • deadlockTimeout (pulumi.Input[str])

    • idleInTransactionSessionTimeout (pulumi.Input[str])

    • jit (pulumi.Input[str])

    • logAutovacuumMinDuration (pulumi.Input[str])

    • logErrorVerbosity (pulumi.Input[str])

    • logMinDurationStatement (pulumi.Input[str])

    • maxLocksPerTransaction (pulumi.Input[str])

    • maxParallelWorkers (pulumi.Input[str])

    • maxParallelWorkersPerGather (pulumi.Input[str])

    • maxPredLocksPerTransaction (pulumi.Input[str])

    • maxPreparedTransactions (pulumi.Input[str])

    • maxStackDepth (pulumi.Input[str])

    • maxStandbyArchiveDelay (pulumi.Input[str])

    • maxStandbyStreamingDelay (pulumi.Input[str])

    • maxWorkerProcesses (pulumi.Input[str])

    • pgStatStatementsTrack (pulumi.Input[str])

    • tempFileLimit (pulumi.Input[str])

    • timezone (pulumi.Input[str])

    • trackActivityQuerySize (pulumi.Input[str])

    • trackCommitTimestamp (pulumi.Input[str])

    • trackFunctions (pulumi.Input[str])

    • walSenderTimeout (pulumi.Input[str])

    • walWriterDelay (pulumi.Input[str])

  • pgReadReplica (pulumi.Input[str])

  • pgServiceToForkFrom (pulumi.Input[str])

  • pgVersion (pulumi.Input[str])

  • pgbouncer (pulumi.Input[dict])

    • ignoreStartupParameters (pulumi.Input[list])

    • serverResetQueryAlways (pulumi.Input[str])

  • pglookout (pulumi.Input[dict])

    • maxFailoverReplicationTimeLag (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • pg (pulumi.Input[str])

    • pgbouncer (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • pg (pulumi.Input[str])

    • pgbouncer (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • recoveryTargetTime (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

  • synchronousReplication (pulumi.Input[str])

  • timescaledb (pulumi.Input[dict])

    • maxBackgroundWorkers (pulumi.Input[str])

  • variant (pulumi.Input[str])

The redis_user_config object supports the following:

  • ipFilters (pulumi.Input[list])

  • migration (pulumi.Input[dict])

    • host (pulumi.Input[str])

    • password (pulumi.Input[str])

    • port (pulumi.Input[str])

    • ssl (pulumi.Input[str])

    • username (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

    • redis (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

    • redis (pulumi.Input[str])

  • redisLfuDecayTime (pulumi.Input[str])

  • redisLfuLogFactor (pulumi.Input[str])

  • redisMaxmemoryPolicy (pulumi.Input[str])

  • redisNotifyKeyspaceEvents (pulumi.Input[str])

  • redisSsl (pulumi.Input[str])

  • redisTimeout (pulumi.Input[str])

The service_integrations object supports the following:

  • integration_type (pulumi.Input[str])

  • source_service_name (pulumi.Input[str])

cassandra: pulumi.Output[dict] = None

Cassandra specific server provided values

cassandra_user_config: pulumi.Output[dict] = None

Cassandra specific user configurable settings

  • ipFilters (list)

  • migrateSstableloader (str)

  • privateAccess (dict)

    • prometheus (str)

  • publicAccess (dict)

    • prometheus (str)

  • serviceToForkFrom (str)

client_timeout: pulumi.Output[dict] = None

Custom Terraform Client timeouts

  • create (str)

  • update (str)

cloud_name: pulumi.Output[str] = None

Cloud the service runs in

components: pulumi.Output[list] = None

Service component information objects

  • component (str)

  • host (str)

  • kafkaAuthenticationMethod (str)

  • port (float)

  • route (str)

  • ssl (bool)

  • usage (str)

elasticsearch: pulumi.Output[dict] = None

Elasticsearch specific server provided values

  • kibanaUri (str)

elasticsearch_user_config: pulumi.Output[dict] = None

Elasticsearch specific user configurable settings

  • customDomain (str)

  • disableReplicationFactorAdjustment (str)

  • elasticsearch (dict)

    • actionAutoCreateIndexEnabled (str)

    • actionDestructiveRequiresName (str)

    • httpMaxContentLength (str)

    • httpMaxHeaderSize (str)

    • httpMaxInitialLineLength (str)

    • indicesFielddataCacheSize (str)

    • indicesMemoryIndexBufferSize (str)

    • indicesQueriesCacheSize (str)

    • indicesQueryBoolMaxClauseCount (str)

    • reindexRemoteWhitelists (list)

    • threadPoolAnalyzeQueueSize (str)

    • threadPoolAnalyzeSize (str)

    • threadPoolForceMergeSize (str)

    • threadPoolGetQueueSize (str)

    • threadPoolGetSize (str)

    • threadPoolIndexQueueSize (str)

    • threadPoolIndexSize (str)

    • threadPoolSearchQueueSize (str)

    • threadPoolSearchSize (str)

    • threadPoolSearchThrottledQueueSize (str)

    • threadPoolSearchThrottledSize (str)

    • threadPoolWriteQueueSize (str)

    • threadPoolWriteSize (str)

  • elasticsearchVersion (str)

  • indexPatterns (list)

    • maxIndexCount (str)

    • pattern (str)

  • ipFilters (list)

  • kibana (dict)

    • elasticsearchRequestTimeout (str)

    • enabled (str)

    • maxOldSpaceSize (str)

  • maxIndexCount (str)

  • privateAccess (dict)

    • elasticsearch (str)

    • kibana (str)

    • prometheus (str)

  • publicAccess (dict)

    • elasticsearch (str)

    • kibana (str)

    • prometheus (str)

  • recoveryBasebackupName (str)

  • serviceToForkFrom (str)

grafana: pulumi.Output[dict] = None

Grafana specific server provided values

grafana_user_config: pulumi.Output[dict] = None

Grafana specific user configurable settings

  • alertingEnabled (str)

  • alertingErrorOrTimeout (str)

  • alertingNodataOrNullvalues (str)

  • allowEmbedding (str)

  • authBasicEnabled (str)

  • authGenericOauth (dict)

    • allowSignUp (str)

    • allowedDomains (list)

    • allowedOrganizations (list)

    • apiUrl (str)

    • authUrl (str)

    • clientId (str)

    • clientSecret (str)

    • name (str)

    • scopes (list)

    • tokenUrl (str)

  • authGithub (dict)

    • allowSignUp (str)

    • allowedOrganizations (list)

    • clientId (str)

    • clientSecret (str)

    • teamIds (list)

  • authGitlab (dict)

    • allowSignUp (str)

    • allowedGroups (list)

    • apiUrl (str)

    • authUrl (str)

    • clientId (str)

    • clientSecret (str)

    • tokenUrl (str)

  • authGoogle (dict)

    • allowSignUp (str)

    • allowedDomains (list)

    • clientId (str)

    • clientSecret (str)

  • cookieSamesite (str)

  • customDomain (str)

  • dashboardsVersionsToKeep (str)

  • dataproxySendUserHeader (str)

  • dataproxyTimeout (str)

  • disableGravatar (str)

  • editorsCanAdmin (str)

  • externalImageStorage (dict)

    • access_key (str)

    • bucketUrl (str)

    • provider (str)

    • secretKey (str)

  • googleAnalyticsUaId (str)

  • ipFilters (list)

  • metricsEnabled (str)

  • privateAccess (dict)

    • grafana (str)

  • publicAccess (dict)

    • grafana (str)

  • smtpServer (dict)

    • fromAddress (str)

    • fromName (str)

    • host (str)

    • password (str)

    • port (str)

    • skipVerify (str)

    • username (str)

  • userAutoAssignOrg (str)

  • userAutoAssignOrgRole (str)

  • viewersCanEdit (str)

influxdb: pulumi.Output[dict] = None

InfluxDB specific server provided values

  • database_name (str)

influxdb_user_config: pulumi.Output[dict] = None

InfluxDB specific user configurable settings

  • customDomain (str)

  • ipFilters (list)

  • privateAccess (dict)

    • influxdb (str)

  • publicAccess (dict)

    • influxdb (str)

  • serviceToForkFrom (str)

kafka: pulumi.Output[dict] = None

Kafka specific server provided values

  • access_cert (str)

  • access_key (str)

  • connectUri (str)

  • restUri (str)

  • schemaRegistryUri (str)

kafka_connect: pulumi.Output[dict] = None

Kafka Connect specific server provided values

kafka_connect_user_config: pulumi.Output[dict] = None

Kafka Connect specific user configurable settings

  • ipFilters (list)

  • kafka_connect (dict)

    • consumerIsolationLevel (str)

    • consumerMaxPollRecords (str)

    • offsetFlushIntervalMs (str)

  • privateAccess (dict)

    • kafka_connect (str)

    • prometheus (str)

  • publicAccess (dict)

    • kafka_connect (str)

    • prometheus (str)

kafka_mirrormaker: pulumi.Output[dict] = None

Kafka MirrorMaker 2 specific server provided values

kafka_mirrormaker_user_config: pulumi.Output[dict] = None

Kafka MirrorMaker 2 specific user configurable settings

  • ipFilters (list)

  • kafka_mirrormaker (dict)

    • refreshGroupsEnabled (str)

    • refreshGroupsIntervalSeconds (str)

    • refreshTopicsEnabled (str)

    • refreshTopicsIntervalSeconds (str)

kafka_user_config: pulumi.Output[dict] = None

Kafka specific user configurable settings

  • customDomain (str)

  • ipFilters (list)

  • kafka (dict)

    • autoCreateTopicsEnable (str)

    • compressionType (str)

    • connectionsMaxIdleMs (str)

    • defaultReplicationFactor (str)

    • groupMaxSessionTimeoutMs (str)

    • groupMinSessionTimeoutMs (str)

    • logCleanerMaxCompactionLagMs (str)

    • logCleanerMinCleanableRatio (str)

    • logCleanerMinCompactionLagMs (str)

    • logCleanupPolicy (str)

    • logMessageTimestampDifferenceMaxMs (str)

    • logMessageTimestampType (str)

    • logRetentionBytes (str)

    • logRetentionHours (str)

    • logSegmentBytes (str)

    • maxConnectionsPerIp (str)

    • messageMaxBytes (str)

    • numPartitions (str)

    • offsetsRetentionMinutes (str)

    • producerPurgatoryPurgeIntervalRequests (str)

    • replicaFetchMaxBytes (str)

    • replicaFetchResponseMaxBytes (str)

    • socketRequestMaxBytes (str)

  • kafkaAuthenticationMethods (dict)

    • certificate (str)

    • sasl (str)

  • kafka_connect (str)

  • kafkaConnectConfig (dict)

    • consumerIsolationLevel (str)

    • consumerMaxPollRecords (str)

    • offsetFlushIntervalMs (str)

  • kafkaRest (str)

  • kafkaRestConfig (dict)

    • consumerEnableAutoCommit (str)

    • consumerRequestMaxBytes (str)

    • consumerRequestTimeoutMs (str)

    • producerAcks (str)

    • producerLingerMs (str)

    • simpleconsumerPoolSizeMax (str)

  • kafkaVersion (str)

  • privateAccess (dict)

    • prometheus (str)

  • publicAccess (dict)

    • kafka (str)

    • kafka_connect (str)

    • kafkaRest (str)

    • prometheus (str)

    • schemaRegistry (str)

  • schemaRegistry (str)

maintenance_window_dow: pulumi.Output[str] = None

Day of week when maintenance operations should be performed. One monday, tuesday, wednesday, etc.

maintenance_window_time: pulumi.Output[str] = None

Time of day when maintenance operations should be performed. UTC time in HH:mm:ss format.

mysql: pulumi.Output[dict] = None

MySQL specific server provided values

mysql_user_config: pulumi.Output[dict] = None

MySQL specific user configurable settings

  • adminPassword (str)

  • adminUsername (str)

  • backupHour (str)

  • backupMinute (str)

  • ipFilters (list)

  • mysql (dict)

    • connectTimeout (str)

    • defaultTimeZone (str)

    • groupConcatMaxLen (str)

    • informationSchemaStatsExpiry (str)

    • innodbFtMinTokenSize (str)

    • innodbFtServerStopwordTable (str)

    • innodbLockWaitTimeout (str)

    • innodbLogBufferSize (str)

    • innodbOnlineAlterLogMaxSize (str)

    • innodbRollbackOnTimeout (str)

    • interactiveTimeout (str)

    • maxAllowedPacket (str)

    • maxHeapTableSize (str)

    • netReadTimeout (str)

    • netWriteTimeout (str)

    • sortBufferSize (str)

    • sqlMode (str)

    • sqlRequirePrimaryKey (str)

    • tmpTableSize (str)

    • waitTimeout (str)

  • mysqlVersion (str)

  • privateAccess (dict)

    • mysql (str)

    • prometheus (str)

  • publicAccess (dict)

    • mysql (str)

    • prometheus (str)

  • recoveryTargetTime (str)

  • serviceToForkFrom (str)

pg: pulumi.Output[dict] = None

PostgreSQL specific server provided values

  • dbname (str)

  • host (str)

  • password (str)

  • port (float)

  • replicaUri (str)

  • sslmode (str)

  • uri (str)

  • user (str)

pg_user_config: pulumi.Output[dict] = None

PostgreSQL specific user configurable settings

  • adminPassword (str)

  • adminUsername (str)

  • backupHour (str)

  • backupMinute (str)

  • ipFilters (list)

  • pg (dict)

    • autovacuumAnalyzeScaleFactor (str)

    • autovacuumAnalyzeThreshold (str)

    • autovacuumFreezeMaxAge (str)

    • autovacuumMaxWorkers (str)

    • autovacuumNaptime (str)

    • autovacuumVacuumCostDelay (str)

    • autovacuumVacuumCostLimit (str)

    • autovacuumVacuumScaleFactor (str)

    • autovacuumVacuumThreshold (str)

    • deadlockTimeout (str)

    • idleInTransactionSessionTimeout (str)

    • jit (str)

    • logAutovacuumMinDuration (str)

    • logErrorVerbosity (str)

    • logMinDurationStatement (str)

    • maxLocksPerTransaction (str)

    • maxParallelWorkers (str)

    • maxParallelWorkersPerGather (str)

    • maxPredLocksPerTransaction (str)

    • maxPreparedTransactions (str)

    • maxStackDepth (str)

    • maxStandbyArchiveDelay (str)

    • maxStandbyStreamingDelay (str)

    • maxWorkerProcesses (str)

    • pgStatStatementsTrack (str)

    • tempFileLimit (str)

    • timezone (str)

    • trackActivityQuerySize (str)

    • trackCommitTimestamp (str)

    • trackFunctions (str)

    • walSenderTimeout (str)

    • walWriterDelay (str)

  • pgReadReplica (str)

  • pgServiceToForkFrom (str)

  • pgVersion (str)

  • pgbouncer (dict)

    • ignoreStartupParameters (list)

    • serverResetQueryAlways (str)

  • pglookout (dict)

    • maxFailoverReplicationTimeLag (str)

  • privateAccess (dict)

    • pg (str)

    • pgbouncer (str)

    • prometheus (str)

  • publicAccess (dict)

    • pg (str)

    • pgbouncer (str)

    • prometheus (str)

  • recoveryTargetTime (str)

  • serviceToForkFrom (str)

  • synchronousReplication (str)

  • timescaledb (dict)

    • maxBackgroundWorkers (str)

  • variant (str)

plan: pulumi.Output[str] = None

Subscription plan

project: pulumi.Output[str] = None

Target project

project_vpc_id: pulumi.Output[str] = None

Identifier of the VPC the service should be in, if any

redis: pulumi.Output[dict] = None

Redis specific server provided values

redis_user_config: pulumi.Output[dict] = None

Redis specific user configurable settings

  • ipFilters (list)

  • migration (dict)

    • host (str)

    • password (str)

    • port (str)

    • ssl (str)

    • username (str)

  • privateAccess (dict)

    • prometheus (str)

    • redis (str)

  • publicAccess (dict)

    • prometheus (str)

    • redis (str)

  • redisLfuDecayTime (str)

  • redisLfuLogFactor (str)

  • redisMaxmemoryPolicy (str)

  • redisNotifyKeyspaceEvents (str)

  • redisSsl (str)

  • redisTimeout (str)

service_host: pulumi.Output[str] = None

Service hostname

service_integrations: pulumi.Output[list] = None

Service integrations to specify when creating a service. Not applied after initial service creation

  • integration_type (str)

  • source_service_name (str)

service_name: pulumi.Output[str] = None

Service name

service_password: pulumi.Output[str] = None

Password used for connecting to the service, if applicable

service_port: pulumi.Output[float] = None

Service port

service_type: pulumi.Output[str] = None

Service type code

service_uri: pulumi.Output[str] = None

URI for connecting to the service. Service specific info is under “kafka”, “pg”, etc.

service_username: pulumi.Output[str] = None

Username used for connecting to the service, if applicable

state: pulumi.Output[str] = None

Service state

termination_protection: pulumi.Output[bool] = None

Prevent service from being deleted. It is recommended to have this enabled for all services.

static get(resource_name, id, opts=None, cassandra=None, cassandra_user_config=None, client_timeout=None, cloud_name=None, components=None, elasticsearch=None, elasticsearch_user_config=None, grafana=None, grafana_user_config=None, influxdb=None, influxdb_user_config=None, kafka=None, kafka_connect=None, kafka_connect_user_config=None, kafka_mirrormaker=None, kafka_mirrormaker_user_config=None, kafka_user_config=None, maintenance_window_dow=None, maintenance_window_time=None, mysql=None, mysql_user_config=None, pg=None, pg_user_config=None, plan=None, project=None, project_vpc_id=None, redis=None, redis_user_config=None, service_host=None, service_integrations=None, service_name=None, service_password=None, service_port=None, service_type=None, service_uri=None, service_username=None, state=None, termination_protection=None)

Get an existing Service resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • cassandra (pulumi.Input[dict]) – Cassandra specific server provided values

  • cassandra_user_config (pulumi.Input[dict]) – Cassandra specific user configurable settings

  • client_timeout (pulumi.Input[dict]) – Custom Terraform Client timeouts

  • cloud_name (pulumi.Input[str]) – Cloud the service runs in

  • components (pulumi.Input[list]) – Service component information objects

  • elasticsearch (pulumi.Input[dict]) – Elasticsearch specific server provided values

  • elasticsearch_user_config (pulumi.Input[dict]) – Elasticsearch specific user configurable settings

  • grafana (pulumi.Input[dict]) – Grafana specific server provided values

  • grafana_user_config (pulumi.Input[dict]) – Grafana specific user configurable settings

  • influxdb (pulumi.Input[dict]) – InfluxDB specific server provided values

  • influxdb_user_config (pulumi.Input[dict]) – InfluxDB specific user configurable settings

  • kafka (pulumi.Input[dict]) – Kafka specific server provided values

  • kafka_connect (pulumi.Input[dict]) – Kafka Connect specific server provided values

  • kafka_connect_user_config (pulumi.Input[dict]) – Kafka Connect specific user configurable settings

  • kafka_mirrormaker (pulumi.Input[dict]) – Kafka MirrorMaker 2 specific server provided values

  • kafka_mirrormaker_user_config (pulumi.Input[dict]) – Kafka MirrorMaker 2 specific user configurable settings

  • kafka_user_config (pulumi.Input[dict]) – Kafka specific user configurable settings

  • maintenance_window_dow (pulumi.Input[str]) – Day of week when maintenance operations should be performed. One monday, tuesday, wednesday, etc.

  • maintenance_window_time (pulumi.Input[str]) – Time of day when maintenance operations should be performed. UTC time in HH:mm:ss format.

  • mysql (pulumi.Input[dict]) – MySQL specific server provided values

  • mysql_user_config (pulumi.Input[dict]) – MySQL specific user configurable settings

  • pg (pulumi.Input[dict]) – PostgreSQL specific server provided values

  • pg_user_config (pulumi.Input[dict]) – PostgreSQL specific user configurable settings

  • plan (pulumi.Input[str]) – Subscription plan

  • project (pulumi.Input[str]) – Target project

  • project_vpc_id (pulumi.Input[str]) – Identifier of the VPC the service should be in, if any

  • redis (pulumi.Input[dict]) – Redis specific server provided values

  • redis_user_config (pulumi.Input[dict]) – Redis specific user configurable settings

  • service_host (pulumi.Input[str]) – Service hostname

  • service_integrations (pulumi.Input[list]) – Service integrations to specify when creating a service. Not applied after initial service creation

  • service_name (pulumi.Input[str]) – Service name

  • service_password (pulumi.Input[str]) – Password used for connecting to the service, if applicable

  • service_port (pulumi.Input[float]) – Service port

  • service_type (pulumi.Input[str]) – Service type code

  • service_uri (pulumi.Input[str]) – URI for connecting to the service. Service specific info is under “kafka”, “pg”, etc.

  • service_username (pulumi.Input[str]) – Username used for connecting to the service, if applicable

  • state (pulumi.Input[str]) – Service state

  • termination_protection (pulumi.Input[bool]) – Prevent service from being deleted. It is recommended to have this enabled for all services.

The cassandra_user_config object supports the following:

  • ipFilters (pulumi.Input[list])

  • migrateSstableloader (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

The client_timeout object supports the following:

  • create (pulumi.Input[str])

  • update (pulumi.Input[str])

The components object supports the following:

  • component (pulumi.Input[str])

  • host (pulumi.Input[str])

  • kafkaAuthenticationMethod (pulumi.Input[str])

  • port (pulumi.Input[float])

  • route (pulumi.Input[str])

  • ssl (pulumi.Input[bool])

  • usage (pulumi.Input[str])

The elasticsearch object supports the following:

  • kibanaUri (pulumi.Input[str])

The elasticsearch_user_config object supports the following:

  • customDomain (pulumi.Input[str])

  • disableReplicationFactorAdjustment (pulumi.Input[str])

  • elasticsearch (pulumi.Input[dict])

    • actionAutoCreateIndexEnabled (pulumi.Input[str])

    • actionDestructiveRequiresName (pulumi.Input[str])

    • httpMaxContentLength (pulumi.Input[str])

    • httpMaxHeaderSize (pulumi.Input[str])

    • httpMaxInitialLineLength (pulumi.Input[str])

    • indicesFielddataCacheSize (pulumi.Input[str])

    • indicesMemoryIndexBufferSize (pulumi.Input[str])

    • indicesQueriesCacheSize (pulumi.Input[str])

    • indicesQueryBoolMaxClauseCount (pulumi.Input[str])

    • reindexRemoteWhitelists (pulumi.Input[list])

    • threadPoolAnalyzeQueueSize (pulumi.Input[str])

    • threadPoolAnalyzeSize (pulumi.Input[str])

    • threadPoolForceMergeSize (pulumi.Input[str])

    • threadPoolGetQueueSize (pulumi.Input[str])

    • threadPoolGetSize (pulumi.Input[str])

    • threadPoolIndexQueueSize (pulumi.Input[str])

    • threadPoolIndexSize (pulumi.Input[str])

    • threadPoolSearchQueueSize (pulumi.Input[str])

    • threadPoolSearchSize (pulumi.Input[str])

    • threadPoolSearchThrottledQueueSize (pulumi.Input[str])

    • threadPoolSearchThrottledSize (pulumi.Input[str])

    • threadPoolWriteQueueSize (pulumi.Input[str])

    • threadPoolWriteSize (pulumi.Input[str])

  • elasticsearchVersion (pulumi.Input[str])

  • indexPatterns (pulumi.Input[list])

    • maxIndexCount (pulumi.Input[str])

    • pattern (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • kibana (pulumi.Input[dict])

    • elasticsearchRequestTimeout (pulumi.Input[str])

    • enabled (pulumi.Input[str])

    • maxOldSpaceSize (pulumi.Input[str])

  • maxIndexCount (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • elasticsearch (pulumi.Input[str])

    • kibana (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • elasticsearch (pulumi.Input[str])

    • kibana (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • recoveryBasebackupName (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

The grafana_user_config object supports the following:

  • alertingEnabled (pulumi.Input[str])

  • alertingErrorOrTimeout (pulumi.Input[str])

  • alertingNodataOrNullvalues (pulumi.Input[str])

  • allowEmbedding (pulumi.Input[str])

  • authBasicEnabled (pulumi.Input[str])

  • authGenericOauth (pulumi.Input[dict])

    • allowSignUp (pulumi.Input[str])

    • allowedDomains (pulumi.Input[list])

    • allowedOrganizations (pulumi.Input[list])

    • apiUrl (pulumi.Input[str])

    • authUrl (pulumi.Input[str])

    • clientId (pulumi.Input[str])

    • clientSecret (pulumi.Input[str])

    • name (pulumi.Input[str])

    • scopes (pulumi.Input[list])

    • tokenUrl (pulumi.Input[str])

  • authGithub (pulumi.Input[dict])

    • allowSignUp (pulumi.Input[str])

    • allowedOrganizations (pulumi.Input[list])

    • clientId (pulumi.Input[str])

    • clientSecret (pulumi.Input[str])

    • teamIds (pulumi.Input[list])

  • authGitlab (pulumi.Input[dict])

    • allowSignUp (pulumi.Input[str])

    • allowedGroups (pulumi.Input[list])

    • apiUrl (pulumi.Input[str])

    • authUrl (pulumi.Input[str])

    • clientId (pulumi.Input[str])

    • clientSecret (pulumi.Input[str])

    • tokenUrl (pulumi.Input[str])

  • authGoogle (pulumi.Input[dict])

    • allowSignUp (pulumi.Input[str])

    • allowedDomains (pulumi.Input[list])

    • clientId (pulumi.Input[str])

    • clientSecret (pulumi.Input[str])

  • cookieSamesite (pulumi.Input[str])

  • customDomain (pulumi.Input[str])

  • dashboardsVersionsToKeep (pulumi.Input[str])

  • dataproxySendUserHeader (pulumi.Input[str])

  • dataproxyTimeout (pulumi.Input[str])

  • disableGravatar (pulumi.Input[str])

  • editorsCanAdmin (pulumi.Input[str])

  • externalImageStorage (pulumi.Input[dict])

    • access_key (pulumi.Input[str])

    • bucketUrl (pulumi.Input[str])

    • provider (pulumi.Input[str])

    • secretKey (pulumi.Input[str])

  • googleAnalyticsUaId (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • metricsEnabled (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • grafana (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • grafana (pulumi.Input[str])

  • smtpServer (pulumi.Input[dict])

    • fromAddress (pulumi.Input[str])

    • fromName (pulumi.Input[str])

    • host (pulumi.Input[str])

    • password (pulumi.Input[str])

    • port (pulumi.Input[str])

    • skipVerify (pulumi.Input[str])

    • username (pulumi.Input[str])

  • userAutoAssignOrg (pulumi.Input[str])

  • userAutoAssignOrgRole (pulumi.Input[str])

  • viewersCanEdit (pulumi.Input[str])

The influxdb object supports the following:

  • database_name (pulumi.Input[str])

The influxdb_user_config object supports the following:

  • customDomain (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • privateAccess (pulumi.Input[dict])

    • influxdb (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • influxdb (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

The kafka object supports the following:

  • access_cert (pulumi.Input[str])

  • access_key (pulumi.Input[str])

  • connectUri (pulumi.Input[str])

  • restUri (pulumi.Input[str])

  • schemaRegistryUri (pulumi.Input[str])

The kafka_connect_user_config object supports the following:

  • ipFilters (pulumi.Input[list])

  • kafka_connect (pulumi.Input[dict])

    • consumerIsolationLevel (pulumi.Input[str])

    • consumerMaxPollRecords (pulumi.Input[str])

    • offsetFlushIntervalMs (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • kafka_connect (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • kafka_connect (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

The kafka_mirrormaker_user_config object supports the following:

  • ipFilters (pulumi.Input[list])

  • kafka_mirrormaker (pulumi.Input[dict])

    • refreshGroupsEnabled (pulumi.Input[str])

    • refreshGroupsIntervalSeconds (pulumi.Input[str])

    • refreshTopicsEnabled (pulumi.Input[str])

    • refreshTopicsIntervalSeconds (pulumi.Input[str])

The kafka_user_config object supports the following:

  • customDomain (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • kafka (pulumi.Input[dict])

    • autoCreateTopicsEnable (pulumi.Input[str])

    • compressionType (pulumi.Input[str])

    • connectionsMaxIdleMs (pulumi.Input[str])

    • defaultReplicationFactor (pulumi.Input[str])

    • groupMaxSessionTimeoutMs (pulumi.Input[str])

    • groupMinSessionTimeoutMs (pulumi.Input[str])

    • logCleanerMaxCompactionLagMs (pulumi.Input[str])

    • logCleanerMinCleanableRatio (pulumi.Input[str])

    • logCleanerMinCompactionLagMs (pulumi.Input[str])

    • logCleanupPolicy (pulumi.Input[str])

    • logMessageTimestampDifferenceMaxMs (pulumi.Input[str])

    • logMessageTimestampType (pulumi.Input[str])

    • logRetentionBytes (pulumi.Input[str])

    • logRetentionHours (pulumi.Input[str])

    • logSegmentBytes (pulumi.Input[str])

    • maxConnectionsPerIp (pulumi.Input[str])

    • messageMaxBytes (pulumi.Input[str])

    • numPartitions (pulumi.Input[str])

    • offsetsRetentionMinutes (pulumi.Input[str])

    • producerPurgatoryPurgeIntervalRequests (pulumi.Input[str])

    • replicaFetchMaxBytes (pulumi.Input[str])

    • replicaFetchResponseMaxBytes (pulumi.Input[str])

    • socketRequestMaxBytes (pulumi.Input[str])

  • kafkaAuthenticationMethods (pulumi.Input[dict])

    • certificate (pulumi.Input[str])

    • sasl (pulumi.Input[str])

  • kafka_connect (pulumi.Input[str])

  • kafkaConnectConfig (pulumi.Input[dict])

    • consumerIsolationLevel (pulumi.Input[str])

    • consumerMaxPollRecords (pulumi.Input[str])

    • offsetFlushIntervalMs (pulumi.Input[str])

  • kafkaRest (pulumi.Input[str])

  • kafkaRestConfig (pulumi.Input[dict])

    • consumerEnableAutoCommit (pulumi.Input[str])

    • consumerRequestMaxBytes (pulumi.Input[str])

    • consumerRequestTimeoutMs (pulumi.Input[str])

    • producerAcks (pulumi.Input[str])

    • producerLingerMs (pulumi.Input[str])

    • simpleconsumerPoolSizeMax (pulumi.Input[str])

  • kafkaVersion (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • kafka (pulumi.Input[str])

    • kafka_connect (pulumi.Input[str])

    • kafkaRest (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

    • schemaRegistry (pulumi.Input[str])

  • schemaRegistry (pulumi.Input[str])

The mysql_user_config object supports the following:

  • adminPassword (pulumi.Input[str])

  • adminUsername (pulumi.Input[str])

  • backupHour (pulumi.Input[str])

  • backupMinute (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • mysql (pulumi.Input[dict])

    • connectTimeout (pulumi.Input[str])

    • defaultTimeZone (pulumi.Input[str])

    • groupConcatMaxLen (pulumi.Input[str])

    • informationSchemaStatsExpiry (pulumi.Input[str])

    • innodbFtMinTokenSize (pulumi.Input[str])

    • innodbFtServerStopwordTable (pulumi.Input[str])

    • innodbLockWaitTimeout (pulumi.Input[str])

    • innodbLogBufferSize (pulumi.Input[str])

    • innodbOnlineAlterLogMaxSize (pulumi.Input[str])

    • innodbRollbackOnTimeout (pulumi.Input[str])

    • interactiveTimeout (pulumi.Input[str])

    • maxAllowedPacket (pulumi.Input[str])

    • maxHeapTableSize (pulumi.Input[str])

    • netReadTimeout (pulumi.Input[str])

    • netWriteTimeout (pulumi.Input[str])

    • sortBufferSize (pulumi.Input[str])

    • sqlMode (pulumi.Input[str])

    • sqlRequirePrimaryKey (pulumi.Input[str])

    • tmpTableSize (pulumi.Input[str])

    • waitTimeout (pulumi.Input[str])

  • mysqlVersion (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • mysql (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • mysql (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • recoveryTargetTime (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

The pg object supports the following:

  • dbname (pulumi.Input[str])

  • host (pulumi.Input[str])

  • password (pulumi.Input[str])

  • port (pulumi.Input[float])

  • replicaUri (pulumi.Input[str])

  • sslmode (pulumi.Input[str])

  • uri (pulumi.Input[str])

  • user (pulumi.Input[str])

The pg_user_config object supports the following:

  • adminPassword (pulumi.Input[str])

  • adminUsername (pulumi.Input[str])

  • backupHour (pulumi.Input[str])

  • backupMinute (pulumi.Input[str])

  • ipFilters (pulumi.Input[list])

  • pg (pulumi.Input[dict])

    • autovacuumAnalyzeScaleFactor (pulumi.Input[str])

    • autovacuumAnalyzeThreshold (pulumi.Input[str])

    • autovacuumFreezeMaxAge (pulumi.Input[str])

    • autovacuumMaxWorkers (pulumi.Input[str])

    • autovacuumNaptime (pulumi.Input[str])

    • autovacuumVacuumCostDelay (pulumi.Input[str])

    • autovacuumVacuumCostLimit (pulumi.Input[str])

    • autovacuumVacuumScaleFactor (pulumi.Input[str])

    • autovacuumVacuumThreshold (pulumi.Input[str])

    • deadlockTimeout (pulumi.Input[str])

    • idleInTransactionSessionTimeout (pulumi.Input[str])

    • jit (pulumi.Input[str])

    • logAutovacuumMinDuration (pulumi.Input[str])

    • logErrorVerbosity (pulumi.Input[str])

    • logMinDurationStatement (pulumi.Input[str])

    • maxLocksPerTransaction (pulumi.Input[str])

    • maxParallelWorkers (pulumi.Input[str])

    • maxParallelWorkersPerGather (pulumi.Input[str])

    • maxPredLocksPerTransaction (pulumi.Input[str])

    • maxPreparedTransactions (pulumi.Input[str])

    • maxStackDepth (pulumi.Input[str])

    • maxStandbyArchiveDelay (pulumi.Input[str])

    • maxStandbyStreamingDelay (pulumi.Input[str])

    • maxWorkerProcesses (pulumi.Input[str])

    • pgStatStatementsTrack (pulumi.Input[str])

    • tempFileLimit (pulumi.Input[str])

    • timezone (pulumi.Input[str])

    • trackActivityQuerySize (pulumi.Input[str])

    • trackCommitTimestamp (pulumi.Input[str])

    • trackFunctions (pulumi.Input[str])

    • walSenderTimeout (pulumi.Input[str])

    • walWriterDelay (pulumi.Input[str])

  • pgReadReplica (pulumi.Input[str])

  • pgServiceToForkFrom (pulumi.Input[str])

  • pgVersion (pulumi.Input[str])

  • pgbouncer (pulumi.Input[dict])

    • ignoreStartupParameters (pulumi.Input[list])

    • serverResetQueryAlways (pulumi.Input[str])

  • pglookout (pulumi.Input[dict])

    • maxFailoverReplicationTimeLag (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • pg (pulumi.Input[str])

    • pgbouncer (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • pg (pulumi.Input[str])

    • pgbouncer (pulumi.Input[str])

    • prometheus (pulumi.Input[str])

  • recoveryTargetTime (pulumi.Input[str])

  • serviceToForkFrom (pulumi.Input[str])

  • synchronousReplication (pulumi.Input[str])

  • timescaledb (pulumi.Input[dict])

    • maxBackgroundWorkers (pulumi.Input[str])

  • variant (pulumi.Input[str])

The redis_user_config object supports the following:

  • ipFilters (pulumi.Input[list])

  • migration (pulumi.Input[dict])

    • host (pulumi.Input[str])

    • password (pulumi.Input[str])

    • port (pulumi.Input[str])

    • ssl (pulumi.Input[str])

    • username (pulumi.Input[str])

  • privateAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

    • redis (pulumi.Input[str])

  • publicAccess (pulumi.Input[dict])

    • prometheus (pulumi.Input[str])

    • redis (pulumi.Input[str])

  • redisLfuDecayTime (pulumi.Input[str])

  • redisLfuLogFactor (pulumi.Input[str])

  • redisMaxmemoryPolicy (pulumi.Input[str])

  • redisNotifyKeyspaceEvents (pulumi.Input[str])

  • redisSsl (pulumi.Input[str])

  • redisTimeout (pulumi.Input[str])

The service_integrations object supports the following:

  • integration_type (pulumi.Input[str])

  • source_service_name (pulumi.Input[str])

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.ServiceIntegration(resource_name, opts=None, destination_endpoint_id=None, destination_service_name=None, integration_type=None, kafka_connect_user_config=None, kafka_mirrormaker_user_config=None, logs_user_config=None, mirrormaker_user_config=None, project=None, source_endpoint_id=None, source_service_name=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

myintegration = aiven.ServiceIntegration("myintegration",
    destination_endpoint_id=aiven_service_integration_endpoint["myendpoint"]["id"],
    destination_service_name="",
    integration_type="datadog",
    project=aiven_project["myproject"]["project"],
    source_endpoint_id="",
    source_service_name=aiven_service["testkafka"]["service_name"])
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • destination_endpoint_id (pulumi.Input[str]) – Destination endpoint for the integration (if any)

  • destination_service_name (pulumi.Input[str]) – Destination service for the integration (if any)

  • integration_type (pulumi.Input[str]) – Type of the service integration

  • kafka_connect_user_config (pulumi.Input[dict]) – Kafka Connect specific user configurable settings

  • kafka_mirrormaker_user_config (pulumi.Input[dict]) – Mirrormaker 2 integration specific user configurable settings

  • logs_user_config (pulumi.Input[dict]) – Log integration specific user configurable settings

  • mirrormaker_user_config (pulumi.Input[dict]) – Mirrormaker 1 integration specific user configurable settings

  • project (pulumi.Input[str]) – Project the integration belongs to

  • source_endpoint_id (pulumi.Input[str]) – Source endpoint for the integration (if any)

  • source_service_name (pulumi.Input[str]) – Source service for the integration (if any)

The kafka_connect_user_config object supports the following:

  • kafka_connect (pulumi.Input[dict])

    • configStorageTopic (pulumi.Input[str])

    • groupId (pulumi.Input[str])

    • offsetStorageTopic (pulumi.Input[str])

    • statusStorageTopic (pulumi.Input[str])

The kafka_mirrormaker_user_config object supports the following:

  • clusterAlias (pulumi.Input[str])

The logs_user_config object supports the following:

  • elasticsearchIndexDaysMax (pulumi.Input[str])

  • elasticsearchIndexPrefix (pulumi.Input[str])

The mirrormaker_user_config object supports the following:

  • mirrormakerWhitelist (pulumi.Input[str])

destination_endpoint_id: pulumi.Output[str] = None

Destination endpoint for the integration (if any)

destination_service_name: pulumi.Output[str] = None

Destination service for the integration (if any)

integration_type: pulumi.Output[str] = None

Type of the service integration

kafka_connect_user_config: pulumi.Output[dict] = None

Kafka Connect specific user configurable settings

  • kafka_connect (dict)

    • configStorageTopic (str)

    • groupId (str)

    • offsetStorageTopic (str)

    • statusStorageTopic (str)

kafka_mirrormaker_user_config: pulumi.Output[dict] = None

Mirrormaker 2 integration specific user configurable settings

  • clusterAlias (str)

logs_user_config: pulumi.Output[dict] = None

Log integration specific user configurable settings

  • elasticsearchIndexDaysMax (str)

  • elasticsearchIndexPrefix (str)

mirrormaker_user_config: pulumi.Output[dict] = None

Mirrormaker 1 integration specific user configurable settings

  • mirrormakerWhitelist (str)

project: pulumi.Output[str] = None

Project the integration belongs to

source_endpoint_id: pulumi.Output[str] = None

Source endpoint for the integration (if any)

source_service_name: pulumi.Output[str] = None

Source service for the integration (if any)

static get(resource_name, id, opts=None, destination_endpoint_id=None, destination_service_name=None, integration_type=None, kafka_connect_user_config=None, kafka_mirrormaker_user_config=None, logs_user_config=None, mirrormaker_user_config=None, project=None, source_endpoint_id=None, source_service_name=None)

Get an existing ServiceIntegration resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • destination_endpoint_id (pulumi.Input[str]) – Destination endpoint for the integration (if any)

  • destination_service_name (pulumi.Input[str]) – Destination service for the integration (if any)

  • integration_type (pulumi.Input[str]) – Type of the service integration

  • kafka_connect_user_config (pulumi.Input[dict]) – Kafka Connect specific user configurable settings

  • kafka_mirrormaker_user_config (pulumi.Input[dict]) – Mirrormaker 2 integration specific user configurable settings

  • logs_user_config (pulumi.Input[dict]) – Log integration specific user configurable settings

  • mirrormaker_user_config (pulumi.Input[dict]) – Mirrormaker 1 integration specific user configurable settings

  • project (pulumi.Input[str]) – Project the integration belongs to

  • source_endpoint_id (pulumi.Input[str]) – Source endpoint for the integration (if any)

  • source_service_name (pulumi.Input[str]) – Source service for the integration (if any)

The kafka_connect_user_config object supports the following:

  • kafka_connect (pulumi.Input[dict])

    • configStorageTopic (pulumi.Input[str])

    • groupId (pulumi.Input[str])

    • offsetStorageTopic (pulumi.Input[str])

    • statusStorageTopic (pulumi.Input[str])

The kafka_mirrormaker_user_config object supports the following:

  • clusterAlias (pulumi.Input[str])

The logs_user_config object supports the following:

  • elasticsearchIndexDaysMax (pulumi.Input[str])

  • elasticsearchIndexPrefix (pulumi.Input[str])

The mirrormaker_user_config object supports the following:

  • mirrormakerWhitelist (pulumi.Input[str])

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.ServiceIntegrationEndpoint(resource_name, opts=None, datadog_user_config=None, endpoint_name=None, endpoint_type=None, external_elasticsearch_logs_user_config=None, project=None, prometheus_user_config=None, rsyslog_user_config=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

myendpoint = aiven.ServiceIntegrationEndpoint("myendpoint",
    datadog_user_config={
        "datadogApiKey": "<DATADOG_API_KEY>",
    },
    endpoint_name="<ENDPOINT_NAME>",
    endpoint_type="datadog",
    project=aiven_project["myproject"]["project"])
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • datadog_user_config (pulumi.Input[dict]) – Datadog specific user configurable settings

  • endpoint_name (pulumi.Input[str]) – Name of the service integration endpoint

  • endpoint_type (pulumi.Input[str]) – Type of the service integration endpoint

  • external_elasticsearch_logs_user_config (pulumi.Input[dict]) – external elasticsearch specific user configurable settings

  • project (pulumi.Input[str]) – Project the service integration endpoint belongs to

  • prometheus_user_config (pulumi.Input[dict]) – Prometheus specific user configurable settings

  • rsyslog_user_config (pulumi.Input[dict]) – rsyslog specific user configurable settings

The datadog_user_config object supports the following:

  • datadogApiKey (pulumi.Input[str])

  • disableConsumerStats (pulumi.Input[str])

  • maxPartitionContexts (pulumi.Input[str])

  • site (pulumi.Input[str])

The external_elasticsearch_logs_user_config object supports the following:

  • ca (pulumi.Input[str])

  • indexDaysMax (pulumi.Input[str])

  • indexPrefix (pulumi.Input[str])

  • timeout (pulumi.Input[str])

  • url (pulumi.Input[str])

The prometheus_user_config object supports the following:

  • basicAuthPassword (pulumi.Input[str])

  • basicAuthUsername (pulumi.Input[str])

The rsyslog_user_config object supports the following:

  • ca (pulumi.Input[str])

  • cert (pulumi.Input[str])

  • format (pulumi.Input[str])

  • key (pulumi.Input[str])

  • logline (pulumi.Input[str])

  • port (pulumi.Input[str])

  • sd (pulumi.Input[str])

  • server (pulumi.Input[str])

  • tls (pulumi.Input[str])

datadog_user_config: pulumi.Output[dict] = None

Datadog specific user configurable settings

  • datadogApiKey (str)

  • disableConsumerStats (str)

  • maxPartitionContexts (str)

  • site (str)

endpoint_config: pulumi.Output[dict] = None

Integration endpoint specific backend configuration

endpoint_name: pulumi.Output[str] = None

Name of the service integration endpoint

endpoint_type: pulumi.Output[str] = None

Type of the service integration endpoint

external_elasticsearch_logs_user_config: pulumi.Output[dict] = None

external elasticsearch specific user configurable settings

  • ca (str)

  • indexDaysMax (str)

  • indexPrefix (str)

  • timeout (str)

  • url (str)

project: pulumi.Output[str] = None

Project the service integration endpoint belongs to

prometheus_user_config: pulumi.Output[dict] = None

Prometheus specific user configurable settings

  • basicAuthPassword (str)

  • basicAuthUsername (str)

rsyslog_user_config: pulumi.Output[dict] = None

rsyslog specific user configurable settings

  • ca (str)

  • cert (str)

  • format (str)

  • key (str)

  • logline (str)

  • port (str)

  • sd (str)

  • server (str)

  • tls (str)

static get(resource_name, id, opts=None, datadog_user_config=None, endpoint_config=None, endpoint_name=None, endpoint_type=None, external_elasticsearch_logs_user_config=None, project=None, prometheus_user_config=None, rsyslog_user_config=None)

Get an existing ServiceIntegrationEndpoint resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • datadog_user_config (pulumi.Input[dict]) – Datadog specific user configurable settings

  • endpoint_config (pulumi.Input[dict]) – Integration endpoint specific backend configuration

  • endpoint_name (pulumi.Input[str]) – Name of the service integration endpoint

  • endpoint_type (pulumi.Input[str]) – Type of the service integration endpoint

  • external_elasticsearch_logs_user_config (pulumi.Input[dict]) – external elasticsearch specific user configurable settings

  • project (pulumi.Input[str]) – Project the service integration endpoint belongs to

  • prometheus_user_config (pulumi.Input[dict]) – Prometheus specific user configurable settings

  • rsyslog_user_config (pulumi.Input[dict]) – rsyslog specific user configurable settings

The datadog_user_config object supports the following:

  • datadogApiKey (pulumi.Input[str])

  • disableConsumerStats (pulumi.Input[str])

  • maxPartitionContexts (pulumi.Input[str])

  • site (pulumi.Input[str])

The external_elasticsearch_logs_user_config object supports the following:

  • ca (pulumi.Input[str])

  • indexDaysMax (pulumi.Input[str])

  • indexPrefix (pulumi.Input[str])

  • timeout (pulumi.Input[str])

  • url (pulumi.Input[str])

The prometheus_user_config object supports the following:

  • basicAuthPassword (pulumi.Input[str])

  • basicAuthUsername (pulumi.Input[str])

The rsyslog_user_config object supports the following:

  • ca (pulumi.Input[str])

  • cert (pulumi.Input[str])

  • format (pulumi.Input[str])

  • key (pulumi.Input[str])

  • logline (pulumi.Input[str])

  • port (pulumi.Input[str])

  • sd (pulumi.Input[str])

  • server (pulumi.Input[str])

  • tls (pulumi.Input[str])

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.ServiceUser(resource_name, opts=None, project=None, service_name=None, username=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

myserviceuser = aiven.ServiceUser("myserviceuser",
    project=aiven_project["myproject"]["project"],
    service_name=aiven_service["myservice"]["service_name"],
    username="<USERNAME>")
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • project (pulumi.Input[str]) – Project to link the user to

  • service_name (pulumi.Input[str]) – Service to link the user to

  • username (pulumi.Input[str]) – Name of the user account

access_cert: pulumi.Output[str] = None

Access certificate for the user if applicable for the service in question

access_key: pulumi.Output[str] = None

Access certificate key for the user if applicable for the service in question

password: pulumi.Output[str] = None

Password of the user

project: pulumi.Output[str] = None

Project to link the user to

service_name: pulumi.Output[str] = None

Service to link the user to

type: pulumi.Output[str] = None

Type of the user account

username: pulumi.Output[str] = None

Name of the user account

static get(resource_name, id, opts=None, access_cert=None, access_key=None, password=None, project=None, service_name=None, type=None, username=None)

Get an existing ServiceUser resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • access_cert (pulumi.Input[str]) – Access certificate for the user if applicable for the service in question

  • access_key (pulumi.Input[str]) – Access certificate key for the user if applicable for the service in question

  • password (pulumi.Input[str]) – Password of the user

  • project (pulumi.Input[str]) – Project to link the user to

  • service_name (pulumi.Input[str]) – Service to link the user to

  • type (pulumi.Input[str]) – Type of the user account

  • username (pulumi.Input[str]) – Name of the user account

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aiven.VpcPeeringConnection(resource_name, opts=None, client_timeout=None, peer_cloud_account=None, peer_region=None, peer_vpc=None, vpc_id=None, __props__=None, __name__=None, __opts__=None)
import pulumi
import pulumi_aiven as aiven

mypeeringconnection = aiven.VpcPeeringConnection("mypeeringconnection",
    peer_cloud_account="<PEER_ACCOUNT_ID>",
    peer_region="<PEER_REGION>",
    peer_vpc="<PEER_VPC_ID/NAME>",
    vpc_id=aiven_project_vpc["myvpc"]["id"])
Parameters
  • resource_name (str) – The name of the resource.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • client_timeout (pulumi.Input[dict]) – Custom Terraform Client timeouts

  • peer_cloud_account (pulumi.Input[str]) – AWS account ID or GCP project ID of the peered VPC

  • peer_region (pulumi.Input[str]) – AWS region of the peered VPC (if not in the same region as Aiven VPC)

  • peer_vpc (pulumi.Input[str]) – AWS VPC ID or GCP VPC network name of the peered VPC

  • vpc_id (pulumi.Input[str]) – The VPC the peering connection belongs to

The client_timeout object supports the following:

  • create (pulumi.Input[str])

client_timeout: pulumi.Output[dict] = None

Custom Terraform Client timeouts

  • create (str)

peer_cloud_account: pulumi.Output[str] = None

AWS account ID or GCP project ID of the peered VPC

peer_region: pulumi.Output[str] = None

AWS region of the peered VPC (if not in the same region as Aiven VPC)

peer_vpc: pulumi.Output[str] = None

AWS VPC ID or GCP VPC network name of the peered VPC

peering_connection_id: pulumi.Output[str] = None

Cloud provider identifier for the peering connection if available

state: pulumi.Output[str] = None

State of the peering connection

state_info: pulumi.Output[dict] = None

State-specific help or error information

vpc_id: pulumi.Output[str] = None

The VPC the peering connection belongs to

static get(resource_name, id, opts=None, client_timeout=None, peer_cloud_account=None, peer_region=None, peer_vpc=None, peering_connection_id=None, state=None, state_info=None, vpc_id=None)

Get an existing VpcPeeringConnection resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters
  • resource_name (str) – The unique name of the resulting resource.

  • id (str) – The unique provider ID of the resource to lookup.

  • opts (pulumi.ResourceOptions) – Options for the resource.

  • client_timeout (pulumi.Input[dict]) – Custom Terraform Client timeouts

  • peer_cloud_account (pulumi.Input[str]) – AWS account ID or GCP project ID of the peered VPC

  • peer_region (pulumi.Input[str]) – AWS region of the peered VPC (if not in the same region as Aiven VPC)

  • peer_vpc (pulumi.Input[str]) – AWS VPC ID or GCP VPC network name of the peered VPC

  • peering_connection_id (pulumi.Input[str]) – Cloud provider identifier for the peering connection if available

  • state (pulumi.Input[str]) – State of the peering connection

  • state_info (pulumi.Input[dict]) – State-specific help or error information

  • vpc_id (pulumi.Input[str]) – The VPC the peering connection belongs to

The client_timeout object supports the following:

  • create (pulumi.Input[str])

translate_output_property(prop)

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

pulumi_aiven.get_account(account_id=None, create_time=None, name=None, owner_team_id=None, tenant_id=None, update_time=None, opts=None)
import pulumi
import pulumi_aiven as aiven

account1 = aiven.get_account(name="<ACCOUNT_NAME>")
pulumi_aiven.get_account_authentication(account_id=None, authentication_id=None, create_time=None, enabled=None, name=None, saml_acs_url=None, saml_certificate=None, saml_entity_id=None, saml_idp_url=None, saml_metadata_url=None, type=None, update_time=None, opts=None)

Use this data source to access information about an existing resource.

pulumi_aiven.get_account_team(account_id=None, create_time=None, name=None, team_id=None, update_time=None, opts=None)
import pulumi
import pulumi_aiven as aiven

account_team1 = aiven.get_account_team(account_id=aiven_account["team"]["account_id"],
    name="account_team1")
pulumi_aiven.get_account_team_member(accepted=None, account_id=None, create_time=None, invited_by_user_email=None, team_id=None, user_email=None, opts=None)
import pulumi
import pulumi_aiven as aiven

foo = aiven.get_account_team_member(account_id=aiven_account["developers"]["account_id"],
    team_id=aiven_account["developers"]["account_id"],
    user_email="user+1@example.com")
pulumi_aiven.get_account_team_project(account_id=None, project_name=None, team_id=None, team_type=None, opts=None)
import pulumi
import pulumi_aiven as aiven

account_team_project1 = aiven.get_account_team_project(account_id=aiven_account_team["developers"]["account_id"],
    project_name=aiven_project["project1"]["project"],
    team_id=aiven_account_team["developers"]["team_id"])
pulumi_aiven.get_connection_pool(connection_uri=None, database_name=None, pool_mode=None, pool_name=None, pool_size=None, project=None, service_name=None, username=None, opts=None)
import pulumi
import pulumi_aiven as aiven

mytestpool = aiven.get_connection_pool(project=data[".Service"]["myservice"]["project"],
    service_name=data[".Service"]["myservice"]["service_name"],
    pool_name="<POOLNAME>")
pulumi_aiven.get_database(database_name=None, lc_collate=None, lc_ctype=None, project=None, service_name=None, termination_protection=None, opts=None)
import pulumi
import pulumi_aiven as aiven

mydatabase = aiven.get_database(project=data[".Service"]["myservice"]["project"],
    service_name=data[".Service"]["myservice"]["service_name"],
    database_name="<DATABASE_NAME>")
pulumi_aiven.get_elastic_search_acl(acls=None, enabled=None, extended_acl=None, project=None, service_name=None, opts=None)

Use this data source to access information about an existing resource.

The acls object supports the following:

  • rules (list)

    • index (str)

    • permission (str)

  • username (str)

pulumi_aiven.get_kafka_acl(permission=None, project=None, service_name=None, topic=None, username=None, opts=None)
import pulumi
import pulumi_aiven as aiven

mytestacl = aiven.get_kafka_acl(project=data[".Service"]["myservice"]["project"],
    service_name=data[".Service"]["myservice"]["service_name"],
    topic="<TOPIC_NAME_PATTERN>",
    username="<USERNAME_PATTERN>")
pulumi_aiven.get_kafka_connector(config=None, connector_name=None, plugin_author=None, plugin_class=None, plugin_doc_url=None, plugin_title=None, plugin_type=None, plugin_version=None, project=None, service_name=None, tasks=None, opts=None)

Use this data source to access information about an existing resource.

The tasks object supports the following:

  • connector (str)

  • task (float)

pulumi_aiven.get_kafka_schema(project=None, schema=None, service_name=None, subject_name=None, version=None, opts=None)

Use this data source to access information about an existing resource.

pulumi_aiven.get_kafka_schema_configuration(project=None, schema=None, service_name=None, subject_name=None, version=None, opts=None)

Use this data source to access information about an existing resource.

pulumi_aiven.get_kafka_topic(cleanup_policy=None, client_timeout=None, minimum_in_sync_replicas=None, partitions=None, project=None, replication=None, retention_bytes=None, retention_hours=None, service_name=None, termination_protection=None, topic_name=None, opts=None)
import pulumi
import pulumi_aiven as aiven

mytesttopic = aiven.get_kafka_topic(project=data[".Service"]["myservice"]["project"],
    service_name=data[".Service"]["myservice"]["service_name"],
    topic_name="<TOPIC_NAME>")

The client_timeout object supports the following:

  • create (str)

  • read (str)

pulumi_aiven.get_mirror_maker_replication_flow(enable=None, project=None, service_name=None, source_cluster=None, target_cluster=None, topics=None, topics_blacklists=None, opts=None)

Use this data source to access information about an existing resource.

pulumi_aiven.get_project(account_id=None, billing_address=None, billing_emails=None, ca_cert=None, card_id=None, copy_from_project=None, country_code=None, project=None, technical_emails=None, opts=None)
import pulumi
import pulumi_aiven as aiven

myproject = aiven.get_project(project="<PROJECT_NAME>")
pulumi_aiven.get_project_user(accepted=None, email=None, member_type=None, project=None, opts=None)
import pulumi
import pulumi_aiven as aiven

mytestuser = aiven.get_project_user(project=data[".Project"]["myproject"]["project"],
    email="john.doe@example.com")
pulumi_aiven.get_project_vpc(client_timeout=None, cloud_name=None, network_cidr=None, project=None, state=None, opts=None)
import pulumi
import pulumi_aiven as aiven

myvpc = aiven.get_project_vpc(project=data[".Project"]["myproject"]["project"],
    cloud_name="google-europe-west1")

The client_timeout object supports the following:

  • create (str)

  • delete (str)

pulumi_aiven.get_service(cassandra=None, cassandra_user_config=None, client_timeout=None, cloud_name=None, components=None, elasticsearch=None, elasticsearch_user_config=None, grafana=None, grafana_user_config=None, influxdb=None, influxdb_user_config=None, kafka=None, kafka_connect=None, kafka_connect_user_config=None, kafka_mirrormaker=None, kafka_mirrormaker_user_config=None, kafka_user_config=None, maintenance_window_dow=None, maintenance_window_time=None, mysql=None, mysql_user_config=None, pg=None, pg_user_config=None, plan=None, project=None, project_vpc_id=None, redis=None, redis_user_config=None, service_host=None, service_integrations=None, service_name=None, service_password=None, service_port=None, service_type=None, service_uri=None, service_username=None, state=None, termination_protection=None, opts=None)
import pulumi
import pulumi_aiven as aiven

myservice = aiven.get_service(project=data[".Project"]["myproject"]["project"],
    service_name="<SERVICE_NAME>")

The cassandra_user_config object supports the following:

  • ipFilters (list)

  • migrateSstableloader (str)

  • privateAccess (dict)

    • prometheus (str)

  • publicAccess (dict)

    • prometheus (str)

  • serviceToForkFrom (str)

The client_timeout object supports the following:

  • create (str)

  • update (str)

The components object supports the following:

  • component (str)

  • host (str)

  • kafkaAuthenticationMethod (str)

  • port (float)

  • route (str)

  • ssl (bool)

  • usage (str)

The elasticsearch object supports the following:

  • kibanaUri (str)

The elasticsearch_user_config object supports the following:

  • customDomain (str)

  • disableReplicationFactorAdjustment (str)

  • elasticsearch (dict)

    • actionAutoCreateIndexEnabled (str)

    • actionDestructiveRequiresName (str)

    • httpMaxContentLength (str)

    • httpMaxHeaderSize (str)

    • httpMaxInitialLineLength (str)

    • indicesFielddataCacheSize (str)

    • indicesMemoryIndexBufferSize (str)

    • indicesQueriesCacheSize (str)

    • indicesQueryBoolMaxClauseCount (str)

    • reindexRemoteWhitelists (list)

    • threadPoolAnalyzeQueueSize (str)

    • threadPoolAnalyzeSize (str)

    • threadPoolForceMergeSize (str)

    • threadPoolGetQueueSize (str)

    • threadPoolGetSize (str)

    • threadPoolIndexQueueSize (str)

    • threadPoolIndexSize (str)

    • threadPoolSearchQueueSize (str)

    • threadPoolSearchSize (str)

    • threadPoolSearchThrottledQueueSize (str)

    • threadPoolSearchThrottledSize (str)

    • threadPoolWriteQueueSize (str)

    • threadPoolWriteSize (str)

  • elasticsearchVersion (str)

  • indexPatterns (list)

    • maxIndexCount (str)

    • pattern (str)

  • ipFilters (list)

  • kibana (dict)

    • elasticsearchRequestTimeout (str)

    • enabled (str)

    • maxOldSpaceSize (str)

  • maxIndexCount (str)

  • privateAccess (dict)

    • elasticsearch (str)

    • kibana (str)

    • prometheus (str)

  • publicAccess (dict)

    • elasticsearch (str)

    • kibana (str)

    • prometheus (str)

  • recoveryBasebackupName (str)

  • serviceToForkFrom (str)

The grafana_user_config object supports the following:

  • alertingEnabled (str)

  • alertingErrorOrTimeout (str)

  • alertingNodataOrNullvalues (str)

  • allowEmbedding (str)

  • authBasicEnabled (str)

  • authGenericOauth (dict)

    • allowSignUp (str)

    • allowedDomains (list)

    • allowedOrganizations (list)

    • apiUrl (str)

    • authUrl (str)

    • clientId (str)

    • clientSecret (str)

    • name (str)

    • scopes (list)

    • tokenUrl (str)

  • authGithub (dict)

    • allowSignUp (str)

    • allowedOrganizations (list)

    • clientId (str)

    • clientSecret (str)

    • teamIds (list)

  • authGitlab (dict)

    • allowSignUp (str)

    • allowedGroups (list)

    • apiUrl (str)

    • authUrl (str)

    • clientId (str)

    • clientSecret (str)

    • tokenUrl (str)

  • authGoogle (dict)

    • allowSignUp (str)

    • allowedDomains (list)

    • clientId (str)

    • clientSecret (str)

  • cookieSamesite (str)

  • customDomain (str)

  • dashboardsVersionsToKeep (str)

  • dataproxySendUserHeader (str)

  • dataproxyTimeout (str)

  • disableGravatar (str)

  • editorsCanAdmin (str)

  • externalImageStorage (dict)

    • access_key (str)

    • bucketUrl (str)

    • provider (str)

    • secretKey (str)

  • googleAnalyticsUaId (str)

  • ipFilters (list)

  • metricsEnabled (str)

  • privateAccess (dict)

    • grafana (str)

  • publicAccess (dict)

    • grafana (str)

  • smtpServer (dict)

    • fromAddress (str)

    • fromName (str)

    • host (str)

    • password (str)

    • port (str)

    • skipVerify (str)

    • username (str)

  • userAutoAssignOrg (str)

  • userAutoAssignOrgRole (str)

  • viewersCanEdit (str)

The influxdb object supports the following:

  • database_name (str)

The influxdb_user_config object supports the following:

  • customDomain (str)

  • ipFilters (list)

  • privateAccess (dict)

    • influxdb (str)

  • publicAccess (dict)

    • influxdb (str)

  • serviceToForkFrom (str)

The kafka object supports the following:

  • access_cert (str)

  • access_key (str)

  • connectUri (str)

  • restUri (str)

  • schemaRegistryUri (str)

The kafka_connect_user_config object supports the following:

  • ipFilters (list)

  • kafka_connect (dict)

    • consumerIsolationLevel (str)

    • consumerMaxPollRecords (str)

    • offsetFlushIntervalMs (str)

  • privateAccess (dict)

    • kafka_connect (str)

    • prometheus (str)

  • publicAccess (dict)

    • kafka_connect (str)

    • prometheus (str)

The kafka_mirrormaker_user_config object supports the following:

  • ipFilters (list)

  • kafka_mirrormaker (dict)

    • refreshGroupsEnabled (str)

    • refreshGroupsIntervalSeconds (str)

    • refreshTopicsEnabled (str)

    • refreshTopicsIntervalSeconds (str)

The kafka_user_config object supports the following:

  • customDomain (str)

  • ipFilters (list)

  • kafka (dict)

    • autoCreateTopicsEnable (str)

    • compressionType (str)

    • connectionsMaxIdleMs (str)

    • defaultReplicationFactor (str)

    • groupMaxSessionTimeoutMs (str)

    • groupMinSessionTimeoutMs (str)

    • logCleanerMaxCompactionLagMs (str)

    • logCleanerMinCleanableRatio (str)

    • logCleanerMinCompactionLagMs (str)

    • logCleanupPolicy (str)

    • logMessageTimestampDifferenceMaxMs (str)

    • logMessageTimestampType (str)

    • logRetentionBytes (str)

    • logRetentionHours (str)

    • logSegmentBytes (str)

    • maxConnectionsPerIp (str)

    • messageMaxBytes (str)

    • numPartitions (str)

    • offsetsRetentionMinutes (str)

    • producerPurgatoryPurgeIntervalRequests (str)

    • replicaFetchMaxBytes (str)

    • replicaFetchResponseMaxBytes (str)

    • socketRequestMaxBytes (str)

  • kafkaAuthenticationMethods (dict)

    • certificate (str)

    • sasl (str)

  • kafka_connect (str)

  • kafkaConnectConfig (dict)

    • consumerIsolationLevel (str)

    • consumerMaxPollRecords (str)

    • offsetFlushIntervalMs (str)

  • kafkaRest (str)

  • kafkaRestConfig (dict)

    • consumerEnableAutoCommit (str)

    • consumerRequestMaxBytes (str)

    • consumerRequestTimeoutMs (str)

    • producerAcks (str)

    • producerLingerMs (str)

    • simpleconsumerPoolSizeMax (str)

  • kafkaVersion (str)

  • privateAccess (dict)

    • prometheus (str)

  • publicAccess (dict)

    • kafka (str)

    • kafka_connect (str)

    • kafkaRest (str)

    • prometheus (str)

    • schemaRegistry (str)

  • schemaRegistry (str)

The mysql_user_config object supports the following:

  • adminPassword (str)

  • adminUsername (str)

  • backupHour (str)

  • backupMinute (str)

  • ipFilters (list)

  • mysql (dict)

    • connectTimeout (str)

    • defaultTimeZone (str)

    • groupConcatMaxLen (str)

    • informationSchemaStatsExpiry (str)

    • innodbFtMinTokenSize (str)

    • innodbFtServerStopwordTable (str)

    • innodbLockWaitTimeout (str)

    • innodbLogBufferSize (str)

    • innodbOnlineAlterLogMaxSize (str)

    • innodbRollbackOnTimeout (str)

    • interactiveTimeout (str)

    • maxAllowedPacket (str)

    • maxHeapTableSize (str)

    • netReadTimeout (str)

    • netWriteTimeout (str)

    • sortBufferSize (str)

    • sqlMode (str)

    • sqlRequirePrimaryKey (str)

    • tmpTableSize (str)

    • waitTimeout (str)

  • mysqlVersion (str)

  • privateAccess (dict)

    • mysql (str)

    • prometheus (str)

  • publicAccess (dict)

    • mysql (str)

    • prometheus (str)

  • recoveryTargetTime (str)

  • serviceToForkFrom (str)

The pg object supports the following:

  • dbname (str)

  • host (str)

  • password (str)

  • port (float)

  • replicaUri (str)

  • sslmode (str)

  • uri (str)

  • user (str)

The pg_user_config object supports the following:

  • adminPassword (str)

  • adminUsername (str)

  • backupHour (str)

  • backupMinute (str)

  • ipFilters (list)

  • pg (dict)

    • autovacuumAnalyzeScaleFactor (str)

    • autovacuumAnalyzeThreshold (str)

    • autovacuumFreezeMaxAge (str)

    • autovacuumMaxWorkers (str)

    • autovacuumNaptime (str)

    • autovacuumVacuumCostDelay (str)

    • autovacuumVacuumCostLimit (str)

    • autovacuumVacuumScaleFactor (str)

    • autovacuumVacuumThreshold (str)

    • deadlockTimeout (str)

    • idleInTransactionSessionTimeout (str)

    • jit (str)

    • logAutovacuumMinDuration (str)

    • logErrorVerbosity (str)

    • logMinDurationStatement (str)

    • maxLocksPerTransaction (str)

    • maxParallelWorkers (str)

    • maxParallelWorkersPerGather (str)

    • maxPredLocksPerTransaction (str)

    • maxPreparedTransactions (str)

    • maxStackDepth (str)

    • maxStandbyArchiveDelay (str)

    • maxStandbyStreamingDelay (str)

    • maxWorkerProcesses (str)

    • pgStatStatementsTrack (str)

    • tempFileLimit (str)

    • timezone (str)

    • trackActivityQuerySize (str)

    • trackCommitTimestamp (str)

    • trackFunctions (str)

    • walSenderTimeout (str)

    • walWriterDelay (str)

  • pgReadReplica (str)

  • pgServiceToForkFrom (str)

  • pgVersion (str)

  • pgbouncer (dict)

    • ignoreStartupParameters (list)

    • serverResetQueryAlways (str)

  • pglookout (dict)

    • maxFailoverReplicationTimeLag (str)

  • privateAccess (dict)

    • pg (str)

    • pgbouncer (str)

    • prometheus (str)

  • publicAccess (dict)

    • pg (str)

    • pgbouncer (str)

    • prometheus (str)

  • recoveryTargetTime (str)

  • serviceToForkFrom (str)

  • synchronousReplication (str)

  • timescaledb (dict)

    • maxBackgroundWorkers (str)

  • variant (str)

The redis_user_config object supports the following:

  • ipFilters (list)

  • migration (dict)

    • host (str)

    • password (str)

    • port (str)

    • ssl (str)

    • username (str)

  • privateAccess (dict)

    • prometheus (str)

    • redis (str)

  • publicAccess (dict)

    • prometheus (str)

    • redis (str)

  • redisLfuDecayTime (str)

  • redisLfuLogFactor (str)

  • redisMaxmemoryPolicy (str)

  • redisNotifyKeyspaceEvents (str)

  • redisSsl (str)

  • redisTimeout (str)

The service_integrations object supports the following:

  • integration_type (str)

  • source_service_name (str)

pulumi_aiven.get_service_integration(destination_endpoint_id=None, destination_service_name=None, integration_type=None, kafka_connect_user_config=None, kafka_mirrormaker_user_config=None, logs_user_config=None, mirrormaker_user_config=None, project=None, source_endpoint_id=None, source_service_name=None, opts=None)

Use this data source to access information about an existing resource.

The kafka_connect_user_config object supports the following:

  • kafka_connect (dict)

    • configStorageTopic (str)

    • groupId (str)

    • offsetStorageTopic (str)

    • statusStorageTopic (str)

The kafka_mirrormaker_user_config object supports the following:

  • clusterAlias (str)

The logs_user_config object supports the following:

  • elasticsearchIndexDaysMax (str)

  • elasticsearchIndexPrefix (str)

The mirrormaker_user_config object supports the following:

  • mirrormakerWhitelist (str)

pulumi_aiven.get_service_integration_endpoint(datadog_user_config=None, endpoint_config=None, endpoint_name=None, endpoint_type=None, external_elasticsearch_logs_user_config=None, project=None, prometheus_user_config=None, rsyslog_user_config=None, opts=None)
import pulumi
import pulumi_aiven as aiven

myendpoint = aiven.get_service_integration_endpoint(project=data[".Project"]["myproject"]["project"],
    endpoint_name="<ENDPOINT_NAME>")

The datadog_user_config object supports the following:

  • datadogApiKey (str)

  • disableConsumerStats (str)

  • maxPartitionContexts (str)

  • site (str)

The external_elasticsearch_logs_user_config object supports the following:

  • ca (str)

  • indexDaysMax (str)

  • indexPrefix (str)

  • timeout (str)

  • url (str)

The prometheus_user_config object supports the following:

  • basicAuthPassword (str)

  • basicAuthUsername (str)

The rsyslog_user_config object supports the following:

  • ca (str)

  • cert (str)

  • format (str)

  • key (str)

  • logline (str)

  • port (str)

  • sd (str)

  • server (str)

  • tls (str)

pulumi_aiven.get_service_user(access_cert=None, access_key=None, password=None, project=None, service_name=None, type=None, username=None, opts=None)
import pulumi
import pulumi_aiven as aiven

myserviceuser = aiven.get_service_user(project=data[".Service"]["myservice"]["project"],
    service_name=data[".Service"]["myservice"]["service_name"],
    username="<USERNAME>")
pulumi_aiven.get_vpc_peering_connection(client_timeout=None, peer_cloud_account=None, peer_region=None, peer_vpc=None, peering_connection_id=None, state=None, state_info=None, vpc_id=None, opts=None)
import pulumi
import pulumi_aiven as aiven

mypeeringconnection = aiven.get_vpc_peering_connection(vpc_id=data[".ProjectVpc"]["vpc_id"],
    peer_cloud_account="<PEER_ACCOUNT_ID>",
    peer_vpc="<PEER_VPC_ID/NAME>")

The client_timeout object supports the following:

  • create (str)