Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterCortexAdminServer(s grpc.ServiceRegistrar, srv CortexAdminServer)
- type AdminClientOption
- type AdminClientOptions
- type Alert
- func (*Alert) Descriptor() ([]byte, []int)deprecated
- func (x *Alert) GetActiveAt() string
- func (x *Alert) GetAnnotations() map[string]string
- func (x *Alert) GetLabels() map[string]string
- func (x *Alert) GetState() string
- func (x *Alert) GetValue() string
- func (*Alert) ProtoMessage()
- func (x *Alert) ProtoReflect() protoreflect.Message
- func (x *Alert) Reset()
- func (x *Alert) String() string
- type Cluster
- type CompactorStatus
- func (*CompactorStatus) Descriptor() ([]byte, []int)deprecated
- func (x *CompactorStatus) GetMemberlist() *MemberlistStatus
- func (x *CompactorStatus) GetRing() *RingStatus
- func (x *CompactorStatus) GetServices() *ServiceStatusList
- func (*CompactorStatus) ProtoMessage()
- func (x *CompactorStatus) ProtoReflect() protoreflect.Message
- func (x *CompactorStatus) Reset()
- func (x *CompactorStatus) String() string
- type ConfigRequest
- type ConfigResponse
- type CortexAdminClient
- type CortexAdminServer
- type CortexStatus
- func (*CortexStatus) Descriptor() ([]byte, []int)deprecated
- func (x *CortexStatus) GetCompactor() *CompactorStatus
- func (x *CortexStatus) GetDistributor() *DistributorStatus
- func (x *CortexStatus) GetIngester() *IngesterStatus
- func (x *CortexStatus) GetPurger() *PurgerStatus
- func (x *CortexStatus) GetQuerier() *QuerierStatus
- func (x *CortexStatus) GetQueryFrontend() *QueryFrontendStatus
- func (x *CortexStatus) GetRuler() *RulerStatus
- func (x *CortexStatus) GetStoreGateway() *StoreGatewayStatus
- func (x *CortexStatus) GetTimestamp() *timestamppb.Timestamp
- func (*CortexStatus) ProtoMessage()
- func (x *CortexStatus) ProtoReflect() protoreflect.Message
- func (x *CortexStatus) Reset()
- func (x *CortexStatus) String() string
- type DeleteRuleRequest
- func (*DeleteRuleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRuleRequest) GetClusterId() string
- func (x *DeleteRuleRequest) GetGroupName() string
- func (x *DeleteRuleRequest) GetNamespace() string
- func (*DeleteRuleRequest) ProtoMessage()
- func (x *DeleteRuleRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRuleRequest) Reset()
- func (x *DeleteRuleRequest) String() string
- func (in *DeleteRuleRequest) Validate() error
- type DistributorStatus
- func (*DistributorStatus) Descriptor() ([]byte, []int)deprecated
- func (x *DistributorStatus) GetIngesterRing() *RingStatus
- func (x *DistributorStatus) GetServices() *ServiceStatusList
- func (*DistributorStatus) ProtoMessage()
- func (x *DistributorStatus) ProtoReflect() protoreflect.Message
- func (x *DistributorStatus) Reset()
- func (x *DistributorStatus) String() string
- type Exemplar
- func (*Exemplar) Descriptor() ([]byte, []int)deprecated
- func (x *Exemplar) GetLabels() []*Label
- func (x *Exemplar) GetTimestampMs() int64
- func (x *Exemplar) GetValue() float64
- func (*Exemplar) ProtoMessage()
- func (x *Exemplar) ProtoReflect() protoreflect.Message
- func (x *Exemplar) Reset()
- func (x *Exemplar) String() string
- type GetRuleRequest
- func (*GetRuleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRuleRequest) GetClusterId() string
- func (x *GetRuleRequest) GetGroupName() string
- func (x *GetRuleRequest) GetNamespace() string
- func (*GetRuleRequest) ProtoMessage()
- func (x *GetRuleRequest) ProtoReflect() protoreflect.Message
- func (x *GetRuleRequest) Reset()
- func (x *GetRuleRequest) String() string
- func (in *GetRuleRequest) Validate() error
- type IngesterStatus
- func (*IngesterStatus) Descriptor() ([]byte, []int)deprecated
- func (x *IngesterStatus) GetMemberlist() *MemberlistStatus
- func (x *IngesterStatus) GetRing() *RingStatus
- func (x *IngesterStatus) GetServices() *ServiceStatusList
- func (*IngesterStatus) ProtoMessage()
- func (x *IngesterStatus) ProtoReflect() protoreflect.Message
- func (x *IngesterStatus) Reset()
- func (x *IngesterStatus) String() string
- type Label
- type LabelRequest
- func (*LabelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LabelRequest) GetJobId() string
- func (x *LabelRequest) GetMetricName() string
- func (x *LabelRequest) GetTenant() string
- func (*LabelRequest) ProtoMessage()
- func (x *LabelRequest) ProtoReflect() protoreflect.Message
- func (x *LabelRequest) Reset()
- func (x *LabelRequest) String() string
- type LabelSet
- type ListRulesRequest
- func (l *ListRulesRequest) All() bool
- func (*ListRulesRequest) Descriptor() ([]byte, []int)deprecated
- func (l *ListRulesRequest) Filter(groups *RuleGroups, clusterId string) *RuleGroups
- func (x *ListRulesRequest) GetClusterId() []string
- func (x *ListRulesRequest) GetGroupNameRegexp() string
- func (x *ListRulesRequest) GetHealthFilter() []string
- func (x *ListRulesRequest) GetListInvalid() bool
- func (x *ListRulesRequest) GetNamespaceRegexp() string
- func (x *ListRulesRequest) GetRequestAll() bool
- func (x *ListRulesRequest) GetRuleNameRegexp() string
- func (x *ListRulesRequest) GetRuleType() []string
- func (x *ListRulesRequest) GetStateFilter() []string
- func (l *ListRulesRequest) Invalid() bool
- func (l *ListRulesRequest) MatchesCluster(clusterId string) bool
- func (l *ListRulesRequest) MatchesHealth(health string) bool
- func (l *ListRulesRequest) MatchesNamespace(namespaceRegex *regexp.Regexp, namespace string) bool
- func (l *ListRulesRequest) MatchesRule(ruleNameExpr *regexp.Regexp, ruleName string) bool
- func (l *ListRulesRequest) MatchesRuleGroup(groupNameExpr *regexp.Regexp, groupName string) bool
- func (l *ListRulesRequest) MatchesRuleState(state string) bool
- func (l *ListRulesRequest) MatchesRuleType(ruleType string) bool
- func (*ListRulesRequest) ProtoMessage()
- func (x *ListRulesRequest) ProtoReflect() protoreflect.Message
- func (x *ListRulesRequest) Reset()
- func (x *ListRulesRequest) String() string
- func (l *ListRulesRequest) Validate() error
- type ListRulesResponse
- func (*ListRulesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListRulesResponse) GetData() *RuleGroups
- func (x *ListRulesResponse) GetStatus() string
- func (*ListRulesResponse) ProtoMessage()
- func (x *ListRulesResponse) ProtoReflect() protoreflect.Message
- func (x *ListRulesResponse) Reset()
- func (x *ListRulesResponse) String() string
- type LoadRuleRequest
- func (*LoadRuleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoadRuleRequest) GetClusterId() string
- func (x *LoadRuleRequest) GetNamespace() string
- func (x *LoadRuleRequest) GetYamlContent() []byte
- func (*LoadRuleRequest) ProtoMessage()
- func (x *LoadRuleRequest) ProtoReflect() protoreflect.Message
- func (x *LoadRuleRequest) Reset()
- func (x *LoadRuleRequest) String() string
- func (in *LoadRuleRequest) Validate() error
- type MatcherRequest
- func (*MatcherRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MatcherRequest) GetMatchExpr() string
- func (x *MatcherRequest) GetTenant() string
- func (*MatcherRequest) ProtoMessage()
- func (x *MatcherRequest) ProtoReflect() protoreflect.Message
- func (x *MatcherRequest) Reset()
- func (x *MatcherRequest) String() string
- type MemberStatus
- func (*MemberStatus) Descriptor() ([]byte, []int)deprecated
- func (x *MemberStatus) GetAddress() string
- func (x *MemberStatus) GetName() string
- func (x *MemberStatus) GetPort() uint32
- func (x *MemberStatus) GetState() int32
- func (*MemberStatus) ProtoMessage()
- func (x *MemberStatus) ProtoReflect() protoreflect.Message
- func (x *MemberStatus) Reset()
- func (x *MemberStatus) String() string
- type MemberStatusList
- type MemberlistStatus
- func (*MemberlistStatus) Descriptor() ([]byte, []int)deprecated
- func (x *MemberlistStatus) GetEnabled() bool
- func (x *MemberlistStatus) GetKeys() []string
- func (x *MemberlistStatus) GetMembers() *MemberStatusList
- func (*MemberlistStatus) ProtoMessage()
- func (x *MemberlistStatus) ProtoReflect() protoreflect.Message
- func (x *MemberlistStatus) Reset()
- func (x *MemberlistStatus) String() string
- type MetricLabels
- type MetricMetadata
- func (*MetricMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *MetricMetadata) GetHelp() string
- func (x *MetricMetadata) GetMetricFamilyName() string
- func (x *MetricMetadata) GetType() MetricMetadata_MetricType
- func (x *MetricMetadata) GetUnit() string
- func (*MetricMetadata) ProtoMessage()
- func (x *MetricMetadata) ProtoReflect() protoreflect.Message
- func (x *MetricMetadata) Reset()
- func (x *MetricMetadata) String() string
- type MetricMetadataRequest
- func (*MetricMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MetricMetadataRequest) GetMetricName() string
- func (x *MetricMetadataRequest) GetTenants() []string
- func (*MetricMetadataRequest) ProtoMessage()
- func (x *MetricMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *MetricMetadataRequest) Reset()
- func (x *MetricMetadataRequest) String() string
- type MetricMetadata_MetricType
- func (MetricMetadata_MetricType) Descriptor() protoreflect.EnumDescriptor
- func (x MetricMetadata_MetricType) Enum() *MetricMetadata_MetricType
- func (MetricMetadata_MetricType) EnumDescriptor() ([]byte, []int)deprecated
- func (x MetricMetadata_MetricType) Number() protoreflect.EnumNumber
- func (x MetricMetadata_MetricType) String() string
- func (MetricMetadata_MetricType) Type() protoreflect.EnumType
- type PurgerStatus
- type QuerierStatus
- func (*QuerierStatus) Descriptor() ([]byte, []int)deprecated
- func (x *QuerierStatus) GetMemberlist() *MemberlistStatus
- func (x *QuerierStatus) GetServices() *ServiceStatusList
- func (*QuerierStatus) ProtoMessage()
- func (x *QuerierStatus) ProtoReflect() protoreflect.Message
- func (x *QuerierStatus) Reset()
- func (x *QuerierStatus) String() string
- type QueryFrontendStatus
- func (*QueryFrontendStatus) Descriptor() ([]byte, []int)deprecated
- func (x *QueryFrontendStatus) GetServices() *ServiceStatusList
- func (*QueryFrontendStatus) ProtoMessage()
- func (x *QueryFrontendStatus) ProtoReflect() protoreflect.Message
- func (x *QueryFrontendStatus) Reset()
- func (x *QueryFrontendStatus) String() string
- type QueryRangeRequest
- func (*QueryRangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRangeRequest) GetEnd() *timestamppb.Timestamp
- func (x *QueryRangeRequest) GetQuery() string
- func (x *QueryRangeRequest) GetStart() *timestamppb.Timestamp
- func (x *QueryRangeRequest) GetStep() *durationpb.Duration
- func (x *QueryRangeRequest) GetTenants() []string
- func (*QueryRangeRequest) ProtoMessage()
- func (x *QueryRangeRequest) ProtoReflect() protoreflect.Message
- func (x *QueryRangeRequest) Reset()
- func (x *QueryRangeRequest) String() string
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRequest) GetQuery() string
- func (x *QueryRequest) GetTenants() []string
- func (*QueryRequest) ProtoMessage()
- func (x *QueryRequest) ProtoReflect() protoreflect.Message
- func (x *QueryRequest) Reset()
- func (x *QueryRequest) String() string
- type QueryResponse
- type RingStatus
- func (*RingStatus) Descriptor() ([]byte, []int)deprecated
- func (x *RingStatus) GetEnabled() bool
- func (x *RingStatus) GetShards() *ShardStatusList
- func (*RingStatus) ProtoMessage()
- func (x *RingStatus) ProtoReflect() protoreflect.Message
- func (x *RingStatus) Reset()
- func (x *RingStatus) String() string
- type Rule
- func (*Rule) Descriptor() ([]byte, []int)deprecated
- func (x *Rule) GetAlerts() []*Alert
- func (x *Rule) GetAnnotations() map[string]string
- func (x *Rule) GetDuration() float64
- func (x *Rule) GetEvaluationTime() float64
- func (x *Rule) GetHealth() string
- func (x *Rule) GetLabels() map[string]string
- func (x *Rule) GetLastError() string
- func (x *Rule) GetLastEvaluation() string
- func (x *Rule) GetName() string
- func (x *Rule) GetQuery() string
- func (x *Rule) GetState() string
- func (x *Rule) GetType() string
- func (*Rule) ProtoMessage()
- func (x *Rule) ProtoReflect() protoreflect.Message
- func (x *Rule) Reset()
- func (x *Rule) String() string
- type RuleGroup
- func (*RuleGroup) Descriptor() ([]byte, []int)deprecated
- func (x *RuleGroup) GetClusterId() string
- func (x *RuleGroup) GetEvaluationTime() float64
- func (x *RuleGroup) GetFile() string
- func (x *RuleGroup) GetInterval() float64
- func (x *RuleGroup) GetLastEvaluation() string
- func (x *RuleGroup) GetName() string
- func (x *RuleGroup) GetRules() []*Rule
- func (*RuleGroup) ProtoMessage()
- func (x *RuleGroup) ProtoReflect() protoreflect.Message
- func (x *RuleGroup) Reset()
- func (x *RuleGroup) String() string
- type RuleGroups
- type RulerStatus
- func (*RulerStatus) Descriptor() ([]byte, []int)deprecated
- func (x *RulerStatus) GetMemberlist() *MemberlistStatus
- func (x *RulerStatus) GetRing() *RingStatus
- func (x *RulerStatus) GetServices() *ServiceStatusList
- func (*RulerStatus) ProtoMessage()
- func (x *RulerStatus) ProtoReflect() protoreflect.Message
- func (x *RulerStatus) Reset()
- func (x *RulerStatus) String() string
- type Sample
- type SeriesInfo
- func (*SeriesInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SeriesInfo) GetMetadata() *SeriesMetadata
- func (x *SeriesInfo) GetSeriesName() string
- func (*SeriesInfo) ProtoMessage()
- func (x *SeriesInfo) ProtoReflect() protoreflect.Message
- func (x *SeriesInfo) Reset()
- func (x *SeriesInfo) String() string
- type SeriesInfoList
- type SeriesMetadata
- func (*SeriesMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *SeriesMetadata) GetDescription() string
- func (x *SeriesMetadata) GetType() string
- func (x *SeriesMetadata) GetUnit() string
- func (*SeriesMetadata) ProtoMessage()
- func (x *SeriesMetadata) ProtoReflect() protoreflect.Message
- func (x *SeriesMetadata) Reset()
- func (x *SeriesMetadata) String() string
- type SeriesRequest
- func (*SeriesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SeriesRequest) GetJobId() string
- func (x *SeriesRequest) GetTenant() string
- func (*SeriesRequest) ProtoMessage()
- func (x *SeriesRequest) ProtoReflect() protoreflect.Message
- func (x *SeriesRequest) Reset()
- func (x *SeriesRequest) String() string
- type ServiceStatus
- func (*ServiceStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceStatus) GetName() string
- func (x *ServiceStatus) GetStatus() string
- func (*ServiceStatus) ProtoMessage()
- func (x *ServiceStatus) ProtoReflect() protoreflect.Message
- func (x *ServiceStatus) Reset()
- func (x *ServiceStatus) String() string
- type ServiceStatusList
- func (*ServiceStatusList) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceStatusList) GetServices() []*ServiceStatus
- func (*ServiceStatusList) ProtoMessage()
- func (x *ServiceStatusList) ProtoReflect() protoreflect.Message
- func (x *ServiceStatusList) Reset()
- func (x *ServiceStatusList) String() string
- type ShardStatus
- func (*ShardStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ShardStatus) GetAddress() string
- func (x *ShardStatus) GetId() string
- func (x *ShardStatus) GetRegisteredTimestamp() string
- func (x *ShardStatus) GetState() string
- func (x *ShardStatus) GetTimestamp() string
- func (x *ShardStatus) GetZone() string
- func (*ShardStatus) ProtoMessage()
- func (x *ShardStatus) ProtoReflect() protoreflect.Message
- func (x *ShardStatus) Reset()
- func (x *ShardStatus) String() string
- type ShardStatusList
- type StoreGatewayStatus
- func (*StoreGatewayStatus) Descriptor() ([]byte, []int)deprecated
- func (x *StoreGatewayStatus) GetMemberlist() *MemberlistStatus
- func (x *StoreGatewayStatus) GetRing() *RingStatus
- func (x *StoreGatewayStatus) GetServices() *ServiceStatusList
- func (*StoreGatewayStatus) ProtoMessage()
- func (x *StoreGatewayStatus) ProtoReflect() protoreflect.Message
- func (x *StoreGatewayStatus) Reset()
- func (x *StoreGatewayStatus) String() string
- type TimeSeries
- func (*TimeSeries) Descriptor() ([]byte, []int)deprecated
- func (x *TimeSeries) GetExemplars() []*Exemplar
- func (x *TimeSeries) GetLabels() []*Label
- func (x *TimeSeries) GetSamples() []*Sample
- func (*TimeSeries) ProtoMessage()
- func (x *TimeSeries) ProtoReflect() protoreflect.Message
- func (x *TimeSeries) Reset()
- func (x *TimeSeries) String() string
- type UnimplementedCortexAdminServer
- func (UnimplementedCortexAdminServer) AllUserStats(context.Context, *emptypb.Empty) (*UserIDStatsList, error)
- func (UnimplementedCortexAdminServer) DeleteRule(context.Context, *DeleteRuleRequest) (*emptypb.Empty, error)
- func (UnimplementedCortexAdminServer) ExtractRawSeries(context.Context, *MatcherRequest) (*QueryResponse, error)
- func (UnimplementedCortexAdminServer) FlushBlocks(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedCortexAdminServer) GetCortexConfig(context.Context, *ConfigRequest) (*ConfigResponse, error)
- func (UnimplementedCortexAdminServer) GetCortexStatus(context.Context, *emptypb.Empty) (*CortexStatus, error)
- func (UnimplementedCortexAdminServer) GetMetricLabelSets(context.Context, *LabelRequest) (*MetricLabels, error)
- func (UnimplementedCortexAdminServer) GetMetricMetadata(context.Context, *MetricMetadataRequest) (*MetricMetadata, error)
- func (UnimplementedCortexAdminServer) GetRule(context.Context, *GetRuleRequest) (*QueryResponse, error)
- func (UnimplementedCortexAdminServer) GetSeriesMetrics(context.Context, *SeriesRequest) (*SeriesInfoList, error)
- func (UnimplementedCortexAdminServer) ListRules(context.Context, *ListRulesRequest) (*ListRulesResponse, error)
- func (UnimplementedCortexAdminServer) LoadRules(context.Context, *LoadRuleRequest) (*emptypb.Empty, error)
- func (UnimplementedCortexAdminServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)
- func (UnimplementedCortexAdminServer) QueryRange(context.Context, *QueryRangeRequest) (*QueryResponse, error)
- func (UnimplementedCortexAdminServer) WriteMetrics(context.Context, *WriteRequest) (*WriteResponse, error)
- type UnsafeCortexAdminServer
- type UserIDStats
- func (*UserIDStats) Descriptor() ([]byte, []int)deprecated
- func (x *UserIDStats) GetAPIIngestionRate() float64
- func (x *UserIDStats) GetIngestionRate() float64
- func (x *UserIDStats) GetNumSeries() uint64
- func (x *UserIDStats) GetRuleIngestionRate() float64
- func (x *UserIDStats) GetUserID() string
- func (*UserIDStats) ProtoMessage()
- func (x *UserIDStats) ProtoReflect() protoreflect.Message
- func (x *UserIDStats) Reset()
- func (x *UserIDStats) String() string
- type UserIDStatsList
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteRequest) GetClusterID() string
- func (x *WriteRequest) GetMetadata() []*MetricMetadata
- func (x *WriteRequest) GetTimeseries() []*TimeSeries
- func (*WriteRequest) ProtoMessage()
- func (x *WriteRequest) ProtoReflect() protoreflect.Message
- func (x *WriteRequest) Reset()
- func (x *WriteRequest) String() string
- type WriteResponse
Constants ¶
const ( CortexAdmin_AllUserStats_FullMethodName = "/cortexadmin.CortexAdmin/AllUserStats" CortexAdmin_WriteMetrics_FullMethodName = "/cortexadmin.CortexAdmin/WriteMetrics" CortexAdmin_Query_FullMethodName = "/cortexadmin.CortexAdmin/Query" CortexAdmin_QueryRange_FullMethodName = "/cortexadmin.CortexAdmin/QueryRange" CortexAdmin_GetRule_FullMethodName = "/cortexadmin.CortexAdmin/GetRule" CortexAdmin_GetMetricMetadata_FullMethodName = "/cortexadmin.CortexAdmin/GetMetricMetadata" CortexAdmin_ListRules_FullMethodName = "/cortexadmin.CortexAdmin/ListRules" CortexAdmin_LoadRules_FullMethodName = "/cortexadmin.CortexAdmin/LoadRules" CortexAdmin_DeleteRule_FullMethodName = "/cortexadmin.CortexAdmin/DeleteRule" CortexAdmin_FlushBlocks_FullMethodName = "/cortexadmin.CortexAdmin/FlushBlocks" CortexAdmin_GetSeriesMetrics_FullMethodName = "/cortexadmin.CortexAdmin/GetSeriesMetrics" CortexAdmin_GetMetricLabelSets_FullMethodName = "/cortexadmin.CortexAdmin/GetMetricLabelSets" CortexAdmin_GetCortexStatus_FullMethodName = "/cortexadmin.CortexAdmin/GetCortexStatus" CortexAdmin_GetCortexConfig_FullMethodName = "/cortexadmin.CortexAdmin/GetCortexConfig" CortexAdmin_ExtractRawSeries_FullMethodName = "/cortexadmin.CortexAdmin/ExtractRawSeries" )
Variables ¶
var ( MetricMetadata_MetricType_name = map[int32]string{ 0: "UNKNOWN", 1: "COUNTER", 2: "GAUGE", 3: "HISTOGRAM", 4: "GAUGEHISTOGRAM", 5: "SUMMARY", 6: "INFO", 7: "STATESET", } MetricMetadata_MetricType_value = map[string]int32{ "UNKNOWN": 0, "COUNTER": 1, "GAUGE": 2, "HISTOGRAM": 3, "GAUGEHISTOGRAM": 4, "SUMMARY": 5, "INFO": 6, "STATESET": 7, } )
Enum value maps for MetricMetadata_MetricType.
var CortexAdmin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cortexadmin.CortexAdmin", HandlerType: (*CortexAdminServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AllUserStats", Handler: _CortexAdmin_AllUserStats_Handler, }, { MethodName: "WriteMetrics", Handler: _CortexAdmin_WriteMetrics_Handler, }, { MethodName: "Query", Handler: _CortexAdmin_Query_Handler, }, { MethodName: "QueryRange", Handler: _CortexAdmin_QueryRange_Handler, }, { MethodName: "GetRule", Handler: _CortexAdmin_GetRule_Handler, }, { MethodName: "GetMetricMetadata", Handler: _CortexAdmin_GetMetricMetadata_Handler, }, { MethodName: "ListRules", Handler: _CortexAdmin_ListRules_Handler, }, { MethodName: "LoadRules", Handler: _CortexAdmin_LoadRules_Handler, }, { MethodName: "DeleteRule", Handler: _CortexAdmin_DeleteRule_Handler, }, { MethodName: "FlushBlocks", Handler: _CortexAdmin_FlushBlocks_Handler, }, { MethodName: "GetSeriesMetrics", Handler: _CortexAdmin_GetSeriesMetrics_Handler, }, { MethodName: "GetMetricLabelSets", Handler: _CortexAdmin_GetMetricLabelSets_Handler, }, { MethodName: "GetCortexStatus", Handler: _CortexAdmin_GetCortexStatus_Handler, }, { MethodName: "GetCortexConfig", Handler: _CortexAdmin_GetCortexConfig_Handler, }, { MethodName: "ExtractRawSeries", Handler: _CortexAdmin_ExtractRawSeries_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "github.com/rancher/opni/plugins/metrics/apis/cortexadmin/cortexadmin.proto", }
CortexAdmin_ServiceDesc is the grpc.ServiceDesc for CortexAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_github_com_rancher_opni_plugins_metrics_apis_cortexadmin_cortexadmin_proto protoreflect.FileDescriptor
var File_github_com_rancher_opni_plugins_metrics_apis_cortexadmin_status_proto protoreflect.FileDescriptor
Functions ¶
func RegisterCortexAdminServer ¶
func RegisterCortexAdminServer(s grpc.ServiceRegistrar, srv CortexAdminServer)
Types ¶
type AdminClientOption ¶
type AdminClientOption func(*AdminClientOptions)
func WithDialOptions ¶
func WithDialOptions(options ...grpc.DialOption) AdminClientOption
func WithListenAddress ¶
func WithListenAddress(addr string) AdminClientOption
type AdminClientOptions ¶
type AdminClientOptions struct {
// contains filtered or unexported fields
}
type Alert ¶
type Alert struct { Labels map[string]string `` /* 153-byte string literal not displayed */ Annotations map[string]string `` /* 163-byte string literal not displayed */ State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` // Note : string instead of timestamp to preserve compatibility with native prometheus api return value ActiveAt string `protobuf:"bytes,4,opt,name=activeAt,proto3" json:"activeAt,omitempty"` Value string `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Alert) Descriptor
deprecated
func (*Alert) GetActiveAt ¶
func (*Alert) GetAnnotations ¶
func (*Alert) ProtoMessage ¶
func (*Alert) ProtoMessage()
func (*Alert) ProtoReflect ¶
func (x *Alert) ProtoReflect() protoreflect.Message
type Cluster ¶
type Cluster struct { ClusterId string `protobuf:"bytes,1,opt,name=clusterId,proto3" json:"clusterId,omitempty"` // contains filtered or unexported fields }
func (*Cluster) Descriptor
deprecated
func (*Cluster) GetClusterId ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
type CompactorStatus ¶
type CompactorStatus struct { Services *ServiceStatusList `protobuf:"bytes,1,opt,name=services,proto3" json:"services,omitempty"` Memberlist *MemberlistStatus `protobuf:"bytes,2,opt,name=memberlist,proto3" json:"memberlist,omitempty"` Ring *RingStatus `protobuf:"bytes,3,opt,name=ring,proto3" json:"ring,omitempty"` // contains filtered or unexported fields }
func (*CompactorStatus) Descriptor
deprecated
func (*CompactorStatus) Descriptor() ([]byte, []int)
Deprecated: Use CompactorStatus.ProtoReflect.Descriptor instead.
func (*CompactorStatus) GetMemberlist ¶
func (x *CompactorStatus) GetMemberlist() *MemberlistStatus
func (*CompactorStatus) GetRing ¶
func (x *CompactorStatus) GetRing() *RingStatus
func (*CompactorStatus) GetServices ¶
func (x *CompactorStatus) GetServices() *ServiceStatusList
func (*CompactorStatus) ProtoMessage ¶
func (*CompactorStatus) ProtoMessage()
func (*CompactorStatus) ProtoReflect ¶
func (x *CompactorStatus) ProtoReflect() protoreflect.Message
func (*CompactorStatus) Reset ¶
func (x *CompactorStatus) Reset()
func (*CompactorStatus) String ¶
func (x *CompactorStatus) String() string
type ConfigRequest ¶
type ConfigRequest struct { ConfigModes []string `protobuf:"bytes,1,rep,name=configModes,proto3" json:"configModes,omitempty"` // contains filtered or unexported fields }
func (*ConfigRequest) Descriptor
deprecated
func (*ConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigRequest.ProtoReflect.Descriptor instead.
func (*ConfigRequest) GetConfigModes ¶
func (x *ConfigRequest) GetConfigModes() []string
func (*ConfigRequest) ProtoMessage ¶
func (*ConfigRequest) ProtoMessage()
func (*ConfigRequest) ProtoReflect ¶
func (x *ConfigRequest) ProtoReflect() protoreflect.Message
func (*ConfigRequest) Reset ¶
func (x *ConfigRequest) Reset()
func (*ConfigRequest) String ¶
func (x *ConfigRequest) String() string
type ConfigResponse ¶
type ConfigResponse struct { ConfigYaml []string `protobuf:"bytes,4,rep,name=configYaml,proto3" json:"configYaml,omitempty"` // contains filtered or unexported fields }
func (*ConfigResponse) Descriptor
deprecated
func (*ConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigResponse.ProtoReflect.Descriptor instead.
func (*ConfigResponse) GetConfigYaml ¶
func (x *ConfigResponse) GetConfigYaml() []string
func (*ConfigResponse) ProtoMessage ¶
func (*ConfigResponse) ProtoMessage()
func (*ConfigResponse) ProtoReflect ¶
func (x *ConfigResponse) ProtoReflect() protoreflect.Message
func (*ConfigResponse) Reset ¶
func (x *ConfigResponse) Reset()
func (*ConfigResponse) String ¶
func (x *ConfigResponse) String() string
type CortexAdminClient ¶
type CortexAdminClient interface { AllUserStats(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*UserIDStatsList, error) WriteMetrics(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error) QueryRange(ctx context.Context, in *QueryRangeRequest, opts ...grpc.CallOption) (*QueryResponse, error) GetRule(ctx context.Context, in *GetRuleRequest, opts ...grpc.CallOption) (*QueryResponse, error) GetMetricMetadata(ctx context.Context, in *MetricMetadataRequest, opts ...grpc.CallOption) (*MetricMetadata, error) // Heavy-handed API for diagnostics. ListRules(ctx context.Context, in *ListRulesRequest, opts ...grpc.CallOption) (*ListRulesResponse, error) LoadRules(ctx context.Context, in *LoadRuleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) DeleteRule(ctx context.Context, in *DeleteRuleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) FlushBlocks(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) // list all metrics GetSeriesMetrics(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (*SeriesInfoList, error) GetMetricLabelSets(ctx context.Context, in *LabelRequest, opts ...grpc.CallOption) (*MetricLabels, error) GetCortexStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CortexStatus, error) GetCortexConfig(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*ConfigResponse, error) ExtractRawSeries(ctx context.Context, in *MatcherRequest, opts ...grpc.CallOption) (*QueryResponse, error) }
CortexAdminClient is the client API for CortexAdmin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewClient ¶
func NewClient(ctx waitctx.PermissiveContext, opts ...AdminClientOption) (CortexAdminClient, error)
func NewCortexAdminClient ¶
func NewCortexAdminClient(cc grpc.ClientConnInterface) CortexAdminClient
type CortexAdminServer ¶
type CortexAdminServer interface { AllUserStats(context.Context, *emptypb.Empty) (*UserIDStatsList, error) WriteMetrics(context.Context, *WriteRequest) (*WriteResponse, error) Query(context.Context, *QueryRequest) (*QueryResponse, error) QueryRange(context.Context, *QueryRangeRequest) (*QueryResponse, error) GetRule(context.Context, *GetRuleRequest) (*QueryResponse, error) GetMetricMetadata(context.Context, *MetricMetadataRequest) (*MetricMetadata, error) // Heavy-handed API for diagnostics. ListRules(context.Context, *ListRulesRequest) (*ListRulesResponse, error) LoadRules(context.Context, *LoadRuleRequest) (*emptypb.Empty, error) DeleteRule(context.Context, *DeleteRuleRequest) (*emptypb.Empty, error) FlushBlocks(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // list all metrics GetSeriesMetrics(context.Context, *SeriesRequest) (*SeriesInfoList, error) GetMetricLabelSets(context.Context, *LabelRequest) (*MetricLabels, error) GetCortexStatus(context.Context, *emptypb.Empty) (*CortexStatus, error) GetCortexConfig(context.Context, *ConfigRequest) (*ConfigResponse, error) ExtractRawSeries(context.Context, *MatcherRequest) (*QueryResponse, error) // contains filtered or unexported methods }
CortexAdminServer is the server API for CortexAdmin service. All implementations must embed UnimplementedCortexAdminServer for forward compatibility
type CortexStatus ¶
type CortexStatus struct { Distributor *DistributorStatus `protobuf:"bytes,1,opt,name=distributor,proto3" json:"distributor,omitempty"` Ingester *IngesterStatus `protobuf:"bytes,2,opt,name=ingester,proto3" json:"ingester,omitempty"` Ruler *RulerStatus `protobuf:"bytes,3,opt,name=ruler,proto3" json:"ruler,omitempty"` Purger *PurgerStatus `protobuf:"bytes,4,opt,name=purger,proto3" json:"purger,omitempty"` Compactor *CompactorStatus `protobuf:"bytes,5,opt,name=compactor,proto3" json:"compactor,omitempty"` StoreGateway *StoreGatewayStatus `protobuf:"bytes,6,opt,name=storeGateway,proto3" json:"storeGateway,omitempty"` QueryFrontend *QueryFrontendStatus `protobuf:"bytes,7,opt,name=queryFrontend,proto3" json:"queryFrontend,omitempty"` Querier *QuerierStatus `protobuf:"bytes,8,opt,name=querier,proto3" json:"querier,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*CortexStatus) Descriptor
deprecated
func (*CortexStatus) Descriptor() ([]byte, []int)
Deprecated: Use CortexStatus.ProtoReflect.Descriptor instead.
func (*CortexStatus) GetCompactor ¶
func (x *CortexStatus) GetCompactor() *CompactorStatus
func (*CortexStatus) GetDistributor ¶
func (x *CortexStatus) GetDistributor() *DistributorStatus
func (*CortexStatus) GetIngester ¶
func (x *CortexStatus) GetIngester() *IngesterStatus
func (*CortexStatus) GetPurger ¶
func (x *CortexStatus) GetPurger() *PurgerStatus
func (*CortexStatus) GetQuerier ¶
func (x *CortexStatus) GetQuerier() *QuerierStatus
func (*CortexStatus) GetQueryFrontend ¶
func (x *CortexStatus) GetQueryFrontend() *QueryFrontendStatus
func (*CortexStatus) GetRuler ¶
func (x *CortexStatus) GetRuler() *RulerStatus
func (*CortexStatus) GetStoreGateway ¶
func (x *CortexStatus) GetStoreGateway() *StoreGatewayStatus
func (*CortexStatus) GetTimestamp ¶
func (x *CortexStatus) GetTimestamp() *timestamppb.Timestamp
func (*CortexStatus) ProtoMessage ¶
func (*CortexStatus) ProtoMessage()
func (*CortexStatus) ProtoReflect ¶
func (x *CortexStatus) ProtoReflect() protoreflect.Message
func (*CortexStatus) Reset ¶
func (x *CortexStatus) Reset()
func (*CortexStatus) String ¶
func (x *CortexStatus) String() string
type DeleteRuleRequest ¶
type DeleteRuleRequest struct { ClusterId string `protobuf:"bytes,1,opt,name=clusterId,proto3" json:"clusterId,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` GroupName string `protobuf:"bytes,3,opt,name=groupName,proto3" json:"groupName,omitempty"` // contains filtered or unexported fields }
func (*DeleteRuleRequest) Descriptor
deprecated
func (*DeleteRuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRuleRequest.ProtoReflect.Descriptor instead.
func (*DeleteRuleRequest) GetClusterId ¶
func (x *DeleteRuleRequest) GetClusterId() string
func (*DeleteRuleRequest) GetGroupName ¶
func (x *DeleteRuleRequest) GetGroupName() string
func (*DeleteRuleRequest) GetNamespace ¶
func (x *DeleteRuleRequest) GetNamespace() string
func (*DeleteRuleRequest) ProtoMessage ¶
func (*DeleteRuleRequest) ProtoMessage()
func (*DeleteRuleRequest) ProtoReflect ¶
func (x *DeleteRuleRequest) ProtoReflect() protoreflect.Message
func (*DeleteRuleRequest) Reset ¶
func (x *DeleteRuleRequest) Reset()
func (*DeleteRuleRequest) String ¶
func (x *DeleteRuleRequest) String() string
func (*DeleteRuleRequest) Validate ¶
func (in *DeleteRuleRequest) Validate() error
type DistributorStatus ¶
type DistributorStatus struct { Services *ServiceStatusList `protobuf:"bytes,1,opt,name=services,proto3" json:"services,omitempty"` IngesterRing *RingStatus `protobuf:"bytes,2,opt,name=ingesterRing,proto3" json:"ingesterRing,omitempty"` // contains filtered or unexported fields }
func (*DistributorStatus) Descriptor
deprecated
func (*DistributorStatus) Descriptor() ([]byte, []int)
Deprecated: Use DistributorStatus.ProtoReflect.Descriptor instead.
func (*DistributorStatus) GetIngesterRing ¶
func (x *DistributorStatus) GetIngesterRing() *RingStatus
func (*DistributorStatus) GetServices ¶
func (x *DistributorStatus) GetServices() *ServiceStatusList
func (*DistributorStatus) ProtoMessage ¶
func (*DistributorStatus) ProtoMessage()
func (*DistributorStatus) ProtoReflect ¶
func (x *DistributorStatus) ProtoReflect() protoreflect.Message
func (*DistributorStatus) Reset ¶
func (x *DistributorStatus) Reset()
func (*DistributorStatus) String ¶
func (x *DistributorStatus) String() string
type Exemplar ¶
type Exemplar struct { Labels []*Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` TimestampMs int64 `protobuf:"varint,3,opt,name=timestampMs,proto3" json:"timestampMs,omitempty"` // contains filtered or unexported fields }
func (*Exemplar) Descriptor
deprecated
func (*Exemplar) GetTimestampMs ¶
func (*Exemplar) ProtoMessage ¶
func (*Exemplar) ProtoMessage()
func (*Exemplar) ProtoReflect ¶
func (x *Exemplar) ProtoReflect() protoreflect.Message
type GetRuleRequest ¶
type GetRuleRequest struct { ClusterId string `protobuf:"bytes,1,opt,name=clusterId,proto3" json:"clusterId,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` GroupName string `protobuf:"bytes,3,opt,name=groupName,proto3" json:"groupName,omitempty"` // contains filtered or unexported fields }
func (*GetRuleRequest) Descriptor
deprecated
func (*GetRuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRuleRequest.ProtoReflect.Descriptor instead.
func (*GetRuleRequest) GetClusterId ¶
func (x *GetRuleRequest) GetClusterId() string
func (*GetRuleRequest) GetGroupName ¶
func (x *GetRuleRequest) GetGroupName() string
func (*GetRuleRequest) GetNamespace ¶
func (x *GetRuleRequest) GetNamespace() string
func (*GetRuleRequest) ProtoMessage ¶
func (*GetRuleRequest) ProtoMessage()
func (*GetRuleRequest) ProtoReflect ¶
func (x *GetRuleRequest) ProtoReflect() protoreflect.Message
func (*GetRuleRequest) Reset ¶
func (x *GetRuleRequest) Reset()
func (*GetRuleRequest) String ¶
func (x *GetRuleRequest) String() string
func (*GetRuleRequest) Validate ¶
func (in *GetRuleRequest) Validate() error
type IngesterStatus ¶
type IngesterStatus struct { Services *ServiceStatusList `protobuf:"bytes,1,opt,name=services,proto3" json:"services,omitempty"` Memberlist *MemberlistStatus `protobuf:"bytes,2,opt,name=memberlist,proto3" json:"memberlist,omitempty"` Ring *RingStatus `protobuf:"bytes,3,opt,name=ring,proto3" json:"ring,omitempty"` // contains filtered or unexported fields }
func (*IngesterStatus) Descriptor
deprecated
func (*IngesterStatus) Descriptor() ([]byte, []int)
Deprecated: Use IngesterStatus.ProtoReflect.Descriptor instead.
func (*IngesterStatus) GetMemberlist ¶
func (x *IngesterStatus) GetMemberlist() *MemberlistStatus
func (*IngesterStatus) GetRing ¶
func (x *IngesterStatus) GetRing() *RingStatus
func (*IngesterStatus) GetServices ¶
func (x *IngesterStatus) GetServices() *ServiceStatusList
func (*IngesterStatus) ProtoMessage ¶
func (*IngesterStatus) ProtoMessage()
func (*IngesterStatus) ProtoReflect ¶
func (x *IngesterStatus) ProtoReflect() protoreflect.Message
func (*IngesterStatus) Reset ¶
func (x *IngesterStatus) Reset()
func (*IngesterStatus) String ¶
func (x *IngesterStatus) String() string
type Label ¶
type Label struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Label) Descriptor
deprecated
func (*Label) ProtoMessage ¶
func (*Label) ProtoMessage()
func (*Label) ProtoReflect ¶
func (x *Label) ProtoReflect() protoreflect.Message
type LabelRequest ¶
type LabelRequest struct { Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"` JobId string `protobuf:"bytes,2,opt,name=jobId,proto3" json:"jobId,omitempty"` MetricName string `protobuf:"bytes,3,opt,name=metricName,proto3" json:"metricName,omitempty"` // contains filtered or unexported fields }
func (*LabelRequest) Descriptor
deprecated
func (*LabelRequest) Descriptor() ([]byte, []int)
Deprecated: Use LabelRequest.ProtoReflect.Descriptor instead.
func (*LabelRequest) GetJobId ¶
func (x *LabelRequest) GetJobId() string
func (*LabelRequest) GetMetricName ¶
func (x *LabelRequest) GetMetricName() string
func (*LabelRequest) GetTenant ¶
func (x *LabelRequest) GetTenant() string
func (*LabelRequest) ProtoMessage ¶
func (*LabelRequest) ProtoMessage()
func (*LabelRequest) ProtoReflect ¶
func (x *LabelRequest) ProtoReflect() protoreflect.Message
func (*LabelRequest) Reset ¶
func (x *LabelRequest) Reset()
func (*LabelRequest) String ¶
func (x *LabelRequest) String() string
type LabelSet ¶
type LabelSet struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Items []string `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*LabelSet) Descriptor
deprecated
func (*LabelSet) ProtoMessage ¶
func (*LabelSet) ProtoMessage()
func (*LabelSet) ProtoReflect ¶
func (x *LabelSet) ProtoReflect() protoreflect.Message
type ListRulesRequest ¶
type ListRulesRequest struct { ClusterId []string `protobuf:"bytes,1,rep,name=clusterId,proto3" json:"clusterId,omitempty"` RuleType []string `protobuf:"bytes,2,rep,name=ruleType,proto3" json:"ruleType,omitempty"` HealthFilter []string `protobuf:"bytes,3,rep,name=healthFilter,proto3" json:"healthFilter,omitempty"` StateFilter []string `protobuf:"bytes,4,rep,name=stateFilter,proto3" json:"stateFilter,omitempty"` RuleNameRegexp string `protobuf:"bytes,5,opt,name=ruleNameRegexp,proto3" json:"ruleNameRegexp,omitempty"` GroupNameRegexp string `protobuf:"bytes,6,opt,name=groupNameRegexp,proto3" json:"groupNameRegexp,omitempty"` ListInvalid *bool `protobuf:"varint,7,opt,name=listInvalid,proto3,oneof" json:"listInvalid,omitempty"` RequestAll *bool `protobuf:"varint,8,opt,name=requestAll,proto3,oneof" json:"requestAll,omitempty"` NamespaceRegexp string `protobuf:"bytes,9,opt,name=namespaceRegexp,proto3" json:"namespaceRegexp,omitempty"` // contains filtered or unexported fields }
func (*ListRulesRequest) All ¶
func (l *ListRulesRequest) All() bool
func (*ListRulesRequest) Descriptor
deprecated
func (*ListRulesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRulesRequest.ProtoReflect.Descriptor instead.
func (*ListRulesRequest) Filter ¶
func (l *ListRulesRequest) Filter(groups *RuleGroups, clusterId string) *RuleGroups
func (*ListRulesRequest) GetClusterId ¶
func (x *ListRulesRequest) GetClusterId() []string
func (*ListRulesRequest) GetGroupNameRegexp ¶
func (x *ListRulesRequest) GetGroupNameRegexp() string
func (*ListRulesRequest) GetHealthFilter ¶
func (x *ListRulesRequest) GetHealthFilter() []string
func (*ListRulesRequest) GetListInvalid ¶
func (x *ListRulesRequest) GetListInvalid() bool
func (*ListRulesRequest) GetNamespaceRegexp ¶
func (x *ListRulesRequest) GetNamespaceRegexp() string
func (*ListRulesRequest) GetRequestAll ¶
func (x *ListRulesRequest) GetRequestAll() bool
func (*ListRulesRequest) GetRuleNameRegexp ¶
func (x *ListRulesRequest) GetRuleNameRegexp() string
func (*ListRulesRequest) GetRuleType ¶
func (x *ListRulesRequest) GetRuleType() []string
func (*ListRulesRequest) GetStateFilter ¶
func (x *ListRulesRequest) GetStateFilter() []string
func (*ListRulesRequest) Invalid ¶
func (l *ListRulesRequest) Invalid() bool
func (*ListRulesRequest) MatchesCluster ¶
func (l *ListRulesRequest) MatchesCluster(clusterId string) bool
func (*ListRulesRequest) MatchesHealth ¶
func (l *ListRulesRequest) MatchesHealth(health string) bool
func (*ListRulesRequest) MatchesNamespace ¶
func (l *ListRulesRequest) MatchesNamespace(namespaceRegex *regexp.Regexp, namespace string) bool
func (*ListRulesRequest) MatchesRule ¶
func (l *ListRulesRequest) MatchesRule(ruleNameExpr *regexp.Regexp, ruleName string) bool
func (*ListRulesRequest) MatchesRuleGroup ¶
func (l *ListRulesRequest) MatchesRuleGroup(groupNameExpr *regexp.Regexp, groupName string) bool
func (*ListRulesRequest) MatchesRuleState ¶
func (l *ListRulesRequest) MatchesRuleState(state string) bool
func (*ListRulesRequest) MatchesRuleType ¶
func (l *ListRulesRequest) MatchesRuleType(ruleType string) bool
func (*ListRulesRequest) ProtoMessage ¶
func (*ListRulesRequest) ProtoMessage()
func (*ListRulesRequest) ProtoReflect ¶
func (x *ListRulesRequest) ProtoReflect() protoreflect.Message
func (*ListRulesRequest) Reset ¶
func (x *ListRulesRequest) Reset()
func (*ListRulesRequest) String ¶
func (x *ListRulesRequest) String() string
func (*ListRulesRequest) Validate ¶
func (l *ListRulesRequest) Validate() error
type ListRulesResponse ¶
type ListRulesResponse struct { Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` Data *RuleGroups `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
matches the return of cortex ruler api https://github.com/cortexproject/cortex/blob/c0e4545fd26f33ca5cc3323ee48e4c2ccd182b83/pkg/ruler/api.go#L215
func (*ListRulesResponse) Descriptor
deprecated
func (*ListRulesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListRulesResponse.ProtoReflect.Descriptor instead.
func (*ListRulesResponse) GetData ¶
func (x *ListRulesResponse) GetData() *RuleGroups
func (*ListRulesResponse) GetStatus ¶
func (x *ListRulesResponse) GetStatus() string
func (*ListRulesResponse) ProtoMessage ¶
func (*ListRulesResponse) ProtoMessage()
func (*ListRulesResponse) ProtoReflect ¶
func (x *ListRulesResponse) ProtoReflect() protoreflect.Message
func (*ListRulesResponse) Reset ¶
func (x *ListRulesResponse) Reset()
func (*ListRulesResponse) String ¶
func (x *ListRulesResponse) String() string
type LoadRuleRequest ¶
type LoadRuleRequest struct { ClusterId string `protobuf:"bytes,1,opt,name=clusterId,proto3" json:"clusterId,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` // defaults to "default" YamlContent []byte `protobuf:"bytes,3,opt,name=yamlContent,proto3" json:"yamlContent,omitempty"` // contains filtered or unexported fields }
func (*LoadRuleRequest) Descriptor
deprecated
func (*LoadRuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadRuleRequest.ProtoReflect.Descriptor instead.
func (*LoadRuleRequest) GetClusterId ¶
func (x *LoadRuleRequest) GetClusterId() string
func (*LoadRuleRequest) GetNamespace ¶
func (x *LoadRuleRequest) GetNamespace() string
func (*LoadRuleRequest) GetYamlContent ¶
func (x *LoadRuleRequest) GetYamlContent() []byte
func (*LoadRuleRequest) ProtoMessage ¶
func (*LoadRuleRequest) ProtoMessage()
func (*LoadRuleRequest) ProtoReflect ¶
func (x *LoadRuleRequest) ProtoReflect() protoreflect.Message
func (*LoadRuleRequest) Reset ¶
func (x *LoadRuleRequest) Reset()
func (*LoadRuleRequest) String ¶
func (x *LoadRuleRequest) String() string
func (*LoadRuleRequest) Validate ¶
func (in *LoadRuleRequest) Validate() error
type MatcherRequest ¶
type MatcherRequest struct { Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"` MatchExpr string `protobuf:"bytes,2,opt,name=matchExpr,proto3" json:"matchExpr,omitempty"` // contains filtered or unexported fields }
func (*MatcherRequest) Descriptor
deprecated
func (*MatcherRequest) Descriptor() ([]byte, []int)
Deprecated: Use MatcherRequest.ProtoReflect.Descriptor instead.
func (*MatcherRequest) GetMatchExpr ¶
func (x *MatcherRequest) GetMatchExpr() string
func (*MatcherRequest) GetTenant ¶
func (x *MatcherRequest) GetTenant() string
func (*MatcherRequest) ProtoMessage ¶
func (*MatcherRequest) ProtoMessage()
func (*MatcherRequest) ProtoReflect ¶
func (x *MatcherRequest) ProtoReflect() protoreflect.Message
func (*MatcherRequest) Reset ¶
func (x *MatcherRequest) Reset()
func (*MatcherRequest) String ¶
func (x *MatcherRequest) String() string
type MemberStatus ¶
type MemberStatus struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` State int32 `protobuf:"varint,4,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
Status of a single member of a memberlist
func (*MemberStatus) Descriptor
deprecated
func (*MemberStatus) Descriptor() ([]byte, []int)
Deprecated: Use MemberStatus.ProtoReflect.Descriptor instead.
func (*MemberStatus) GetAddress ¶
func (x *MemberStatus) GetAddress() string
func (*MemberStatus) GetName ¶
func (x *MemberStatus) GetName() string
func (*MemberStatus) GetPort ¶
func (x *MemberStatus) GetPort() uint32
func (*MemberStatus) GetState ¶
func (x *MemberStatus) GetState() int32
func (*MemberStatus) ProtoMessage ¶
func (*MemberStatus) ProtoMessage()
func (*MemberStatus) ProtoReflect ¶
func (x *MemberStatus) ProtoReflect() protoreflect.Message
func (*MemberStatus) Reset ¶
func (x *MemberStatus) Reset()
func (*MemberStatus) String ¶
func (x *MemberStatus) String() string
type MemberStatusList ¶
type MemberStatusList struct { Items []*MemberStatus `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*MemberStatusList) Descriptor
deprecated
func (*MemberStatusList) Descriptor() ([]byte, []int)
Deprecated: Use MemberStatusList.ProtoReflect.Descriptor instead.
func (*MemberStatusList) GetItems ¶
func (x *MemberStatusList) GetItems() []*MemberStatus
func (*MemberStatusList) ProtoMessage ¶
func (*MemberStatusList) ProtoMessage()
func (*MemberStatusList) ProtoReflect ¶
func (x *MemberStatusList) ProtoReflect() protoreflect.Message
func (*MemberStatusList) Reset ¶
func (x *MemberStatusList) Reset()
func (*MemberStatusList) String ¶
func (x *MemberStatusList) String() string
type MemberlistStatus ¶
type MemberlistStatus struct { // Whether the service is currently using a memberlist Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` // The status of each member in the memberlist Members *MemberStatusList `protobuf:"bytes,2,opt,name=members,proto3" json:"members,omitempty"` // A list of keys in the key-value store used by the memberlist Keys []string `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"` // contains filtered or unexported fields }
func (*MemberlistStatus) Descriptor
deprecated
func (*MemberlistStatus) Descriptor() ([]byte, []int)
Deprecated: Use MemberlistStatus.ProtoReflect.Descriptor instead.
func (*MemberlistStatus) GetEnabled ¶
func (x *MemberlistStatus) GetEnabled() bool
func (*MemberlistStatus) GetKeys ¶
func (x *MemberlistStatus) GetKeys() []string
func (*MemberlistStatus) GetMembers ¶
func (x *MemberlistStatus) GetMembers() *MemberStatusList
func (*MemberlistStatus) ProtoMessage ¶
func (*MemberlistStatus) ProtoMessage()
func (*MemberlistStatus) ProtoReflect ¶
func (x *MemberlistStatus) ProtoReflect() protoreflect.Message
func (*MemberlistStatus) Reset ¶
func (x *MemberlistStatus) Reset()
func (*MemberlistStatus) String ¶
func (x *MemberlistStatus) String() string
type MetricLabels ¶
type MetricLabels struct { Items []*LabelSet `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*MetricLabels) Descriptor
deprecated
func (*MetricLabels) Descriptor() ([]byte, []int)
Deprecated: Use MetricLabels.ProtoReflect.Descriptor instead.
func (*MetricLabels) GetItems ¶
func (x *MetricLabels) GetItems() []*LabelSet
func (*MetricLabels) ProtoMessage ¶
func (*MetricLabels) ProtoMessage()
func (*MetricLabels) ProtoReflect ¶
func (x *MetricLabels) ProtoReflect() protoreflect.Message
func (*MetricLabels) Reset ¶
func (x *MetricLabels) Reset()
func (*MetricLabels) String ¶
func (x *MetricLabels) String() string
type MetricMetadata ¶
type MetricMetadata struct { Type MetricMetadata_MetricType `protobuf:"varint,1,opt,name=type,proto3,enum=cortexadmin.MetricMetadata_MetricType" json:"type,omitempty"` MetricFamilyName string `protobuf:"bytes,2,opt,name=metricFamilyName,proto3" json:"metricFamilyName,omitempty"` Help string `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"` Unit string `protobuf:"bytes,5,opt,name=unit,proto3" json:"unit,omitempty"` // contains filtered or unexported fields }
func (*MetricMetadata) Descriptor
deprecated
func (*MetricMetadata) Descriptor() ([]byte, []int)
Deprecated: Use MetricMetadata.ProtoReflect.Descriptor instead.
func (*MetricMetadata) GetHelp ¶
func (x *MetricMetadata) GetHelp() string
func (*MetricMetadata) GetMetricFamilyName ¶
func (x *MetricMetadata) GetMetricFamilyName() string
func (*MetricMetadata) GetType ¶
func (x *MetricMetadata) GetType() MetricMetadata_MetricType
func (*MetricMetadata) GetUnit ¶
func (x *MetricMetadata) GetUnit() string
func (*MetricMetadata) ProtoMessage ¶
func (*MetricMetadata) ProtoMessage()
func (*MetricMetadata) ProtoReflect ¶
func (x *MetricMetadata) ProtoReflect() protoreflect.Message
func (*MetricMetadata) Reset ¶
func (x *MetricMetadata) Reset()
func (*MetricMetadata) String ¶
func (x *MetricMetadata) String() string
type MetricMetadataRequest ¶
type MetricMetadataRequest struct { Tenants []string `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"` MetricName string `protobuf:"bytes,2,opt,name=metricName,proto3" json:"metricName,omitempty"` // contains filtered or unexported fields }
func (*MetricMetadataRequest) Descriptor
deprecated
func (*MetricMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use MetricMetadataRequest.ProtoReflect.Descriptor instead.
func (*MetricMetadataRequest) GetMetricName ¶
func (x *MetricMetadataRequest) GetMetricName() string
func (*MetricMetadataRequest) GetTenants ¶
func (x *MetricMetadataRequest) GetTenants() []string
func (*MetricMetadataRequest) ProtoMessage ¶
func (*MetricMetadataRequest) ProtoMessage()
func (*MetricMetadataRequest) ProtoReflect ¶
func (x *MetricMetadataRequest) ProtoReflect() protoreflect.Message
func (*MetricMetadataRequest) Reset ¶
func (x *MetricMetadataRequest) Reset()
func (*MetricMetadataRequest) String ¶
func (x *MetricMetadataRequest) String() string
type MetricMetadata_MetricType ¶
type MetricMetadata_MetricType int32
const ( MetricMetadata_UNKNOWN MetricMetadata_MetricType = 0 MetricMetadata_COUNTER MetricMetadata_MetricType = 1 MetricMetadata_GAUGE MetricMetadata_MetricType = 2 MetricMetadata_HISTOGRAM MetricMetadata_MetricType = 3 MetricMetadata_GAUGEHISTOGRAM MetricMetadata_MetricType = 4 MetricMetadata_SUMMARY MetricMetadata_MetricType = 5 MetricMetadata_INFO MetricMetadata_MetricType = 6 MetricMetadata_STATESET MetricMetadata_MetricType = 7 )
func (MetricMetadata_MetricType) Descriptor ¶
func (MetricMetadata_MetricType) Descriptor() protoreflect.EnumDescriptor
func (MetricMetadata_MetricType) Enum ¶
func (x MetricMetadata_MetricType) Enum() *MetricMetadata_MetricType
func (MetricMetadata_MetricType) EnumDescriptor
deprecated
func (MetricMetadata_MetricType) EnumDescriptor() ([]byte, []int)
Deprecated: Use MetricMetadata_MetricType.Descriptor instead.
func (MetricMetadata_MetricType) Number ¶
func (x MetricMetadata_MetricType) Number() protoreflect.EnumNumber
func (MetricMetadata_MetricType) String ¶
func (x MetricMetadata_MetricType) String() string
func (MetricMetadata_MetricType) Type ¶
func (MetricMetadata_MetricType) Type() protoreflect.EnumType
type PurgerStatus ¶
type PurgerStatus struct { Services *ServiceStatusList `protobuf:"bytes,1,opt,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
func (*PurgerStatus) Descriptor
deprecated
func (*PurgerStatus) Descriptor() ([]byte, []int)
Deprecated: Use PurgerStatus.ProtoReflect.Descriptor instead.
func (*PurgerStatus) GetServices ¶
func (x *PurgerStatus) GetServices() *ServiceStatusList
func (*PurgerStatus) ProtoMessage ¶
func (*PurgerStatus) ProtoMessage()
func (*PurgerStatus) ProtoReflect ¶
func (x *PurgerStatus) ProtoReflect() protoreflect.Message
func (*PurgerStatus) Reset ¶
func (x *PurgerStatus) Reset()
func (*PurgerStatus) String ¶
func (x *PurgerStatus) String() string
type QuerierStatus ¶
type QuerierStatus struct { Services *ServiceStatusList `protobuf:"bytes,1,opt,name=services,proto3" json:"services,omitempty"` Memberlist *MemberlistStatus `protobuf:"bytes,2,opt,name=memberlist,proto3" json:"memberlist,omitempty"` // contains filtered or unexported fields }
func (*QuerierStatus) Descriptor
deprecated
func (*QuerierStatus) Descriptor() ([]byte, []int)
Deprecated: Use QuerierStatus.ProtoReflect.Descriptor instead.
func (*QuerierStatus) GetMemberlist ¶
func (x *QuerierStatus) GetMemberlist() *MemberlistStatus
func (*QuerierStatus) GetServices ¶
func (x *QuerierStatus) GetServices() *ServiceStatusList
func (*QuerierStatus) ProtoMessage ¶
func (*QuerierStatus) ProtoMessage()
func (*QuerierStatus) ProtoReflect ¶
func (x *QuerierStatus) ProtoReflect() protoreflect.Message
func (*QuerierStatus) Reset ¶
func (x *QuerierStatus) Reset()
func (*QuerierStatus) String ¶
func (x *QuerierStatus) String() string
type QueryFrontendStatus ¶
type QueryFrontendStatus struct { Services *ServiceStatusList `protobuf:"bytes,1,opt,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
func (*QueryFrontendStatus) Descriptor
deprecated
func (*QueryFrontendStatus) Descriptor() ([]byte, []int)
Deprecated: Use QueryFrontendStatus.ProtoReflect.Descriptor instead.
func (*QueryFrontendStatus) GetServices ¶
func (x *QueryFrontendStatus) GetServices() *ServiceStatusList
func (*QueryFrontendStatus) ProtoMessage ¶
func (*QueryFrontendStatus) ProtoMessage()
func (*QueryFrontendStatus) ProtoReflect ¶
func (x *QueryFrontendStatus) ProtoReflect() protoreflect.Message
func (*QueryFrontendStatus) Reset ¶
func (x *QueryFrontendStatus) Reset()
func (*QueryFrontendStatus) String ¶
func (x *QueryFrontendStatus) String() string
type QueryRangeRequest ¶
type QueryRangeRequest struct { Tenants []string `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"` Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` Start *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"` Step *durationpb.Duration `protobuf:"bytes,5,opt,name=step,proto3" json:"step,omitempty"` // contains filtered or unexported fields }
func (*QueryRangeRequest) Descriptor
deprecated
func (*QueryRangeRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRangeRequest.ProtoReflect.Descriptor instead.
func (*QueryRangeRequest) GetEnd ¶
func (x *QueryRangeRequest) GetEnd() *timestamppb.Timestamp
func (*QueryRangeRequest) GetQuery ¶
func (x *QueryRangeRequest) GetQuery() string
func (*QueryRangeRequest) GetStart ¶
func (x *QueryRangeRequest) GetStart() *timestamppb.Timestamp
func (*QueryRangeRequest) GetStep ¶
func (x *QueryRangeRequest) GetStep() *durationpb.Duration
func (*QueryRangeRequest) GetTenants ¶
func (x *QueryRangeRequest) GetTenants() []string
func (*QueryRangeRequest) ProtoMessage ¶
func (*QueryRangeRequest) ProtoMessage()
func (*QueryRangeRequest) ProtoReflect ¶
func (x *QueryRangeRequest) ProtoReflect() protoreflect.Message
func (*QueryRangeRequest) Reset ¶
func (x *QueryRangeRequest) Reset()
func (*QueryRangeRequest) String ¶
func (x *QueryRangeRequest) String() string
type QueryRequest ¶
type QueryRequest struct { Tenants []string `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"` Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*QueryRequest) Descriptor
deprecated
func (*QueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
func (*QueryRequest) GetQuery ¶
func (x *QueryRequest) GetQuery() string
func (*QueryRequest) GetTenants ¶
func (x *QueryRequest) GetTenants() []string
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) ProtoReflect ¶
func (x *QueryRequest) ProtoReflect() protoreflect.Message
func (*QueryRequest) Reset ¶
func (x *QueryRequest) Reset()
func (*QueryRequest) String ¶
func (x *QueryRequest) String() string
type QueryResponse ¶
type QueryResponse struct { Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*QueryResponse) Descriptor
deprecated
func (*QueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.
func (*QueryResponse) GetData ¶
func (x *QueryResponse) GetData() []byte
func (*QueryResponse) ProtoMessage ¶
func (*QueryResponse) ProtoMessage()
func (*QueryResponse) ProtoReflect ¶
func (x *QueryResponse) ProtoReflect() protoreflect.Message
func (*QueryResponse) Reset ¶
func (x *QueryResponse) Reset()
func (*QueryResponse) String ¶
func (x *QueryResponse) String() string
type RingStatus ¶
type RingStatus struct { Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` Shards *ShardStatusList `protobuf:"bytes,2,opt,name=shards,proto3" json:"shards,omitempty"` // contains filtered or unexported fields }
func (*RingStatus) Descriptor
deprecated
func (*RingStatus) Descriptor() ([]byte, []int)
Deprecated: Use RingStatus.ProtoReflect.Descriptor instead.
func (*RingStatus) GetEnabled ¶
func (x *RingStatus) GetEnabled() bool
func (*RingStatus) GetShards ¶
func (x *RingStatus) GetShards() *ShardStatusList
func (*RingStatus) ProtoMessage ¶
func (*RingStatus) ProtoMessage()
func (*RingStatus) ProtoReflect ¶
func (x *RingStatus) ProtoReflect() protoreflect.Message
func (*RingStatus) Reset ¶
func (x *RingStatus) Reset()
func (*RingStatus) String ¶
func (x *RingStatus) String() string
type Rule ¶
type Rule struct { State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Query string `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` Duration float64 `protobuf:"fixed64,4,opt,name=duration,proto3" json:"duration,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ Annotations map[string]string `` /* 163-byte string literal not displayed */ Health string `protobuf:"bytes,7,opt,name=health,proto3" json:"health,omitempty"` Alerts []*Alert `protobuf:"bytes,8,rep,name=alerts,proto3" json:"alerts,omitempty"` LastError string `protobuf:"bytes,9,opt,name=lastError,proto3" json:"lastError,omitempty"` Type string `protobuf:"bytes,10,opt,name=type,proto3" json:"type,omitempty"` // Note : string instead of timestamp to preserve compatibility with native prometheus api return value LastEvaluation string `protobuf:"bytes,11,opt,name=lastEvaluation,proto3" json:"lastEvaluation,omitempty"` EvaluationTime float64 `protobuf:"fixed64,12,opt,name=evaluationTime,proto3" json:"evaluationTime,omitempty"` // contains filtered or unexported fields }
combination of alerting and recording rule (alerting rule is a superset of recording)
func (*Rule) Descriptor
deprecated
func (*Rule) GetAnnotations ¶
func (*Rule) GetDuration ¶
func (*Rule) GetEvaluationTime ¶
func (*Rule) GetLastError ¶
func (*Rule) GetLastEvaluation ¶
func (*Rule) ProtoMessage ¶
func (*Rule) ProtoMessage()
func (*Rule) ProtoReflect ¶
func (x *Rule) ProtoReflect() protoreflect.Message
type RuleGroup ¶
type RuleGroup struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` File string `protobuf:"bytes,2,opt,name=file,proto3" json:"file,omitempty"` Rules []*Rule `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"` Interval float64 `protobuf:"fixed64,4,opt,name=interval,proto3" json:"interval,omitempty"` // Note : string instead of timestamp to preserve compatibility with native prometheus api return value LastEvaluation string `protobuf:"bytes,5,opt,name=lastEvaluation,proto3" json:"lastEvaluation,omitempty"` EvaluationTime float64 `protobuf:"fixed64,6,opt,name=evaluationTime,proto3" json:"evaluationTime,omitempty"` // opni specific field ClusterId string `protobuf:"bytes,7,opt,name=clusterId,proto3" json:"clusterId,omitempty"` // contains filtered or unexported fields }
func (*RuleGroup) Descriptor
deprecated
func (*RuleGroup) GetClusterId ¶
func (*RuleGroup) GetEvaluationTime ¶
func (*RuleGroup) GetInterval ¶
func (*RuleGroup) GetLastEvaluation ¶
func (*RuleGroup) ProtoMessage ¶
func (*RuleGroup) ProtoMessage()
func (*RuleGroup) ProtoReflect ¶
func (x *RuleGroup) ProtoReflect() protoreflect.Message
type RuleGroups ¶
type RuleGroups struct { Groups []*RuleGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"` // contains filtered or unexported fields }
func (*RuleGroups) Descriptor
deprecated
func (*RuleGroups) Descriptor() ([]byte, []int)
Deprecated: Use RuleGroups.ProtoReflect.Descriptor instead.
func (*RuleGroups) GetGroups ¶
func (x *RuleGroups) GetGroups() []*RuleGroup
func (*RuleGroups) ProtoMessage ¶
func (*RuleGroups) ProtoMessage()
func (*RuleGroups) ProtoReflect ¶
func (x *RuleGroups) ProtoReflect() protoreflect.Message
func (*RuleGroups) Reset ¶
func (x *RuleGroups) Reset()
func (*RuleGroups) String ¶
func (x *RuleGroups) String() string
type RulerStatus ¶
type RulerStatus struct { Services *ServiceStatusList `protobuf:"bytes,1,opt,name=services,proto3" json:"services,omitempty"` Memberlist *MemberlistStatus `protobuf:"bytes,2,opt,name=memberlist,proto3" json:"memberlist,omitempty"` Ring *RingStatus `protobuf:"bytes,3,opt,name=ring,proto3" json:"ring,omitempty"` // contains filtered or unexported fields }
func (*RulerStatus) Descriptor
deprecated
func (*RulerStatus) Descriptor() ([]byte, []int)
Deprecated: Use RulerStatus.ProtoReflect.Descriptor instead.
func (*RulerStatus) GetMemberlist ¶
func (x *RulerStatus) GetMemberlist() *MemberlistStatus
func (*RulerStatus) GetRing ¶
func (x *RulerStatus) GetRing() *RingStatus
func (*RulerStatus) GetServices ¶
func (x *RulerStatus) GetServices() *ServiceStatusList
func (*RulerStatus) ProtoMessage ¶
func (*RulerStatus) ProtoMessage()
func (*RulerStatus) ProtoReflect ¶
func (x *RulerStatus) ProtoReflect() protoreflect.Message
func (*RulerStatus) Reset ¶
func (x *RulerStatus) Reset()
func (*RulerStatus) String ¶
func (x *RulerStatus) String() string
type Sample ¶
type Sample struct { TimestampMs int64 `protobuf:"varint,1,opt,name=timestampMs,proto3" json:"timestampMs,omitempty"` Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Sample) Descriptor
deprecated
func (*Sample) GetTimestampMs ¶
func (*Sample) ProtoMessage ¶
func (*Sample) ProtoMessage()
func (*Sample) ProtoReflect ¶
func (x *Sample) ProtoReflect() protoreflect.Message
type SeriesInfo ¶
type SeriesInfo struct { SeriesName string `protobuf:"bytes,1,opt,name=seriesName,proto3" json:"seriesName,omitempty"` Metadata *SeriesMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*SeriesInfo) Descriptor
deprecated
func (*SeriesInfo) Descriptor() ([]byte, []int)
Deprecated: Use SeriesInfo.ProtoReflect.Descriptor instead.
func (*SeriesInfo) GetMetadata ¶
func (x *SeriesInfo) GetMetadata() *SeriesMetadata
func (*SeriesInfo) GetSeriesName ¶
func (x *SeriesInfo) GetSeriesName() string
func (*SeriesInfo) ProtoMessage ¶
func (*SeriesInfo) ProtoMessage()
func (*SeriesInfo) ProtoReflect ¶
func (x *SeriesInfo) ProtoReflect() protoreflect.Message
func (*SeriesInfo) Reset ¶
func (x *SeriesInfo) Reset()
func (*SeriesInfo) String ¶
func (x *SeriesInfo) String() string
type SeriesInfoList ¶
type SeriesInfoList struct { Items []*SeriesInfo `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*SeriesInfoList) Descriptor
deprecated
func (*SeriesInfoList) Descriptor() ([]byte, []int)
Deprecated: Use SeriesInfoList.ProtoReflect.Descriptor instead.
func (*SeriesInfoList) GetItems ¶
func (x *SeriesInfoList) GetItems() []*SeriesInfo
func (*SeriesInfoList) ProtoMessage ¶
func (*SeriesInfoList) ProtoMessage()
func (*SeriesInfoList) ProtoReflect ¶
func (x *SeriesInfoList) ProtoReflect() protoreflect.Message
func (*SeriesInfoList) Reset ¶
func (x *SeriesInfoList) Reset()
func (*SeriesInfoList) String ¶
func (x *SeriesInfoList) String() string
type SeriesMetadata ¶
type SeriesMetadata struct { Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Unit string `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit,omitempty"` // contains filtered or unexported fields }
func (*SeriesMetadata) Descriptor
deprecated
func (*SeriesMetadata) Descriptor() ([]byte, []int)
Deprecated: Use SeriesMetadata.ProtoReflect.Descriptor instead.
func (*SeriesMetadata) GetDescription ¶
func (x *SeriesMetadata) GetDescription() string
func (*SeriesMetadata) GetType ¶
func (x *SeriesMetadata) GetType() string
func (*SeriesMetadata) GetUnit ¶
func (x *SeriesMetadata) GetUnit() string
func (*SeriesMetadata) ProtoMessage ¶
func (*SeriesMetadata) ProtoMessage()
func (*SeriesMetadata) ProtoReflect ¶
func (x *SeriesMetadata) ProtoReflect() protoreflect.Message
func (*SeriesMetadata) Reset ¶
func (x *SeriesMetadata) Reset()
func (*SeriesMetadata) String ¶
func (x *SeriesMetadata) String() string
type SeriesRequest ¶
type SeriesRequest struct { Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"` JobId string `protobuf:"bytes,2,opt,name=jobId,proto3" json:"jobId,omitempty"` // contains filtered or unexported fields }
func (*SeriesRequest) Descriptor
deprecated
func (*SeriesRequest) Descriptor() ([]byte, []int)
Deprecated: Use SeriesRequest.ProtoReflect.Descriptor instead.
func (*SeriesRequest) GetJobId ¶
func (x *SeriesRequest) GetJobId() string
func (*SeriesRequest) GetTenant ¶
func (x *SeriesRequest) GetTenant() string
func (*SeriesRequest) ProtoMessage ¶
func (*SeriesRequest) ProtoMessage()
func (*SeriesRequest) ProtoReflect ¶
func (x *SeriesRequest) ProtoReflect() protoreflect.Message
func (*SeriesRequest) Reset ¶
func (x *SeriesRequest) Reset()
func (*SeriesRequest) String ¶
func (x *SeriesRequest) String() string
type ServiceStatus ¶
type ServiceStatus struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
Status of an individual cortex service (module)
func (*ServiceStatus) Descriptor
deprecated
func (*ServiceStatus) Descriptor() ([]byte, []int)
Deprecated: Use ServiceStatus.ProtoReflect.Descriptor instead.
func (*ServiceStatus) GetName ¶
func (x *ServiceStatus) GetName() string
func (*ServiceStatus) GetStatus ¶
func (x *ServiceStatus) GetStatus() string
func (*ServiceStatus) ProtoMessage ¶
func (*ServiceStatus) ProtoMessage()
func (*ServiceStatus) ProtoReflect ¶
func (x *ServiceStatus) ProtoReflect() protoreflect.Message
func (*ServiceStatus) Reset ¶
func (x *ServiceStatus) Reset()
func (*ServiceStatus) String ¶
func (x *ServiceStatus) String() string
type ServiceStatusList ¶
type ServiceStatusList struct { Services []*ServiceStatus `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` // field name matches cortex // contains filtered or unexported fields }
func (*ServiceStatusList) Descriptor
deprecated
func (*ServiceStatusList) Descriptor() ([]byte, []int)
Deprecated: Use ServiceStatusList.ProtoReflect.Descriptor instead.
func (*ServiceStatusList) GetServices ¶
func (x *ServiceStatusList) GetServices() []*ServiceStatus
func (*ServiceStatusList) ProtoMessage ¶
func (*ServiceStatusList) ProtoMessage()
func (*ServiceStatusList) ProtoReflect ¶
func (x *ServiceStatusList) ProtoReflect() protoreflect.Message
func (*ServiceStatusList) Reset ¶
func (x *ServiceStatusList) Reset()
func (*ServiceStatusList) String ¶
func (x *ServiceStatusList) String() string
type ShardStatus ¶
type ShardStatus struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` State string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` Timestamp string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` RegisteredTimestamp string `protobuf:"bytes,5,opt,name=registeredTimestamp,proto3" json:"registeredTimestamp,omitempty"` Zone string `protobuf:"bytes,6,opt,name=zone,proto3" json:"zone,omitempty"` // contains filtered or unexported fields }
Status of a single shard in a ring
func (*ShardStatus) Descriptor
deprecated
func (*ShardStatus) Descriptor() ([]byte, []int)
Deprecated: Use ShardStatus.ProtoReflect.Descriptor instead.
func (*ShardStatus) GetAddress ¶
func (x *ShardStatus) GetAddress() string
func (*ShardStatus) GetId ¶
func (x *ShardStatus) GetId() string
func (*ShardStatus) GetRegisteredTimestamp ¶
func (x *ShardStatus) GetRegisteredTimestamp() string
func (*ShardStatus) GetState ¶
func (x *ShardStatus) GetState() string
func (*ShardStatus) GetTimestamp ¶
func (x *ShardStatus) GetTimestamp() string
func (*ShardStatus) GetZone ¶
func (x *ShardStatus) GetZone() string
func (*ShardStatus) ProtoMessage ¶
func (*ShardStatus) ProtoMessage()
func (*ShardStatus) ProtoReflect ¶
func (x *ShardStatus) ProtoReflect() protoreflect.Message
func (*ShardStatus) Reset ¶
func (x *ShardStatus) Reset()
func (*ShardStatus) String ¶
func (x *ShardStatus) String() string
type ShardStatusList ¶
type ShardStatusList struct { Shards []*ShardStatus `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"` // field name matches cortex // contains filtered or unexported fields }
func (*ShardStatusList) Descriptor
deprecated
func (*ShardStatusList) Descriptor() ([]byte, []int)
Deprecated: Use ShardStatusList.ProtoReflect.Descriptor instead.
func (*ShardStatusList) GetShards ¶
func (x *ShardStatusList) GetShards() []*ShardStatus
func (*ShardStatusList) ProtoMessage ¶
func (*ShardStatusList) ProtoMessage()
func (*ShardStatusList) ProtoReflect ¶
func (x *ShardStatusList) ProtoReflect() protoreflect.Message
func (*ShardStatusList) Reset ¶
func (x *ShardStatusList) Reset()
func (*ShardStatusList) String ¶
func (x *ShardStatusList) String() string
type StoreGatewayStatus ¶
type StoreGatewayStatus struct { Services *ServiceStatusList `protobuf:"bytes,1,opt,name=services,proto3" json:"services,omitempty"` Memberlist *MemberlistStatus `protobuf:"bytes,2,opt,name=memberlist,proto3" json:"memberlist,omitempty"` Ring *RingStatus `protobuf:"bytes,3,opt,name=ring,proto3" json:"ring,omitempty"` // contains filtered or unexported fields }
func (*StoreGatewayStatus) Descriptor
deprecated
func (*StoreGatewayStatus) Descriptor() ([]byte, []int)
Deprecated: Use StoreGatewayStatus.ProtoReflect.Descriptor instead.
func (*StoreGatewayStatus) GetMemberlist ¶
func (x *StoreGatewayStatus) GetMemberlist() *MemberlistStatus
func (*StoreGatewayStatus) GetRing ¶
func (x *StoreGatewayStatus) GetRing() *RingStatus
func (*StoreGatewayStatus) GetServices ¶
func (x *StoreGatewayStatus) GetServices() *ServiceStatusList
func (*StoreGatewayStatus) ProtoMessage ¶
func (*StoreGatewayStatus) ProtoMessage()
func (*StoreGatewayStatus) ProtoReflect ¶
func (x *StoreGatewayStatus) ProtoReflect() protoreflect.Message
func (*StoreGatewayStatus) Reset ¶
func (x *StoreGatewayStatus) Reset()
func (*StoreGatewayStatus) String ¶
func (x *StoreGatewayStatus) String() string
type TimeSeries ¶
type TimeSeries struct { Labels []*Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` Samples []*Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"` Exemplars []*Exemplar `protobuf:"bytes,3,rep,name=exemplars,proto3" json:"exemplars,omitempty"` // contains filtered or unexported fields }
func (*TimeSeries) Descriptor
deprecated
func (*TimeSeries) Descriptor() ([]byte, []int)
Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.
func (*TimeSeries) GetExemplars ¶
func (x *TimeSeries) GetExemplars() []*Exemplar
func (*TimeSeries) GetLabels ¶
func (x *TimeSeries) GetLabels() []*Label
func (*TimeSeries) GetSamples ¶
func (x *TimeSeries) GetSamples() []*Sample
func (*TimeSeries) ProtoMessage ¶
func (*TimeSeries) ProtoMessage()
func (*TimeSeries) ProtoReflect ¶
func (x *TimeSeries) ProtoReflect() protoreflect.Message
func (*TimeSeries) Reset ¶
func (x *TimeSeries) Reset()
func (*TimeSeries) String ¶
func (x *TimeSeries) String() string
type UnimplementedCortexAdminServer ¶
type UnimplementedCortexAdminServer struct { }
UnimplementedCortexAdminServer must be embedded to have forward compatible implementations.
func (UnimplementedCortexAdminServer) AllUserStats ¶
func (UnimplementedCortexAdminServer) AllUserStats(context.Context, *emptypb.Empty) (*UserIDStatsList, error)
func (UnimplementedCortexAdminServer) DeleteRule ¶
func (UnimplementedCortexAdminServer) DeleteRule(context.Context, *DeleteRuleRequest) (*emptypb.Empty, error)
func (UnimplementedCortexAdminServer) ExtractRawSeries ¶
func (UnimplementedCortexAdminServer) ExtractRawSeries(context.Context, *MatcherRequest) (*QueryResponse, error)
func (UnimplementedCortexAdminServer) FlushBlocks ¶
func (UnimplementedCortexAdminServer) GetCortexConfig ¶
func (UnimplementedCortexAdminServer) GetCortexConfig(context.Context, *ConfigRequest) (*ConfigResponse, error)
func (UnimplementedCortexAdminServer) GetCortexStatus ¶
func (UnimplementedCortexAdminServer) GetCortexStatus(context.Context, *emptypb.Empty) (*CortexStatus, error)
func (UnimplementedCortexAdminServer) GetMetricLabelSets ¶
func (UnimplementedCortexAdminServer) GetMetricLabelSets(context.Context, *LabelRequest) (*MetricLabels, error)
func (UnimplementedCortexAdminServer) GetMetricMetadata ¶
func (UnimplementedCortexAdminServer) GetMetricMetadata(context.Context, *MetricMetadataRequest) (*MetricMetadata, error)
func (UnimplementedCortexAdminServer) GetRule ¶
func (UnimplementedCortexAdminServer) GetRule(context.Context, *GetRuleRequest) (*QueryResponse, error)
func (UnimplementedCortexAdminServer) GetSeriesMetrics ¶
func (UnimplementedCortexAdminServer) GetSeriesMetrics(context.Context, *SeriesRequest) (*SeriesInfoList, error)
func (UnimplementedCortexAdminServer) ListRules ¶
func (UnimplementedCortexAdminServer) ListRules(context.Context, *ListRulesRequest) (*ListRulesResponse, error)
func (UnimplementedCortexAdminServer) LoadRules ¶
func (UnimplementedCortexAdminServer) LoadRules(context.Context, *LoadRuleRequest) (*emptypb.Empty, error)
func (UnimplementedCortexAdminServer) Query ¶
func (UnimplementedCortexAdminServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)
func (UnimplementedCortexAdminServer) QueryRange ¶
func (UnimplementedCortexAdminServer) QueryRange(context.Context, *QueryRangeRequest) (*QueryResponse, error)
func (UnimplementedCortexAdminServer) WriteMetrics ¶
func (UnimplementedCortexAdminServer) WriteMetrics(context.Context, *WriteRequest) (*WriteResponse, error)
type UnsafeCortexAdminServer ¶
type UnsafeCortexAdminServer interface {
// contains filtered or unexported methods
}
UnsafeCortexAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CortexAdminServer will result in compilation errors.
type UserIDStats ¶
type UserIDStats struct { UserID string `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID,omitempty"` IngestionRate float64 `protobuf:"fixed64,2,opt,name=ingestionRate,proto3" json:"ingestionRate,omitempty"` NumSeries uint64 `protobuf:"varint,3,opt,name=numSeries,proto3" json:"numSeries,omitempty"` APIIngestionRate float64 `protobuf:"fixed64,4,opt,name=APIIngestionRate,proto3" json:"APIIngestionRate,omitempty"` // title case to match cortex RuleIngestionRate float64 `protobuf:"fixed64,5,opt,name=RuleIngestionRate,proto3" json:"RuleIngestionRate,omitempty"` // title case to match cortex // contains filtered or unexported fields }
func (*UserIDStats) Descriptor
deprecated
func (*UserIDStats) Descriptor() ([]byte, []int)
Deprecated: Use UserIDStats.ProtoReflect.Descriptor instead.
func (*UserIDStats) GetAPIIngestionRate ¶
func (x *UserIDStats) GetAPIIngestionRate() float64
func (*UserIDStats) GetIngestionRate ¶
func (x *UserIDStats) GetIngestionRate() float64
func (*UserIDStats) GetNumSeries ¶
func (x *UserIDStats) GetNumSeries() uint64
func (*UserIDStats) GetRuleIngestionRate ¶
func (x *UserIDStats) GetRuleIngestionRate() float64
func (*UserIDStats) GetUserID ¶
func (x *UserIDStats) GetUserID() string
func (*UserIDStats) ProtoMessage ¶
func (*UserIDStats) ProtoMessage()
func (*UserIDStats) ProtoReflect ¶
func (x *UserIDStats) ProtoReflect() protoreflect.Message
func (*UserIDStats) Reset ¶
func (x *UserIDStats) Reset()
func (*UserIDStats) String ¶
func (x *UserIDStats) String() string
type UserIDStatsList ¶
type UserIDStatsList struct { Items []*UserIDStats `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*UserIDStatsList) Descriptor
deprecated
func (*UserIDStatsList) Descriptor() ([]byte, []int)
Deprecated: Use UserIDStatsList.ProtoReflect.Descriptor instead.
func (*UserIDStatsList) GetItems ¶
func (x *UserIDStatsList) GetItems() []*UserIDStats
func (*UserIDStatsList) ProtoMessage ¶
func (*UserIDStatsList) ProtoMessage()
func (*UserIDStatsList) ProtoReflect ¶
func (x *UserIDStatsList) ProtoReflect() protoreflect.Message
func (*UserIDStatsList) Reset ¶
func (x *UserIDStatsList) Reset()
func (*UserIDStatsList) String ¶
func (x *UserIDStatsList) String() string
type WriteRequest ¶
type WriteRequest struct { ClusterID string `protobuf:"bytes,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"` Timeseries []*TimeSeries `protobuf:"bytes,2,rep,name=timeseries,proto3" json:"timeseries,omitempty"` Metadata []*MetricMetadata `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*WriteRequest) Descriptor
deprecated
func (*WriteRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.
func (*WriteRequest) GetClusterID ¶
func (x *WriteRequest) GetClusterID() string
func (*WriteRequest) GetMetadata ¶
func (x *WriteRequest) GetMetadata() []*MetricMetadata
func (*WriteRequest) GetTimeseries ¶
func (x *WriteRequest) GetTimeseries() []*TimeSeries
func (*WriteRequest) ProtoMessage ¶
func (*WriteRequest) ProtoMessage()
func (*WriteRequest) ProtoReflect ¶
func (x *WriteRequest) ProtoReflect() protoreflect.Message
func (*WriteRequest) Reset ¶
func (x *WriteRequest) Reset()
func (*WriteRequest) String ¶
func (x *WriteRequest) String() string
type WriteResponse ¶
type WriteResponse struct {
// contains filtered or unexported fields
}
func (*WriteResponse) Descriptor
deprecated
func (*WriteResponse) Descriptor() ([]byte, []int)
Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.
func (*WriteResponse) ProtoMessage ¶
func (*WriteResponse) ProtoMessage()
func (*WriteResponse) ProtoReflect ¶
func (x *WriteResponse) ProtoReflect() protoreflect.Message
func (*WriteResponse) Reset ¶
func (x *WriteResponse) Reset()
func (*WriteResponse) String ¶
func (x *WriteResponse) String() string