cortexadmin

package
v0.9.2-rc3 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2023 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Overview

Package cortexadmin is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

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/pkg/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_pkg_apis_cortexadmin_cortexadmin_proto protoreflect.FileDescriptor
View Source 
var File_github_com_rancher_opni_plugins_metrics_pkg_apis_cortexadmin_status_proto protoreflect.FileDescriptor

Functions

func RegisterCortexAdminHandler 

func RegisterCortexAdminHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterCortexAdminHandler registers the http handlers for service CortexAdmin to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterCortexAdminHandlerClient 

func RegisterCortexAdminHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CortexAdminClient) error

RegisterCortexAdminHandlerClient registers the http handlers for service CortexAdmin to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "CortexAdminClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "CortexAdminClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "CortexAdminClient" to call the correct interceptors.

func RegisterCortexAdminHandlerFromEndpoint 

func RegisterCortexAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterCortexAdminHandlerFromEndpoint is same as RegisterCortexAdminHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterCortexAdminHandlerServer 

func RegisterCortexAdminHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CortexAdminServer) error

RegisterCortexAdminHandlerServer registers the http handlers for service CortexAdmin to "mux". UnaryRPC :call CortexAdminServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterCortexAdminHandlerFromEndpoint instead.

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 added in v0.8.2 

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 added in v0.8.2 

func (*Alert) Descriptor() ([]byte, []int)

Deprecated: Use Alert.ProtoReflect.Descriptor instead.

func (*Alert) GetActiveAt added in v0.8.2 

func (x *Alert) GetActiveAt() string

func (*Alert) GetAnnotations added in v0.8.2 

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

func (*Alert) GetLabels added in v0.8.2 

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

func (*Alert) GetState added in v0.8.2 

func (x *Alert) GetState() string

func (*Alert) GetValue added in v0.8.2 

func (x *Alert) GetValue() string

func (*Alert) ProtoMessage added in v0.8.2 

func (*Alert) ProtoMessage()

func (*Alert) ProtoReflect added in v0.8.2 

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

func (*Alert) Reset added in v0.8.2 

func (x *Alert) Reset()

func (*Alert) String added in v0.8.2 

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 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 added in v0.8.0 

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 added in v0.8.2 

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 added in v0.8.2 

func (*DeleteRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRuleRequest.ProtoReflect.Descriptor instead.

func (*DeleteRuleRequest) GetClusterId added in v0.8.2 

func (x *DeleteRuleRequest) GetClusterId() string

func (*DeleteRuleRequest) GetGroupName added in v0.8.2 

func (x *DeleteRuleRequest) GetGroupName() string

func (*DeleteRuleRequest) GetNamespace added in v0.8.2 

func (x *DeleteRuleRequest) GetNamespace() string

func (*DeleteRuleRequest) ProtoMessage added in v0.8.2 

func (*DeleteRuleRequest) ProtoMessage()

func (*DeleteRuleRequest) ProtoReflect added in v0.8.2 

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

func (*DeleteRuleRequest) Reset added in v0.8.2 

func (x *DeleteRuleRequest) Reset()

func (*DeleteRuleRequest) String added in v0.8.2 

func (x *DeleteRuleRequest) String() string

func (*DeleteRuleRequest) Validate added in v0.8.2 

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 added in v0.8.2 

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 added in v0.8.2 

func (*GetRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRuleRequest.ProtoReflect.Descriptor instead.

func (*GetRuleRequest) GetClusterId added in v0.8.2 

func (x *GetRuleRequest) GetClusterId() string

func (*GetRuleRequest) GetGroupName added in v0.8.2 

func (x *GetRuleRequest) GetGroupName() string

func (*GetRuleRequest) GetNamespace added in v0.8.2 

func (x *GetRuleRequest) GetNamespace() string

func (*GetRuleRequest) ProtoMessage added in v0.8.2 

func (*GetRuleRequest) ProtoMessage()

func (*GetRuleRequest) ProtoReflect added in v0.8.2 

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

func (*GetRuleRequest) Reset added in v0.8.2 

func (x *GetRuleRequest) Reset()

func (*GetRuleRequest) String added in v0.8.2 

func (x *GetRuleRequest) String() string

func (*GetRuleRequest) Validate added in v0.8.2 

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 added in v0.8.2 

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 added in v0.8.2 

func (l *ListRulesRequest) All() bool

func (*ListRulesRequest) Descriptor deprecated added in v0.8.2 

func (*ListRulesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListRulesRequest.ProtoReflect.Descriptor instead.

func (*ListRulesRequest) Filter added in v0.8.2 

func (l *ListRulesRequest) Filter(groups *RuleGroups, clusterId string) *RuleGroups

func (*ListRulesRequest) GetClusterId added in v0.8.2 

func (x *ListRulesRequest) GetClusterId() []string

func (*ListRulesRequest) GetGroupNameRegexp added in v0.8.2 

func (x *ListRulesRequest) GetGroupNameRegexp() string

func (*ListRulesRequest) GetHealthFilter added in v0.8.2 

func (x *ListRulesRequest) GetHealthFilter() []string

func (*ListRulesRequest) GetListInvalid added in v0.8.2 

func (x *ListRulesRequest) GetListInvalid() bool

func (*ListRulesRequest) GetNamespaceRegexp added in v0.8.2 

func (x *ListRulesRequest) GetNamespaceRegexp() string

func (*ListRulesRequest) GetRequestAll added in v0.8.2 

func (x *ListRulesRequest) GetRequestAll() bool

func (*ListRulesRequest) GetRuleNameRegexp added in v0.8.2 

func (x *ListRulesRequest) GetRuleNameRegexp() string

func (*ListRulesRequest) GetRuleType added in v0.8.2 

func (x *ListRulesRequest) GetRuleType() []string

func (*ListRulesRequest) GetStateFilter added in v0.8.2 

func (x *ListRulesRequest) GetStateFilter() []string

func (*ListRulesRequest) Invalid added in v0.8.2 

func (l *ListRulesRequest) Invalid() bool

func (*ListRulesRequest) MatchesCluster added in v0.8.2 

func (l *ListRulesRequest) MatchesCluster(clusterId string) bool

func (*ListRulesRequest) MatchesHealth added in v0.8.2 

func (l *ListRulesRequest) MatchesHealth(health string) bool

func (*ListRulesRequest) MatchesNamespace added in v0.8.2 

func (l *ListRulesRequest) MatchesNamespace(namespaceRegex *regexp.Regexp, namespace string) bool

func (*ListRulesRequest) MatchesRule added in v0.8.2 

func (l *ListRulesRequest) MatchesRule(ruleNameExpr *regexp.Regexp, ruleName string) bool

func (*ListRulesRequest) MatchesRuleGroup added in v0.8.2 

func (l *ListRulesRequest) MatchesRuleGroup(groupNameExpr *regexp.Regexp, groupName string) bool

func (*ListRulesRequest) MatchesRuleState added in v0.8.2 

func (l *ListRulesRequest) MatchesRuleState(state string) bool

func (*ListRulesRequest) MatchesRuleType added in v0.8.2 

func (l *ListRulesRequest) MatchesRuleType(ruleType string) bool

func (*ListRulesRequest) ProtoMessage added in v0.8.2 

func (*ListRulesRequest) ProtoMessage()

func (*ListRulesRequest) ProtoReflect added in v0.8.2 

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

func (*ListRulesRequest) Reset added in v0.8.2 

func (x *ListRulesRequest) Reset()

func (*ListRulesRequest) String added in v0.8.2 

func (x *ListRulesRequest) String() string

func (*ListRulesRequest) Validate added in v0.8.2 

func (l *ListRulesRequest) Validate() error

type ListRulesResponse added in v0.8.2 

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 added in v0.8.2 

func (*ListRulesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListRulesResponse.ProtoReflect.Descriptor instead.

func (*ListRulesResponse) GetData added in v0.8.2 

func (x *ListRulesResponse) GetData() *RuleGroups

func (*ListRulesResponse) GetStatus added in v0.8.2 

func (x *ListRulesResponse) GetStatus() string

func (*ListRulesResponse) ProtoMessage added in v0.8.2 

func (*ListRulesResponse) ProtoMessage()

func (*ListRulesResponse) ProtoReflect added in v0.8.2 

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

func (*ListRulesResponse) Reset added in v0.8.2 

func (x *ListRulesResponse) Reset()

func (*ListRulesResponse) String added in v0.8.2 

func (x *ListRulesResponse) String() string

type LoadRuleRequest added in v0.8.2 

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 added in v0.8.2 

func (*LoadRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadRuleRequest.ProtoReflect.Descriptor instead.

func (*LoadRuleRequest) GetClusterId added in v0.8.2 

func (x *LoadRuleRequest) GetClusterId() string

func (*LoadRuleRequest) GetNamespace added in v0.8.2 

func (x *LoadRuleRequest) GetNamespace() string

func (*LoadRuleRequest) GetYamlContent added in v0.8.2 

func (x *LoadRuleRequest) GetYamlContent() []byte

func (*LoadRuleRequest) ProtoMessage added in v0.8.2 

func (*LoadRuleRequest) ProtoMessage()

func (*LoadRuleRequest) ProtoReflect added in v0.8.2 

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

func (*LoadRuleRequest) Reset added in v0.8.2 

func (x *LoadRuleRequest) Reset()

func (*LoadRuleRequest) String added in v0.8.2 

func (x *LoadRuleRequest) String() string

func (*LoadRuleRequest) Validate added in v0.8.2 

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 added in v0.9.1 

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 added in v0.9.1 

func (*MetricMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use MetricMetadataRequest.ProtoReflect.Descriptor instead.

func (*MetricMetadataRequest) GetMetricName added in v0.9.1 

func (x *MetricMetadataRequest) GetMetricName() string

func (*MetricMetadataRequest) GetTenants added in v0.9.1 

func (x *MetricMetadataRequest) GetTenants() []string

func (*MetricMetadataRequest) ProtoMessage added in v0.9.1 

func (*MetricMetadataRequest) ProtoMessage()

func (*MetricMetadataRequest) ProtoReflect added in v0.9.1 

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

func (*MetricMetadataRequest) Reset added in v0.9.1 

func (x *MetricMetadataRequest) Reset()

func (*MetricMetadataRequest) String added in v0.9.1 

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 added in v0.8.2 

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 added in v0.8.2 

func (*Rule) Descriptor() ([]byte, []int)

Deprecated: Use Rule.ProtoReflect.Descriptor instead.

func (*Rule) GetAlerts added in v0.8.2 

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

func (*Rule) GetAnnotations added in v0.8.2 

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

func (*Rule) GetDuration added in v0.8.2 

func (x *Rule) GetDuration() float64

func (*Rule) GetEvaluationTime added in v0.8.2 

func (x *Rule) GetEvaluationTime() float64

func (*Rule) GetHealth added in v0.8.2 

func (x *Rule) GetHealth() string

func (*Rule) GetLabels added in v0.8.2 

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

func (*Rule) GetLastError added in v0.8.2 

func (x *Rule) GetLastError() string

func (*Rule) GetLastEvaluation added in v0.8.2 

func (x *Rule) GetLastEvaluation() string

func (*Rule) GetName added in v0.8.2 

func (x *Rule) GetName() string

func (*Rule) GetQuery added in v0.8.2 

func (x *Rule) GetQuery() string

func (*Rule) GetState added in v0.8.2 

func (x *Rule) GetState() string

func (*Rule) GetType added in v0.8.2 

func (x *Rule) GetType() string

func (*Rule) ProtoMessage added in v0.8.2 

func (*Rule) ProtoMessage()

func (*Rule) ProtoReflect added in v0.8.2 

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

func (*Rule) Reset added in v0.8.2 

func (x *Rule) Reset()

func (*Rule) String added in v0.8.2 

func (x *Rule) String() string

type RuleGroup added in v0.8.2 

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 added in v0.8.2 

func (*RuleGroup) Descriptor() ([]byte, []int)

Deprecated: Use RuleGroup.ProtoReflect.Descriptor instead.

func (*RuleGroup) GetClusterId added in v0.8.2 

func (x *RuleGroup) GetClusterId() string

func (*RuleGroup) GetEvaluationTime added in v0.8.2 

func (x *RuleGroup) GetEvaluationTime() float64

func (*RuleGroup) GetFile added in v0.8.2 

func (x *RuleGroup) GetFile() string

func (*RuleGroup) GetInterval added in v0.8.2 

func (x *RuleGroup) GetInterval() float64

func (*RuleGroup) GetLastEvaluation added in v0.8.2 

func (x *RuleGroup) GetLastEvaluation() string

func (*RuleGroup) GetName added in v0.8.2 

func (x *RuleGroup) GetName() string

func (*RuleGroup) GetRules added in v0.8.2 

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

func (*RuleGroup) ProtoMessage added in v0.8.2 

func (*RuleGroup) ProtoMessage()

func (*RuleGroup) ProtoReflect added in v0.8.2 

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

func (*RuleGroup) Reset added in v0.8.2 

func (x *RuleGroup) Reset()

func (*RuleGroup) String added in v0.8.2 

func (x *RuleGroup) String() string

type RuleGroups added in v0.8.2 

type RuleGroups struct {
	Groups []*RuleGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleGroups) Descriptor deprecated added in v0.8.2 

func (*RuleGroups) Descriptor() ([]byte, []int)

Deprecated: Use RuleGroups.ProtoReflect.Descriptor instead.

func (*RuleGroups) GetGroups added in v0.8.2 

func (x *RuleGroups) GetGroups() []*RuleGroup

func (*RuleGroups) ProtoMessage added in v0.8.2 

func (*RuleGroups) ProtoMessage()

func (*RuleGroups) ProtoReflect added in v0.8.2 

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

func (*RuleGroups) Reset added in v0.8.2 

func (x *RuleGroups) Reset()

func (*RuleGroups) String added in v0.8.2 

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 added in v0.9.1 

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.