MANAGEDKAFKA
managedkafka.projects.locations.clusters.acls.addAclEntry
valid {
input.Body.host == STRING
input.Body.operation == STRING
input.Body.permissionType == STRING
input.Body.principal == STRING
input.ReqMap.acl == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.acls.create
valid {
input.Body.aclEntries[_].host == STRING
input.Body.aclEntries[_].operation == STRING
input.Body.aclEntries[_].permissionType == STRING
input.Body.aclEntries[_].principal == STRING
input.Body.etag == STRING
input.Body.name == STRING
input.ReqMap.parent == STRING
input.Qs.aclId == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.acls.delete
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.acls.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.acls.list
valid {
input.ReqMap.parent == STRING
input.Qs.pageSize == INTEGER
input.Qs.pageToken == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.acls.patch
valid {
input.Body.aclEntries[_].host == STRING
input.Body.aclEntries[_].operation == STRING
input.Body.aclEntries[_].permissionType == STRING
input.Body.aclEntries[_].principal == STRING
input.Body.etag == STRING
input.Body.name == STRING
input.ReqMap.name == STRING
input.Qs.updateMask == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.acls.removeAclEntry
valid {
input.Body.host == STRING
input.Body.operation == STRING
input.Body.permissionType == STRING
input.Body.principal == STRING
input.ReqMap.acl == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.consumerGroups.delete
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.consumerGroups.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.consumerGroups.list
valid {
input.ReqMap.parent == STRING
input.Qs.pageSize == INTEGER
input.Qs.pageToken == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.consumerGroups.patch
valid {
input.Body.name == STRING
input.Body.topics.STRING.partitions.STRING.metadata == STRING
input.Body.topics.STRING.partitions.STRING.offset == STRING
input.ReqMap.name == STRING
input.Qs.updateMask == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.create
enum_RebalanceConfigMode := [ "MODE_UNSPECIFIED", "NO_REBALANCE", "AUTO_REBALANCE_ON_SCALE_UP" ]
valid {
input.Body.capacityConfig.memoryBytes == STRING
input.Body.capacityConfig.vcpuCount == STRING
input.Body.gcpConfig.accessConfig.networkConfigs[_].subnet == STRING
input.Body.gcpConfig.kmsKey == STRING
input.Body.labels.STRING == STRING
input.Body.name == STRING
input.Body.rebalanceConfig.mode == enum_RebalanceConfigMode[_]
input.ReqMap.parent == STRING
input.Qs.clusterId == STRING
input.Qs.requestId == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.delete
valid {
input.ReqMap.name == STRING
input.Qs.requestId == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.list
valid {
input.ReqMap.parent == STRING
input.Qs.filter == STRING
input.Qs.orderBy == STRING
input.Qs.pageSize == INTEGER
input.Qs.pageToken == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.patch
enum_RebalanceConfigMode := [ "MODE_UNSPECIFIED", "NO_REBALANCE", "AUTO_REBALANCE_ON_SCALE_UP" ]
valid {
input.Body.capacityConfig.memoryBytes == STRING
input.Body.capacityConfig.vcpuCount == STRING
input.Body.gcpConfig.accessConfig.networkConfigs[_].subnet == STRING
input.Body.gcpConfig.kmsKey == STRING
input.Body.labels.STRING == STRING
input.Body.name == STRING
input.Body.rebalanceConfig.mode == enum_RebalanceConfigMode[_]
input.ReqMap.name == STRING
input.Qs.requestId == STRING
input.Qs.updateMask == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.topics.create
valid {
input.Body.configs.STRING == STRING
input.Body.name == STRING
input.Body.partitionCount == INTEGER
input.Body.replicationFactor == INTEGER
input.ReqMap.parent == STRING
input.Qs.topicId == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.topics.delete
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.topics.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.topics.list
valid {
input.ReqMap.parent == STRING
input.Qs.pageSize == INTEGER
input.Qs.pageToken == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.clusters.topics.patch
valid {
input.Body.configs.STRING == STRING
input.Body.name == STRING
input.Body.partitionCount == INTEGER
input.Body.replicationFactor == INTEGER
input.ReqMap.name == STRING
input.Qs.updateMask == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.connectors.create
valid {
input.Body.configs.STRING == STRING
input.Body.name == STRING
input.Body.taskRestartPolicy.maximumBackoff == STRING
input.Body.taskRestartPolicy.minimumBackoff == STRING
input.ReqMap.parent == STRING
input.Qs.connectorId == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.connectors.delete
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.connectors.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.connectors.list
valid {
input.ReqMap.parent == STRING
input.Qs.pageSize == INTEGER
input.Qs.pageToken == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.connectors.patch
valid {
input.Body.configs.STRING == STRING
input.Body.name == STRING
input.Body.taskRestartPolicy.maximumBackoff == STRING
input.Body.taskRestartPolicy.minimumBackoff == STRING
input.ReqMap.name == STRING
input.Qs.updateMask == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.connectors.pause
valid {
input.Body.STRING == STRING
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.connectors.restart
valid {
input.Body.STRING == STRING
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.connectors.resume
valid {
input.Body.STRING == STRING
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.connectors.stop
valid {
input.Body.STRING == STRING
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.create
valid {
input.Body.capacityConfig.memoryBytes == STRING
input.Body.capacityConfig.vcpuCount == STRING
input.Body.config.STRING == STRING
input.Body.gcpConfig.accessConfig.networkConfigs[_].additionalSubnets[_] == STRING
input.Body.gcpConfig.accessConfig.networkConfigs[_].dnsDomainNames[_] == STRING
input.Body.gcpConfig.accessConfig.networkConfigs[_].primarySubnet == STRING
input.Body.gcpConfig.secretPaths[_] == STRING
input.Body.kafkaCluster == STRING
input.Body.labels.STRING == STRING
input.Body.name == STRING
input.ReqMap.parent == STRING
input.Qs.connectClusterId == STRING
input.Qs.requestId == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.delete
valid {
input.ReqMap.name == STRING
input.Qs.requestId == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.list
valid {
input.ReqMap.parent == STRING
input.Qs.filter == STRING
input.Qs.orderBy == STRING
input.Qs.pageSize == INTEGER
input.Qs.pageToken == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.connectClusters.patch
valid {
input.Body.capacityConfig.memoryBytes == STRING
input.Body.capacityConfig.vcpuCount == STRING
input.Body.config.STRING == STRING
input.Body.gcpConfig.accessConfig.networkConfigs[_].additionalSubnets[_] == STRING
input.Body.gcpConfig.accessConfig.networkConfigs[_].dnsDomainNames[_] == STRING
input.Body.gcpConfig.accessConfig.networkConfigs[_].primarySubnet == STRING
input.Body.gcpConfig.secretPaths[_] == STRING
input.Body.kafkaCluster == STRING
input.Body.labels.STRING == STRING
input.Body.name == STRING
input.ReqMap.name == STRING
input.Qs.requestId == STRING
input.Qs.updateMask == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.list
valid {
input.ReqMap.name == STRING
input.Qs.extraLocationTypes == STRING
input.Qs.filter == STRING
input.Qs.pageSize == INTEGER
input.Qs.pageToken == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.operations.cancel
valid {
input.Body.STRING == STRING
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.operations.delete
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.operations.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.operations.list
valid {
input.ReqMap.name == STRING
input.Qs.filter == STRING
input.Qs.pageSize == INTEGER
input.Qs.pageToken == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.compatibility.checkCompatibility
enum_CheckCompatibilityRequestSchemaType := [ "SCHEMA_TYPE_UNSPECIFIED", "AVRO", "JSON", "PROTOBUF" ]
valid {
input.Body.references[_].name == STRING
input.Body.references[_].subject == STRING
input.Body.references[_].version == INTEGER
input.Body.schema == STRING
input.Body.schemaType == enum_CheckCompatibilityRequestSchemaType[_]
input.Body.verbose == BOOLEAN
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.config.delete
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.config.get
valid {
input.ReqMap.name == STRING
input.Qs.defaultToGlobal == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.config.update
enum_UpdateSchemaConfigRequestCompatibility := [ "NONE", "BACKWARD", "BACKWARD_TRANSITIVE", "FORWARD", "FORWARD_TRANSITIVE", "FULL", "FULL_TRANSITIVE" ]
valid {
input.Body.compatibility == enum_UpdateSchemaConfigRequestCompatibility[_]
input.Body.normalize == BOOLEAN
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.compatibility.checkCompatibility
enum_CheckCompatibilityRequestSchemaType := [ "SCHEMA_TYPE_UNSPECIFIED", "AVRO", "JSON", "PROTOBUF" ]
valid {
input.Body.references[_].name == STRING
input.Body.references[_].subject == STRING
input.Body.references[_].version == INTEGER
input.Body.schema == STRING
input.Body.schemaType == enum_CheckCompatibilityRequestSchemaType[_]
input.Body.verbose == BOOLEAN
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.config.delete
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.config.get
valid {
input.ReqMap.name == STRING
input.Qs.defaultToGlobal == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.config.update
enum_UpdateSchemaConfigRequestCompatibility := [ "NONE", "BACKWARD", "BACKWARD_TRANSITIVE", "FORWARD", "FORWARD_TRANSITIVE", "FULL", "FULL_TRANSITIVE" ]
valid {
input.Body.compatibility == enum_UpdateSchemaConfigRequestCompatibility[_]
input.Body.normalize == BOOLEAN
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.list
valid {
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.mode.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.mode.update
enum_UpdateSchemaModeRequestMode := [ "NONE", "READONLY", "READWRITE", "IMPORT" ]
valid {
input.Body.mode == enum_UpdateSchemaModeRequestMode[_]
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.schemas.get
valid {
input.ReqMap.name == STRING
input.Qs.subject == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.schemas.getSchema
valid {
input.ReqMap.name == STRING
input.Qs.subject == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.schemas.subjects.list
valid {
input.ReqMap.parent == STRING
input.Qs.deleted == BOOLEAN
input.Qs.subject == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.schemas.types.list
valid {
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.schemas.versions.list
valid {
input.ReqMap.parent == STRING
input.Qs.deleted == BOOLEAN
input.Qs.subject == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.subjects.delete
valid {
input.ReqMap.name == STRING
input.Qs.permanent == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.subjects.list
valid {
input.ReqMap.parent == STRING
input.Qs.deleted == BOOLEAN
input.Qs.subjectPrefix == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.subjects.lookupVersion
enum_LookupVersionRequestSchemaType := [ "SCHEMA_TYPE_UNSPECIFIED", "AVRO", "JSON", "PROTOBUF" ]
valid {
input.Body.deleted == BOOLEAN
input.Body.normalize == BOOLEAN
input.Body.references[_].name == STRING
input.Body.references[_].subject == STRING
input.Body.references[_].version == INTEGER
input.Body.schema == STRING
input.Body.schemaType == enum_LookupVersionRequestSchemaType[_]
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.create
enum_CreateVersionRequestSchemaType := [ "SCHEMA_TYPE_UNSPECIFIED", "AVRO", "JSON", "PROTOBUF" ]
valid {
input.Body.id == INTEGER
input.Body.normalize == BOOLEAN
input.Body.references[_].name == STRING
input.Body.references[_].subject == STRING
input.Body.references[_].version == INTEGER
input.Body.schema == STRING
input.Body.schemaType == enum_CreateVersionRequestSchemaType[_]
input.Body.version == INTEGER
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.delete
valid {
input.ReqMap.name == STRING
input.Qs.permanent == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.get
valid {
input.ReqMap.name == STRING
input.Qs.deleted == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.getSchema
valid {
input.ReqMap.name == STRING
input.Qs.deleted == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.list
valid {
input.ReqMap.parent == STRING
input.Qs.deleted == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.referencedby.list
valid {
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.create
valid {
input.Body.schemaRegistry.name == STRING
input.Body.schemaRegistryId == STRING
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.delete
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.list
valid {
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.mode.get
valid {
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.mode.update
enum_UpdateSchemaModeRequestMode := [ "NONE", "READONLY", "READWRITE", "IMPORT" ]
valid {
input.Body.mode == enum_UpdateSchemaModeRequestMode[_]
input.ReqMap.name == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.schemas.get
valid {
input.ReqMap.name == STRING
input.Qs.subject == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.schemas.getSchema
valid {
input.ReqMap.name == STRING
input.Qs.subject == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.schemas.subjects.list
valid {
input.ReqMap.parent == STRING
input.Qs.deleted == BOOLEAN
input.Qs.subject == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.schemas.types.list
valid {
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.schemas.versions.list
valid {
input.ReqMap.parent == STRING
input.Qs.deleted == BOOLEAN
input.Qs.subject == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.subjects.delete
valid {
input.ReqMap.name == STRING
input.Qs.permanent == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.subjects.list
valid {
input.ReqMap.parent == STRING
input.Qs.deleted == BOOLEAN
input.Qs.subjectPrefix == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.subjects.lookupVersion
enum_LookupVersionRequestSchemaType := [ "SCHEMA_TYPE_UNSPECIFIED", "AVRO", "JSON", "PROTOBUF" ]
valid {
input.Body.deleted == BOOLEAN
input.Body.normalize == BOOLEAN
input.Body.references[_].name == STRING
input.Body.references[_].subject == STRING
input.Body.references[_].version == INTEGER
input.Body.schema == STRING
input.Body.schemaType == enum_LookupVersionRequestSchemaType[_]
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.subjects.versions.create
enum_CreateVersionRequestSchemaType := [ "SCHEMA_TYPE_UNSPECIFIED", "AVRO", "JSON", "PROTOBUF" ]
valid {
input.Body.id == INTEGER
input.Body.normalize == BOOLEAN
input.Body.references[_].name == STRING
input.Body.references[_].subject == STRING
input.Body.references[_].version == INTEGER
input.Body.schema == STRING
input.Body.schemaType == enum_CreateVersionRequestSchemaType[_]
input.Body.version == INTEGER
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.subjects.versions.delete
valid {
input.ReqMap.name == STRING
input.Qs.permanent == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.subjects.versions.get
valid {
input.ReqMap.name == STRING
input.Qs.deleted == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.subjects.versions.getSchema
valid {
input.ReqMap.name == STRING
input.Qs.deleted == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.subjects.versions.list
valid {
input.ReqMap.parent == STRING
input.Qs.deleted == BOOLEAN
input.ProviderMetadata.Region == STRING
}
managedkafka.projects.locations.schemaRegistries.subjects.versions.referencedby.list
valid {
input.ReqMap.parent == STRING
input.ProviderMetadata.Region == STRING
}
Updated 15 days ago