|
1 | | -use std::collections::BTreeMap; |
2 | | -use std::sync::atomic::AtomicBool; |
3 | | -use std::sync::Arc; |
4 | | -use std::time::Duration; |
| 1 | +use std::{ |
| 2 | + collections::BTreeMap, |
| 3 | + sync::{atomic::AtomicBool, Arc}, |
| 4 | + time::Duration, |
| 5 | +}; |
5 | 6 |
|
6 | 7 | use futures::{stream, Stream, StreamExt, TryStream}; |
7 | 8 | use serde_json::json; |
8 | 9 | use snafu::{ResultExt, Snafu}; |
9 | | -use stackable_operator::client::Client; |
10 | | -use stackable_operator::k8s_openapi::api::apps::v1::StatefulSet; |
11 | | -use stackable_operator::k8s_openapi::api::core::v1::{ |
12 | | - ConfigMap, EnvFromSource, EnvVar, PodSpec, Secret, Volume, |
13 | | -}; |
14 | | -use stackable_operator::kube; |
15 | | -use stackable_operator::kube::api::{PartialObjectMeta, Patch, PatchParams}; |
16 | | -use stackable_operator::kube::core::{error_boundary, DeserializeGuard, DynamicObject}; |
17 | | -use stackable_operator::kube::runtime::controller::{ |
18 | | - trigger_self, trigger_with, Action, ReconcileRequest, |
19 | | -}; |
20 | | -use stackable_operator::kube::runtime::events::{Recorder, Reporter}; |
21 | | -use stackable_operator::kube::runtime::reflector::{ObjectRef, Store}; |
22 | | -use stackable_operator::kube::runtime::{ |
23 | | - applier, metadata_watcher, reflector, watcher, Config, WatchStreamExt, |
| 10 | +use stackable_operator::{ |
| 11 | + client::Client, |
| 12 | + k8s_openapi::api::{ |
| 13 | + apps::v1::StatefulSet, |
| 14 | + core::v1::{ConfigMap, EnvFromSource, EnvVar, PodSpec, Secret, Volume}, |
| 15 | + }, |
| 16 | + kube, |
| 17 | + kube::{ |
| 18 | + api::{PartialObjectMeta, Patch, PatchParams}, |
| 19 | + core::{error_boundary, DeserializeGuard, DynamicObject}, |
| 20 | + runtime::{ |
| 21 | + applier, |
| 22 | + controller::{trigger_self, trigger_with, Action, ReconcileRequest}, |
| 23 | + events::{Recorder, Reporter}, |
| 24 | + metadata_watcher, reflector, |
| 25 | + reflector::{ObjectRef, Store}, |
| 26 | + watcher, Config, WatchStreamExt, |
| 27 | + }, |
| 28 | + Resource, ResourceExt, |
| 29 | + }, |
| 30 | + logging::controller::{report_controller_reconciled, ReconcilerError}, |
| 31 | + namespace::WatchNamespace, |
24 | 32 | }; |
25 | | -use stackable_operator::kube::{Resource, ResourceExt}; |
26 | | -use stackable_operator::logging::controller::{report_controller_reconciled, ReconcilerError}; |
27 | | -use stackable_operator::namespace::WatchNamespace; |
28 | 33 | use strum::{EnumDiscriminants, IntoStaticStr}; |
29 | 34 |
|
30 | 35 | const FULL_CONTROLLER_NAME: &str = "statefulset.restarter.commons.stackable.tech"; |
|
0 commit comments