Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Implement Hadron worker CR watch loop #54

Closed
thedodd opened this issue Jun 2, 2021 · 1 comment
Closed

Implement Hadron worker CR watch loop #54

thedodd opened this issue Jun 2, 2021 · 1 comment
Labels
A-crd Hadron K8s CRDs
Projects
Milestone

Comments

@thedodd
Copy link
Collaborator

thedodd commented Jun 2, 2021

Implement the K8s CR watch loops for the various CRs. For each CR, it will be as simple as:

let clusters: Api<models::HadronCluster> = Api::all(self.client.clone());
let cluster_changes = watcher(clusters, ListParams::default());

Each change will then be handled by a specific function per CR type. Changes will cause updates to the metadata cache in the app, and will trigger spawning of controllers for Stream partitions, Pipeline partitions and other such objects.

Communication channels for spawned objects should then be passed along to the network controller to facilitate networking.

@thedodd thedodd created this issue from a note in Main (In progress) Jun 2, 2021
@thedodd thedodd added A-crd Hadron K8s CRDs server labels Jun 2, 2021
@thedodd thedodd added this to the First Release milestone Jun 2, 2021
@thedodd
Copy link
Collaborator Author

thedodd commented Jun 7, 2021

Donel.

@thedodd thedodd closed this as completed Jun 7, 2021
Main automation moved this from In progress to Done Jun 7, 2021
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
A-crd Hadron K8s CRDs
Projects
Main
Done
Development

No branches or pull requests

1 participant