valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.parent == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

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
}

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
}

valid {
    input.ReqMap.name == STRING
    input.Qs.requestId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

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
}

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
}

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
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.parent == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

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
}

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
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.parent == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

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
}

valid {
    input.Body.STRING == STRING
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.STRING == STRING
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.STRING == STRING
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.STRING == STRING
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

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
}

valid {
    input.ReqMap.name == STRING
    input.Qs.requestId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

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
}

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
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.name == STRING
    input.Qs.filter == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.STRING == STRING
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.name == STRING
    input.Qs.filter == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}