metrics

package
v0.0.0-...-af36fda Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Aggregator_name = map[int32]string{
		0: "AGGREGATOR_UNSPECIFIED",
		1: "AGGREGATOR_AVG",
		2: "AGGREGATOR_MIN",
		3: "AGGREGATOR_MAX",
		4: "AGGREGATOR_SUM",
	}
	Aggregator_value = map[string]int32{
		"AGGREGATOR_UNSPECIFIED": 0,
		"AGGREGATOR_AVG":         1,
		"AGGREGATOR_MIN":         2,
		"AGGREGATOR_MAX":         3,
		"AGGREGATOR_SUM":         4,
	}
)

Enum value maps for Aggregator.

View Source 
var (
	BinOp_name = map[int32]string{
		0: "BINOP_UNSPECIFIED",
		1: "BINOP_ADD",
		2: "BINOP_SUB",
		3: "BINOP_MULT",
		4: "BINOP_DIV",
	}
	BinOp_value = map[string]int32{
		"BINOP_UNSPECIFIED": 0,
		"BINOP_ADD":         1,
		"BINOP_SUB":         2,
		"BINOP_MULT":        3,
		"BINOP_DIV":         4,
	}
)

Enum value maps for BinOp.

View Source 
var File_api_v1_metrics_metrics_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_metrics_service_proto protoreflect.FileDescriptor
View Source 
var Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1.metrics.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMetrics",
			Handler:    _Service_GetMetrics_Handler,
		},
		{
			MethodName: "GetMetricsMany",
			Handler:    _Service_GetMetricsMany_Handler,
		},
		{
			MethodName: "GetMetricsExpression",
			Handler:    _Service_GetMetricsExpression_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/metrics/service.proto",
}

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

Functions

func RegisterServiceServer 

func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

Types

type Aggregation 

type Aggregation struct {
	Aggregator Aggregator           `protobuf:"varint,1,opt,name=aggregator,proto3,enum=api.v1.metrics.Aggregator" json:"aggregator,omitempty"`
	BucketSize *durationpb.Duration `protobuf:"bytes,2,opt,name=bucket_size,json=bucketSize,proto3" json:"bucket_size,omitempty"`
	// contains filtered or unexported fields
}

func (*Aggregation) Descriptor deprecated 

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

Deprecated: Use Aggregation.ProtoReflect.Descriptor instead.

func (*Aggregation) GetAggregator 

func (x *Aggregation) GetAggregator() Aggregator

func (*Aggregation) GetBucketSize 

func (x *Aggregation) GetBucketSize() *durationpb.Duration

func (*Aggregation) ProtoMessage 

func (*Aggregation) ProtoMessage()

func (*Aggregation) ProtoReflect 

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

func (*Aggregation) Reset 

func (x *Aggregation) Reset()

func (*Aggregation) String 

func (x *Aggregation) String() string

type Aggregator 

type Aggregator int32
const (
	Aggregator_AGGREGATOR_UNSPECIFIED Aggregator = 0
	Aggregator_AGGREGATOR_AVG         Aggregator = 1
	Aggregator_AGGREGATOR_MIN         Aggregator = 2
	Aggregator_AGGREGATOR_MAX         Aggregator = 3
	Aggregator_AGGREGATOR_SUM         Aggregator = 4
)

func (Aggregator) Descriptor 

func (Aggregator) Descriptor() protoreflect.EnumDescriptor

func (Aggregator) Enum 

func (x Aggregator) Enum() *Aggregator

func (Aggregator) EnumDescriptor deprecated 

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

Deprecated: Use Aggregator.Descriptor instead.

func (Aggregator) Number 

func (x Aggregator) Number() protoreflect.EnumNumber

func (Aggregator) String 

func (x Aggregator) String() string

func (Aggregator) Type 

func (Aggregator) Type() protoreflect.EnumType

type BinOp 

type BinOp int32
const (
	BinOp_BINOP_UNSPECIFIED BinOp = 0
	BinOp_BINOP_ADD         BinOp = 1
	BinOp_BINOP_SUB         BinOp = 2
	BinOp_BINOP_MULT        BinOp = 3
	BinOp_BINOP_DIV         BinOp = 4
)

func (BinOp) Descriptor 

func (BinOp) Descriptor() protoreflect.EnumDescriptor

func (BinOp) Enum 

func (x BinOp) Enum() *BinOp

func (BinOp) EnumDescriptor deprecated 

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

Deprecated: Use BinOp.Descriptor instead.

func (BinOp) Number 

func (x BinOp) Number() protoreflect.EnumNumber

func (BinOp) String 

func (x BinOp) String() string

func (BinOp) Type 

func (BinOp) Type() protoreflect.EnumType

type Expression 

type Expression struct {

	// Types that are assignable to Expression:
	//
	//	*Expression_Leaf_
	//	*Expression_Operation_
	//	*Expression_Constant_
	//	*Expression_WithDefault_
	//	*Expression_Sum_
	Expression isExpression_Expression `protobuf_oneof:"expression"`
	// contains filtered or unexported fields
}

func (*Expression) Descriptor deprecated 

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

Deprecated: Use Expression.ProtoReflect.Descriptor instead.

func (*Expression) GetConstant 

func (x *Expression) GetConstant() *Expression_Constant

func (*Expression) GetExpression 

func (m *Expression) GetExpression() isExpression_Expression

func (*Expression) GetLeaf 

func (x *Expression) GetLeaf() *Expression_Leaf

func (*Expression) GetOperation 

func (x *Expression) GetOperation() *Expression_Operation

func (*Expression) GetSum 

func (x *Expression) GetSum() *Expression_Sum

func (*Expression) GetWithDefault 

func (x *Expression) GetWithDefault() *Expression_WithDefault

func (*Expression) ProtoMessage 

func (*Expression) ProtoMessage()

func (*Expression) ProtoReflect 

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

func (*Expression) Reset 

func (x *Expression) Reset()

func (*Expression) String 

func (x *Expression) String() string

type Expression_Constant 

type Expression_Constant struct {
	Constant float64 `protobuf:"fixed64,1,opt,name=constant,proto3" json:"constant,omitempty"`
	// contains filtered or unexported fields
}

func (*Expression_Constant) Descriptor deprecated 

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

Deprecated: Use Expression_Constant.ProtoReflect.Descriptor instead.

func (*Expression_Constant) GetConstant 

func (x *Expression_Constant) GetConstant() float64

func (*Expression_Constant) ProtoMessage 

func (*Expression_Constant) ProtoMessage()

func (*Expression_Constant) ProtoReflect 

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

func (*Expression_Constant) Reset 

func (x *Expression_Constant) Reset()

func (*Expression_Constant) String 

func (x *Expression_Constant) String() string

type Expression_Constant_ 

type Expression_Constant_ struct {
	Constant *Expression_Constant `protobuf:"bytes,3,opt,name=constant,proto3,oneof"`
}

type Expression_Leaf 

type Expression_Leaf struct {
	Tags       *Tags      `protobuf:"bytes,1,opt,name=tags,proto3" json:"tags,omitempty"`
	Aggregator Aggregator `protobuf:"varint,2,opt,name=aggregator,proto3,enum=api.v1.metrics.Aggregator" json:"aggregator,omitempty"`
	// contains filtered or unexported fields
}

func (*Expression_Leaf) Descriptor deprecated 

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

Deprecated: Use Expression_Leaf.ProtoReflect.Descriptor instead.

func (*Expression_Leaf) GetAggregator 

func (x *Expression_Leaf) GetAggregator() Aggregator

func (*Expression_Leaf) GetTags 

func (x *Expression_Leaf) GetTags() *Tags

func (*Expression_Leaf) ProtoMessage 

func (*Expression_Leaf) ProtoMessage()

func (*Expression_Leaf) ProtoReflect 

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

func (*Expression_Leaf) Reset 

func (x *Expression_Leaf) Reset()

func (*Expression_Leaf) String 

func (x *Expression_Leaf) String() string

type Expression_Leaf_ 

type Expression_Leaf_ struct {
	Leaf *Expression_Leaf `protobuf:"bytes,1,opt,name=leaf,proto3,oneof"`
}

type Expression_Operation 

type Expression_Operation struct {
	Left      *Expression `protobuf:"bytes,1,opt,name=left,proto3" json:"left,omitempty"`
	Right     *Expression `protobuf:"bytes,2,opt,name=right,proto3" json:"right,omitempty"`
	Operation BinOp       `protobuf:"varint,3,opt,name=operation,proto3,enum=api.v1.metrics.BinOp" json:"operation,omitempty"`
	On        *Keys       `protobuf:"bytes,4,opt,name=on,proto3" json:"on,omitempty"`
	Ignore    *Keys       `protobuf:"bytes,5,opt,name=ignore,proto3" json:"ignore,omitempty"`
	// contains filtered or unexported fields
}

func (*Expression_Operation) Descriptor deprecated 

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

Deprecated: Use Expression_Operation.ProtoReflect.Descriptor instead.

func (*Expression_Operation) GetIgnore 

func (x *Expression_Operation) GetIgnore() *Keys

func (*Expression_Operation) GetLeft 

func (x *Expression_Operation) GetLeft() *Expression

func (*Expression_Operation) GetOn 

func (x *Expression_Operation) GetOn() *Keys

func (*Expression_Operation) GetOperation 

func (x *Expression_Operation) GetOperation() BinOp

func (*Expression_Operation) GetRight 

func (x *Expression_Operation) GetRight() *Expression

func (*Expression_Operation) ProtoMessage 

func (*Expression_Operation) ProtoMessage()

func (*Expression_Operation) ProtoReflect 

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

func (*Expression_Operation) Reset 

func (x *Expression_Operation) Reset()

func (*Expression_Operation) String 

func (x *Expression_Operation) String() string

type Expression_Operation_ 

type Expression_Operation_ struct {
	Operation *Expression_Operation `protobuf:"bytes,2,opt,name=operation,proto3,oneof"`
}

type Expression_Sum 

type Expression_Sum struct {
	On         *Keys       `protobuf:"bytes,1,opt,name=on,proto3" json:"on,omitempty"`
	Ignore     *Keys       `protobuf:"bytes,2,opt,name=ignore,proto3" json:"ignore,omitempty"`
	Expression *Expression `protobuf:"bytes,3,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*Expression_Sum) Descriptor deprecated 

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

Deprecated: Use Expression_Sum.ProtoReflect.Descriptor instead.

func (*Expression_Sum) GetExpression 

func (x *Expression_Sum) GetExpression() *Expression

func (*Expression_Sum) GetIgnore 

func (x *Expression_Sum) GetIgnore() *Keys

func (*Expression_Sum) GetOn 

func (x *Expression_Sum) GetOn() *Keys

func (*Expression_Sum) ProtoMessage 

func (*Expression_Sum) ProtoMessage()

func (*Expression_Sum) ProtoReflect 

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

func (*Expression_Sum) Reset 

func (x *Expression_Sum) Reset()

func (*Expression_Sum) String 

func (x *Expression_Sum) String() string

type Expression_Sum_ 

type Expression_Sum_ struct {
	Sum *Expression_Sum `protobuf:"bytes,5,opt,name=sum,proto3,oneof"`
}

type Expression_WithDefault 

type Expression_WithDefault struct {
	Expression *Expression `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	Default    float64     `protobuf:"fixed64,2,opt,name=default,proto3" json:"default,omitempty"`
	// contains filtered or unexported fields
}

func (*Expression_WithDefault) Descriptor deprecated 

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

Deprecated: Use Expression_WithDefault.ProtoReflect.Descriptor instead.

func (*Expression_WithDefault) GetDefault 

func (x *Expression_WithDefault) GetDefault() float64

func (*Expression_WithDefault) GetExpression 

func (x *Expression_WithDefault) GetExpression() *Expression

func (*Expression_WithDefault) ProtoMessage 

func (*Expression_WithDefault) ProtoMessage()

func (*Expression_WithDefault) ProtoReflect 

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

func (*Expression_WithDefault) Reset 

func (x *Expression_WithDefault) Reset()

func (*Expression_WithDefault) String 

func (x *Expression_WithDefault) String() string

type Expression_WithDefault_ 

type Expression_WithDefault_ struct {
	WithDefault *Expression_WithDefault `protobuf:"bytes,4,opt,name=with_default,json=withDefault,proto3,oneof"`
}

type GetMetricsExpressionRequest 

type GetMetricsExpressionRequest struct {
	Expression *Expression            `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	From       *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To         *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	BucketSize *durationpb.Duration   `protobuf:"bytes,4,opt,name=bucket_size,json=bucketSize,proto3" json:"bucket_size,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricsExpressionRequest) Descriptor deprecated 

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

Deprecated: Use GetMetricsExpressionRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsExpressionRequest) GetBucketSize 

func (x *GetMetricsExpressionRequest) GetBucketSize() *durationpb.Duration

func (*GetMetricsExpressionRequest) GetExpression 

func (x *GetMetricsExpressionRequest) GetExpression() *Expression

func (*GetMetricsExpressionRequest) GetFrom 

func (x *GetMetricsExpressionRequest) GetFrom() *timestamppb.Timestamp

func (*GetMetricsExpressionRequest) GetTo 

func (x *GetMetricsExpressionRequest) GetTo() *timestamppb.Timestamp

func (*GetMetricsExpressionRequest) ProtoMessage 

func (*GetMetricsExpressionRequest) ProtoMessage()

func (*GetMetricsExpressionRequest) ProtoReflect 

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

func (*GetMetricsExpressionRequest) Reset 

func (x *GetMetricsExpressionRequest) Reset()

func (*GetMetricsExpressionRequest) String 

func (x *GetMetricsExpressionRequest) String() string

type GetMetricsExpressionResponse 

type GetMetricsExpressionResponse struct {
	Metrics []*Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricsExpressionResponse) Descriptor deprecated 

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

Deprecated: Use GetMetricsExpressionResponse.ProtoReflect.Descriptor instead.

func (*GetMetricsExpressionResponse) GetMetrics 

func (x *GetMetricsExpressionResponse) GetMetrics() []*Metric

func (*GetMetricsExpressionResponse) ProtoMessage 

func (*GetMetricsExpressionResponse) ProtoMessage()

func (*GetMetricsExpressionResponse) ProtoReflect 

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

func (*GetMetricsExpressionResponse) Reset 

func (x *GetMetricsExpressionResponse) Reset()

func (*GetMetricsExpressionResponse) String 

func (x *GetMetricsExpressionResponse) String() string

type GetMetricsManyRequest 

type GetMetricsManyRequest struct {
	Tags        []*Tags                `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	From        *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To          *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	Aggregation *Aggregation           `protobuf:"bytes,4,opt,name=aggregation,proto3" json:"aggregation,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricsManyRequest) Descriptor deprecated 

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

Deprecated: Use GetMetricsManyRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsManyRequest) GetAggregation 

func (x *GetMetricsManyRequest) GetAggregation() *Aggregation

func (*GetMetricsManyRequest) GetFrom 

func (x *GetMetricsManyRequest) GetFrom() *timestamppb.Timestamp

func (*GetMetricsManyRequest) GetTags 

func (x *GetMetricsManyRequest) GetTags() []*Tags

func (*GetMetricsManyRequest) GetTo 

func (x *GetMetricsManyRequest) GetTo() *timestamppb.Timestamp

func (*GetMetricsManyRequest) ProtoMessage 

func (*GetMetricsManyRequest) ProtoMessage()

func (*GetMetricsManyRequest) ProtoReflect 

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

func (*GetMetricsManyRequest) Reset 

func (x *GetMetricsManyRequest) Reset()

func (*GetMetricsManyRequest) String 

func (x *GetMetricsManyRequest) String() string

type GetMetricsManyResponse 

type GetMetricsManyResponse struct {
	Metrics []*MetricFull `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricsManyResponse) Descriptor deprecated 

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

Deprecated: Use GetMetricsManyResponse.ProtoReflect.Descriptor instead.

func (*GetMetricsManyResponse) GetMetrics 

func (x *GetMetricsManyResponse) GetMetrics() []*MetricFull

func (*GetMetricsManyResponse) ProtoMessage 

func (*GetMetricsManyResponse) ProtoMessage()

func (*GetMetricsManyResponse) ProtoReflect 

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

func (*GetMetricsManyResponse) Reset 

func (x *GetMetricsManyResponse) Reset()

func (*GetMetricsManyResponse) String 

func (x *GetMetricsManyResponse) String() string

type GetMetricsRequest 

type GetMetricsRequest struct {
	Tags        *Tags                  `protobuf:"bytes,1,opt,name=tags,proto3" json:"tags,omitempty"`
	From        *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To          *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	Aggregation *Aggregation           `protobuf:"bytes,4,opt,name=aggregation,proto3" json:"aggregation,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricsRequest) Descriptor deprecated 

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

Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsRequest) GetAggregation 

func (x *GetMetricsRequest) GetAggregation() *Aggregation

func (*GetMetricsRequest) GetFrom 

func (x *GetMetricsRequest) GetFrom() *timestamppb.Timestamp

func (*GetMetricsRequest) GetTags 

func (x *GetMetricsRequest) GetTags() *Tags

func (*GetMetricsRequest) GetTo 

func (x *GetMetricsRequest) GetTo() *timestamppb.Timestamp

func (*GetMetricsRequest) ProtoMessage 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) ProtoReflect 

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

func (*GetMetricsRequest) Reset 

func (x *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String 

func (x *GetMetricsRequest) String() string

type GetMetricsResponse 

type GetMetricsResponse struct {
	Metrics []*Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricsResponse) Descriptor deprecated 

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

Deprecated: Use GetMetricsResponse.ProtoReflect.Descriptor instead.

func (*GetMetricsResponse) GetMetrics 

func (x *GetMetricsResponse) GetMetrics() []*Metric

func (*GetMetricsResponse) ProtoMessage 

func (*GetMetricsResponse) ProtoMessage()

func (*GetMetricsResponse) ProtoReflect 

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

func (*GetMetricsResponse) Reset 

func (x *GetMetricsResponse) Reset()

func (*GetMetricsResponse) String 

func (x *GetMetricsResponse) String() string

type Keys 

type Keys struct {
	Project     bool   `protobuf:"varint,1,opt,name=project,proto3" json:"project,omitempty"`
	Environment bool   `protobuf:"varint,2,opt,name=environment,proto3" json:"environment,omitempty"`
	Capsule     bool   `protobuf:"varint,3,opt,name=capsule,proto3" json:"capsule,omitempty"`
	MetricName  bool   `protobuf:"varint,4,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	Cluster     string `protobuf:"bytes,6,opt,name=cluster,proto3" json:"cluster,omitempty"`
	All         bool   `protobuf:"varint,5,opt,name=all,proto3" json:"all,omitempty"`
	// contains filtered or unexported fields
}

func (*Keys) Descriptor deprecated 

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

Deprecated: Use Keys.ProtoReflect.Descriptor instead.

func (*Keys) GetAll 

func (x *Keys) GetAll() bool

func (*Keys) GetCapsule 

func (x *Keys) GetCapsule() bool

func (*Keys) GetCluster 

func (x *Keys) GetCluster() string

func (*Keys) GetEnvironment 

func (x *Keys) GetEnvironment() bool

func (*Keys) GetMetricName 

func (x *Keys) GetMetricName() bool

func (*Keys) GetProject 

func (x *Keys) GetProject() bool

func (*Keys) ProtoMessage 

func (*Keys) ProtoMessage()

func (*Keys) ProtoReflect 

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

func (*Keys) Reset 

func (x *Keys) Reset()

func (*Keys) String 

func (x *Keys) String() string

type Metric 

type Metric struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,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 (*Metric) Descriptor deprecated 

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetTimestamp 

func (x *Metric) GetTimestamp() *timestamppb.Timestamp

func (*Metric) GetValue 

func (x *Metric) GetValue() float64

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect 

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

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

type MetricFull 

type MetricFull struct {
	Metric *Metric `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Tags   *Tags   `protobuf:"bytes,2,opt,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricFull) Descriptor deprecated 

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

Deprecated: Use MetricFull.ProtoReflect.Descriptor instead.

func (*MetricFull) GetMetric 

func (x *MetricFull) GetMetric() *Metric

func (*MetricFull) GetTags 

func (x *MetricFull) GetTags() *Tags

func (*MetricFull) ProtoMessage 

func (*MetricFull) ProtoMessage()

func (*MetricFull) ProtoReflect 

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

func (*MetricFull) Reset 

func (x *MetricFull) Reset()

func (*MetricFull) String 

func (x *MetricFull) String() string

type ServiceClient 

type ServiceClient interface {
	// Retrieve metrics. metric_type is mandatory, while the rest of the fields
	// in the tags are optional. If project, env or capsule is not
	// specified, they will be treated as wildcards.
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)
	// Retrive metrics for multiple sets of tags at a time. Metrics within the
	// same set of tags will be in ascending order of timestamp.
	GetMetricsMany(ctx context.Context, in *GetMetricsManyRequest, opts ...grpc.CallOption) (*GetMetricsManyResponse, error)
	GetMetricsExpression(ctx context.Context, in *GetMetricsExpressionRequest, opts ...grpc.CallOption) (*GetMetricsExpressionResponse, error)
}

ServiceClient is the client API for Service 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 NewServiceClient 

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer 

type ServiceServer interface {
	// Retrieve metrics. metric_type is mandatory, while the rest of the fields
	// in the tags are optional. If project, env or capsule is not
	// specified, they will be treated as wildcards.
	GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
	// Retrive metrics for multiple sets of tags at a time. Metrics within the
	// same set of tags will be in ascending order of timestamp.
	GetMetricsMany(context.Context, *GetMetricsManyRequest) (*GetMetricsManyResponse, error)
	GetMetricsExpression(context.Context, *GetMetricsExpressionRequest) (*GetMetricsExpressionResponse, error)
	// contains filtered or unexported methods
}

ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility

type Tags 

type Tags struct {
	Project     string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Environment string `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	Capsule     string `protobuf:"bytes,3,opt,name=capsule,proto3" json:"capsule,omitempty"`
	MetricName  string `protobuf:"bytes,4,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	Cluster     string `protobuf:"bytes,5,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*Tags) Descriptor deprecated 

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

Deprecated: Use Tags.ProtoReflect.Descriptor instead.

func (*Tags) GetCapsule 

func (x *Tags) GetCapsule() string

func (*Tags) GetCluster 

func (x *Tags) GetCluster() string

func (*Tags) GetEnvironment 

func (x *Tags) GetEnvironment() string

func (*Tags) GetMetricName 

func (x *Tags) GetMetricName() string

func (*Tags) GetProject 

func (x *Tags) GetProject() string

func (*Tags) ProtoMessage 

func (*Tags) ProtoMessage()

func (*Tags) ProtoReflect 

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

func (*Tags) Reset 

func (x *Tags) Reset()

func (*Tags) String 

func (x *Tags) String() string

type UnimplementedServiceServer 

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceServer) GetMetrics 

func (UnimplementedServiceServer) GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)

func (UnimplementedServiceServer) GetMetricsExpression 

func (UnimplementedServiceServer) GetMetricsExpression(context.Context, *GetMetricsExpressionRequest) (*GetMetricsExpressionResponse, error)

func (UnimplementedServiceServer) GetMetricsMany 

func (UnimplementedServiceServer) GetMetricsMany(context.Context, *GetMetricsManyRequest) (*GetMetricsManyResponse, error)

type UnsafeServiceServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis

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.