Skip to content

Add cluster service and SelectCluster method#7187

Merged
katrogan merged 4 commits intov2from
katrina/eng26-351-create-a-selectcluster-rpc
Apr 10, 2026
Merged

Add cluster service and SelectCluster method#7187
katrogan merged 4 commits intov2from
katrina/eng26-351-create-a-selectcluster-rpc

Conversation

@katrogan
Copy link
Copy Markdown
Contributor

@katrogan katrogan commented Apr 9, 2026

Add stub implementation in Dataproxy

Why are the changes needed?

What changes were proposed in this pull request?

How was this patch tested?

Labels

Please add one or more of the following labels to categorize your PR:

  • added: For new features.
  • changed: For changes in existing functionality.
  • deprecated: For soon-to-be-removed features.
  • removed: For features being removed.
  • fixed: For any bug fixed.
  • security: In case of vulnerabilities

This is important to improve the readability of release notes.

Setup process

Screenshots

Check all the applicable boxes

  • I updated the documentation accordingly.
  • All new and existing tests passed.
  • All commits are signed-off.

Related PRs

Docs link

Signed-off-by: Katrina Rogan <katroganGH@gmail.com>
@github-actions github-actions bot mentioned this pull request Apr 9, 2026
3 tasks
Comment on lines +12 to +15
option (google.api.http) = {
post: "/cluster/api/v1/select"
body: "*"
};
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

No google/api annotations needed.. we don't use gateway anymore

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

thanks, updated

sc.Mux.Handle(path, handler)
logger.Infof(ctx, "Mounted DataProxyService at %s", path)

clusterSvc := service.NewClusterService(baseURL)
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Does this have dns:/// prefix? http://? does it matter?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

http but i was thinking clients can normalize it as they please? can also switch to dns if you think that makes more sense!

 $ curl -s -X POST http://localhost:30080/flyteidl2.cluster.ClusterService/SelectCluster \                                                                                            
    -H "Content-Type: application/json" \                                                                                                                                              
    -d '{"resource": {"orgId": {"name": "test"}}, "operation": "OPERATION_CREATE_UPLOAD_LOCATION"}'                                                                                    
                                                            
  {"clusterEndpoint":"http://localhost:8090"}   

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We expect clients to be using connect, in which case I think http works?

Signed-off-by: Katrina Rogan <katroganGH@gmail.com>
Signed-off-by: Katrina Rogan <katroganGH@gmail.com>
sc.Mux.Handle(path, handler)
logger.Infof(ctx, "Mounted DataProxyService at %s", path)

clusterSvc := service.NewClusterService(baseURL)
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We expect clients to be using connect, in which case I think http works?

@katrogan katrogan merged commit ffb5abb into v2 Apr 10, 2026
20 checks passed
@katrogan katrogan deleted the katrina/eng26-351-create-a-selectcluster-rpc branch April 10, 2026 17:20
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants