pb

package
v0.0.0-...-5c7ffcf Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_gateway_pb_gateway_for_agent_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use DataNode.ProtoReflect.Descriptor instead.

func (*DataNode) GetBytes 

func (x *DataNode) GetBytes() []byte

func (*DataNode) GetCount 

func (x *DataNode) GetCount() int32

func (*DataNode) GetType 

func (x *DataNode) GetType() int32

func (*DataNode) GetValue 

func (x *DataNode) GetValue() float64

func (*DataNode) ProtoMessage 

func (*DataNode) ProtoMessage()

func (*DataNode) ProtoReflect 

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

func (*DataNode) Reset 

func (x *DataNode) Reset()

func (*DataNode) String 

func (x *DataNode) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Point.ProtoReflect.Descriptor instead.

func (*Point) GetMetricName 

func (x *Point) GetMetricName() string

func (*Point) GetNumberValues 

func (x *Point) GetNumberValues() map[string]float64

func (*Point) GetStringValues 

func (x *Point) GetStringValues() map[string]string

func (*Point) GetTags 

func (x *Point) GetTags() map[string]string

func (*Point) GetTimestamp 

func (x *Point) GetTimestamp() int64

func (*Point) ProtoMessage 

func (*Point) ProtoMessage()

func (*Point) ProtoReflect 

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

func (*Point) Reset 

func (x *Point) Reset()

func (*Point) String 

func (x *Point) String() string

type 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) Ping 

func (UnimplementedGatewayServiceServer) Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, 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

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.