Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(32)

Unified Diff: common/tsmon/target/target.go

Issue 1857643003: Revert of Migrate tsmon protos to proto3 (Closed) Base URL: git@github.com:luci/luci-go.git@master
Patch Set: Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « common/tsmon/store/testing.go ('k') | common/tsmon/ts_mon_proto/acquisition_network_device.proto » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: common/tsmon/target/target.go
diff --git a/common/tsmon/target/target.go b/common/tsmon/target/target.go
index e1d5a9b7bf4e38e17dd8cd904ef87907d3516d10..bdecd249237e6a3ee1d1c951a544a9ff0341bb0b 100644
--- a/common/tsmon/target/target.go
+++ b/common/tsmon/target/target.go
@@ -32,22 +32,22 @@
// IsPopulatedIn returns true if the MetricsData message is for this target.
func (t *Task) IsPopulatedIn(d *pb.MetricsData) bool {
return d.Task != nil &&
- d.Task.ServiceName == t.AsProto().ServiceName &&
- d.Task.JobName == t.AsProto().JobName &&
- d.Task.DataCenter == t.AsProto().DataCenter &&
- d.Task.HostName == t.AsProto().HostName &&
- d.Task.TaskNum == t.AsProto().TaskNum
+ d.Task.GetServiceName() == t.AsProto().GetServiceName() &&
+ d.Task.GetJobName() == t.AsProto().GetJobName() &&
+ d.Task.GetDataCenter() == t.AsProto().GetDataCenter() &&
+ d.Task.GetHostName() == t.AsProto().GetHostName() &&
+ d.Task.GetTaskNum() == t.AsProto().GetTaskNum()
}
// Hash returns a uint64 hash of this target.
func (t *Task) Hash() uint64 {
h := fnv.New64a()
fmt.Fprintf(h, "%s\n%s\n%s\n%s\n%d",
- t.AsProto().ServiceName,
- t.AsProto().JobName,
- t.AsProto().DataCenter,
- t.AsProto().HostName,
- t.AsProto().TaskNum)
+ t.AsProto().GetServiceName(),
+ t.AsProto().GetJobName(),
+ t.AsProto().GetDataCenter(),
+ t.AsProto().GetHostName(),
+ t.AsProto().GetTaskNum())
return h.Sum64()
}
@@ -68,24 +68,24 @@
// IsPopulatedIn returns true if the MetricsData message is for this target.
func (t *NetworkDevice) IsPopulatedIn(d *pb.MetricsData) bool {
return d.NetworkDevice != nil &&
- d.NetworkDevice.Alertable == t.AsProto().Alertable &&
- d.NetworkDevice.Realm == t.AsProto().Realm &&
- d.NetworkDevice.Metro == t.AsProto().Metro &&
- d.NetworkDevice.Role == t.AsProto().Role &&
- d.NetworkDevice.Hostname == t.AsProto().Hostname &&
- d.NetworkDevice.Hostgroup == t.AsProto().Hostgroup
+ d.NetworkDevice.GetAlertable() == t.AsProto().GetAlertable() &&
+ d.NetworkDevice.GetRealm() == t.AsProto().GetRealm() &&
+ d.NetworkDevice.GetMetro() == t.AsProto().GetMetro() &&
+ d.NetworkDevice.GetRole() == t.AsProto().GetRole() &&
+ d.NetworkDevice.GetHostname() == t.AsProto().GetHostname() &&
+ d.NetworkDevice.GetHostgroup() == t.AsProto().GetHostgroup()
}
// Hash returns a uint64 hash of this target.
func (t *NetworkDevice) Hash() uint64 {
h := fnv.New64a()
fmt.Fprintf(h, "%t%s\n%s\n%s\n%s\n%s",
- t.AsProto().Alertable,
- t.AsProto().Realm,
- t.AsProto().Metro,
- t.AsProto().Role,
- t.AsProto().Hostname,
- t.AsProto().Hostgroup)
+ t.AsProto().GetAlertable(),
+ t.AsProto().GetRealm(),
+ t.AsProto().GetMetro(),
+ t.AsProto().GetRole(),
+ t.AsProto().GetHostname(),
+ t.AsProto().GetHostgroup())
return h.Sum64()
}
@@ -107,20 +107,20 @@
}
return (*Task)(&pb.Task{
- ServiceName: fl.TaskServiceName,
- JobName: fl.TaskJobName,
- DataCenter: fl.TaskRegion,
- HostName: fl.TaskHostname,
- TaskNum: int32(fl.TaskNumber),
+ ServiceName: proto.String(fl.TaskServiceName),
+ JobName: proto.String(fl.TaskJobName),
+ DataCenter: proto.String(fl.TaskRegion),
+ HostName: proto.String(fl.TaskHostname),
+ TaskNum: proto.Int32(int32(fl.TaskNumber)),
}), nil
} else if fl.TargetType == "device" {
return (*NetworkDevice)(&pb.NetworkDevice{
- Alertable: true,
- Realm: "ACQ_CHROME",
- Metro: fl.DeviceRegion,
- Role: fl.DeviceRole,
- Hostname: fl.DeviceHostname,
- Hostgroup: fl.DeviceNetwork,
+ Alertable: proto.Bool(true),
+ Realm: proto.String("ACQ_CHROME"),
+ Metro: proto.String(fl.DeviceRegion),
+ Role: proto.String(fl.DeviceRole),
+ Hostname: proto.String(fl.DeviceHostname),
+ Hostgroup: proto.String(fl.DeviceNetwork),
}), nil
} else {
return nil, fmt.Errorf("unknown --ts-mon-target-type '%s'", fl.TargetType)
« no previous file with comments | « common/tsmon/store/testing.go ('k') | common/tsmon/ts_mon_proto/acquisition_network_device.proto » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698