metricpb

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Mar 18, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MetricPlugin_GetSupportedResources_FullMethodName = "/omniview.sdk.metric.v1.MetricPlugin/GetSupportedResources"
	MetricPlugin_Query_FullMethodName                 = "/omniview.sdk.metric.v1.MetricPlugin/Query"
	MetricPlugin_StreamMetrics_FullMethodName         = "/omniview.sdk.metric.v1.MetricPlugin/StreamMetrics"
)

Variables

View Source 
var (
	MetricUnit_name = map[int32]string{
		0:  "METRIC_UNIT_NONE",
		1:  "METRIC_UNIT_BYTES",
		2:  "METRIC_UNIT_KB",
		3:  "METRIC_UNIT_MB",
		4:  "METRIC_UNIT_GB",
		5:  "METRIC_UNIT_PERCENTAGE",
		6:  "METRIC_UNIT_MILLISECONDS",
		7:  "METRIC_UNIT_SECONDS",
		8:  "METRIC_UNIT_COUNT",
		9:  "METRIC_UNIT_OPS_PER_SEC",
		10: "METRIC_UNIT_BYTES_PER_SEC",
		11: "METRIC_UNIT_MILLICORES",
		12: "METRIC_UNIT_CORES",
	}
	MetricUnit_value = map[string]int32{
		"METRIC_UNIT_NONE":          0,
		"METRIC_UNIT_BYTES":         1,
		"METRIC_UNIT_KB":            2,
		"METRIC_UNIT_MB":            3,
		"METRIC_UNIT_GB":            4,
		"METRIC_UNIT_PERCENTAGE":    5,
		"METRIC_UNIT_MILLISECONDS":  6,
		"METRIC_UNIT_SECONDS":       7,
		"METRIC_UNIT_COUNT":         8,
		"METRIC_UNIT_OPS_PER_SEC":   9,
		"METRIC_UNIT_BYTES_PER_SEC": 10,
		"METRIC_UNIT_MILLICORES":    11,
		"METRIC_UNIT_CORES":         12,
	}
)

Enum value maps for MetricUnit.

View Source 
var (
	MetricShape_name = map[int32]string{
		0: "METRIC_SHAPE_CURRENT",
		1: "METRIC_SHAPE_TIMESERIES",
		2: "METRIC_SHAPE_AGGREGATE",
	}
	MetricShape_value = map[string]int32{
		"METRIC_SHAPE_CURRENT":    0,
		"METRIC_SHAPE_TIMESERIES": 1,
		"METRIC_SHAPE_AGGREGATE":  2,
	}
)

Enum value maps for MetricShape.

View Source 
var (
	MetricStreamCommand_name = map[int32]string{
		0: "METRIC_STREAM_COMMAND_SUBSCRIBE",
		1: "METRIC_STREAM_COMMAND_UNSUBSCRIBE",
		2: "METRIC_STREAM_COMMAND_CLOSE",
	}
	MetricStreamCommand_value = map[string]int32{
		"METRIC_STREAM_COMMAND_SUBSCRIBE":   0,
		"METRIC_STREAM_COMMAND_UNSUBSCRIBE": 1,
		"METRIC_STREAM_COMMAND_CLOSE":       2,
	}
)

Enum value maps for MetricStreamCommand.

View Source 
var File_proto_v1_metric_metric_proto protoreflect.FileDescriptor
View Source 
var MetricPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "omniview.sdk.metric.v1.MetricPlugin",
	HandlerType: (*MetricPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSupportedResources",
			Handler:    _MetricPlugin_GetSupportedResources_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _MetricPlugin_Query_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamMetrics",
			Handler:       _MetricPlugin_StreamMetrics_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/v1/metric/metric.proto",
}

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

Functions

func RegisterMetricPluginServer 

func RegisterMetricPluginServer(s grpc.ServiceRegistrar, srv MetricPluginServer)

Types

type AggregateValue 

type AggregateValue struct {
	MetricId string               `protobuf:"bytes,1,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"`
	Min      float64              `protobuf:"fixed64,2,opt,name=min,proto3" json:"min,omitempty"`
	Max      float64              `protobuf:"fixed64,3,opt,name=max,proto3" json:"max,omitempty"`
	Avg      float64              `protobuf:"fixed64,4,opt,name=avg,proto3" json:"avg,omitempty"`
	Sum      float64              `protobuf:"fixed64,5,opt,name=sum,proto3" json:"sum,omitempty"`
	P50      float64              `protobuf:"fixed64,6,opt,name=p50,proto3" json:"p50,omitempty"`
	P90      float64              `protobuf:"fixed64,7,opt,name=p90,proto3" json:"p90,omitempty"`
	P99      float64              `protobuf:"fixed64,8,opt,name=p99,proto3" json:"p99,omitempty"`
	Count    int64                `protobuf:"varint,9,opt,name=count,proto3" json:"count,omitempty"`
	Window   *durationpb.Duration `protobuf:"bytes,10,opt,name=window,proto3" json:"window,omitempty"`
	Labels   map[string]string    `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AggregateValue) Descriptor deprecated 

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

Deprecated: Use AggregateValue.ProtoReflect.Descriptor instead.

func (*AggregateValue) GetAvg 

func (x *AggregateValue) GetAvg() float64

func (*AggregateValue) GetCount 

func (x *AggregateValue) GetCount() int64

func (*AggregateValue) GetLabels 

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

func (*AggregateValue) GetMax 

func (x *AggregateValue) GetMax() float64

func (*AggregateValue) GetMetricId 

func (x *AggregateValue) GetMetricId() string

func (*AggregateValue) GetMin 

func (x *AggregateValue) GetMin() float64

func (*AggregateValue) GetP50 

func (x *AggregateValue) GetP50() float64

func (*AggregateValue) GetP90 

func (x *AggregateValue) GetP90() float64

func (*AggregateValue) GetP99 

func (x *AggregateValue) GetP99() float64

func (*AggregateValue) GetSum 

func (x *AggregateValue) GetSum() float64

func (*AggregateValue) GetWindow 

func (x *AggregateValue) GetWindow() *durationpb.Duration

func (*AggregateValue) ProtoMessage 

func (*AggregateValue) ProtoMessage()

func (*AggregateValue) ProtoReflect 

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

func (*AggregateValue) Reset 

func (x *AggregateValue) Reset()

func (*AggregateValue) String 

func (x *AggregateValue) String() string

type CurrentValue 

type CurrentValue struct {
	MetricId  string                 `protobuf:"bytes,1,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"`
	Value     float64                `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Labels    map[string]string      `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CurrentValue) Descriptor deprecated 

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

Deprecated: Use CurrentValue.ProtoReflect.Descriptor instead.

func (*CurrentValue) GetLabels 

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

func (*CurrentValue) GetMetricId 

func (x *CurrentValue) GetMetricId() string

func (*CurrentValue) GetTimestamp 

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

func (*CurrentValue) GetValue 

func (x *CurrentValue) GetValue() float64

func (*CurrentValue) ProtoMessage 

func (*CurrentValue) ProtoMessage()

func (*CurrentValue) ProtoReflect 

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

func (*CurrentValue) Reset 

func (x *CurrentValue) Reset()

func (*CurrentValue) String 

func (x *CurrentValue) String() string

type DataPoint 

type DataPoint 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"`
	Labels    map[string]string      `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DataPoint) Descriptor deprecated 

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

Deprecated: Use DataPoint.ProtoReflect.Descriptor instead.

func (*DataPoint) GetLabels 

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

func (*DataPoint) GetTimestamp 

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

func (*DataPoint) GetValue 

func (x *DataPoint) GetValue() float64

func (*DataPoint) ProtoMessage 

func (*DataPoint) ProtoMessage()

func (*DataPoint) ProtoReflect 

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

func (*DataPoint) Reset 

func (x *DataPoint) Reset()

func (*DataPoint) String 

func (x *DataPoint) String() string

type GetSupportedMetricResourcesResponse 

type GetSupportedMetricResourcesResponse struct {
	Provider *MetricProviderInfo `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
	Handlers []*MetricHandler    `protobuf:"bytes,2,rep,name=handlers,proto3" json:"handlers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSupportedMetricResourcesResponse) Descriptor deprecated 

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

Deprecated: Use GetSupportedMetricResourcesResponse.ProtoReflect.Descriptor instead.

func (*GetSupportedMetricResourcesResponse) GetHandlers 

func (x *GetSupportedMetricResourcesResponse) GetHandlers() []*MetricHandler

func (*GetSupportedMetricResourcesResponse) GetProvider 

func (x *GetSupportedMetricResourcesResponse) GetProvider() *MetricProviderInfo

func (*GetSupportedMetricResourcesResponse) ProtoMessage 

func (*GetSupportedMetricResourcesResponse) ProtoMessage()

func (*GetSupportedMetricResourcesResponse) ProtoReflect 

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

func (*GetSupportedMetricResourcesResponse) Reset 

func (x *GetSupportedMetricResourcesResponse) Reset()

func (*GetSupportedMetricResourcesResponse) String 

func (x *GetSupportedMetricResourcesResponse) String() string

type MetricColorRange 

type MetricColorRange struct {
	Min   float64 `protobuf:"fixed64,1,opt,name=min,proto3" json:"min,omitempty"`
	Max   float64 `protobuf:"fixed64,2,opt,name=max,proto3" json:"max,omitempty"`
	Color string  `protobuf:"bytes,3,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricColorRange) Descriptor deprecated 

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

Deprecated: Use MetricColorRange.ProtoReflect.Descriptor instead.

func (*MetricColorRange) GetColor 

func (x *MetricColorRange) GetColor() string

func (*MetricColorRange) GetMax 

func (x *MetricColorRange) GetMax() float64

func (*MetricColorRange) GetMin 

func (x *MetricColorRange) GetMin() float64

func (*MetricColorRange) ProtoMessage 

func (*MetricColorRange) ProtoMessage()

func (*MetricColorRange) ProtoReflect 

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

func (*MetricColorRange) Reset 

func (x *MetricColorRange) Reset()

func (*MetricColorRange) String 

func (x *MetricColorRange) String() string

type MetricDescriptor 

type MetricDescriptor struct {
	Id              string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name            string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Unit            MetricUnit          `protobuf:"varint,3,opt,name=unit,proto3,enum=omniview.sdk.metric.v1.MetricUnit" json:"unit,omitempty"`
	Icon            string              `protobuf:"bytes,4,opt,name=icon,proto3" json:"icon,omitempty"`
	ColorRanges     []*MetricColorRange `protobuf:"bytes,5,rep,name=color_ranges,json=colorRanges,proto3" json:"color_ranges,omitempty"`
	FormatString    string              `protobuf:"bytes,6,opt,name=format_string,json=formatString,proto3" json:"format_string,omitempty"`
	SupportedShapes []MetricShape       `` /* 154-byte string literal not displayed */
	ChartGroup      string              `protobuf:"bytes,8,opt,name=chart_group,json=chartGroup,proto3" json:"chart_group,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricDescriptor) Descriptor deprecated 

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

Deprecated: Use MetricDescriptor.ProtoReflect.Descriptor instead.

func (*MetricDescriptor) GetChartGroup 

func (x *MetricDescriptor) GetChartGroup() string

func (*MetricDescriptor) GetColorRanges 

func (x *MetricDescriptor) GetColorRanges() []*MetricColorRange

func (*MetricDescriptor) GetFormatString 

func (x *MetricDescriptor) GetFormatString() string

func (*MetricDescriptor) GetIcon 

func (x *MetricDescriptor) GetIcon() string

func (*MetricDescriptor) GetId 

func (x *MetricDescriptor) GetId() string

func (*MetricDescriptor) GetName 

func (x *MetricDescriptor) GetName() string

func (*MetricDescriptor) GetSupportedShapes 

func (x *MetricDescriptor) GetSupportedShapes() []MetricShape

func (*MetricDescriptor) GetUnit 

func (x *MetricDescriptor) GetUnit() MetricUnit

func (*MetricDescriptor) ProtoMessage 

func (*MetricDescriptor) ProtoMessage()

func (*MetricDescriptor) ProtoReflect 

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

func (*MetricDescriptor) Reset 

func (x *MetricDescriptor) Reset()

func (*MetricDescriptor) String 

func (x *MetricDescriptor) String() string

type MetricHandler 

type MetricHandler struct {
	Resource string              `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Metrics  []*MetricDescriptor `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricHandler) Descriptor deprecated 

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

Deprecated: Use MetricHandler.ProtoReflect.Descriptor instead.

func (*MetricHandler) GetMetrics 

func (x *MetricHandler) GetMetrics() []*MetricDescriptor

func (*MetricHandler) GetResource 

func (x *MetricHandler) GetResource() string

func (*MetricHandler) ProtoMessage 

func (*MetricHandler) ProtoMessage()

func (*MetricHandler) ProtoReflect 

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

func (*MetricHandler) Reset 

func (x *MetricHandler) Reset()

func (*MetricHandler) String 

func (x *MetricHandler) String() string

type MetricPluginClient 

type MetricPluginClient interface {
	GetSupportedResources(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSupportedMetricResourcesResponse, error)
	Query(ctx context.Context, in *QueryMetricsRequest, opts ...grpc.CallOption) (*QueryMetricsResponse, error)
	StreamMetrics(ctx context.Context, opts ...grpc.CallOption) (MetricPlugin_StreamMetricsClient, error)
}

MetricPluginClient is the client API for MetricPlugin 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 NewMetricPluginClient 

func NewMetricPluginClient(cc grpc.ClientConnInterface) MetricPluginClient

type MetricPluginServer 

type MetricPluginServer interface {
	GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedMetricResourcesResponse, error)
	Query(context.Context, *QueryMetricsRequest) (*QueryMetricsResponse, error)
	StreamMetrics(MetricPlugin_StreamMetricsServer) error
}

MetricPluginServer is the server API for MetricPlugin service. All implementations should embed UnimplementedMetricPluginServer for forward compatibility

type MetricPlugin_StreamMetricsClient 

type MetricPlugin_StreamMetricsClient interface {
	Send(*MetricStreamInput) error
	Recv() (*MetricStreamOutput, error)
	grpc.ClientStream
}

type MetricPlugin_StreamMetricsServer 

type MetricPlugin_StreamMetricsServer interface {
	Send(*MetricStreamOutput) error
	Recv() (*MetricStreamInput, error)
	grpc.ServerStream
}

type MetricProviderInfo 

type MetricProviderInfo struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Icon        string `protobuf:"bytes,3,opt,name=icon,proto3" json:"icon,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricProviderInfo) Descriptor deprecated 

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

Deprecated: Use MetricProviderInfo.ProtoReflect.Descriptor instead.

func (*MetricProviderInfo) GetDescription 

func (x *MetricProviderInfo) GetDescription() string

func (*MetricProviderInfo) GetIcon 

func (x *MetricProviderInfo) GetIcon() string

func (*MetricProviderInfo) GetId 

func (x *MetricProviderInfo) GetId() string

func (*MetricProviderInfo) GetName 

func (x *MetricProviderInfo) GetName() string

func (*MetricProviderInfo) ProtoMessage 

func (*MetricProviderInfo) ProtoMessage()

func (*MetricProviderInfo) ProtoReflect 

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

func (*MetricProviderInfo) Reset 

func (x *MetricProviderInfo) Reset()

func (*MetricProviderInfo) String 

func (x *MetricProviderInfo) String() string

type MetricResult 

type MetricResult struct {

	// Types that are valid to be assigned to Result:
	//
	//	*MetricResult_TimeSeries
	//	*MetricResult_CurrentValue
	//	*MetricResult_AggregateValue
	Result isMetricResult_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*MetricResult) Descriptor deprecated 

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

Deprecated: Use MetricResult.ProtoReflect.Descriptor instead.

func (*MetricResult) GetAggregateValue 

func (x *MetricResult) GetAggregateValue() *AggregateValue

func (*MetricResult) GetCurrentValue 

func (x *MetricResult) GetCurrentValue() *CurrentValue

func (*MetricResult) GetResult 

func (x *MetricResult) GetResult() isMetricResult_Result

func (*MetricResult) GetTimeSeries 

func (x *MetricResult) GetTimeSeries() *TimeSeries

func (*MetricResult) ProtoMessage 

func (*MetricResult) ProtoMessage()

func (*MetricResult) ProtoReflect 

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

func (*MetricResult) Reset 

func (x *MetricResult) Reset()

func (*MetricResult) String 

func (x *MetricResult) String() string

type MetricResult_AggregateValue 

type MetricResult_AggregateValue struct {
	AggregateValue *AggregateValue `protobuf:"bytes,3,opt,name=aggregate_value,json=aggregateValue,proto3,oneof"`
}

type MetricResult_CurrentValue 

type MetricResult_CurrentValue struct {
	CurrentValue *CurrentValue `protobuf:"bytes,2,opt,name=current_value,json=currentValue,proto3,oneof"`
}

type MetricResult_TimeSeries 

type MetricResult_TimeSeries struct {
	TimeSeries *TimeSeries `protobuf:"bytes,1,opt,name=time_series,json=timeSeries,proto3,oneof"`
}

type MetricShape 

type MetricShape int32
const (
	MetricShape_METRIC_SHAPE_CURRENT    MetricShape = 0
	MetricShape_METRIC_SHAPE_TIMESERIES MetricShape = 1
	MetricShape_METRIC_SHAPE_AGGREGATE  MetricShape = 2
)

func (MetricShape) Descriptor 

func (MetricShape) Descriptor() protoreflect.EnumDescriptor

func (MetricShape) Enum 

func (x MetricShape) Enum() *MetricShape

func (MetricShape) EnumDescriptor deprecated 

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

Deprecated: Use MetricShape.Descriptor instead.

func (MetricShape) Number 

func (x MetricShape) Number() protoreflect.EnumNumber

func (MetricShape) String 

func (x MetricShape) String() string

func (MetricShape) Type 

func (MetricShape) Type() protoreflect.EnumType

type MetricStreamCommand 

type MetricStreamCommand int32
const (
	MetricStreamCommand_METRIC_STREAM_COMMAND_SUBSCRIBE   MetricStreamCommand = 0
	MetricStreamCommand_METRIC_STREAM_COMMAND_UNSUBSCRIBE MetricStreamCommand = 1
	MetricStreamCommand_METRIC_STREAM_COMMAND_CLOSE       MetricStreamCommand = 2
)

func (MetricStreamCommand) Descriptor 

func (MetricStreamCommand) Descriptor() protoreflect.EnumDescriptor

func (MetricStreamCommand) Enum 

func (x MetricStreamCommand) Enum() *MetricStreamCommand

func (MetricStreamCommand) EnumDescriptor deprecated 

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

Deprecated: Use MetricStreamCommand.Descriptor instead.

func (MetricStreamCommand) Number 

func (x MetricStreamCommand) Number() protoreflect.EnumNumber

func (MetricStreamCommand) String 

func (x MetricStreamCommand) String() string

func (MetricStreamCommand) Type 

func (MetricStreamCommand) Type() protoreflect.EnumType

type MetricStreamInput 

type MetricStreamInput struct {
	SubscriptionId    string               `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	Command           MetricStreamCommand  `protobuf:"varint,2,opt,name=command,proto3,enum=omniview.sdk.metric.v1.MetricStreamCommand" json:"command,omitempty"`
	ResourceKey       string               `protobuf:"bytes,3,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceId        string               `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceNamespace string               `protobuf:"bytes,5,opt,name=resource_namespace,json=resourceNamespace,proto3" json:"resource_namespace,omitempty"`
	ResourceData      *structpb.Struct     `protobuf:"bytes,6,opt,name=resource_data,json=resourceData,proto3" json:"resource_data,omitempty"`
	MetricIds         []string             `protobuf:"bytes,7,rep,name=metric_ids,json=metricIds,proto3" json:"metric_ids,omitempty"`
	Interval          *durationpb.Duration `protobuf:"bytes,8,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricStreamInput) Descriptor deprecated 

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

Deprecated: Use MetricStreamInput.ProtoReflect.Descriptor instead.

func (*MetricStreamInput) GetCommand 

func (x *MetricStreamInput) GetCommand() MetricStreamCommand

func (*MetricStreamInput) GetInterval 

func (x *MetricStreamInput) GetInterval() *durationpb.Duration

func (*MetricStreamInput) GetMetricIds 

func (x *MetricStreamInput) GetMetricIds() []string

func (*MetricStreamInput) GetResourceData 

func (x *MetricStreamInput) GetResourceData() *structpb.Struct

func (*MetricStreamInput) GetResourceId 

func (x *MetricStreamInput) GetResourceId() string

func (*MetricStreamInput) GetResourceKey 

func (x *MetricStreamInput) GetResourceKey() string

func (*MetricStreamInput) GetResourceNamespace 

func (x *MetricStreamInput) GetResourceNamespace() string

func (*MetricStreamInput) GetSubscriptionId 

func (x *MetricStreamInput) GetSubscriptionId() string

func (*MetricStreamInput) ProtoMessage 

func (*MetricStreamInput) ProtoMessage()

func (*MetricStreamInput) ProtoReflect 

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

func (*MetricStreamInput) Reset 

func (x *MetricStreamInput) Reset()

func (*MetricStreamInput) String 

func (x *MetricStreamInput) String() string

type MetricStreamOutput 

type MetricStreamOutput struct {
	SubscriptionId string                 `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	Results        []*MetricResult        `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	Timestamp      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Error          string                 `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricStreamOutput) Descriptor deprecated 

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

Deprecated: Use MetricStreamOutput.ProtoReflect.Descriptor instead.

func (*MetricStreamOutput) GetError 

func (x *MetricStreamOutput) GetError() string

func (*MetricStreamOutput) GetResults 

func (x *MetricStreamOutput) GetResults() []*MetricResult

func (*MetricStreamOutput) GetSubscriptionId 

func (x *MetricStreamOutput) GetSubscriptionId() string

func (*MetricStreamOutput) GetTimestamp 

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

func (*MetricStreamOutput) ProtoMessage 

func (*MetricStreamOutput) ProtoMessage()

func (*MetricStreamOutput) ProtoReflect 

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

func (*MetricStreamOutput) Reset 

func (x *MetricStreamOutput) Reset()

func (*MetricStreamOutput) String 

func (x *MetricStreamOutput) String() string

type MetricUnit 

type MetricUnit int32
const (
	MetricUnit_METRIC_UNIT_NONE          MetricUnit = 0
	MetricUnit_METRIC_UNIT_BYTES         MetricUnit = 1
	MetricUnit_METRIC_UNIT_KB            MetricUnit = 2
	MetricUnit_METRIC_UNIT_MB            MetricUnit = 3
	MetricUnit_METRIC_UNIT_GB            MetricUnit = 4
	MetricUnit_METRIC_UNIT_PERCENTAGE    MetricUnit = 5
	MetricUnit_METRIC_UNIT_MILLISECONDS  MetricUnit = 6
	MetricUnit_METRIC_UNIT_SECONDS       MetricUnit = 7
	MetricUnit_METRIC_UNIT_COUNT         MetricUnit = 8
	MetricUnit_METRIC_UNIT_OPS_PER_SEC   MetricUnit = 9
	MetricUnit_METRIC_UNIT_BYTES_PER_SEC MetricUnit = 10
	MetricUnit_METRIC_UNIT_MILLICORES    MetricUnit = 11
	MetricUnit_METRIC_UNIT_CORES         MetricUnit = 12
)

func (MetricUnit) Descriptor 

func (MetricUnit) Descriptor() protoreflect.EnumDescriptor

func (MetricUnit) Enum 

func (x MetricUnit) Enum() *MetricUnit

func (MetricUnit) EnumDescriptor deprecated 

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

Deprecated: Use MetricUnit.Descriptor instead.

func (MetricUnit) Number 

func (x MetricUnit) Number() protoreflect.EnumNumber

func (MetricUnit) String 

func (x MetricUnit) String() string

func (MetricUnit) Type 

func (MetricUnit) Type() protoreflect.EnumType

type QueryMetricsRequest 

type QueryMetricsRequest struct {
	ResourceKey       string                 `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceId        string                 `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceNamespace string                 `protobuf:"bytes,3,opt,name=resource_namespace,json=resourceNamespace,proto3" json:"resource_namespace,omitempty"`
	ResourceData      *structpb.Struct       `protobuf:"bytes,4,opt,name=resource_data,json=resourceData,proto3" json:"resource_data,omitempty"`
	MetricIds         []string               `protobuf:"bytes,5,rep,name=metric_ids,json=metricIds,proto3" json:"metric_ids,omitempty"`
	Shape             MetricShape            `protobuf:"varint,6,opt,name=shape,proto3,enum=omniview.sdk.metric.v1.MetricShape" json:"shape,omitempty"`
	StartTime         *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime           *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Step              *durationpb.Duration   `protobuf:"bytes,9,opt,name=step,proto3" json:"step,omitempty"`
	Params            map[string]string      `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryMetricsRequest) Descriptor deprecated 

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

Deprecated: Use QueryMetricsRequest.ProtoReflect.Descriptor instead.

func (*QueryMetricsRequest) GetEndTime 

func (x *QueryMetricsRequest) GetEndTime() *timestamppb.Timestamp

func (*QueryMetricsRequest) GetMetricIds 

func (x *QueryMetricsRequest) GetMetricIds() []string

func (*QueryMetricsRequest) GetParams 

func (x *QueryMetricsRequest) GetParams() map[string]string

func (*QueryMetricsRequest) GetResourceData 

func (x *QueryMetricsRequest) GetResourceData() *structpb.Struct

func (*QueryMetricsRequest) GetResourceId 

func (x *QueryMetricsRequest) GetResourceId() string

func (*QueryMetricsRequest) GetResourceKey 

func (x *QueryMetricsRequest) GetResourceKey() string

func (*QueryMetricsRequest) GetResourceNamespace 

func (x *QueryMetricsRequest) GetResourceNamespace() string

func (*QueryMetricsRequest) GetShape 

func (x *QueryMetricsRequest) GetShape() MetricShape

func (*QueryMetricsRequest) GetStartTime 

func (x *QueryMetricsRequest) GetStartTime() *timestamppb.Timestamp

func (*QueryMetricsRequest) GetStep 

func (x *QueryMetricsRequest) GetStep() *durationpb.Duration

func (*QueryMetricsRequest) ProtoMessage 

func (*QueryMetricsRequest) ProtoMessage()

func (*QueryMetricsRequest) ProtoReflect 

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

func (*QueryMetricsRequest) Reset 

func (x *QueryMetricsRequest) Reset()

func (*QueryMetricsRequest) String 

func (x *QueryMetricsRequest) String() string

type QueryMetricsResponse 

type QueryMetricsResponse struct {
	Success bool            `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Results []*MetricResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	Error   string          `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMetricsResponse) Descriptor deprecated 

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

Deprecated: Use QueryMetricsResponse.ProtoReflect.Descriptor instead.

func (*QueryMetricsResponse) GetError 

func (x *QueryMetricsResponse) GetError() string

func (*QueryMetricsResponse) GetResults 

func (x *QueryMetricsResponse) GetResults() []*MetricResult

func (*QueryMetricsResponse) GetSuccess 

func (x *QueryMetricsResponse) GetSuccess() bool

func (*QueryMetricsResponse) ProtoMessage 

func (*QueryMetricsResponse) ProtoMessage()

func (*QueryMetricsResponse) ProtoReflect 

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

func (*QueryMetricsResponse) Reset 

func (x *QueryMetricsResponse) Reset()

func (*QueryMetricsResponse) String 

func (x *QueryMetricsResponse) String() string

type TimeSeries 

type TimeSeries struct {
	MetricId   string            `protobuf:"bytes,1,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"`
	DataPoints []*DataPoint      `protobuf:"bytes,2,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"`
	Labels     map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TimeSeries) Descriptor deprecated 

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

Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.

func (*TimeSeries) GetDataPoints 

func (x *TimeSeries) GetDataPoints() []*DataPoint

func (*TimeSeries) GetLabels 

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

func (*TimeSeries) GetMetricId 

func (x *TimeSeries) GetMetricId() string

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 UnimplementedMetricPluginServer 

type UnimplementedMetricPluginServer struct {
}

UnimplementedMetricPluginServer should be embedded to have forward compatible implementations.

func (UnimplementedMetricPluginServer) GetSupportedResources 

func (UnimplementedMetricPluginServer) GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedMetricResourcesResponse, error)

func (UnimplementedMetricPluginServer) Query 

func (UnimplementedMetricPluginServer) Query(context.Context, *QueryMetricsRequest) (*QueryMetricsResponse, error)

func (UnimplementedMetricPluginServer) StreamMetrics 

func (UnimplementedMetricPluginServer) StreamMetrics(MetricPlugin_StreamMetricsServer) error

type UnsafeMetricPluginServer 

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

UnsafeMetricPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricPluginServer 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.