// Query current sharding state
client.cluster().shardingStateQuerier().withShard("test-shard").run();

// Launch new replication and query its status
client.cluster().replicator().withClassName("Pizza").withShard("test-shard").run();
client.cluster().replication().querier().withShard("test-shard").includeStatusHistory(true).run()
client.cluster().replication().canceler().withUuid("test-repl-uuid").run();
client.cluster().replication().deleter().withUuid("test-repl-uuid").run();

Permission.replicate("Pizza", "test-shard", ReplicatePermission.Action.CREATE, ReplicatePermission.Action.UPDATE);