Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion example_config_ingest_router.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ ingest_router:
locator:
type: in_process
control_plane:
url: http://127.0.0.1:9000
url: http://127.0.0.1:8000
backup_route_store:
type: filesystem
base_dir: target/cache
Expand Down
2 changes: 1 addition & 1 deletion example_config_locator.yaml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
locator:
control_plane:
url: "http://127.0.0.1:9000"
url: "http://127.0.0.1:8000"
backup_route_store:
type: filesystem
base_dir: target/cache
Expand Down
2 changes: 1 addition & 1 deletion example_config_locator_gcs.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ locator:
host: "0.0.0.0"
port: 3000
control_plane:
url: "http://127.0.0.1:9000"
url: "http://127.0.0.1:8000"
backup_route_store:
type: gcs
bucket: synapse
Expand Down
2 changes: 1 addition & 1 deletion example_config_proxy.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ proxy:
locality_to_default_cell:
us: us1
control_plane:
url: http://127.0.0.1:9000
url: http://127.0.0.1:8000
upstreams:
- name: us1-getsentry
url: "http://127.0.0.1:8080"
Expand Down
2 changes: 1 addition & 1 deletion ingest-router/src/testutils.rs
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ pub async fn create_test_locator(key_to_cell: HashMap<String, String>) -> Locato

let service = locator::locator::Locator::new(
locator::config::LocatorDataType::ProjectKey,
"http://invalid-control-plane:9000".to_string(),
"http://invalid-control-plane:8000".to_string(),
Comment thread
cursor[bot] marked this conversation as resolved.
provider,
None,
None,
Expand Down
2 changes: 1 addition & 1 deletion locator/src/locator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -466,7 +466,7 @@ mod tests {

let locator = Locator::new(
LocatorDataType::Organization,
"http://invalid-control-plane:9000".to_string(),
"http://invalid-control-plane:8000".to_string(),
provider,
None,
Some(HashMap::from([("de".into(), "de".into())])),
Expand Down
6 changes: 3 additions & 3 deletions proxy/src/proxy_service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -237,11 +237,11 @@ mod tests {
upstreams: vec![
config::UpstreamConfig {
name: "upstream".to_string(),
url: "http://127.0.0.1:9000".to_string(),
url: "http://127.0.0.1:8100".to_string(),
},
config::UpstreamConfig {
name: "invalid_upstream".to_string(),
url: "http://256.256.256.256:9000".to_string(),
url: "http://256.256.256.256:8100".to_string(),
},
],
routes: vec![
Expand Down Expand Up @@ -298,7 +298,7 @@ mod tests {
let response = service.call(request).await.expect("Request failed");
assert_eq!(response.status(), StatusCode::OK);
assert_eq!(response.headers().get("x-custom").unwrap(), "test");
assert_eq!(response.headers().get("host").unwrap(), "127.0.0.1:9000");
assert_eq!(response.headers().get("host").unwrap(), "127.0.0.1:8100");
tracing::debug!("response headers: {:?}", response.headers());
let body_bytes = response.into_body().collect().await.unwrap().to_bytes();
assert_eq!(body_bytes.as_ref(), content);
Expand Down
4 changes: 2 additions & 2 deletions scripts/echo_server.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,6 @@ def _handle(self):


if __name__ == "__main__":
server = HTTPServer(("127.0.0.1", 9000), EchoHandler)
print("Echo server listening on http://127.0.0.1:9000")
server = HTTPServer(("127.0.0.1", 8100), EchoHandler)
print("Echo server listening on http://127.0.0.1:8100")
server.serve_forever()
2 changes: 1 addition & 1 deletion scripts/mock_control_api.py
Original file line number Diff line number Diff line change
Expand Up @@ -207,7 +207,7 @@ def make_cursor(updated_at: int, entity_id: str) -> str:
args = parser.parse_args()

host = args.host or "127.0.0.1"
port = args.port or 9000
port = args.port or 8000
Comment thread
lynnagara marked this conversation as resolved.

server = HTTPServer((host, port), MockControlApi)
print(f"Mock control plane listening on http://{host}:{port}")
Expand Down
2 changes: 1 addition & 1 deletion synapse/src/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ mod tests {
fn proxy_config() {
let proxy_yaml = r#"
proxy:
upstreams: [{name: local, url: http://127.0.0.1:9000}]
upstreams: [{name: local, url: http://127.0.0.1:8100}]
routes: [{match: {path: test}, action: {to: local}}]
listener:
host: 0.0.0.0
Expand Down
Loading