diff --git a/docs/conf2.proto.md b/docs/conf2.proto.md index b0659bc..69d80ab 100644 --- a/docs/conf2.proto.md +++ b/docs/conf2.proto.md @@ -1,6 +1,6 @@ # Package: zaphiro.c37118.v1 - +Copyright 2024 Zaphiro Technologies Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Messages describing PMU C37.118 Configurations. See [C37.118](https://www.typhoon-hil.com/documentation/typhoon-hil-software-manual/References/c37_118_protocol.html) protocol. diff --git a/docs/data.proto.md b/docs/data.proto.md index 534dc27..e016348 100644 --- a/docs/data.proto.md +++ b/docs/data.proto.md @@ -1,6 +1,6 @@ # Package: zaphiro.grid.v1 - +Copyright 2024 Zaphiro Technologies Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Messages to support data injection in the platform. The data injected may be originated from different sources (e.g. a PMU, RTU, an external service). diff --git a/docs/device_event.proto.md b/docs/device_event.proto.md index 30f4303..dec3b44 100644 --- a/docs/device_event.proto.md +++ b/docs/device_event.proto.md @@ -1,6 +1,6 @@ # Package: zaphiro.grid.v1 - +Copyright 2024 Zaphiro Technologies Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Messages to support device event detection in the platform. Device events are sub classes of Events. diff --git a/docs/event.proto.md b/docs/event.proto.md index 748a431..fc78b53 100644 --- a/docs/event.proto.md +++ b/docs/event.proto.md @@ -1,6 +1,6 @@ # Package: zaphiro.grid.v1 - +Copyright 2024 Zaphiro Technologies Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Messages to support event detection in the platform. The event detected may be originated from different sources: devices (e.g. a PMU, RTU), services (e.g. state estimator), or an external service (e.g. SCADA). diff --git a/docs/fault.proto.md b/docs/fault.proto.md index 75e7103..b2a9e20 100644 --- a/docs/fault.proto.md +++ b/docs/fault.proto.md @@ -1,6 +1,6 @@ # Package: zaphiro.grid.v1 - +Copyright 2024 Zaphiro Technologies Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Messages describing faults. diff --git a/docs/grid_event.proto.md b/docs/grid_event.proto.md index 0a5af6c..cbabcc4 100644 --- a/docs/grid_event.proto.md +++ b/docs/grid_event.proto.md @@ -1,6 +1,6 @@ # Package: zaphiro.grid.v1 - +Copyright 2024 Zaphiro Technologies Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Messages to support grid event detection in the platform. Grid events are sub classes of Events. diff --git a/docs/stat.proto.md b/docs/stat.proto.md index 8402d65..11139ed 100644 --- a/docs/stat.proto.md +++ b/docs/stat.proto.md @@ -1,6 +1,6 @@ # Package: zaphiro.c37118.v1 - +Copyright 2024 Zaphiro Technologies Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Messages to support stat data injection exchange in the platform. diff --git a/docs/task.proto.md b/docs/task.proto.md index e906248..390a22a 100644 --- a/docs/task.proto.md +++ b/docs/task.proto.md @@ -11,7 +11,7 @@ services. | Import | Description | |---------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| -| google/protobuf/any.proto | | +| google/protobuf/any.proto | Copyright 2024 Zaphiro Technologies Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. | diff --git a/docs/topology.proto.md b/docs/topology.proto.md index 075eea9..d7f4060 100644 --- a/docs/topology.proto.md +++ b/docs/topology.proto.md @@ -1,6 +1,6 @@ # Package: zaphiro.grid.v1 - +Copyright 2024 Zaphiro Technologies Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Messages to support topology data exchange in the platform. diff --git a/go/c37118/v1/conf2.pb.go b/go/c37118/v1/conf2.pb.go index aa85154..a9c40b7 100644 --- a/go/c37118/v1/conf2.pb.go +++ b/go/c37118/v1/conf2.pb.go @@ -44,8 +44,8 @@ type Conf2Frame struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Header *Conf2Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` //Configuration frame 2 header - Configs []*Config `protobuf:"bytes,2,rep,name=configs,proto3" json:"configs,omitempty"` //Set of PMU configurations + Header *Conf2Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` //Configuration frame 2 header + Configs []*Config `protobuf:"bytes,2,rep,name=configs,proto3" json:"configs,omitempty"` //Set of PMU configurations DATA_RATE uint32 `protobuf:"varint,3,opt,name=DATA_RATE,json=DATARATE,proto3" json:"DATA_RATE,omitempty"` //Rate of data transmission } @@ -107,13 +107,13 @@ type Conf2Header struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - SYNC uint32 `protobuf:"varint,1,opt,name=SYNC,proto3" json:"SYNC,omitempty"` //Sync byte followed by frame type and version number - FRAMESIZE uint32 `protobuf:"varint,2,opt,name=FRAMESIZE,proto3" json:"FRAMESIZE,omitempty"` //Number of bytes in the frame - IDCODE uint32 `protobuf:"varint,3,opt,name=IDCODE,proto3" json:"IDCODE,omitempty"` //Stream source ID number - SOC uint32 `protobuf:"varint,4,opt,name=SOC,proto3" json:"SOC,omitempty"` //SOC time stamp - FRACSEC uint32 `protobuf:"varint,5,opt,name=FRACSEC,proto3" json:"FRACSEC,omitempty"` //Fraction of Second and Message Time Quality + SYNC uint32 `protobuf:"varint,1,opt,name=SYNC,proto3" json:"SYNC,omitempty"` //Sync byte followed by frame type and version number + FRAMESIZE uint32 `protobuf:"varint,2,opt,name=FRAMESIZE,proto3" json:"FRAMESIZE,omitempty"` //Number of bytes in the frame + IDCODE uint32 `protobuf:"varint,3,opt,name=IDCODE,proto3" json:"IDCODE,omitempty"` //Stream source ID number + SOC uint32 `protobuf:"varint,4,opt,name=SOC,proto3" json:"SOC,omitempty"` //SOC time stamp + FRACSEC uint32 `protobuf:"varint,5,opt,name=FRACSEC,proto3" json:"FRACSEC,omitempty"` //Fraction of Second and Message Time Quality TIME_BASE uint32 `protobuf:"varint,6,opt,name=TIME_BASE,json=TIMEBASE,proto3" json:"TIME_BASE,omitempty"` //Resolution of FRACSEC time stamp - NUM_PMU uint32 `protobuf:"varint,7,opt,name=NUM_PMU,json=NUMPMU,proto3" json:"NUM_PMU,omitempty"` //The number of PMUs included in the data frame + NUM_PMU uint32 `protobuf:"varint,7,opt,name=NUM_PMU,json=NUMPMU,proto3" json:"NUM_PMU,omitempty"` //The number of PMUs included in the data frame } func (x *Conf2Header) Reset() { @@ -202,18 +202,18 @@ type Config struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - STN string `protobuf:"bytes,1,opt,name=STN,proto3" json:"STN,omitempty"` //Station name - IDCODE uint32 `protobuf:"varint,2,opt,name=IDCODE,proto3" json:"IDCODE,omitempty"` //Data source ID number - FORMAT uint32 `protobuf:"varint,3,opt,name=FORMAT,proto3" json:"FORMAT,omitempty"` //Data format within data frame - PHNMR uint32 `protobuf:"varint,4,opt,name=PHNMR,proto3" json:"PHNMR,omitempty"` //Number of phasors - ANNMR uint32 `protobuf:"varint,5,opt,name=ANNMR,proto3" json:"ANNMR,omitempty"` //Number of analog values - DGNMR uint32 `protobuf:"varint,6,opt,name=DGNMR,proto3" json:"DGNMR,omitempty"` //Number of digital status words - CHNAM string `protobuf:"bytes,7,opt,name=CHNAM,proto3" json:"CHNAM,omitempty"` //Phasor and channel names - PHUNIT []uint32 `protobuf:"varint,8,rep,packed,name=PHUNIT,proto3" json:"PHUNIT,omitempty"` //Conversion factor for phasor channels - ANUNIT []uint32 `protobuf:"varint,9,rep,packed,name=ANUNIT,proto3" json:"ANUNIT,omitempty"` //Conversion factor for analog channels + STN string `protobuf:"bytes,1,opt,name=STN,proto3" json:"STN,omitempty"` //Station name + IDCODE uint32 `protobuf:"varint,2,opt,name=IDCODE,proto3" json:"IDCODE,omitempty"` //Data source ID number + FORMAT uint32 `protobuf:"varint,3,opt,name=FORMAT,proto3" json:"FORMAT,omitempty"` //Data format within data frame + PHNMR uint32 `protobuf:"varint,4,opt,name=PHNMR,proto3" json:"PHNMR,omitempty"` //Number of phasors + ANNMR uint32 `protobuf:"varint,5,opt,name=ANNMR,proto3" json:"ANNMR,omitempty"` //Number of analog values + DGNMR uint32 `protobuf:"varint,6,opt,name=DGNMR,proto3" json:"DGNMR,omitempty"` //Number of digital status words + CHNAM string `protobuf:"bytes,7,opt,name=CHNAM,proto3" json:"CHNAM,omitempty"` //Phasor and channel names + PHUNIT []uint32 `protobuf:"varint,8,rep,packed,name=PHUNIT,proto3" json:"PHUNIT,omitempty"` //Conversion factor for phasor channels + ANUNIT []uint32 `protobuf:"varint,9,rep,packed,name=ANUNIT,proto3" json:"ANUNIT,omitempty"` //Conversion factor for analog channels DIGUNIT []uint32 `protobuf:"varint,10,rep,packed,name=DIGUNIT,proto3" json:"DIGUNIT,omitempty"` //Mask words for digital status words - FNOM uint32 `protobuf:"varint,11,opt,name=FNOM,proto3" json:"FNOM,omitempty"` //Nominal line frequency code and flags - CFGCNT uint32 `protobuf:"varint,12,opt,name=CFGCNT,proto3" json:"CFGCNT,omitempty"` //Configuration change count + FNOM uint32 `protobuf:"varint,11,opt,name=FNOM,proto3" json:"FNOM,omitempty"` //Nominal line frequency code and flags + CFGCNT uint32 `protobuf:"varint,12,opt,name=CFGCNT,proto3" json:"CFGCNT,omitempty"` //Configuration change count } func (x *Config) Reset() { @@ -388,9 +388,7 @@ var ( func file_zaphiro_c37118_v1_conf2_proto_rawDescGZIP() []byte { file_zaphiro_c37118_v1_conf2_proto_rawDescOnce.Do(func() { - file_zaphiro_c37118_v1_conf2_proto_rawDescData = protoimpl.X.CompressGZIP( - file_zaphiro_c37118_v1_conf2_proto_rawDescData, - ) + file_zaphiro_c37118_v1_conf2_proto_rawDescData = protoimpl.X.CompressGZIP(file_zaphiro_c37118_v1_conf2_proto_rawDescData) }) return file_zaphiro_c37118_v1_conf2_proto_rawDescData } diff --git a/go/c37118/v1/stat.pb.go b/go/c37118/v1/stat.pb.go index 4432a95..efed2dd 100644 --- a/go/c37118/v1/stat.pb.go +++ b/go/c37118/v1/stat.pb.go @@ -42,15 +42,15 @@ type Stat struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - MeasuredAt int64 `protobuf:"varint,1,opt,name=measuredAt,proto3" json:"measuredAt,omitempty"` // The time of creation of the stat data (Unix msec timestamp). - Error uint32 `protobuf:"varint,2,opt,name=error,proto3" json:"error,omitempty"` // Error code uint8 - Sync bool `protobuf:"varint,3,opt,name=sync,proto3" json:"sync,omitempty"` // Synchronization status - Sorting bool `protobuf:"varint,4,opt,name=sorting,proto3" json:"sorting,omitempty"` // Sorting status - Trigger bool `protobuf:"varint,5,opt,name=trigger,proto3" json:"trigger,omitempty"` // Trigger status - ConfigChange bool `protobuf:"varint,6,opt,name=configChange,proto3" json:"configChange,omitempty"` // Configuration change status - DataModified bool `protobuf:"varint,7,opt,name=dataModified,proto3" json:"dataModified,omitempty"` // Data modification status - TimeQuality uint32 `protobuf:"varint,8,opt,name=timeQuality,proto3" json:"timeQuality,omitempty"` // Time quality uint8 - UnlockedTime uint32 `protobuf:"varint,9,opt,name=unlockedTime,proto3" json:"unlockedTime,omitempty"` // Unlocked time uint8 + MeasuredAt int64 `protobuf:"varint,1,opt,name=measuredAt,proto3" json:"measuredAt,omitempty"` // The time of creation of the stat data (Unix msec timestamp). + Error uint32 `protobuf:"varint,2,opt,name=error,proto3" json:"error,omitempty"` // Error code uint8 + Sync bool `protobuf:"varint,3,opt,name=sync,proto3" json:"sync,omitempty"` // Synchronization status + Sorting bool `protobuf:"varint,4,opt,name=sorting,proto3" json:"sorting,omitempty"` // Sorting status + Trigger bool `protobuf:"varint,5,opt,name=trigger,proto3" json:"trigger,omitempty"` // Trigger status + ConfigChange bool `protobuf:"varint,6,opt,name=configChange,proto3" json:"configChange,omitempty"` // Configuration change status + DataModified bool `protobuf:"varint,7,opt,name=dataModified,proto3" json:"dataModified,omitempty"` // Data modification status + TimeQuality uint32 `protobuf:"varint,8,opt,name=timeQuality,proto3" json:"timeQuality,omitempty"` // Time quality uint8 + UnlockedTime uint32 `protobuf:"varint,9,opt,name=unlockedTime,proto3" json:"unlockedTime,omitempty"` // Unlocked time uint8 TriggerReason uint32 `protobuf:"varint,10,opt,name=triggerReason,proto3" json:"triggerReason,omitempty"` // Trigger reason uint8 } @@ -193,9 +193,7 @@ var ( func file_zaphiro_c37118_v1_stat_proto_rawDescGZIP() []byte { file_zaphiro_c37118_v1_stat_proto_rawDescOnce.Do(func() { - file_zaphiro_c37118_v1_stat_proto_rawDescData = protoimpl.X.CompressGZIP( - file_zaphiro_c37118_v1_stat_proto_rawDescData, - ) + file_zaphiro_c37118_v1_stat_proto_rawDescData = protoimpl.X.CompressGZIP(file_zaphiro_c37118_v1_stat_proto_rawDescData) }) return file_zaphiro_c37118_v1_stat_proto_rawDescData } diff --git a/go/grid/v1/data.pb.go b/go/grid/v1/data.pb.go index 06f9662..7d7ff25 100644 --- a/go/grid/v1/data.pb.go +++ b/go/grid/v1/data.pb.go @@ -238,9 +238,9 @@ type Data struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - DataType DataType `protobuf:"varint,1,opt,name=dataType,proto3,enum=zaphiro.grid.v1.DataType" json:"dataType,omitempty"` //The type of data see `DataType` enum. - MeasuredAt int64 `protobuf:"varint,2,opt,name=measuredAt,proto3" json:"measuredAt,omitempty"` //The time of measurement (Unix msec timestamp). - Value *uint64 `protobuf:"varint,3,opt,name=value,proto3,oneof" json:"value,omitempty"` //The data value casted to uint64. + DataType DataType `protobuf:"varint,1,opt,name=dataType,proto3,enum=zaphiro.grid.v1.DataType" json:"dataType,omitempty"` //The type of data see `DataType` enum. + MeasuredAt int64 `protobuf:"varint,2,opt,name=measuredAt,proto3" json:"measuredAt,omitempty"` //The time of measurement (Unix msec timestamp). + Value *uint64 `protobuf:"varint,3,opt,name=value,proto3,oneof" json:"value,omitempty"` //The data value casted to uint64. } func (x *Data) Reset() { @@ -301,8 +301,8 @@ type DataSet struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - ProducerId string `protobuf:"bytes,1,opt,name=producerId,proto3" json:"producerId,omitempty"` //The id of the device / service that produced the data set. - Data map[string]*Data `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` //The map of data included in the dataset. + ProducerId string `protobuf:"bytes,1,opt,name=producerId,proto3" json:"producerId,omitempty"` //The id of the device / service that produced the data set. + Data map[string]*Data `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` //The map of data included in the dataset. } func (x *DataSet) Reset() { @@ -487,9 +487,7 @@ var ( func file_zaphiro_grid_v1_data_proto_rawDescGZIP() []byte { file_zaphiro_grid_v1_data_proto_rawDescOnce.Do(func() { - file_zaphiro_grid_v1_data_proto_rawDescData = protoimpl.X.CompressGZIP( - file_zaphiro_grid_v1_data_proto_rawDescData, - ) + file_zaphiro_grid_v1_data_proto_rawDescData = protoimpl.X.CompressGZIP(file_zaphiro_grid_v1_data_proto_rawDescData) }) return file_zaphiro_grid_v1_data_proto_rawDescData } diff --git a/go/grid/v1/device_event.pb.go b/go/grid/v1/device_event.pb.go index e590792..cecd2b3 100644 --- a/go/grid/v1/device_event.pb.go +++ b/go/grid/v1/device_event.pb.go @@ -42,12 +42,12 @@ type DeviceEvent struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` //The base event message - DeviceID string `protobuf:"bytes,2,opt,name=deviceID,proto3" json:"deviceID,omitempty"` //The ID of the device where the event occurred. - SubstationID string `protobuf:"bytes,3,opt,name=substationID,proto3" json:"substationID,omitempty"` //The ID of the substation where the event occurred. - Value *float64 `protobuf:"fixed64,4,opt,name=value,proto3,oneof" json:"value,omitempty"` //The measured / estimated value in relation to the event. + Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` //The base event message + DeviceID string `protobuf:"bytes,2,opt,name=deviceID,proto3" json:"deviceID,omitempty"` //The ID of the device where the event occurred. + SubstationID string `protobuf:"bytes,3,opt,name=substationID,proto3" json:"substationID,omitempty"` //The ID of the substation where the event occurred. + Value *float64 `protobuf:"fixed64,4,opt,name=value,proto3,oneof" json:"value,omitempty"` //The measured / estimated value in relation to the event. ReferenceLimit *float64 `protobuf:"fixed64,5,opt,name=referenceLimit,proto3,oneof" json:"referenceLimit,omitempty"` //The reference limit or expected value. - Code *string `protobuf:"bytes,6,opt,name=code,proto3,oneof" json:"code,omitempty"` //The device event code (or the mapped string) + Code *string `protobuf:"bytes,6,opt,name=code,proto3,oneof" json:"code,omitempty"` //The device event code (or the mapped string) } func (x *DeviceEvent) Reset() { @@ -517,9 +517,7 @@ var ( func file_zaphiro_grid_v1_device_event_proto_rawDescGZIP() []byte { file_zaphiro_grid_v1_device_event_proto_rawDescOnce.Do(func() { - file_zaphiro_grid_v1_device_event_proto_rawDescData = protoimpl.X.CompressGZIP( - file_zaphiro_grid_v1_device_event_proto_rawDescData, - ) + file_zaphiro_grid_v1_device_event_proto_rawDescData = protoimpl.X.CompressGZIP(file_zaphiro_grid_v1_device_event_proto_rawDescData) }) return file_zaphiro_grid_v1_device_event_proto_rawDescData } diff --git a/go/grid/v1/event.pb.go b/go/grid/v1/event.pb.go index 74f87f2..890fdf0 100644 --- a/go/grid/v1/event.pb.go +++ b/go/grid/v1/event.pb.go @@ -150,13 +150,13 @@ type Event struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` //The uuid of the event. - SourceId string `protobuf:"bytes,2,opt,name=sourceId,proto3" json:"sourceId,omitempty"` //The id of the source (e.g. a PMU) that generated the event. + Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` //The uuid of the event. + SourceId string `protobuf:"bytes,2,opt,name=sourceId,proto3" json:"sourceId,omitempty"` //The id of the source (e.g. a PMU) that generated the event. SourceType EventSourceType `protobuf:"varint,3,opt,name=sourceType,proto3,enum=zaphiro.grid.v1.EventSourceType" json:"sourceType,omitempty"` //The type of data see `DataType` enum. - OccurredAt int64 `protobuf:"varint,4,opt,name=occurredAt,proto3" json:"occurredAt,omitempty"` //The time of occurency of the event (Unix msec timestamp) usually is the same value as timestampId. - DetectedAt *int64 `protobuf:"varint,5,opt,name=detectedAt,proto3,oneof" json:"detectedAt,omitempty"` //The time of detection of the event (Unix msec timestamp). - Message string `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"` //Event message. - Status *EventStatus `protobuf:"varint,7,opt,name=status,proto3,enum=zaphiro.grid.v1.EventStatus,oneof" json:"status,omitempty"` //The status of the event. + OccurredAt int64 `protobuf:"varint,4,opt,name=occurredAt,proto3" json:"occurredAt,omitempty"` //The time of occurency of the event (Unix msec timestamp) usually is the same value as timestampId. + DetectedAt *int64 `protobuf:"varint,5,opt,name=detectedAt,proto3,oneof" json:"detectedAt,omitempty"` //The time of detection of the event (Unix msec timestamp). + Message string `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"` //Event message. + Status *EventStatus `protobuf:"varint,7,opt,name=status,proto3,enum=zaphiro.grid.v1.EventStatus,oneof" json:"status,omitempty"` //The status of the event. } func (x *Event) Reset() { @@ -293,9 +293,7 @@ var ( func file_zaphiro_grid_v1_event_proto_rawDescGZIP() []byte { file_zaphiro_grid_v1_event_proto_rawDescOnce.Do(func() { - file_zaphiro_grid_v1_event_proto_rawDescData = protoimpl.X.CompressGZIP( - file_zaphiro_grid_v1_event_proto_rawDescData, - ) + file_zaphiro_grid_v1_event_proto_rawDescData = protoimpl.X.CompressGZIP(file_zaphiro_grid_v1_event_proto_rawDescData) }) return file_zaphiro_grid_v1_event_proto_rawDescData } diff --git a/go/grid/v1/fault.pb.go b/go/grid/v1/fault.pb.go index 15f6e75..8717471 100644 --- a/go/grid/v1/fault.pb.go +++ b/go/grid/v1/fault.pb.go @@ -274,18 +274,18 @@ type Fault struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` //The textual id of the fault. - Description *string `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"` //The textual description of the fault. - Kind PhaseConnectedFaultKind `protobuf:"varint,3,opt,name=kind,proto3,enum=zaphiro.grid.v1.PhaseConnectedFaultKind" json:"kind,omitempty"` //The kind of phase fault. - Phases PhaseCode `protobuf:"varint,4,opt,name=phases,proto3,enum=zaphiro.grid.v1.PhaseCode" json:"phases,omitempty"` //The phases participating in the fault. The fault connections into these phases are further specified by the type of fault. - UpdatedAt int64 `protobuf:"varint,5,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"` //The date and time at which the fault started/located/ended depending on the Fault Status (Unix msec timestamp). - FaultEventType FaultEventType `protobuf:"varint,6,opt,name=faultEventType,proto3,enum=zaphiro.grid.v1.FaultEventType" json:"faultEventType,omitempty"` //The type of the fault event. - FaultyEquipmentId *string `protobuf:"bytes,7,opt,name=faultyEquipmentId,proto3,oneof" json:"faultyEquipmentId,omitempty"` //The equipment with the fault. - FaultCurrent *float32 `protobuf:"fixed32,8,opt,name=faultCurrent,proto3,oneof" json:"faultCurrent,omitempty"` //The current associated to the fault. - ImpactedEquipmentIds []string `protobuf:"bytes,9,rep,name=impactedEquipmentIds,proto3" json:"impactedEquipmentIds,omitempty"` //The set of IDs of equipments impacted by the fault. - UsedMeasurementIds []*FaultMeasurement `protobuf:"bytes,10,rep,name=usedMeasurementIds,proto3" json:"usedMeasurementIds,omitempty"` //The set of measurements used to locate the fault. - MeasurementTimestamp *int64 `protobuf:"varint,11,opt,name=measurementTimestamp,proto3,oneof" json:"measurementTimestamp,omitempty"` // The timestamp of the measurements used to compute the fault location. - LocationProbability *float32 `protobuf:"fixed32,12,opt,name=locationProbability,proto3,oneof" json:"locationProbability,omitempty"` // The probability associated to the location. (This is relevant because multiple locations can be returned for a fault) + Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` //The textual id of the fault. + Description *string `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"` //The textual description of the fault. + Kind PhaseConnectedFaultKind `protobuf:"varint,3,opt,name=kind,proto3,enum=zaphiro.grid.v1.PhaseConnectedFaultKind" json:"kind,omitempty"` //The kind of phase fault. + Phases PhaseCode `protobuf:"varint,4,opt,name=phases,proto3,enum=zaphiro.grid.v1.PhaseCode" json:"phases,omitempty"` //The phases participating in the fault. The fault connections into these phases are further specified by the type of fault. + UpdatedAt int64 `protobuf:"varint,5,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"` //The date and time at which the fault started/located/ended depending on the Fault Status (Unix msec timestamp). + FaultEventType FaultEventType `protobuf:"varint,6,opt,name=faultEventType,proto3,enum=zaphiro.grid.v1.FaultEventType" json:"faultEventType,omitempty"` //The type of the fault event. + FaultyEquipmentId *string `protobuf:"bytes,7,opt,name=faultyEquipmentId,proto3,oneof" json:"faultyEquipmentId,omitempty"` //The equipment with the fault. + FaultCurrent *float32 `protobuf:"fixed32,8,opt,name=faultCurrent,proto3,oneof" json:"faultCurrent,omitempty"` //The current associated to the fault. + ImpactedEquipmentIds []string `protobuf:"bytes,9,rep,name=impactedEquipmentIds,proto3" json:"impactedEquipmentIds,omitempty"` //The set of IDs of equipments impacted by the fault. + UsedMeasurementIds []*FaultMeasurement `protobuf:"bytes,10,rep,name=usedMeasurementIds,proto3" json:"usedMeasurementIds,omitempty"` //The set of measurements used to locate the fault. + MeasurementTimestamp *int64 `protobuf:"varint,11,opt,name=measurementTimestamp,proto3,oneof" json:"measurementTimestamp,omitempty"` // The timestamp of the measurements used to compute the fault location. + LocationProbability *float32 `protobuf:"fixed32,12,opt,name=locationProbability,proto3,oneof" json:"locationProbability,omitempty"` // The probability associated to the location. (This is relevant because multiple locations can be returned for a fault) } func (x *Fault) Reset() { @@ -409,9 +409,9 @@ type LineFault struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Fault *Fault `protobuf:"bytes,1,opt,name=fault,proto3" json:"fault,omitempty"` //The base fault message. + Fault *Fault `protobuf:"bytes,1,opt,name=fault,proto3" json:"fault,omitempty"` //The base fault message. LengthFromTerminal1 *float32 `protobuf:"fixed32,2,opt,name=lengthFromTerminal1,proto3,oneof" json:"lengthFromTerminal1,omitempty"` //The length to the place where the fault is located starting from terminal with sequence number 1 of the faulted line segment. - LengthUncertainty *float32 `protobuf:"fixed32,3,opt,name=lengthUncertainty,proto3,oneof" json:"lengthUncertainty,omitempty"` //The +/- uncertainty on the reported length. + LengthUncertainty *float32 `protobuf:"fixed32,3,opt,name=lengthUncertainty,proto3,oneof" json:"lengthUncertainty,omitempty"` //The +/- uncertainty on the reported length. } func (x *LineFault) Reset() { @@ -472,7 +472,7 @@ type EquipmentFault struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Fault *Fault `protobuf:"bytes,1,opt,name=fault,proto3" json:"fault,omitempty"` //The base fault message. + Fault *Fault `protobuf:"bytes,1,opt,name=fault,proto3" json:"fault,omitempty"` //The base fault message. TerminalID *string `protobuf:"bytes,2,opt,name=terminalID,proto3,oneof" json:"terminalID,omitempty"` //The terminal connecting to the bus to which the fault is applied. } @@ -725,9 +725,7 @@ var ( func file_zaphiro_grid_v1_fault_proto_rawDescGZIP() []byte { file_zaphiro_grid_v1_fault_proto_rawDescOnce.Do(func() { - file_zaphiro_grid_v1_fault_proto_rawDescData = protoimpl.X.CompressGZIP( - file_zaphiro_grid_v1_fault_proto_rawDescData, - ) + file_zaphiro_grid_v1_fault_proto_rawDescData = protoimpl.X.CompressGZIP(file_zaphiro_grid_v1_fault_proto_rawDescData) }) return file_zaphiro_grid_v1_fault_proto_rawDescData } diff --git a/go/grid/v1/grid_event.pb.go b/go/grid/v1/grid_event.pb.go index d76e7d3..1def130 100644 --- a/go/grid/v1/grid_event.pb.go +++ b/go/grid/v1/grid_event.pb.go @@ -42,12 +42,12 @@ type GridEvent struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` //The base event message - ComponentID string `protobuf:"bytes,2,opt,name=componentID,proto3" json:"componentID,omitempty"` //The ID of the component where the event occurred. - SubstationID *string `protobuf:"bytes,3,opt,name=substationID,proto3,oneof" json:"substationID,omitempty"` //The ID of the substation where the event occurred. - Value float64 `protobuf:"fixed64,4,opt,name=value,proto3" json:"value,omitempty"` //The measured / estimated value in relation to the event (e.g. in the case of a `VoltageEvent` is the voltage, in the case of a `CurrentEvent` is the current event). - ReferenceLimit float64 `protobuf:"fixed64,5,opt,name=referenceLimit,proto3" json:"referenceLimit,omitempty"` //The reference limit or expected value. - Probability *float64 `protobuf:"fixed64,6,opt,name=probability,proto3,oneof" json:"probability,omitempty"` //The probability that the event actually occurred. + Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` //The base event message + ComponentID string `protobuf:"bytes,2,opt,name=componentID,proto3" json:"componentID,omitempty"` //The ID of the component where the event occurred. + SubstationID *string `protobuf:"bytes,3,opt,name=substationID,proto3,oneof" json:"substationID,omitempty"` //The ID of the substation where the event occurred. + Value float64 `protobuf:"fixed64,4,opt,name=value,proto3" json:"value,omitempty"` //The measured / estimated value in relation to the event (e.g. in the case of a `VoltageEvent` is the voltage, in the case of a `CurrentEvent` is the current event). + ReferenceLimit float64 `protobuf:"fixed64,5,opt,name=referenceLimit,proto3" json:"referenceLimit,omitempty"` //The reference limit or expected value. + Probability *float64 `protobuf:"fixed64,6,opt,name=probability,proto3,oneof" json:"probability,omitempty"` //The probability that the event actually occurred. } func (x *GridEvent) Reset() { @@ -129,7 +129,7 @@ type VoltageEvent struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Event *GridEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` //The base grid event message + Event *GridEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` //The base grid event message PhaseCode *PhaseCode `protobuf:"varint,2,opt,name=phaseCode,proto3,enum=zaphiro.grid.v1.PhaseCode,oneof" json:"phaseCode,omitempty"` //The phase for which the event occured } @@ -997,9 +997,7 @@ var ( func file_zaphiro_grid_v1_grid_event_proto_rawDescGZIP() []byte { file_zaphiro_grid_v1_grid_event_proto_rawDescOnce.Do(func() { - file_zaphiro_grid_v1_grid_event_proto_rawDescData = protoimpl.X.CompressGZIP( - file_zaphiro_grid_v1_grid_event_proto_rawDescData, - ) + file_zaphiro_grid_v1_grid_event_proto_rawDescData = protoimpl.X.CompressGZIP(file_zaphiro_grid_v1_grid_event_proto_rawDescData) }) return file_zaphiro_grid_v1_grid_event_proto_rawDescData } diff --git a/go/grid/v1/topology.pb.go b/go/grid/v1/topology.pb.go index 768fc64..22511d8 100644 --- a/go/grid/v1/topology.pb.go +++ b/go/grid/v1/topology.pb.go @@ -43,7 +43,7 @@ type Topology struct { unknownFields protoimpl.UnknownFields CreatedAt int64 `protobuf:"varint,1,opt,name=createdAt,proto3" json:"createdAt,omitempty"` // The time of creation of the topology data (Unix msec timestamp). - Tp []byte `protobuf:"bytes,2,opt,name=tp,proto3" json:"tp,omitempty"` // The TP profile file serialized as bytes. + Tp []byte `protobuf:"bytes,2,opt,name=tp,proto3" json:"tp,omitempty"` // The TP profile file serialized as bytes. } func (x *Topology) Reset() { @@ -99,12 +99,12 @@ type TopologicalNode struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - TerminalIds []string `protobuf:"bytes,1,rep,name=TerminalIds,proto3" json:"TerminalIds,omitempty"` //The list of Terminal ids in the TopologicalNode. - ConnectivityNodeIds []string `protobuf:"bytes,2,rep,name=ConnectivityNodeIds,proto3" json:"ConnectivityNodeIds,omitempty"` //The list of ConnectivityNode ids in the TopologicalNode. - BranchIds []string `protobuf:"bytes,3,rep,name=BranchIds,proto3" json:"BranchIds,omitempty"` //The list of Branch ids in the TopologicalNode. + TerminalIds []string `protobuf:"bytes,1,rep,name=TerminalIds,proto3" json:"TerminalIds,omitempty"` //The list of Terminal ids in the TopologicalNode. + ConnectivityNodeIds []string `protobuf:"bytes,2,rep,name=ConnectivityNodeIds,proto3" json:"ConnectivityNodeIds,omitempty"` //The list of ConnectivityNode ids in the TopologicalNode. + BranchIds []string `protobuf:"bytes,3,rep,name=BranchIds,proto3" json:"BranchIds,omitempty"` //The list of Branch ids in the TopologicalNode. ConnectivityNodeContainerId string `protobuf:"bytes,4,opt,name=ConnectivityNodeContainerId,proto3" json:"ConnectivityNodeContainerId,omitempty"` //The id of the ConnectivityNodeContainer in the TopologicalNode. - BaseVoltageId string `protobuf:"bytes,5,opt,name=BaseVoltageId,proto3" json:"BaseVoltageId,omitempty"` //The id of the BaseVoltage in the TopologicalNode. - BaseVoltage float64 `protobuf:"fixed64,6,opt,name=BaseVoltage,proto3" json:"BaseVoltage,omitempty"` //The BaseVoltage in the TopologicalNode. + BaseVoltageId string `protobuf:"bytes,5,opt,name=BaseVoltageId,proto3" json:"BaseVoltageId,omitempty"` //The id of the BaseVoltage in the TopologicalNode. + BaseVoltage float64 `protobuf:"fixed64,6,opt,name=BaseVoltage,proto3" json:"BaseVoltage,omitempty"` //The BaseVoltage in the TopologicalNode. } func (x *TopologicalNode) Reset() { @@ -188,7 +188,7 @@ type TopologicalIsland struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` //The id of the TopologicalIsland. + Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` //The id of the TopologicalIsland. TopologicalNodes map[string]*TopologicalNode `protobuf:"bytes,2,rep,name=TopologicalNodes,proto3" json:"TopologicalNodes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` //The list of TopologicalNode in the TopologicalIsland. TN id -> TN. } @@ -299,9 +299,9 @@ type ComputedTopology struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - EqId string `protobuf:"bytes,1,opt,name=eqId,proto3" json:"eqId,omitempty"` //The id of the EQ file used. + EqId string `protobuf:"bytes,1,opt,name=eqId,proto3" json:"eqId,omitempty"` //The id of the EQ file used. TopologicalIslands map[string]*TopologicalIsland `protobuf:"bytes,2,rep,name=topologicalIslands,proto3" json:"topologicalIslands,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` // The map of TopologicalIslands in the Topology. TI id -> TI. - BranchConnections map[string]*BranchConnection `protobuf:"bytes,3,rep,name=BranchConnections,proto3" json:"BranchConnections,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` // All the connections between the TopologicalNodes in the TopologicalIsland. TN id -> TN connection. + BranchConnections map[string]*BranchConnection `protobuf:"bytes,3,rep,name=BranchConnections,proto3" json:"BranchConnections,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` // All the connections between the TopologicalNodes in the TopologicalIsland. TN id -> TN connection. } func (x *ComputedTopology) Reset() { @@ -443,9 +443,7 @@ var ( func file_zaphiro_grid_v1_topology_proto_rawDescGZIP() []byte { file_zaphiro_grid_v1_topology_proto_rawDescOnce.Do(func() { - file_zaphiro_grid_v1_topology_proto_rawDescData = protoimpl.X.CompressGZIP( - file_zaphiro_grid_v1_topology_proto_rawDescData, - ) + file_zaphiro_grid_v1_topology_proto_rawDescData = protoimpl.X.CompressGZIP(file_zaphiro_grid_v1_topology_proto_rawDescData) }) return file_zaphiro_grid_v1_topology_proto_rawDescData } diff --git a/go/platform/v1/task.pb.go b/go/platform/v1/task.pb.go index d02c69f..e5d1390 100644 --- a/go/platform/v1/task.pb.go +++ b/go/platform/v1/task.pb.go @@ -159,7 +159,7 @@ type Parameter struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` //The parameter name + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` //The parameter name Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` //The parameter value } @@ -214,9 +214,9 @@ type Task struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - TaskType TaskType `protobuf:"varint,1,opt,name=taskType,proto3,enum=zaphiro.platform.v1.TaskType" json:"taskType,omitempty"` //Type of the task - CreatedAt int64 `protobuf:"varint,2,opt,name=createdAt,proto3" json:"createdAt,omitempty"` //Task creation time (Unix msec timestamp) - Parameters []*Parameter `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty"` + TaskType TaskType `protobuf:"varint,1,opt,name=taskType,proto3,enum=zaphiro.platform.v1.TaskType" json:"taskType,omitempty"` //Type of the task + CreatedAt int64 `protobuf:"varint,2,opt,name=createdAt,proto3" json:"createdAt,omitempty"` //Task creation time (Unix msec timestamp) + Parameters []*Parameter `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty"` } func (x *Task) Reset() { @@ -278,9 +278,9 @@ type Notification struct { unknownFields protoimpl.UnknownFields NotificationType NotificationType `protobuf:"varint,1,opt,name=notificationType,proto3,enum=zaphiro.platform.v1.NotificationType" json:"notificationType,omitempty"` //Notification type - CreatedAt int64 `protobuf:"varint,2,opt,name=createdAt,proto3" json:"createdAt,omitempty"` //Notification creation time (Unix msec timestamp) - Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` //Notification message, it can be a string or a integer (which maps to a enum value). - Parameters []*Parameter `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty"` + CreatedAt int64 `protobuf:"varint,2,opt,name=createdAt,proto3" json:"createdAt,omitempty"` //Notification creation time (Unix msec timestamp) + Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` //Notification message, it can be a string or a integer (which maps to a enum value). + Parameters []*Parameter `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty"` } func (x *Notification) Reset() { @@ -415,9 +415,7 @@ var ( func file_zaphiro_platform_v1_task_proto_rawDescGZIP() []byte { file_zaphiro_platform_v1_task_proto_rawDescOnce.Do(func() { - file_zaphiro_platform_v1_task_proto_rawDescData = protoimpl.X.CompressGZIP( - file_zaphiro_platform_v1_task_proto_rawDescData, - ) + file_zaphiro_platform_v1_task_proto_rawDescData = protoimpl.X.CompressGZIP(file_zaphiro_platform_v1_task_proto_rawDescData) }) return file_zaphiro_platform_v1_task_proto_rawDescData }