Documentation ¶
Index ¶
- Variables
- func RegisterGatewayServiceServer(s grpc.ServiceRegistrar, srv GatewayServiceServer)
- type DataNode
- func (*DataNode) Descriptor() ([]byte, []int)deprecated
- func (x *DataNode) GetBytes() []byte
- func (x *DataNode) GetCount() int32
- func (x *DataNode) GetType() int32
- func (x *DataNode) GetValue() float64
- func (*DataNode) ProtoMessage()
- func (x *DataNode) ProtoReflect() protoreflect.Message
- func (x *DataNode) Reset()
- func (x *DataNode) String() string
- type GatewayServiceClient
- type GatewayServiceServer
- type GetControlConfigsRequest
- func (*GetControlConfigsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetControlConfigsRequest) GetAgentId() string
- func (x *GetControlConfigsRequest) GetHeader() *pb.CommonRequestHeader
- func (*GetControlConfigsRequest) ProtoMessage()
- func (x *GetControlConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *GetControlConfigsRequest) Reset()
- func (x *GetControlConfigsRequest) String() string
- type GetControlConfigsResponse
- func (*GetControlConfigsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetControlConfigsResponse) GetHeader() *pb.CommonResponseHeader
- func (*GetControlConfigsResponse) ProtoMessage()
- func (x *GetControlConfigsResponse) ProtoReflect() protoreflect.Message
- func (x *GetControlConfigsResponse) Reset()
- func (x *GetControlConfigsResponse) String() string
- type Point
- func (*Point) Descriptor() ([]byte, []int)deprecated
- func (x *Point) GetMetricName() string
- func (x *Point) GetNumberValues() map[string]float64
- func (x *Point) GetStringValues() map[string]string
- func (x *Point) GetTags() map[string]string
- func (x *Point) GetTimestamp() int64
- func (*Point) ProtoMessage()
- func (x *Point) ProtoReflect() protoreflect.Message
- func (x *Point) Reset()
- func (x *Point) String() string
- type UnimplementedGatewayServiceServer
- func (UnimplementedGatewayServiceServer) GetControlConfigs(context.Context, *GetControlConfigsRequest) (*GetControlConfigsResponse, error)
- func (UnimplementedGatewayServiceServer) Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedGatewayServiceServer) WriteMetricsV1(context.Context, *WriteMetricsRequestV1) (*WriteMetricsResponse, error)
- func (UnimplementedGatewayServiceServer) WriteMetricsV2(context.Context, *WriteMetricsRequestV2) (*WriteMetricsResponse, error)
- func (UnimplementedGatewayServiceServer) WriteMetricsV3(context.Context, *WriteMetricsRequestV3) (*WriteMetricsResponse, error)
- func (UnimplementedGatewayServiceServer) WriteMetricsV4(context.Context, *WriteMetricsRequestV4) (*WriteMetricsResponse, error)
- type UnsafeGatewayServiceServer
- type WriteMetricsRequestV1
- func (*WriteMetricsRequestV1) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV1) GetHeader() *pb.CommonRequestHeader
- func (x *WriteMetricsRequestV1) GetPoint() []*Point
- func (*WriteMetricsRequestV1) ProtoMessage()
- func (x *WriteMetricsRequestV1) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV1) Reset()
- func (x *WriteMetricsRequestV1) String() string
- type WriteMetricsRequestV2
- func (*WriteMetricsRequestV2) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV2) GetBatch() []*WriteMetricsRequestV2_Batch
- func (x *WriteMetricsRequestV2) GetHeader() *pb.CommonRequestHeader
- func (*WriteMetricsRequestV2) ProtoMessage()
- func (x *WriteMetricsRequestV2) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV2) Reset()
- func (x *WriteMetricsRequestV2) String() string
- type WriteMetricsRequestV2_Batch
- func (*WriteMetricsRequestV2_Batch) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV2_Batch) GetHeader() *WriteMetricsRequestV2_BatchHeader
- func (x *WriteMetricsRequestV2_Batch) GetValue() []*WriteMetricsRequestV2_BatchValue
- func (*WriteMetricsRequestV2_Batch) ProtoMessage()
- func (x *WriteMetricsRequestV2_Batch) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV2_Batch) Reset()
- func (x *WriteMetricsRequestV2_Batch) String() string
- type WriteMetricsRequestV2_BatchHeader
- func (*WriteMetricsRequestV2_BatchHeader) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV2_BatchHeader) GetDataKeys() []string
- func (x *WriteMetricsRequestV2_BatchHeader) GetMetricName() string
- func (x *WriteMetricsRequestV2_BatchHeader) GetNumberKeys() []string
- func (x *WriteMetricsRequestV2_BatchHeader) GetStringKeys() []string
- func (x *WriteMetricsRequestV2_BatchHeader) GetTagKeys() []string
- func (*WriteMetricsRequestV2_BatchHeader) ProtoMessage()
- func (x *WriteMetricsRequestV2_BatchHeader) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV2_BatchHeader) Reset()
- func (x *WriteMetricsRequestV2_BatchHeader) String() string
- type WriteMetricsRequestV2_BatchValue
- func (*WriteMetricsRequestV2_BatchValue) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV2_BatchValue) GetDataValues() []*DataNode
- func (x *WriteMetricsRequestV2_BatchValue) GetNumberValues() []float64
- func (x *WriteMetricsRequestV2_BatchValue) GetStringValues() []string
- func (x *WriteMetricsRequestV2_BatchValue) GetTagValues() []string
- func (x *WriteMetricsRequestV2_BatchValue) GetTimestamp() int64
- func (*WriteMetricsRequestV2_BatchValue) ProtoMessage()
- func (x *WriteMetricsRequestV2_BatchValue) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV2_BatchValue) Reset()
- func (x *WriteMetricsRequestV2_BatchValue) String() string
- type WriteMetricsRequestV3
- func (*WriteMetricsRequestV3) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV3) GetBatch() []*WriteMetricsRequestV3_TaskBatch
- func (x *WriteMetricsRequestV3) GetHeader() *pb.CommonRequestHeader
- func (*WriteMetricsRequestV3) ProtoMessage()
- func (x *WriteMetricsRequestV3) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV3) Reset()
- func (x *WriteMetricsRequestV3) String() string
- type WriteMetricsRequestV3_TaskBatch
- func (*WriteMetricsRequestV3_TaskBatch) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV3_TaskBatch) GetBatch() *WriteMetricsRequestV2_Batch
- func (x *WriteMetricsRequestV3_TaskBatch) GetKey() string
- func (x *WriteMetricsRequestV3_TaskBatch) GetRefCollectKey() string
- func (x *WriteMetricsRequestV3_TaskBatch) GetRefTargetKey() string
- func (*WriteMetricsRequestV3_TaskBatch) ProtoMessage()
- func (x *WriteMetricsRequestV3_TaskBatch) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV3_TaskBatch) Reset()
- func (x *WriteMetricsRequestV3_TaskBatch) String() string
- type WriteMetricsRequestV4
- func (*WriteMetricsRequestV4) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV4) GetHeader() *pb.CommonRequestHeader
- func (x *WriteMetricsRequestV4) GetResults() []*WriteMetricsRequestV4_TaskResult
- func (*WriteMetricsRequestV4) ProtoMessage()
- func (x *WriteMetricsRequestV4) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV4) Reset()
- func (x *WriteMetricsRequestV4) String() string
- type WriteMetricsRequestV4_Completeness
- func (*WriteMetricsRequestV4_Completeness) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV4_Completeness) GetExtension() map[string]string
- func (x *WriteMetricsRequestV4_Completeness) GetOk() bool
- func (*WriteMetricsRequestV4_Completeness) ProtoMessage()
- func (x *WriteMetricsRequestV4_Completeness) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV4_Completeness) Reset()
- func (x *WriteMetricsRequestV4_Completeness) String() string
- type WriteMetricsRequestV4_Header
- func (*WriteMetricsRequestV4_Header) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV4_Header) GetMetricName() string
- func (x *WriteMetricsRequestV4_Header) GetTagKeys() []string
- func (x *WriteMetricsRequestV4_Header) GetValueKeys() []string
- func (*WriteMetricsRequestV4_Header) ProtoMessage()
- func (x *WriteMetricsRequestV4_Header) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV4_Header) Reset()
- func (x *WriteMetricsRequestV4_Header) String() string
- type WriteMetricsRequestV4_Row
- func (*WriteMetricsRequestV4_Row) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV4_Row) GetTagValues() []string
- func (x *WriteMetricsRequestV4_Row) GetTimestamp() int64
- func (x *WriteMetricsRequestV4_Row) GetValueValues() []*DataNode
- func (*WriteMetricsRequestV4_Row) ProtoMessage()
- func (x *WriteMetricsRequestV4_Row) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV4_Row) Reset()
- func (x *WriteMetricsRequestV4_Row) String() string
- type WriteMetricsRequestV4_Table
- func (*WriteMetricsRequestV4_Table) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV4_Table) GetHeader() *WriteMetricsRequestV4_Header
- func (x *WriteMetricsRequestV4_Table) GetRows() []*WriteMetricsRequestV4_Row
- func (x *WriteMetricsRequestV4_Table) GetTimestamp() int64
- func (*WriteMetricsRequestV4_Table) ProtoMessage()
- func (x *WriteMetricsRequestV4_Table) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV4_Table) Reset()
- func (x *WriteMetricsRequestV4_Table) String() string
- type WriteMetricsRequestV4_TaskResult
- func (*WriteMetricsRequestV4_TaskResult) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsRequestV4_TaskResult) GetCompleteness() *WriteMetricsRequestV4_Completeness
- func (x *WriteMetricsRequestV4_TaskResult) GetExtension() map[string]string
- func (x *WriteMetricsRequestV4_TaskResult) GetKey() string
- func (x *WriteMetricsRequestV4_TaskResult) GetRefCollectKey() string
- func (x *WriteMetricsRequestV4_TaskResult) GetRefTargetKey() string
- func (x *WriteMetricsRequestV4_TaskResult) GetTable() *WriteMetricsRequestV4_Table
- func (x *WriteMetricsRequestV4_TaskResult) GetTimestamp() int64
- func (*WriteMetricsRequestV4_TaskResult) ProtoMessage()
- func (x *WriteMetricsRequestV4_TaskResult) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsRequestV4_TaskResult) Reset()
- func (x *WriteMetricsRequestV4_TaskResult) String() string
- type WriteMetricsResponse
- func (*WriteMetricsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WriteMetricsResponse) GetHeader() *pb.CommonResponseHeader
- func (*WriteMetricsResponse) ProtoMessage()
- func (x *WriteMetricsResponse) ProtoReflect() protoreflect.Message
- func (x *WriteMetricsResponse) Reset()
- func (x *WriteMetricsResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var File_gateway_pb_gateway_for_agent_proto protoreflect.FileDescriptor
var GatewayService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "io.holoinsight.server.gateway.grpc.GatewayService", HandlerType: (*GatewayServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ping", Handler: _GatewayService_Ping_Handler, }, { MethodName: "get_control_configs", Handler: _GatewayService_GetControlConfigs_Handler, }, { MethodName: "write_metrics_v1", Handler: _GatewayService_WriteMetricsV1_Handler, }, { MethodName: "write_metrics_v2", Handler: _GatewayService_WriteMetricsV2_Handler, }, { MethodName: "write_metrics_v3", Handler: _GatewayService_WriteMetricsV3_Handler, }, { MethodName: "write_metrics_v4", Handler: _GatewayService_WriteMetricsV4_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "gateway/pb/gateway-for-agent.proto", }
GatewayService_ServiceDesc is the grpc.ServiceDesc for GatewayService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGatewayServiceServer ¶
func RegisterGatewayServiceServer(s grpc.ServiceRegistrar, srv GatewayServiceServer)
Types ¶
type DataNode ¶
type DataNode struct { // 表示数据类型, 其实这里不存也行, 根据配置元数据理论是可以知道的 // 比如约定: // 0 的话 value 就是聚合后的结果, count是聚合次数(可能没用) // 1 的话 value 表示聚合类型是avg, count是聚合次数, value是sum值, 此时用 sum/count 可以得到正确的avg, 方便做分布式avg计算 // 2 的话 表示 bytes 是字符串, 需要根据具体业务语义进行解释 // 3 的话 表示 bytes 是复杂的字节数据, 需要根据具体业务语义进行解释 Type int32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` // 聚合次数 Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // 聚合的值, 根据情况可能是一个聚合结果, 或avg的sum值(此时需要与count配合使用) Value float64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"` // 还能携带任意二进制数据, 字符串也可以使用这种方式存 Bytes []byte `protobuf:"bytes,4,opt,name=bytes,proto3" json:"bytes,omitempty"` // contains filtered or unexported fields }
可以存下各种类型的万能字段
func (*DataNode) Descriptor
deprecated
func (*DataNode) ProtoMessage ¶
func (*DataNode) ProtoMessage()
func (*DataNode) ProtoReflect ¶
func (x *DataNode) ProtoReflect() protoreflect.Message
type GatewayServiceClient ¶
type GatewayServiceClient interface { Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) // 查询控制参数 GetControlConfigs(ctx context.Context, in *GetControlConfigsRequest, opts ...grpc.CallOption) (*GetControlConfigsResponse, error) WriteMetricsV1(ctx context.Context, in *WriteMetricsRequestV1, opts ...grpc.CallOption) (*WriteMetricsResponse, error) // deprecated WriteMetricsV2(ctx context.Context, in *WriteMetricsRequestV2, opts ...grpc.CallOption) (*WriteMetricsResponse, error) // deprecated WriteMetricsV3(ctx context.Context, in *WriteMetricsRequestV3, opts ...grpc.CallOption) (*WriteMetricsResponse, error) WriteMetricsV4(ctx context.Context, in *WriteMetricsRequestV4, opts ...grpc.CallOption) (*WriteMetricsResponse, error) }
GatewayServiceClient is the client API for GatewayService 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 NewGatewayServiceClient ¶
func NewGatewayServiceClient(cc grpc.ClientConnInterface) GatewayServiceClient
type GatewayServiceServer ¶
type GatewayServiceServer interface { Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // 查询控制参数 GetControlConfigs(context.Context, *GetControlConfigsRequest) (*GetControlConfigsResponse, error) WriteMetricsV1(context.Context, *WriteMetricsRequestV1) (*WriteMetricsResponse, error) // deprecated WriteMetricsV2(context.Context, *WriteMetricsRequestV2) (*WriteMetricsResponse, error) // deprecated WriteMetricsV3(context.Context, *WriteMetricsRequestV3) (*WriteMetricsResponse, error) WriteMetricsV4(context.Context, *WriteMetricsRequestV4) (*WriteMetricsResponse, error) }
GatewayServiceServer is the server API for GatewayService service. All implementations should embed UnimplementedGatewayServiceServer for forward compatibility
type GetControlConfigsRequest ¶
type GetControlConfigsRequest struct { Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` AgentId string `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` // contains filtered or unexported fields }
func (*GetControlConfigsRequest) Descriptor
deprecated
func (*GetControlConfigsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetControlConfigsRequest.ProtoReflect.Descriptor instead.
func (*GetControlConfigsRequest) GetAgentId ¶
func (x *GetControlConfigsRequest) GetAgentId() string
func (*GetControlConfigsRequest) GetHeader ¶
func (x *GetControlConfigsRequest) GetHeader() *pb.CommonRequestHeader
func (*GetControlConfigsRequest) ProtoMessage ¶
func (*GetControlConfigsRequest) ProtoMessage()
func (*GetControlConfigsRequest) ProtoReflect ¶
func (x *GetControlConfigsRequest) ProtoReflect() protoreflect.Message
func (*GetControlConfigsRequest) Reset ¶
func (x *GetControlConfigsRequest) Reset()
func (*GetControlConfigsRequest) String ¶
func (x *GetControlConfigsRequest) String() string
type GetControlConfigsResponse ¶
type GetControlConfigsResponse struct { Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // contains filtered or unexported fields }
func (*GetControlConfigsResponse) Descriptor
deprecated
func (*GetControlConfigsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetControlConfigsResponse.ProtoReflect.Descriptor instead.
func (*GetControlConfigsResponse) GetHeader ¶
func (x *GetControlConfigsResponse) GetHeader() *pb.CommonResponseHeader
func (*GetControlConfigsResponse) ProtoMessage ¶
func (*GetControlConfigsResponse) ProtoMessage()
func (*GetControlConfigsResponse) ProtoReflect ¶
func (x *GetControlConfigsResponse) ProtoReflect() protoreflect.Message
func (*GetControlConfigsResponse) Reset ¶
func (x *GetControlConfigsResponse) Reset()
func (*GetControlConfigsResponse) String ¶
func (x *GetControlConfigsResponse) String() string
type Point ¶
type Point struct { MetricName string `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"` // 秒级时间戳 Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ // ceresdb 支持2种values: float/string // 别用Any/OneOf, 那样效率太低, 直接分成两个, 并且规定一旦同名的话 number 优先级 > string NumberValues map[string]float64 `` /* 187-byte string literal not displayed */ StringValues map[string]string `` /* 185-byte string literal not displayed */ // contains filtered or unexported fields }
对应ceresdb的一个数据点
func (*Point) Descriptor
deprecated
func (*Point) GetMetricName ¶
func (*Point) GetNumberValues ¶
func (*Point) GetStringValues ¶
func (*Point) GetTimestamp ¶
func (*Point) ProtoMessage ¶
func (*Point) ProtoMessage()
func (*Point) ProtoReflect ¶
func (x *Point) ProtoReflect() protoreflect.Message
type UnimplementedGatewayServiceServer ¶
type UnimplementedGatewayServiceServer struct { }
UnimplementedGatewayServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedGatewayServiceServer) GetControlConfigs ¶
func (UnimplementedGatewayServiceServer) GetControlConfigs(context.Context, *GetControlConfigsRequest) (*GetControlConfigsResponse, error)
func (UnimplementedGatewayServiceServer) WriteMetricsV1 ¶
func (UnimplementedGatewayServiceServer) WriteMetricsV1(context.Context, *WriteMetricsRequestV1) (*WriteMetricsResponse, error)
func (UnimplementedGatewayServiceServer) WriteMetricsV2 ¶
func (UnimplementedGatewayServiceServer) WriteMetricsV2(context.Context, *WriteMetricsRequestV2) (*WriteMetricsResponse, error)
func (UnimplementedGatewayServiceServer) WriteMetricsV3 ¶
func (UnimplementedGatewayServiceServer) WriteMetricsV3(context.Context, *WriteMetricsRequestV3) (*WriteMetricsResponse, error)
func (UnimplementedGatewayServiceServer) WriteMetricsV4 ¶
func (UnimplementedGatewayServiceServer) WriteMetricsV4(context.Context, *WriteMetricsRequestV4) (*WriteMetricsResponse, error)
type UnsafeGatewayServiceServer ¶
type UnsafeGatewayServiceServer interface {
// contains filtered or unexported methods
}
UnsafeGatewayServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GatewayServiceServer will result in compilation errors.
type WriteMetricsRequestV1 ¶
type WriteMetricsRequestV1 struct { // 在请求头里还有apikey, 可以供我们找出租户 Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Point []*Point `protobuf:"bytes,2,rep,name=point,proto3" json:"point,omitempty"` // contains filtered or unexported fields }
TODO 写数据接口 v1 优点是简单, 基本和用户的数据是匹配的, 可以很简单转换 缺点是彻底失去对内容的控制能力, agent传过来啥就写啥, 会不会有点不太好? 另外还有一个是数据的keys大量冗余
func (*WriteMetricsRequestV1) Descriptor
deprecated
func (*WriteMetricsRequestV1) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV1.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV1) GetHeader ¶
func (x *WriteMetricsRequestV1) GetHeader() *pb.CommonRequestHeader
func (*WriteMetricsRequestV1) GetPoint ¶
func (x *WriteMetricsRequestV1) GetPoint() []*Point
func (*WriteMetricsRequestV1) ProtoMessage ¶
func (*WriteMetricsRequestV1) ProtoMessage()
func (*WriteMetricsRequestV1) ProtoReflect ¶
func (x *WriteMetricsRequestV1) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV1) Reset ¶
func (x *WriteMetricsRequestV1) Reset()
func (*WriteMetricsRequestV1) String ¶
func (x *WriteMetricsRequestV1) String() string
type WriteMetricsRequestV2 ¶
type WriteMetricsRequestV2 struct { Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Batch []*WriteMetricsRequestV2_Batch `protobuf:"bytes,2,rep,name=batch,proto3" json:"batch,omitempty"` // contains filtered or unexported fields }
TODO 写数据接口 v2 优点是 调整结构使得数据复用程度提高 缺点是用户发数据的时候需要按我的格式调整
func (*WriteMetricsRequestV2) Descriptor
deprecated
func (*WriteMetricsRequestV2) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV2.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV2) GetBatch ¶
func (x *WriteMetricsRequestV2) GetBatch() []*WriteMetricsRequestV2_Batch
func (*WriteMetricsRequestV2) GetHeader ¶
func (x *WriteMetricsRequestV2) GetHeader() *pb.CommonRequestHeader
func (*WriteMetricsRequestV2) ProtoMessage ¶
func (*WriteMetricsRequestV2) ProtoMessage()
func (*WriteMetricsRequestV2) ProtoReflect ¶
func (x *WriteMetricsRequestV2) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV2) Reset ¶
func (x *WriteMetricsRequestV2) Reset()
func (*WriteMetricsRequestV2) String ¶
func (x *WriteMetricsRequestV2) String() string
type WriteMetricsRequestV2_Batch ¶
type WriteMetricsRequestV2_Batch struct { Header *WriteMetricsRequestV2_BatchHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Value []*WriteMetricsRequestV2_BatchValue `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*WriteMetricsRequestV2_Batch) Descriptor
deprecated
func (*WriteMetricsRequestV2_Batch) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV2_Batch.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV2_Batch) GetHeader ¶
func (x *WriteMetricsRequestV2_Batch) GetHeader() *WriteMetricsRequestV2_BatchHeader
func (*WriteMetricsRequestV2_Batch) GetValue ¶
func (x *WriteMetricsRequestV2_Batch) GetValue() []*WriteMetricsRequestV2_BatchValue
func (*WriteMetricsRequestV2_Batch) ProtoMessage ¶
func (*WriteMetricsRequestV2_Batch) ProtoMessage()
func (*WriteMetricsRequestV2_Batch) ProtoReflect ¶
func (x *WriteMetricsRequestV2_Batch) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV2_Batch) Reset ¶
func (x *WriteMetricsRequestV2_Batch) Reset()
func (*WriteMetricsRequestV2_Batch) String ¶
func (x *WriteMetricsRequestV2_Batch) String() string
type WriteMetricsRequestV2_BatchHeader ¶
type WriteMetricsRequestV2_BatchHeader struct { MetricName string `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"` TagKeys []string `protobuf:"bytes,2,rep,name=tag_keys,json=tagKeys,proto3" json:"tag_keys,omitempty"` // 由于存在多种values的值, 这里有2种设计方式 // 1. 针对每种数据类型有自己的数据 NumberKeys []string `protobuf:"bytes,3,rep,name=number_keys,json=numberKeys,proto3" json:"number_keys,omitempty"` StringKeys []string `protobuf:"bytes,4,rep,name=string_keys,json=stringKeys,proto3" json:"string_keys,omitempty"` // 2. 使用一种更通用的数据类型来包装我们的多种数据类型 DataKeys []string `protobuf:"bytes,5,rep,name=data_keys,json=dataKeys,proto3" json:"data_keys,omitempty"` // contains filtered or unexported fields }
func (*WriteMetricsRequestV2_BatchHeader) Descriptor
deprecated
func (*WriteMetricsRequestV2_BatchHeader) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV2_BatchHeader.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV2_BatchHeader) GetDataKeys ¶
func (x *WriteMetricsRequestV2_BatchHeader) GetDataKeys() []string
func (*WriteMetricsRequestV2_BatchHeader) GetMetricName ¶
func (x *WriteMetricsRequestV2_BatchHeader) GetMetricName() string
func (*WriteMetricsRequestV2_BatchHeader) GetNumberKeys ¶
func (x *WriteMetricsRequestV2_BatchHeader) GetNumberKeys() []string
func (*WriteMetricsRequestV2_BatchHeader) GetStringKeys ¶
func (x *WriteMetricsRequestV2_BatchHeader) GetStringKeys() []string
func (*WriteMetricsRequestV2_BatchHeader) GetTagKeys ¶
func (x *WriteMetricsRequestV2_BatchHeader) GetTagKeys() []string
func (*WriteMetricsRequestV2_BatchHeader) ProtoMessage ¶
func (*WriteMetricsRequestV2_BatchHeader) ProtoMessage()
func (*WriteMetricsRequestV2_BatchHeader) ProtoReflect ¶
func (x *WriteMetricsRequestV2_BatchHeader) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV2_BatchHeader) Reset ¶
func (x *WriteMetricsRequestV2_BatchHeader) Reset()
func (*WriteMetricsRequestV2_BatchHeader) String ¶
func (x *WriteMetricsRequestV2_BatchHeader) String() string
type WriteMetricsRequestV2_BatchValue ¶
type WriteMetricsRequestV2_BatchValue struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` TagValues []string `protobuf:"bytes,2,rep,name=tag_values,json=tagValues,proto3" json:"tag_values,omitempty"` NumberValues []float64 `protobuf:"fixed64,3,rep,packed,name=number_values,json=numberValues,proto3" json:"number_values,omitempty"` StringValues []string `protobuf:"bytes,4,rep,name=string_values,json=stringValues,proto3" json:"string_values,omitempty"` DataValues []*DataNode `protobuf:"bytes,5,rep,name=data_values,json=dataValues,proto3" json:"data_values,omitempty"` // contains filtered or unexported fields }
func (*WriteMetricsRequestV2_BatchValue) Descriptor
deprecated
func (*WriteMetricsRequestV2_BatchValue) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV2_BatchValue.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV2_BatchValue) GetDataValues ¶
func (x *WriteMetricsRequestV2_BatchValue) GetDataValues() []*DataNode
func (*WriteMetricsRequestV2_BatchValue) GetNumberValues ¶
func (x *WriteMetricsRequestV2_BatchValue) GetNumberValues() []float64
func (*WriteMetricsRequestV2_BatchValue) GetStringValues ¶
func (x *WriteMetricsRequestV2_BatchValue) GetStringValues() []string
func (*WriteMetricsRequestV2_BatchValue) GetTagValues ¶
func (x *WriteMetricsRequestV2_BatchValue) GetTagValues() []string
func (*WriteMetricsRequestV2_BatchValue) GetTimestamp ¶
func (x *WriteMetricsRequestV2_BatchValue) GetTimestamp() int64
func (*WriteMetricsRequestV2_BatchValue) ProtoMessage ¶
func (*WriteMetricsRequestV2_BatchValue) ProtoMessage()
func (*WriteMetricsRequestV2_BatchValue) ProtoReflect ¶
func (x *WriteMetricsRequestV2_BatchValue) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV2_BatchValue) Reset ¶
func (x *WriteMetricsRequestV2_BatchValue) Reset()
func (*WriteMetricsRequestV2_BatchValue) String ¶
func (x *WriteMetricsRequestV2_BatchValue) String() string
type WriteMetricsRequestV3 ¶
type WriteMetricsRequestV3 struct { Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Batch []*WriteMetricsRequestV3_TaskBatch `protobuf:"bytes,2,rep,name=batch,proto3" json:"batch,omitempty"` // contains filtered or unexported fields }
TODO 写数据接口 v3 优点 数据复用程度最高, 传输效率应该也是最高 缺点 该格式基本是为我们的agent而定制的了
func (*WriteMetricsRequestV3) Descriptor
deprecated
func (*WriteMetricsRequestV3) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV3.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV3) GetBatch ¶
func (x *WriteMetricsRequestV3) GetBatch() []*WriteMetricsRequestV3_TaskBatch
func (*WriteMetricsRequestV3) GetHeader ¶
func (x *WriteMetricsRequestV3) GetHeader() *pb.CommonRequestHeader
func (*WriteMetricsRequestV3) ProtoMessage ¶
func (*WriteMetricsRequestV3) ProtoMessage()
func (*WriteMetricsRequestV3) ProtoReflect ¶
func (x *WriteMetricsRequestV3) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV3) Reset ¶
func (x *WriteMetricsRequestV3) Reset()
func (*WriteMetricsRequestV3) String ¶
func (x *WriteMetricsRequestV3) String() string
type WriteMetricsRequestV3_TaskBatch ¶
type WriteMetricsRequestV3_TaskBatch struct { // 任务的key TODO 这个有点冗余, 其实下面2个key够用了 Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // 对应哪个采集配置 RefCollectKey string `protobuf:"bytes,2,opt,name=ref_collect_key,json=refCollectKey,proto3" json:"ref_collect_key,omitempty"` // 对应哪个采集目标 RefTargetKey string `protobuf:"bytes,3,opt,name=ref_target_key,json=refTargetKey,proto3" json:"ref_target_key,omitempty"` // 指标名 // string metric_name = 4; Batch *WriteMetricsRequestV2_Batch `protobuf:"bytes,4,opt,name=batch,proto3" json:"batch,omitempty"` // contains filtered or unexported fields }
func (*WriteMetricsRequestV3_TaskBatch) Descriptor
deprecated
func (*WriteMetricsRequestV3_TaskBatch) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV3_TaskBatch.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV3_TaskBatch) GetBatch ¶
func (x *WriteMetricsRequestV3_TaskBatch) GetBatch() *WriteMetricsRequestV2_Batch
func (*WriteMetricsRequestV3_TaskBatch) GetKey ¶
func (x *WriteMetricsRequestV3_TaskBatch) GetKey() string
func (*WriteMetricsRequestV3_TaskBatch) GetRefCollectKey ¶
func (x *WriteMetricsRequestV3_TaskBatch) GetRefCollectKey() string
func (*WriteMetricsRequestV3_TaskBatch) GetRefTargetKey ¶
func (x *WriteMetricsRequestV3_TaskBatch) GetRefTargetKey() string
func (*WriteMetricsRequestV3_TaskBatch) ProtoMessage ¶
func (*WriteMetricsRequestV3_TaskBatch) ProtoMessage()
func (*WriteMetricsRequestV3_TaskBatch) ProtoReflect ¶
func (x *WriteMetricsRequestV3_TaskBatch) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV3_TaskBatch) Reset ¶
func (x *WriteMetricsRequestV3_TaskBatch) Reset()
func (*WriteMetricsRequestV3_TaskBatch) String ¶
func (x *WriteMetricsRequestV3_TaskBatch) String() string
type WriteMetricsRequestV4 ¶
type WriteMetricsRequestV4 struct { Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Results []*WriteMetricsRequestV4_TaskResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"` // contains filtered or unexported fields }
相比v3进一步提升为table形式
func (*WriteMetricsRequestV4) Descriptor
deprecated
func (*WriteMetricsRequestV4) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV4.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV4) GetHeader ¶
func (x *WriteMetricsRequestV4) GetHeader() *pb.CommonRequestHeader
func (*WriteMetricsRequestV4) GetResults ¶
func (x *WriteMetricsRequestV4) GetResults() []*WriteMetricsRequestV4_TaskResult
func (*WriteMetricsRequestV4) ProtoMessage ¶
func (*WriteMetricsRequestV4) ProtoMessage()
func (*WriteMetricsRequestV4) ProtoReflect ¶
func (x *WriteMetricsRequestV4) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV4) Reset ¶
func (x *WriteMetricsRequestV4) Reset()
func (*WriteMetricsRequestV4) String ¶
func (x *WriteMetricsRequestV4) String() string
type WriteMetricsRequestV4_Completeness ¶
type WriteMetricsRequestV4_Completeness struct { Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"` Extension map[string]string `` /* 159-byte string literal not displayed */ // contains filtered or unexported fields }
func (*WriteMetricsRequestV4_Completeness) Descriptor
deprecated
func (*WriteMetricsRequestV4_Completeness) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV4_Completeness.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV4_Completeness) GetExtension ¶
func (x *WriteMetricsRequestV4_Completeness) GetExtension() map[string]string
func (*WriteMetricsRequestV4_Completeness) GetOk ¶
func (x *WriteMetricsRequestV4_Completeness) GetOk() bool
func (*WriteMetricsRequestV4_Completeness) ProtoMessage ¶
func (*WriteMetricsRequestV4_Completeness) ProtoMessage()
func (*WriteMetricsRequestV4_Completeness) ProtoReflect ¶
func (x *WriteMetricsRequestV4_Completeness) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV4_Completeness) Reset ¶
func (x *WriteMetricsRequestV4_Completeness) Reset()
func (*WriteMetricsRequestV4_Completeness) String ¶
func (x *WriteMetricsRequestV4_Completeness) String() string
type WriteMetricsRequestV4_Header ¶
type WriteMetricsRequestV4_Header struct { MetricName string `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"` TagKeys []string `protobuf:"bytes,2,rep,name=tag_keys,json=tagKeys,proto3" json:"tag_keys,omitempty"` ValueKeys []string `protobuf:"bytes,3,rep,name=value_keys,json=valueKeys,proto3" json:"value_keys,omitempty"` // contains filtered or unexported fields }
表头
func (*WriteMetricsRequestV4_Header) Descriptor
deprecated
func (*WriteMetricsRequestV4_Header) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV4_Header.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV4_Header) GetMetricName ¶
func (x *WriteMetricsRequestV4_Header) GetMetricName() string
func (*WriteMetricsRequestV4_Header) GetTagKeys ¶
func (x *WriteMetricsRequestV4_Header) GetTagKeys() []string
func (*WriteMetricsRequestV4_Header) GetValueKeys ¶
func (x *WriteMetricsRequestV4_Header) GetValueKeys() []string
func (*WriteMetricsRequestV4_Header) ProtoMessage ¶
func (*WriteMetricsRequestV4_Header) ProtoMessage()
func (*WriteMetricsRequestV4_Header) ProtoReflect ¶
func (x *WriteMetricsRequestV4_Header) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV4_Header) Reset ¶
func (x *WriteMetricsRequestV4_Header) Reset()
func (*WriteMetricsRequestV4_Header) String ¶
func (x *WriteMetricsRequestV4_Header) String() string
type WriteMetricsRequestV4_Row ¶
type WriteMetricsRequestV4_Row struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` TagValues []string `protobuf:"bytes,2,rep,name=tag_values,json=tagValues,proto3" json:"tag_values,omitempty"` ValueValues []*DataNode `protobuf:"bytes,3,rep,name=value_values,json=valueValues,proto3" json:"value_values,omitempty"` // contains filtered or unexported fields }
行
func (*WriteMetricsRequestV4_Row) Descriptor
deprecated
func (*WriteMetricsRequestV4_Row) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV4_Row.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV4_Row) GetTagValues ¶
func (x *WriteMetricsRequestV4_Row) GetTagValues() []string
func (*WriteMetricsRequestV4_Row) GetTimestamp ¶
func (x *WriteMetricsRequestV4_Row) GetTimestamp() int64
func (*WriteMetricsRequestV4_Row) GetValueValues ¶
func (x *WriteMetricsRequestV4_Row) GetValueValues() []*DataNode
func (*WriteMetricsRequestV4_Row) ProtoMessage ¶
func (*WriteMetricsRequestV4_Row) ProtoMessage()
func (*WriteMetricsRequestV4_Row) ProtoReflect ¶
func (x *WriteMetricsRequestV4_Row) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV4_Row) Reset ¶
func (x *WriteMetricsRequestV4_Row) Reset()
func (*WriteMetricsRequestV4_Row) String ¶
func (x *WriteMetricsRequestV4_Row) String() string
type WriteMetricsRequestV4_Table ¶
type WriteMetricsRequestV4_Table struct { // 表头 Header *WriteMetricsRequestV4_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // 每个行就是一个维度组合的聚合结果 Rows []*WriteMetricsRequestV4_Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"` // if timestamp > 0, then all rows use this same timestamp Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*WriteMetricsRequestV4_Table) Descriptor
deprecated
func (*WriteMetricsRequestV4_Table) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV4_Table.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV4_Table) GetHeader ¶
func (x *WriteMetricsRequestV4_Table) GetHeader() *WriteMetricsRequestV4_Header
func (*WriteMetricsRequestV4_Table) GetRows ¶
func (x *WriteMetricsRequestV4_Table) GetRows() []*WriteMetricsRequestV4_Row
func (*WriteMetricsRequestV4_Table) GetTimestamp ¶
func (x *WriteMetricsRequestV4_Table) GetTimestamp() int64
func (*WriteMetricsRequestV4_Table) ProtoMessage ¶
func (*WriteMetricsRequestV4_Table) ProtoMessage()
func (*WriteMetricsRequestV4_Table) ProtoReflect ¶
func (x *WriteMetricsRequestV4_Table) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV4_Table) Reset ¶
func (x *WriteMetricsRequestV4_Table) Reset()
func (*WriteMetricsRequestV4_Table) String ¶
func (x *WriteMetricsRequestV4_Table) String() string
type WriteMetricsRequestV4_TaskResult ¶
type WriteMetricsRequestV4_TaskResult struct { // 任务的key TODO 这个有点冗余, 其实下面2个key够用了 Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // 对应哪个采集配置 RefCollectKey string `protobuf:"bytes,2,opt,name=ref_collect_key,json=refCollectKey,proto3" json:"ref_collect_key,omitempty"` // 对应哪个采集目标 RefTargetKey string `protobuf:"bytes,3,opt,name=ref_target_key,json=refTargetKey,proto3" json:"ref_target_key,omitempty"` // 数据结果, 使用表的形式 Table *WriteMetricsRequestV4_Table `protobuf:"bytes,4,opt,name=table,proto3" json:"table,omitempty"` Extension map[string]string `` /* 159-byte string literal not displayed */ Timestamp int64 `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Completeness *WriteMetricsRequestV4_Completeness `protobuf:"bytes,7,opt,name=completeness,proto3" json:"completeness,omitempty"` // contains filtered or unexported fields }
采集任务的结果
func (*WriteMetricsRequestV4_TaskResult) Descriptor
deprecated
func (*WriteMetricsRequestV4_TaskResult) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsRequestV4_TaskResult.ProtoReflect.Descriptor instead.
func (*WriteMetricsRequestV4_TaskResult) GetCompleteness ¶
func (x *WriteMetricsRequestV4_TaskResult) GetCompleteness() *WriteMetricsRequestV4_Completeness
func (*WriteMetricsRequestV4_TaskResult) GetExtension ¶
func (x *WriteMetricsRequestV4_TaskResult) GetExtension() map[string]string
func (*WriteMetricsRequestV4_TaskResult) GetKey ¶
func (x *WriteMetricsRequestV4_TaskResult) GetKey() string
func (*WriteMetricsRequestV4_TaskResult) GetRefCollectKey ¶
func (x *WriteMetricsRequestV4_TaskResult) GetRefCollectKey() string
func (*WriteMetricsRequestV4_TaskResult) GetRefTargetKey ¶
func (x *WriteMetricsRequestV4_TaskResult) GetRefTargetKey() string
func (*WriteMetricsRequestV4_TaskResult) GetTable ¶
func (x *WriteMetricsRequestV4_TaskResult) GetTable() *WriteMetricsRequestV4_Table
func (*WriteMetricsRequestV4_TaskResult) GetTimestamp ¶
func (x *WriteMetricsRequestV4_TaskResult) GetTimestamp() int64
func (*WriteMetricsRequestV4_TaskResult) ProtoMessage ¶
func (*WriteMetricsRequestV4_TaskResult) ProtoMessage()
func (*WriteMetricsRequestV4_TaskResult) ProtoReflect ¶
func (x *WriteMetricsRequestV4_TaskResult) ProtoReflect() protoreflect.Message
func (*WriteMetricsRequestV4_TaskResult) Reset ¶
func (x *WriteMetricsRequestV4_TaskResult) Reset()
func (*WriteMetricsRequestV4_TaskResult) String ¶
func (x *WriteMetricsRequestV4_TaskResult) String() string
type WriteMetricsResponse ¶
type WriteMetricsResponse struct { Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // contains filtered or unexported fields }
func (*WriteMetricsResponse) Descriptor
deprecated
func (*WriteMetricsResponse) Descriptor() ([]byte, []int)
Deprecated: Use WriteMetricsResponse.ProtoReflect.Descriptor instead.
func (*WriteMetricsResponse) GetHeader ¶
func (x *WriteMetricsResponse) GetHeader() *pb.CommonResponseHeader
func (*WriteMetricsResponse) ProtoMessage ¶
func (*WriteMetricsResponse) ProtoMessage()
func (*WriteMetricsResponse) ProtoReflect ¶
func (x *WriteMetricsResponse) ProtoReflect() protoreflect.Message
func (*WriteMetricsResponse) Reset ¶
func (x *WriteMetricsResponse) Reset()
func (*WriteMetricsResponse) String ¶
func (x *WriteMetricsResponse) String() string