|
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