-
Notifications
You must be signed in to change notification settings - Fork 92
Conversation
ad0cee8
to
cf8f22f
Compare
Signed-off-by: Steve Sloka <steves@heptio.com>
cf8f22f
to
220f17b
Compare
@@ -45,6 +45,8 @@ var ( | |||
discovererMetrics localmetrics.DiscovererMetrics | |||
) | |||
|
|||
const clusterType = "kubernetes" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Seems like this could live inside k8s.NewController
? Similar with the openstack one.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yup it could, for openstack you would put into the Reconciler
? I was trying to be explicit since the cmd
was the entry point.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think so, yeah
@@ -52,17 +54,20 @@ func NewQueue(logger *logrus.Logger, clusterName string, kubeClient kubernetes.I | |||
Threadiness: threadiness, | |||
Metrics: metrics, | |||
ClusterName: clusterName, | |||
ClusterType: clusterType, | |||
} | |||
} | |||
|
|||
// Action that is added to the queue for processing | |||
type Action interface { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I am wondering if this should be called "Resource" or something... Not this PRs concern though
Signed-off-by: Steve Sloka <steves@heptio.com>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM!
This adds the queue size metric. Fixes #48
Signed-off-by: Steve Sloka steves@heptio.com