MetricManage

type MetricService interface {
	//TODO 获取指定服务2小时的指标
	FetchMetricsForServiceLastTwoHour(ctx context.Context, service *ServiceManage.Service) (*ServiceInstanceMetrics, error)
	//TODO 取指定服务的6小时内的指标
	FetchMetricsForServiceLastSixHour(ctx context.Context, service *ServiceManage.Service) (*ServiceInstanceMetrics, error)
	//TODO  获取指定服务12小时内的指标
	FetchMetricsForServiceRecent(ctx context.Context, service *ServiceManage.Service) (*ServiceInstanceMetrics, error)
	//TODO 获取指定服务24小时内的指标
	FetchServiceMetricsForLastDay(ctx context.Context, service *ServiceManage.Service) (*ServiceInstanceMetrics, error)
	//GRPC server,上报各种指标
	MetricsServiceServer
}

type MetricsData struct {
	CpuUsage    []float64 `protobuf:"fixed64,1,rep,packed,name=cpuUsage,proto3" json:"cpuUsage,omitempty"` // CPU使用率，百分比
	MemoryUsage float64   `protobuf:"fixed64,2,opt,name=memoryUsage,proto3" json:"memoryUsage,omitempty"`  // 内存使用率，百分比
	IcmpDelay   int64     `protobuf:"varint,3,opt,name=icmpDelay,proto3" json:"icmpDelay,omitempty"`       // ICMP延迟，毫秒
	TimeStamp   int64     `protobuf:"varint,4,opt,name=timeStamp,proto3" json:"timeStamp,omitempty"`       //时间戳
	ServiceName string    `protobuf:"bytes,5,opt,name=ServiceName,proto3" json:"ServiceName,omitempty"`    //服务前缀
	ServiceHost string    `protobuf:"bytes,6,opt,name=ServiceHost,proto3" json:"ServiceHost,omitempty"`    //服务地址和端口
	IsPriority  string    `protobuf:"bytes,7,opt,name=IsPriority,proto3" json:"IsPriority,omitempty"`      //是否优先
	ProjectName string    `protobuf:"bytes,8,opt,name=ProjectName,proto3" json:"ProjectName,omitempty"`    //项目名
	LeaseId     int64     `protobuf:"varint,9,opt,name=LeaseId,proto3" json:"LeaseId,omitempty"`           // etcd租约id
	// contains filtered or unexported fields
}

type MetricsServiceClient interface {
	// 客户端流模式的RPC方法
	ReportMetrics(ctx context.Context, opts ...grpc.CallOption) (MetricsService_ReportMetricsClient, error)
}

type MetricsServiceServer interface {
	// 客户端流模式的RPC方法
	ReportMetrics(MetricsService_ReportMetricsServer) error
	// contains filtered or unexported methods
}

type MetricsService_ReportMetricsClient interface {
	Send(*MetricsData) error
	CloseAndRecv() (*ReportResponse, error)
	grpc.ClientStream
}

type MetricsService_ReportMetricsServer interface {
	SendAndClose(*ReportResponse) error
	Recv() (*MetricsData, error)
	grpc.ServerStream
}

type ReportResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // 上报是否成功
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`  // 服务端返回的消息，例如错误信息
	// contains filtered or unexported fields
}

type ServiceInstance struct {
	ServiceHost string       `json:"service_host"`
	MetricsData *MetricsData `json:"metrics_data"`
}

type ServiceInstanceMetrics struct {
	ServiceHost string         `json:"service_host"`
	MetricsData []*MetricsData `json:"metrics_data"`
}

type UnimplementedMetricsServiceServer struct {
}

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