blob: 569bae85718395ced1524e201455a24692d5fad3 [file] [log] [blame]
// Licensed to Apache Software Foundation (ASF) under one or more contributor
// license agreements. See the NOTICE file distributed with
// this work for additional information regarding copyright
// ownership. Apache Software Foundation (ASF) licenses this file to you under
// the Apache License, Version 2.0 (the "License"); you may
// not use this file except in compliance with the License.
// You may obtain a copy of the License at
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
package v1alpha1
import (
v1 ""
metav1 ""
// FetcherSpec defines the desired state of Fetcher
type FetcherSpec struct {
// Fetcher is the type of how to fetch metrics from target.
// +kubebuilder:validation:Required
Type []FetcherType `json:"type,omitempty"`
// OAPServerAddress is the address of backend OAPServers
// +kubebuilder:validation:Required
OAPServerAddress string `json:"OAPServerAddress,omitempty"`
// ClusterName
// +kubebuilder:validation:Optional
ClusterName string `json:"clusterName,omitempty"`
// Service Type string describes ingress methods for a service
type FetcherType string
const (
// ServiceTypeClusterIP means a service will only be accessible inside the
// cluster, via the cluster IP.
FetcherTypePrometheus = "prometheus"
func (f *FetcherSpec) GetType() []string {
result := make([]string, len(f.Type))
for _, t := range f.Type {
result = append(result, string(t))
return result
// FetcherStatus defines the observed state of Fetcher
type FetcherStatus struct {
// Replicas is currently not being set and might be removed in the next version.
// +kubebuilder:validation:Optional
Replicas int32 `json:"replicas,omitempty"`
// Represents the latest available observations of a fetcher's current state.
// +kubebuilder:validation:Optional
Conditions []FetcherCondition `json:"conditions,omitempty"`
type FetcherConditionType string
var (
FetcherConditionTypeRead FetcherConditionType = "Ready"
// DeploymentCondition describes the state of a deployment at a certain point.
type FetcherCondition struct {
// Type of deployment condition.
Type FetcherConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=DeploymentConditionType"`
// Status of the condition, one of True, False, Unknown.
Status v1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,"`
// The last time this condition was updated.
LastUpdateTime metav1.Time `json:"lastUpdateTime,omitempty" protobuf:"bytes,6,opt,name=lastUpdateTime"`
// Last time the condition transitioned from one status to another.
LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty" protobuf:"bytes,7,opt,name=lastTransitionTime"`
// A human readable message indicating details about the transition.
Message string `json:"message,omitempty" protobuf:"bytes,5,opt,name=message"`
// +kubebuilder:object:root=true
// +kubebuilder:subresource:status
// Fetcher is the Schema for the fetchers API
type Fetcher struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec FetcherSpec `json:"spec,omitempty"`
Status FetcherStatus `json:"status,omitempty"`
// +kubebuilder:object:root=true
// FetcherList contains a list of Fetcher
type FetcherList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Fetcher `json:"items"`
func init() {
SchemeBuilder.Register(&Fetcher{}, &FetcherList{})