cortexadmin

package
v0.12.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
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

View Source 
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.

View Source 
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)

View Source 
var File_github_com_rancher_opni_plugins_metrics_apis_cortexadmin_cortexadmin_proto protoreflect.FileDescriptor
View Source 
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 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) Descriptor() ([]byte, []int)

Deprecated: Use Alert.ProtoReflect.Descriptor instead.

func (*Alert) GetActiveAt 

func (x *Alert) GetActiveAt() string

func (*Alert) GetAnnotations 

func (x *Alert) GetAnnotations() map[string]string

func (*Alert) GetLabels 

func (x *Alert) GetLabels() map[string]string

func (*Alert) GetState 

func (x *Alert) GetState() string

func (*Alert) GetValue 

func (x *Alert) GetValue() string

func (*Alert) ProtoMessage 

func (*Alert) ProtoMessage()

func (*Alert) ProtoReflect 

func (x *Alert) ProtoReflect() protoreflect.Message

func (*Alert) Reset 

func (x *Alert) Reset()

func (*Alert) String 

func (x *Alert) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetClusterId 

func (x *Cluster) GetClusterId() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

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 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) Descriptor() ([]byte, []int)

Deprecated: Use Exemplar.ProtoReflect.Descriptor instead.

func (*Exemplar) GetLabels 

func (x *Exemplar) GetLabels() []*Label

func (*Exemplar) GetTimestampMs 

func (x *Exemplar) GetTimestampMs() int64

func (*Exemplar) GetValue 

func (x *Exemplar) GetValue() float64

func (*Exemplar) ProtoMessage 

func (*Exemplar) ProtoMessage()

func (*Exemplar) ProtoReflect 

func (x *Exemplar) ProtoReflect() protoreflect.Message

func (*Exemplar) Reset 

func (x *Exemplar) Reset()

func (*Exemplar) String 

func (x *Exemplar) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetName 

func (x *Label) GetName() string

func (*Label) GetValue 

func (x *Label) GetValue() string

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) ProtoReflect 

func (x *Label) ProtoReflect() protoreflect.Message

func (*Label) Reset 

func (x *Label) Reset()

func (*Label) String 

func (x *Label) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use LabelSet.ProtoReflect.Descriptor instead.

func (*LabelSet) GetItems 

func (x *LabelSet) GetItems() []string

func (*LabelSet) GetName 

func (x *LabelSet) GetName() string

func (*LabelSet) ProtoMessage 

func (*LabelSet) ProtoMessage()

func (*LabelSet) ProtoReflect 

func (x *LabelSet) ProtoReflect() protoreflect.Message

func (*LabelSet) Reset 

func (x *LabelSet) Reset()

func (*LabelSet) String 

func (x *LabelSet) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Rule.ProtoReflect.Descriptor instead.

func (*Rule) GetAlerts 

func (x *Rule) GetAlerts() []*Alert

func (*Rule) GetAnnotations 

func (x *Rule) GetAnnotations() map[string]string

func (*Rule) GetDuration 

func (x *Rule) GetDuration() float64

func (*Rule) GetEvaluationTime 

func (x *Rule) GetEvaluationTime() float64

func (*Rule) GetHealth 

func (x *Rule) GetHealth() string

func (*Rule) GetLabels 

func (x *Rule) GetLabels() map[string]string

func (*Rule) GetLastError 

func (x *Rule) GetLastError() string

func (*Rule) GetLastEvaluation 

func (x *Rule) GetLastEvaluation() string

func (*Rule) GetName 

func (x *Rule) GetName() string

func (*Rule) GetQuery 

func (x *Rule) GetQuery() string

func (*Rule) GetState 

func (x *Rule) GetState() string

func (*Rule) GetType 

func (x *Rule) GetType() string

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) ProtoReflect 

func (x *Rule) ProtoReflect() protoreflect.Message

func (*Rule) Reset 

func (x *Rule) Reset()

func (*Rule) String 

func (x *Rule) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use RuleGroup.ProtoReflect.Descriptor instead.

func (*RuleGroup) GetClusterId 

func (x *RuleGroup) GetClusterId() string

func (*RuleGroup) GetEvaluationTime 

func (x *RuleGroup) GetEvaluationTime() float64

func (*RuleGroup) GetFile 

func (x *RuleGroup) GetFile() string

func (*RuleGroup) GetInterval 

func (x *RuleGroup) GetInterval() float64

func (*RuleGroup) GetLastEvaluation 

func (x *RuleGroup) GetLastEvaluation() string

func (*RuleGroup) GetName 

func (x *RuleGroup) GetName() string

func (*RuleGroup) GetRules 

func (x *RuleGroup) GetRules() []*Rule

func (*RuleGroup) ProtoMessage 

func (*RuleGroup) ProtoMessage()

func (*RuleGroup) ProtoReflect 

func (x *RuleGroup) ProtoReflect() protoreflect.Message

func (*RuleGroup) Reset 

func (x *RuleGroup) Reset()

func (*RuleGroup) String 

func (x *RuleGroup) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Sample.ProtoReflect.Descriptor instead.

func (*Sample) GetTimestampMs 

func (x *Sample) GetTimestampMs() int64

func (*Sample) GetValue 

func (x *Sample) GetValue() float64

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) ProtoReflect 

func (x *Sample) ProtoReflect() protoreflect.Message

func (*Sample) Reset 

func (x *Sample) Reset()

func (*Sample) String 

func (x *Sample) String() string

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) FlushBlocks(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.