v1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Error_name = map[int32]string{
		0: "RESOURCE_ERR_UNKNOWN",
		1: "RESOURCE_ERR_NOT_FOUND",
		2: "RESOURCE_ERR_LIST_MYSQL",
		3: "RESOURCE_ERR_INFO_MYSQL",
		4: "MONITORING_ERR_INVALID_ARGUMENT",
	}
	Error_value = map[string]int32{
		"RESOURCE_ERR_UNKNOWN":            0,
		"RESOURCE_ERR_NOT_FOUND":          1,
		"RESOURCE_ERR_LIST_MYSQL":         2,
		"RESOURCE_ERR_INFO_MYSQL":         3,
		"MONITORING_ERR_INVALID_ARGUMENT": 4,
	}
)

Enum value maps for Error.

View Source 
var File_api_prometheus_v1_error_proto protoreflect.FileDescriptor
View Source 
var File_api_prometheus_v1_prometheus_proto protoreflect.FileDescriptor
View Source 
var Prometheus_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "prometheus.v1.Prometheus",
	HandlerType: (*PrometheusServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Query",
			Handler:    _Prometheus_Query_Handler,
		},
		{
			MethodName: "BatchQuery",
			Handler:    _Prometheus_BatchQuery_Handler,
		},
		{
			MethodName: "TKMeter",
			Handler:    _Prometheus_TKMeter_Handler,
		},
		{
			MethodName: "BatchTKMeter",
			Handler:    _Prometheus_BatchTKMeter_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/prometheus/v1/prometheus.proto",
}

Prometheus_ServiceDesc is the grpc.ServiceDesc for Prometheus service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func MonitoringErrInvalidArgument 

func MonitoringErrInvalidArgument() errors.Error

func RegisterPrometheusHTTPServer 

func RegisterPrometheusHTTPServer(container *go_restful.Container, srv PrometheusHTTPServer)

func RegisterPrometheusServer 

func RegisterPrometheusServer(s grpc.ServiceRegistrar, srv PrometheusServer)

func ResourceErrInfoMysql 

func ResourceErrInfoMysql() errors.Error

func ResourceErrListMysql 

func ResourceErrListMysql() errors.Error

func ResourceErrNotFound 

func ResourceErrNotFound() errors.Error

func ResourceErrUnknown 

func ResourceErrUnknown() errors.Error

Types

type BatchQueryRequest 

type BatchQueryRequest struct {
	Query    string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	St       int64  `protobuf:"varint,2,opt,name=st,proto3" json:"st,omitempty"`
	Et       int64  `protobuf:"varint,3,opt,name=et,proto3" json:"et,omitempty"`
	Step     string `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"`
	TenantId string `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the user's name.

func (*BatchQueryRequest) Descriptor deprecated 

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

Deprecated: Use BatchQueryRequest.ProtoReflect.Descriptor instead.

func (*BatchQueryRequest) GetEt 

func (x *BatchQueryRequest) GetEt() int64

func (*BatchQueryRequest) GetQuery 

func (x *BatchQueryRequest) GetQuery() string

func (*BatchQueryRequest) GetSt 

func (x *BatchQueryRequest) GetSt() int64

func (*BatchQueryRequest) GetStep 

func (x *BatchQueryRequest) GetStep() string

func (*BatchQueryRequest) GetTenantId 

func (x *BatchQueryRequest) GetTenantId() string

func (*BatchQueryRequest) ProtoMessage 

func (*BatchQueryRequest) ProtoMessage()

func (*BatchQueryRequest) ProtoReflect 

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

func (*BatchQueryRequest) Reset 

func (x *BatchQueryRequest) Reset()

func (*BatchQueryRequest) String 

func (x *BatchQueryRequest) String() string

type BatchQueryResponse 

type BatchQueryResponse struct {
	Results []*MetricsData `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the greetings

func (*BatchQueryResponse) Descriptor deprecated 

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

Deprecated: Use BatchQueryResponse.ProtoReflect.Descriptor instead.

func (*BatchQueryResponse) GetResults 

func (x *BatchQueryResponse) GetResults() []*MetricsData

func (*BatchQueryResponse) ProtoMessage 

func (*BatchQueryResponse) ProtoMessage()

func (*BatchQueryResponse) ProtoReflect 

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

func (*BatchQueryResponse) Reset 

func (x *BatchQueryResponse) Reset()

func (*BatchQueryResponse) String 

func (x *BatchQueryResponse) String() string

type Error 

type Error int32

@plugins=protoc-gen-go-errors 错误 

const (
	// 未知类型
	// @code=UNKNOWN
	Error_RESOURCE_ERR_UNKNOWN Error = 0
	// 找不到资源
	// @code=NOT_FOUND
	Error_RESOURCE_ERR_NOT_FOUND Error = 1
	// 获取列表数据出错
	// @code=INTERNAL
	Error_RESOURCE_ERR_LIST_MYSQL Error = 2
	// 获取详情数据出错
	// @code=INTERNAL
	Error_RESOURCE_ERR_INFO_MYSQL Error = 3
	// 参数错误
	// @code=INVALID_ARGUMENT
	Error_MONITORING_ERR_INVALID_ARGUMENT Error = 4
)

func (Error) Descriptor 

func (Error) Descriptor() protoreflect.EnumDescriptor

func (Error) Enum 

func (x Error) Enum() *Error

func (Error) EnumDescriptor deprecated 

func (Error) EnumDescriptor() ([]byte, []int)

Deprecated: Use Error.Descriptor instead.

func (Error) Number 

func (x Error) Number() protoreflect.EnumNumber

func (Error) String 

func (x Error) String() string

func (Error) Type 

func (Error) Type() protoreflect.EnumType

type MetricValue 

type MetricValue struct {
	Metric map[string]string `` /* 153-byte string literal not displayed */
	Value  *Point            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Values []*Point          `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricValue) Descriptor deprecated 

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

Deprecated: Use MetricValue.ProtoReflect.Descriptor instead.

func (*MetricValue) GetMetric 

func (x *MetricValue) GetMetric() map[string]string

func (*MetricValue) GetValue 

func (x *MetricValue) GetValue() *Point

func (*MetricValue) GetValues 

func (x *MetricValue) GetValues() []*Point

func (*MetricValue) ProtoMessage 

func (*MetricValue) ProtoMessage()

func (*MetricValue) ProtoReflect 

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

func (*MetricValue) Reset 

func (x *MetricValue) Reset()

func (*MetricValue) String 

func (x *MetricValue) String() string

type MetricsData 

type MetricsData struct {
	ResultType string         `protobuf:"bytes,1,opt,name=result_type,json=resultType,proto3" json:"result_type,omitempty"`
	Query      string         `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	Result     []*MetricValue `protobuf:"bytes,3,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsData) Descriptor deprecated 

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

Deprecated: Use MetricsData.ProtoReflect.Descriptor instead.

func (*MetricsData) GetQuery 

func (x *MetricsData) GetQuery() string

func (*MetricsData) GetResult 

func (x *MetricsData) GetResult() []*MetricValue

func (*MetricsData) GetResultType 

func (x *MetricsData) GetResultType() string

func (*MetricsData) ProtoMessage 

func (*MetricsData) ProtoMessage()

func (*MetricsData) ProtoReflect 

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

func (*MetricsData) Reset 

func (x *MetricsData) Reset()

func (*MetricsData) String 

func (x *MetricsData) String() string

type Point 

type Point struct {
	Timestamp float64 `protobuf:"fixed64,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Point) Descriptor deprecated 

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

Deprecated: Use Point.ProtoReflect.Descriptor instead.

func (*Point) GetTimestamp 

func (x *Point) GetTimestamp() float64

func (*Point) GetValue 

func (x *Point) GetValue() float64

func (*Point) ProtoMessage 

func (*Point) ProtoMessage()

func (*Point) ProtoReflect 

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

func (*Point) Reset 

func (x *Point) Reset()

func (*Point) String 

func (x *Point) String() string

type PrometheusClient 

type PrometheusClient interface {
	// Sends query.
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	// Sends query.
	BatchQuery(ctx context.Context, in *BatchQueryRequest, opts ...grpc.CallOption) (*BatchQueryResponse, error)
	// Sends query.
	TKMeter(ctx context.Context, in *TKMeterRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	// Sends query.
	BatchTKMeter(ctx context.Context, in *TKMeterBatchRequest, opts ...grpc.CallOption) (*BatchQueryResponse, error)
}

PrometheusClient is the client API for Prometheus 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 NewPrometheusClient 

func NewPrometheusClient(cc grpc.ClientConnInterface) PrometheusClient

type PrometheusHTTPHandler 

type PrometheusHTTPHandler struct {
	// contains filtered or unexported fields
}

func (*PrometheusHTTPHandler) BatchQuery 

func (h *PrometheusHTTPHandler) BatchQuery(req *go_restful.Request, resp *go_restful.Response)

func (*PrometheusHTTPHandler) BatchTKMeter 

func (h *PrometheusHTTPHandler) BatchTKMeter(req *go_restful.Request, resp *go_restful.Response)

func (*PrometheusHTTPHandler) Query 

func (h *PrometheusHTTPHandler) Query(req *go_restful.Request, resp *go_restful.Response)

func (*PrometheusHTTPHandler) TKMeter 

func (h *PrometheusHTTPHandler) TKMeter(req *go_restful.Request, resp *go_restful.Response)

type PrometheusHTTPServer 

type PrometheusHTTPServer interface {
	BatchQuery(context.Context, *BatchQueryRequest) (*BatchQueryResponse, error)
	BatchTKMeter(context.Context, *TKMeterBatchRequest) (*BatchQueryResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	TKMeter(context.Context, *TKMeterRequest) (*QueryResponse, error)
}

type PrometheusServer 

type PrometheusServer interface {
	// Sends query.
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	// Sends query.
	BatchQuery(context.Context, *BatchQueryRequest) (*BatchQueryResponse, error)
	// Sends query.
	TKMeter(context.Context, *TKMeterRequest) (*QueryResponse, error)
	// Sends query.
	BatchTKMeter(context.Context, *TKMeterBatchRequest) (*BatchQueryResponse, error)
	// contains filtered or unexported methods
}

PrometheusServer is the server API for Prometheus service. All implementations must embed UnimplementedPrometheusServer for forward compatibility

type QueryRequest 

type QueryRequest struct {
	Query    string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	St       int64  `protobuf:"varint,2,opt,name=st,proto3" json:"st,omitempty"`
	Et       int64  `protobuf:"varint,3,opt,name=et,proto3" json:"et,omitempty"`
	Step     string `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"`
	TenantId string `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the user's name.

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetEt 

func (x *QueryRequest) GetEt() int64

func (*QueryRequest) GetQuery 

func (x *QueryRequest) GetQuery() string

func (*QueryRequest) GetSt 

func (x *QueryRequest) GetSt() int64

func (*QueryRequest) GetStep 

func (x *QueryRequest) GetStep() string

func (*QueryRequest) GetTenantId 

func (x *QueryRequest) GetTenantId() 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 {
	Result *MetricsData `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the greetings

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetResult 

func (x *QueryResponse) GetResult() *MetricsData

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 TKMeterBatchRequest 

type TKMeterBatchRequest struct {
	Meters   string `protobuf:"bytes,1,opt,name=meters,proto3" json:"meters,omitempty"`
	St       int64  `protobuf:"varint,2,opt,name=st,proto3" json:"st,omitempty"`
	Et       int64  `protobuf:"varint,3,opt,name=et,proto3" json:"et,omitempty"`
	Step     string `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"`
	TenantId string `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the user's name.

func (*TKMeterBatchRequest) Descriptor deprecated 

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

Deprecated: Use TKMeterBatchRequest.ProtoReflect.Descriptor instead.

func (*TKMeterBatchRequest) GetEt 

func (x *TKMeterBatchRequest) GetEt() int64

func (*TKMeterBatchRequest) GetMeters 

func (x *TKMeterBatchRequest) GetMeters() string

func (*TKMeterBatchRequest) GetSt 

func (x *TKMeterBatchRequest) GetSt() int64

func (*TKMeterBatchRequest) GetStep 

func (x *TKMeterBatchRequest) GetStep() string

func (*TKMeterBatchRequest) GetTenantId 

func (x *TKMeterBatchRequest) GetTenantId() string

func (*TKMeterBatchRequest) ProtoMessage 

func (*TKMeterBatchRequest) ProtoMessage()

func (*TKMeterBatchRequest) ProtoReflect 

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

func (*TKMeterBatchRequest) Reset 

func (x *TKMeterBatchRequest) Reset()

func (*TKMeterBatchRequest) String 

func (x *TKMeterBatchRequest) String() string

type TKMeterRequest 

type TKMeterRequest struct {
	Meter    string `protobuf:"bytes,1,opt,name=meter,proto3" json:"meter,omitempty"`
	St       int64  `protobuf:"varint,2,opt,name=st,proto3" json:"st,omitempty"`
	Et       int64  `protobuf:"varint,3,opt,name=et,proto3" json:"et,omitempty"`
	Step     string `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"`
	TenantId string `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TKMeterRequest) Descriptor deprecated 

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

Deprecated: Use TKMeterRequest.ProtoReflect.Descriptor instead.

func (*TKMeterRequest) GetEt 

func (x *TKMeterRequest) GetEt() int64

func (*TKMeterRequest) GetMeter 

func (x *TKMeterRequest) GetMeter() string

func (*TKMeterRequest) GetSt 

func (x *TKMeterRequest) GetSt() int64

func (*TKMeterRequest) GetStep 

func (x *TKMeterRequest) GetStep() string

func (*TKMeterRequest) GetTenantId 

func (x *TKMeterRequest) GetTenantId() string

func (*TKMeterRequest) ProtoMessage 

func (*TKMeterRequest) ProtoMessage()

func (*TKMeterRequest) ProtoReflect 

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

func (*TKMeterRequest) Reset 

func (x *TKMeterRequest) Reset()

func (*TKMeterRequest) String 

func (x *TKMeterRequest) String() string

type UnimplementedPrometheusServer 

type UnimplementedPrometheusServer struct {
}

UnimplementedPrometheusServer must be embedded to have forward compatible implementations.

func (UnimplementedPrometheusServer) BatchQuery 

func (UnimplementedPrometheusServer) BatchQuery(context.Context, *BatchQueryRequest) (*BatchQueryResponse, error)

func (UnimplementedPrometheusServer) BatchTKMeter 

func (UnimplementedPrometheusServer) BatchTKMeter(context.Context, *TKMeterBatchRequest) (*BatchQueryResponse, error)

func (UnimplementedPrometheusServer) Query 

func (UnimplementedPrometheusServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

func (UnimplementedPrometheusServer) TKMeter 

func (UnimplementedPrometheusServer) TKMeter(context.Context, *TKMeterRequest) (*QueryResponse, error)

type UnsafePrometheusServer 

type UnsafePrometheusServer interface {
	// contains filtered or unexported methods
}

UnsafePrometheusServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PrometheusServer will result in compilation errors.

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.