Documentation ¶
Overview ¶
Package resources contains various utilities for dealing with Kubernetes resources.
Index ¶
- func GetScaleResource(namespace string, ref corev1.ObjectReference, ...) (*pav1alpha1.PodScalable, error)
- func NotReadyAddressCount(endpoints *corev1.Endpoints) int
- func ReadyAddressCount(endpoints *corev1.Endpoints) int
- func ScaleResourceArguments(ref corev1.ObjectReference) (*schema.GroupVersionResource, string, error)
- type EndpointsCounter
- type PodAccessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetScaleResource ¶ added in v0.7.0
func GetScaleResource(namespace string, ref corev1.ObjectReference, psInformerFactory duck.InformerFactory) (*pav1alpha1.PodScalable, error)
GetScaleResource returns the current scale resource for the PA. TODO(markusthoemmes): We shouldn't need to pass namespace here.
func NotReadyAddressCount ¶ added in v0.13.0
NotReadyAddressCount returns the total number of addresses ready for the given endpoint.
func ReadyAddressCount ¶
ReadyAddressCount returns the total number of addresses ready for the given endpoint.
func ScaleResourceArguments ¶ added in v0.7.0
func ScaleResourceArguments(ref corev1.ObjectReference) (*schema.GroupVersionResource, string, error)
ScaleResourceArguments returns GroupResource and the resource name.
Types ¶
type EndpointsCounter ¶ added in v0.13.0
EndpointsCounter provides a count of currently ready and notReady pods. This information is used by UniScaler implementations to make scaling decisions. The interface prevents the UniScaler from needing to know how counts are performed. The int return value represents the number of pods that are ready to handle incoming requests. The error value is returned if the EndpointsCounter is unable to calculate a value.
func NewScopedEndpointsCounter ¶ added in v0.7.0
func NewScopedEndpointsCounter(lister corev1listers.EndpointsLister, namespace, serviceName string) EndpointsCounter
NewScopedEndpointsCounter creates a EndpointsCounter that uses a count of endpoints for a namespace/serviceName as the value of ready pods. The values returned by ReadyCount() will vary over time. lister is used to retrieve endpoints for counting with the scope of namespace/serviceName.
type PodAccessor ¶ added in v0.15.0
type PodAccessor struct {
// contains filtered or unexported fields
}
PodAccessor provides access to various dimensions of pods listing and querying for a given bound revision.
func NewPodAccessor ¶ added in v0.15.0
func NewPodAccessor(lister corev1listers.PodLister, namespace, revisionName string) PodAccessor
NewPodAccessor creates a PodAccessor implementation that counts pods for a namespace/revision.
func (PodAccessor) PendingTerminatingCount ¶ added in v0.15.0
func (pc PodAccessor) PendingTerminatingCount() (int, int, error)
PendingTerminatingCount returns the number of pods in a Pending or Terminating state
func (PodAccessor) PodIPsByAge ¶ added in v0.15.0
func (pc PodAccessor) PodIPsByAge() ([]string, error)