diff --git a/core/capabilities/remote/types/messages.pb.go b/core/capabilities/remote/types/messages.pb.go index dcbca5d6398..3fe12775c6e 100644 --- a/core/capabilities/remote/types/messages.pb.go +++ b/core/capabilities/remote/types/messages.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.4 +// protoc-gen-go v1.35.2 // protoc v5.29.3 // source: core/capabilities/remote/types/messages.proto @@ -11,7 +11,6 @@ import ( protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" - unsafe "unsafe" ) const ( @@ -80,11 +79,12 @@ func (Error) EnumDescriptor() ([]byte, []int) { } type Message struct { - state protoimpl.MessageState `protogen:"open.v1"` - Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"` - Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // proto-encoded MessageBody to sign - unknownFields protoimpl.UnknownFields + state protoimpl.MessageState sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"` + Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // proto-encoded MessageBody to sign } func (x *Message) Reset() { @@ -132,27 +132,28 @@ func (x *Message) GetBody() []byte { } type MessageBody struct { - state protoimpl.MessageState `protogen:"open.v1"` - Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` - Sender []byte `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"` - Receiver []byte `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"` - Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` - MessageId []byte `protobuf:"bytes,5,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` // scoped to sender - CapabilityId string `protobuf:"bytes,6,opt,name=capability_id,json=capabilityId,proto3" json:"capability_id,omitempty"` - Method string `protobuf:"bytes,9,opt,name=method,proto3" json:"method,omitempty"` - Error Error `protobuf:"varint,10,opt,name=error,proto3,enum=remote.Error" json:"error,omitempty"` - ErrorMsg string `protobuf:"bytes,11,opt,name=errorMsg,proto3" json:"errorMsg,omitempty"` + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` + Sender []byte `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"` + Receiver []byte `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"` + Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + MessageId []byte `protobuf:"bytes,5,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` // scoped to sender + CapabilityId string `protobuf:"bytes,6,opt,name=capability_id,json=capabilityId,proto3" json:"capability_id,omitempty"` + Method string `protobuf:"bytes,9,opt,name=method,proto3" json:"method,omitempty"` + Error Error `protobuf:"varint,10,opt,name=error,proto3,enum=remote.Error" json:"error,omitempty"` + ErrorMsg string `protobuf:"bytes,11,opt,name=errorMsg,proto3" json:"errorMsg,omitempty"` // payload contains a CapabilityRequest or CapabilityResponse Payload []byte `protobuf:"bytes,12,opt,name=payload,proto3" json:"payload,omitempty"` - // Types that are valid to be assigned to Metadata: + // Types that are assignable to Metadata: // // *MessageBody_TriggerRegistrationMetadata // *MessageBody_TriggerEventMetadata Metadata isMessageBody_Metadata `protobuf_oneof:"metadata"` CapabilityDonId uint32 `protobuf:"varint,15,opt,name=capability_don_id,json=capabilityDonId,proto3" json:"capability_don_id,omitempty"` CallerDonId uint32 `protobuf:"varint,16,opt,name=caller_don_id,json=callerDonId,proto3" json:"caller_don_id,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache } func (x *MessageBody) Reset() { @@ -255,27 +256,23 @@ func (x *MessageBody) GetPayload() []byte { return nil } -func (x *MessageBody) GetMetadata() isMessageBody_Metadata { - if x != nil { - return x.Metadata +func (m *MessageBody) GetMetadata() isMessageBody_Metadata { + if m != nil { + return m.Metadata } return nil } func (x *MessageBody) GetTriggerRegistrationMetadata() *TriggerRegistrationMetadata { - if x != nil { - if x, ok := x.Metadata.(*MessageBody_TriggerRegistrationMetadata); ok { - return x.TriggerRegistrationMetadata - } + if x, ok := x.GetMetadata().(*MessageBody_TriggerRegistrationMetadata); ok { + return x.TriggerRegistrationMetadata } return nil } func (x *MessageBody) GetTriggerEventMetadata() *TriggerEventMetadata { - if x != nil { - if x, ok := x.Metadata.(*MessageBody_TriggerEventMetadata); ok { - return x.TriggerEventMetadata - } + if x, ok := x.GetMetadata().(*MessageBody_TriggerEventMetadata); ok { + return x.TriggerEventMetadata } return nil } @@ -311,10 +308,11 @@ func (*MessageBody_TriggerRegistrationMetadata) isMessageBody_Metadata() {} func (*MessageBody_TriggerEventMetadata) isMessageBody_Metadata() {} type TriggerRegistrationMetadata struct { - state protoimpl.MessageState `protogen:"open.v1"` - LastReceivedEventId string `protobuf:"bytes,1,opt,name=last_received_event_id,json=lastReceivedEventId,proto3" json:"last_received_event_id,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + LastReceivedEventId string `protobuf:"bytes,1,opt,name=last_received_event_id,json=lastReceivedEventId,proto3" json:"last_received_event_id,omitempty"` } func (x *TriggerRegistrationMetadata) Reset() { @@ -355,11 +353,12 @@ func (x *TriggerRegistrationMetadata) GetLastReceivedEventId() string { } type TriggerEventMetadata struct { - state protoimpl.MessageState `protogen:"open.v1"` - TriggerEventId string `protobuf:"bytes,1,opt,name=trigger_event_id,json=triggerEventId,proto3" json:"trigger_event_id,omitempty"` - WorkflowIds []string `protobuf:"bytes,2,rep,name=workflow_ids,json=workflowIds,proto3" json:"workflow_ids,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + TriggerEventId string `protobuf:"bytes,1,opt,name=trigger_event_id,json=triggerEventId,proto3" json:"trigger_event_id,omitempty"` + WorkflowIds []string `protobuf:"bytes,2,rep,name=workflow_ids,json=workflowIds,proto3" json:"workflow_ids,omitempty"` } func (x *TriggerEventMetadata) Reset() { @@ -408,7 +407,7 @@ func (x *TriggerEventMetadata) GetWorkflowIds() []string { var File_core_capabilities_remote_types_messages_proto protoreflect.FileDescriptor -var file_core_capabilities_remote_types_messages_proto_rawDesc = string([]byte{ +var file_core_capabilities_remote_types_messages_proto_rawDesc = []byte{ 0x0a, 0x2d, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x63, 0x61, 0x70, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x69, 0x65, 0x73, 0x2f, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x2f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, @@ -476,16 +475,16 @@ var file_core_capabilities_remote_types_messages_proto_rawDesc = string([]byte{ 0x05, 0x42, 0x20, 0x5a, 0x1e, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x63, 0x61, 0x70, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x69, 0x65, 0x73, 0x2f, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x2f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -}) +} var ( file_core_capabilities_remote_types_messages_proto_rawDescOnce sync.Once - file_core_capabilities_remote_types_messages_proto_rawDescData []byte + file_core_capabilities_remote_types_messages_proto_rawDescData = file_core_capabilities_remote_types_messages_proto_rawDesc ) func file_core_capabilities_remote_types_messages_proto_rawDescGZIP() []byte { file_core_capabilities_remote_types_messages_proto_rawDescOnce.Do(func() { - file_core_capabilities_remote_types_messages_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_core_capabilities_remote_types_messages_proto_rawDesc), len(file_core_capabilities_remote_types_messages_proto_rawDesc))) + file_core_capabilities_remote_types_messages_proto_rawDescData = protoimpl.X.CompressGZIP(file_core_capabilities_remote_types_messages_proto_rawDescData) }) return file_core_capabilities_remote_types_messages_proto_rawDescData } @@ -523,7 +522,7 @@ func file_core_capabilities_remote_types_messages_proto_init() { out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: unsafe.Slice(unsafe.StringData(file_core_capabilities_remote_types_messages_proto_rawDesc), len(file_core_capabilities_remote_types_messages_proto_rawDesc)), + RawDescriptor: file_core_capabilities_remote_types_messages_proto_rawDesc, NumEnums: 1, NumMessages: 4, NumExtensions: 0, @@ -535,6 +534,7 @@ func file_core_capabilities_remote_types_messages_proto_init() { MessageInfos: file_core_capabilities_remote_types_messages_proto_msgTypes, }.Build() File_core_capabilities_remote_types_messages_proto = out.File + file_core_capabilities_remote_types_messages_proto_rawDesc = nil file_core_capabilities_remote_types_messages_proto_goTypes = nil file_core_capabilities_remote_types_messages_proto_depIdxs = nil } diff --git a/core/services/llo/attested_retirement_report.pb.go b/core/services/llo/attested_retirement_report.pb.go index d093a8eda25..9be4dc5bb8d 100644 --- a/core/services/llo/attested_retirement_report.pb.go +++ b/core/services/llo/attested_retirement_report.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.4 +// protoc-gen-go v1.35.2 // protoc v5.29.3 // source: attested_retirement_report.proto @@ -11,7 +11,6 @@ import ( protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" - unsafe "unsafe" ) const ( @@ -22,12 +21,13 @@ const ( ) type AttestedRetirementReport struct { - state protoimpl.MessageState `protogen:"open.v1"` + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + RetirementReport []byte `protobuf:"bytes,1,opt,name=retirementReport,proto3" json:"retirementReport,omitempty"` SeqNr uint64 `protobuf:"varint,2,opt,name=seqNr,proto3" json:"seqNr,omitempty"` Sigs []*AttributedOnchainSignature `protobuf:"bytes,3,rep,name=sigs,proto3" json:"sigs,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache } func (x *AttestedRetirementReport) Reset() { @@ -82,11 +82,12 @@ func (x *AttestedRetirementReport) GetSigs() []*AttributedOnchainSignature { } type AttributedOnchainSignature struct { - state protoimpl.MessageState `protogen:"open.v1"` - Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"` - Signer uint32 `protobuf:"varint,2,opt,name=signer,proto3" json:"signer,omitempty"` - unknownFields protoimpl.UnknownFields + state protoimpl.MessageState sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"` + Signer uint32 `protobuf:"varint,2,opt,name=signer,proto3" json:"signer,omitempty"` } func (x *AttributedOnchainSignature) Reset() { @@ -135,7 +136,7 @@ func (x *AttributedOnchainSignature) GetSigner() uint32 { var File_attested_retirement_report_proto protoreflect.FileDescriptor -var file_attested_retirement_report_proto_rawDesc = string([]byte{ +var file_attested_retirement_report_proto_rawDesc = []byte{ 0x0a, 0x20, 0x61, 0x74, 0x74, 0x65, 0x73, 0x74, 0x65, 0x64, 0x5f, 0x72, 0x65, 0x74, 0x69, 0x72, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x72, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x03, 0x6c, 0x6c, 0x6f, 0x22, 0x91, 0x01, 0x0a, 0x18, 0x41, 0x74, 0x74, 0x65, @@ -158,16 +159,16 @@ var file_attested_retirement_report_proto_rawDesc = string([]byte{ 0x68, 0x61, 0x69, 0x6e, 0x6c, 0x69, 0x6e, 0x6b, 0x2f, 0x76, 0x32, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x73, 0x2f, 0x6c, 0x6c, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -}) +} var ( file_attested_retirement_report_proto_rawDescOnce sync.Once - file_attested_retirement_report_proto_rawDescData []byte + file_attested_retirement_report_proto_rawDescData = file_attested_retirement_report_proto_rawDesc ) func file_attested_retirement_report_proto_rawDescGZIP() []byte { file_attested_retirement_report_proto_rawDescOnce.Do(func() { - file_attested_retirement_report_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_attested_retirement_report_proto_rawDesc), len(file_attested_retirement_report_proto_rawDesc))) + file_attested_retirement_report_proto_rawDescData = protoimpl.X.CompressGZIP(file_attested_retirement_report_proto_rawDescData) }) return file_attested_retirement_report_proto_rawDescData } @@ -195,7 +196,7 @@ func file_attested_retirement_report_proto_init() { out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: unsafe.Slice(unsafe.StringData(file_attested_retirement_report_proto_rawDesc), len(file_attested_retirement_report_proto_rawDesc)), + RawDescriptor: file_attested_retirement_report_proto_rawDesc, NumEnums: 0, NumMessages: 2, NumExtensions: 0, @@ -206,6 +207,7 @@ func file_attested_retirement_report_proto_init() { MessageInfos: file_attested_retirement_report_proto_msgTypes, }.Build() File_attested_retirement_report_proto = out.File + file_attested_retirement_report_proto_rawDesc = nil file_attested_retirement_report_proto_goTypes = nil file_attested_retirement_report_proto_depIdxs = nil } diff --git a/core/services/llo/telem/telem_streams.pb.go b/core/services/llo/telem/telem_streams.pb.go index 1ea10cf35ab..646fec7eb4b 100644 --- a/core/services/llo/telem/telem_streams.pb.go +++ b/core/services/llo/telem/telem_streams.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.4 +// protoc-gen-go v1.35.2 // protoc v5.29.3 // source: telem_streams.proto @@ -11,7 +11,6 @@ import ( protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" - unsafe "unsafe" ) const ( @@ -22,24 +21,25 @@ const ( ) type LLOBridgeTelemetry struct { - state protoimpl.MessageState `protogen:"open.v1"` - BridgeAdapterName string `protobuf:"bytes,1,opt,name=bridge_adapter_name,json=bridgeAdapterName,proto3" json:"bridge_adapter_name,omitempty"` - BridgeRequestData []byte `protobuf:"bytes,2,opt,name=bridge_request_data,json=bridgeRequestData,proto3" json:"bridge_request_data,omitempty"` - BridgeResponseData []byte `protobuf:"bytes,3,opt,name=bridge_response_data,json=bridgeResponseData,proto3" json:"bridge_response_data,omitempty"` - BridgeResponseError *string `protobuf:"bytes,4,opt,name=bridge_response_error,json=bridgeResponseError,proto3,oneof" json:"bridge_response_error,omitempty"` - BridgeResponseStatusCode int32 `protobuf:"varint,5,opt,name=bridge_response_status_code,json=bridgeResponseStatusCode,proto3" json:"bridge_response_status_code,omitempty"` - RequestStartTimestamp int64 `protobuf:"varint,6,opt,name=request_start_timestamp,json=requestStartTimestamp,proto3" json:"request_start_timestamp,omitempty"` - RequestFinishTimestamp int64 `protobuf:"varint,7,opt,name=request_finish_timestamp,json=requestFinishTimestamp,proto3" json:"request_finish_timestamp,omitempty"` - LocalCacheHit bool `protobuf:"varint,8,opt,name=local_cache_hit,json=localCacheHit,proto3" json:"local_cache_hit,omitempty"` - SpecId int32 `protobuf:"varint,9,opt,name=spec_id,json=specId,proto3" json:"spec_id,omitempty"` - StreamId *uint32 `protobuf:"varint,10,opt,name=stream_id,json=streamId,proto3,oneof" json:"stream_id,omitempty"` - DotId string `protobuf:"bytes,11,opt,name=dot_id,json=dotId,proto3" json:"dot_id,omitempty"` - DonId uint32 `protobuf:"varint,12,opt,name=don_id,json=donId,proto3" json:"don_id,omitempty"` - SeqNr uint64 `protobuf:"varint,13,opt,name=seq_nr,json=seqNr,proto3" json:"seq_nr,omitempty"` - ConfigDigest []byte `protobuf:"bytes,14,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"` - ObservationTimestamp int64 `protobuf:"varint,15,opt,name=observation_timestamp,json=observationTimestamp,proto3" json:"observation_timestamp,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + BridgeAdapterName string `protobuf:"bytes,1,opt,name=bridge_adapter_name,json=bridgeAdapterName,proto3" json:"bridge_adapter_name,omitempty"` + BridgeRequestData []byte `protobuf:"bytes,2,opt,name=bridge_request_data,json=bridgeRequestData,proto3" json:"bridge_request_data,omitempty"` + BridgeResponseData []byte `protobuf:"bytes,3,opt,name=bridge_response_data,json=bridgeResponseData,proto3" json:"bridge_response_data,omitempty"` + BridgeResponseError *string `protobuf:"bytes,4,opt,name=bridge_response_error,json=bridgeResponseError,proto3,oneof" json:"bridge_response_error,omitempty"` + BridgeResponseStatusCode int32 `protobuf:"varint,5,opt,name=bridge_response_status_code,json=bridgeResponseStatusCode,proto3" json:"bridge_response_status_code,omitempty"` + RequestStartTimestamp int64 `protobuf:"varint,6,opt,name=request_start_timestamp,json=requestStartTimestamp,proto3" json:"request_start_timestamp,omitempty"` + RequestFinishTimestamp int64 `protobuf:"varint,7,opt,name=request_finish_timestamp,json=requestFinishTimestamp,proto3" json:"request_finish_timestamp,omitempty"` + LocalCacheHit bool `protobuf:"varint,8,opt,name=local_cache_hit,json=localCacheHit,proto3" json:"local_cache_hit,omitempty"` + SpecId int32 `protobuf:"varint,9,opt,name=spec_id,json=specId,proto3" json:"spec_id,omitempty"` + StreamId *uint32 `protobuf:"varint,10,opt,name=stream_id,json=streamId,proto3,oneof" json:"stream_id,omitempty"` + DotId string `protobuf:"bytes,11,opt,name=dot_id,json=dotId,proto3" json:"dot_id,omitempty"` + DonId uint32 `protobuf:"varint,12,opt,name=don_id,json=donId,proto3" json:"don_id,omitempty"` + SeqNr uint64 `protobuf:"varint,13,opt,name=seq_nr,json=seqNr,proto3" json:"seq_nr,omitempty"` + ConfigDigest []byte `protobuf:"bytes,14,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"` + ObservationTimestamp int64 `protobuf:"varint,15,opt,name=observation_timestamp,json=observationTimestamp,proto3" json:"observation_timestamp,omitempty"` } func (x *LLOBridgeTelemetry) Reset() { @@ -178,19 +178,20 @@ func (x *LLOBridgeTelemetry) GetObservationTimestamp() int64 { } type LLOObservationTelemetry struct { - state protoimpl.MessageState `protogen:"open.v1"` - StreamId uint32 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` - StreamValueType int32 `protobuf:"varint,2,opt,name=stream_value_type,json=streamValueType,proto3" json:"stream_value_type,omitempty"` - StreamValueBinary []byte `protobuf:"bytes,3,opt,name=stream_value_binary,json=streamValueBinary,proto3" json:"stream_value_binary,omitempty"` - StreamValueText string `protobuf:"bytes,4,opt,name=stream_value_text,json=streamValueText,proto3" json:"stream_value_text,omitempty"` - ObservationError *string `protobuf:"bytes,5,opt,name=observation_error,json=observationError,proto3,oneof" json:"observation_error,omitempty"` - ObservationTimestamp int64 `protobuf:"varint,6,opt,name=observation_timestamp,json=observationTimestamp,proto3" json:"observation_timestamp,omitempty"` - ObservationFinishedAt int64 `protobuf:"varint,7,opt,name=observation_finished_at,json=observationFinishedAt,proto3" json:"observation_finished_at,omitempty"` - DonId uint32 `protobuf:"varint,8,opt,name=don_id,json=donId,proto3" json:"don_id,omitempty"` - SeqNr uint64 `protobuf:"varint,9,opt,name=seq_nr,json=seqNr,proto3" json:"seq_nr,omitempty"` - ConfigDigest []byte `protobuf:"bytes,10,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + StreamId uint32 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` + StreamValueType int32 `protobuf:"varint,2,opt,name=stream_value_type,json=streamValueType,proto3" json:"stream_value_type,omitempty"` + StreamValueBinary []byte `protobuf:"bytes,3,opt,name=stream_value_binary,json=streamValueBinary,proto3" json:"stream_value_binary,omitempty"` + StreamValueText string `protobuf:"bytes,4,opt,name=stream_value_text,json=streamValueText,proto3" json:"stream_value_text,omitempty"` + ObservationError *string `protobuf:"bytes,5,opt,name=observation_error,json=observationError,proto3,oneof" json:"observation_error,omitempty"` + ObservationTimestamp int64 `protobuf:"varint,6,opt,name=observation_timestamp,json=observationTimestamp,proto3" json:"observation_timestamp,omitempty"` + ObservationFinishedAt int64 `protobuf:"varint,7,opt,name=observation_finished_at,json=observationFinishedAt,proto3" json:"observation_finished_at,omitempty"` + DonId uint32 `protobuf:"varint,8,opt,name=don_id,json=donId,proto3" json:"don_id,omitempty"` + SeqNr uint64 `protobuf:"varint,9,opt,name=seq_nr,json=seqNr,proto3" json:"seq_nr,omitempty"` + ConfigDigest []byte `protobuf:"bytes,10,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"` } func (x *LLOObservationTelemetry) Reset() { @@ -295,7 +296,7 @@ func (x *LLOObservationTelemetry) GetConfigDigest() []byte { var File_telem_streams_proto protoreflect.FileDescriptor -var file_telem_streams_proto_rawDesc = string([]byte{ +var file_telem_streams_proto_rawDesc = []byte{ 0x0a, 0x13, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x22, 0xba, 0x05, 0x0a, 0x12, 0x4c, 0x4c, 0x4f, 0x42, 0x72, 0x69, 0x64, 0x67, 0x65, 0x54, 0x65, 0x6c, 0x65, 0x6d, 0x65, @@ -375,16 +376,16 @@ var file_telem_streams_proto_rawDesc = string([]byte{ 0x74, 0x2f, 0x63, 0x68, 0x61, 0x69, 0x6e, 0x6c, 0x69, 0x6e, 0x6b, 0x2f, 0x76, 0x32, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x73, 0x2f, 0x6c, 0x6c, 0x6f, 0x2f, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -}) +} var ( file_telem_streams_proto_rawDescOnce sync.Once - file_telem_streams_proto_rawDescData []byte + file_telem_streams_proto_rawDescData = file_telem_streams_proto_rawDesc ) func file_telem_streams_proto_rawDescGZIP() []byte { file_telem_streams_proto_rawDescOnce.Do(func() { - file_telem_streams_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_telem_streams_proto_rawDesc), len(file_telem_streams_proto_rawDesc))) + file_telem_streams_proto_rawDescData = protoimpl.X.CompressGZIP(file_telem_streams_proto_rawDescData) }) return file_telem_streams_proto_rawDescData } @@ -413,7 +414,7 @@ func file_telem_streams_proto_init() { out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: unsafe.Slice(unsafe.StringData(file_telem_streams_proto_rawDesc), len(file_telem_streams_proto_rawDesc)), + RawDescriptor: file_telem_streams_proto_rawDesc, NumEnums: 0, NumMessages: 2, NumExtensions: 0, @@ -424,6 +425,7 @@ func file_telem_streams_proto_init() { MessageInfos: file_telem_streams_proto_msgTypes, }.Build() File_telem_streams_proto = out.File + file_telem_streams_proto_rawDesc = nil file_telem_streams_proto_goTypes = nil file_telem_streams_proto_depIdxs = nil } diff --git a/core/services/relay/evm/mercury/wsrpc/pb/mercury.pb.go b/core/services/relay/evm/mercury/wsrpc/pb/mercury.pb.go index 260a8c25a24..3c28fe46770 100644 --- a/core/services/relay/evm/mercury/wsrpc/pb/mercury.pb.go +++ b/core/services/relay/evm/mercury/wsrpc/pb/mercury.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.4 +// protoc-gen-go v1.35.2 // protoc v5.29.3 // source: mercury.proto @@ -11,7 +11,6 @@ import ( protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" - unsafe "unsafe" ) const ( @@ -22,11 +21,12 @@ const ( ) type TransmitRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` - ReportFormat uint32 `protobuf:"varint,2,opt,name=reportFormat,proto3" json:"reportFormat,omitempty"` - unknownFields protoimpl.UnknownFields + state protoimpl.MessageState sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` + ReportFormat uint32 `protobuf:"varint,2,opt,name=reportFormat,proto3" json:"reportFormat,omitempty"` } func (x *TransmitRequest) Reset() { @@ -74,11 +74,12 @@ func (x *TransmitRequest) GetReportFormat() uint32 { } type TransmitResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` - Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` - unknownFields protoimpl.UnknownFields + state protoimpl.MessageState sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` + Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` } func (x *TransmitResponse) Reset() { @@ -126,10 +127,11 @@ func (x *TransmitResponse) GetError() string { } type LatestReportRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - FeedId []byte `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"` - unknownFields protoimpl.UnknownFields + state protoimpl.MessageState sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + FeedId []byte `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"` } func (x *LatestReportRequest) Reset() { @@ -170,11 +172,12 @@ func (x *LatestReportRequest) GetFeedId() []byte { } type LatestReportResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` - Report *Report `protobuf:"bytes,2,opt,name=report,proto3" json:"report,omitempty"` - unknownFields protoimpl.UnknownFields + state protoimpl.MessageState sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` + Report *Report `protobuf:"bytes,2,opt,name=report,proto3" json:"report,omitempty"` } func (x *LatestReportResponse) Reset() { @@ -222,23 +225,24 @@ func (x *LatestReportResponse) GetReport() *Report { } type Report struct { - state protoimpl.MessageState `protogen:"open.v1"` - FeedId []byte `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"` - Price []byte `protobuf:"bytes,2,opt,name=price,proto3" json:"price,omitempty"` - Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` - ValidFromBlockNumber int64 `protobuf:"varint,4,opt,name=validFromBlockNumber,proto3" json:"validFromBlockNumber,omitempty"` - CurrentBlockNumber int64 `protobuf:"varint,5,opt,name=currentBlockNumber,proto3" json:"currentBlockNumber,omitempty"` - CurrentBlockHash []byte `protobuf:"bytes,6,opt,name=currentBlockHash,proto3" json:"currentBlockHash,omitempty"` - CurrentBlockTimestamp uint64 `protobuf:"varint,7,opt,name=currentBlockTimestamp,proto3" json:"currentBlockTimestamp,omitempty"` - ObservationsTimestamp int64 `protobuf:"varint,8,opt,name=observationsTimestamp,proto3" json:"observationsTimestamp,omitempty"` - ConfigDigest []byte `protobuf:"bytes,9,opt,name=configDigest,proto3" json:"configDigest,omitempty"` - Epoch uint32 `protobuf:"varint,10,opt,name=epoch,proto3" json:"epoch,omitempty"` - Round uint32 `protobuf:"varint,11,opt,name=round,proto3" json:"round,omitempty"` - OperatorName string `protobuf:"bytes,12,opt,name=operatorName,proto3" json:"operatorName,omitempty"` - TransmittingOperator []byte `protobuf:"bytes,13,opt,name=transmittingOperator,proto3" json:"transmittingOperator,omitempty"` - CreatedAt *Timestamp `protobuf:"bytes,14,opt,name=createdAt,proto3" json:"createdAt,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + FeedId []byte `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"` + Price []byte `protobuf:"bytes,2,opt,name=price,proto3" json:"price,omitempty"` + Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` + ValidFromBlockNumber int64 `protobuf:"varint,4,opt,name=validFromBlockNumber,proto3" json:"validFromBlockNumber,omitempty"` + CurrentBlockNumber int64 `protobuf:"varint,5,opt,name=currentBlockNumber,proto3" json:"currentBlockNumber,omitempty"` + CurrentBlockHash []byte `protobuf:"bytes,6,opt,name=currentBlockHash,proto3" json:"currentBlockHash,omitempty"` + CurrentBlockTimestamp uint64 `protobuf:"varint,7,opt,name=currentBlockTimestamp,proto3" json:"currentBlockTimestamp,omitempty"` + ObservationsTimestamp int64 `protobuf:"varint,8,opt,name=observationsTimestamp,proto3" json:"observationsTimestamp,omitempty"` + ConfigDigest []byte `protobuf:"bytes,9,opt,name=configDigest,proto3" json:"configDigest,omitempty"` + Epoch uint32 `protobuf:"varint,10,opt,name=epoch,proto3" json:"epoch,omitempty"` + Round uint32 `protobuf:"varint,11,opt,name=round,proto3" json:"round,omitempty"` + OperatorName string `protobuf:"bytes,12,opt,name=operatorName,proto3" json:"operatorName,omitempty"` + TransmittingOperator []byte `protobuf:"bytes,13,opt,name=transmittingOperator,proto3" json:"transmittingOperator,omitempty"` + CreatedAt *Timestamp `protobuf:"bytes,14,opt,name=createdAt,proto3" json:"createdAt,omitempty"` } func (x *Report) Reset() { @@ -371,7 +375,10 @@ func (x *Report) GetCreatedAt() *Timestamp { // Taken from: https://github.com/protocolbuffers/protobuf/blob/main/src/google/protobuf/timestamp.proto type Timestamp struct { - state protoimpl.MessageState `protogen:"open.v1"` + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + // Represents seconds of UTC time since Unix epoch // 1970-01-01T00:00:00Z. Must be from 0001-01-01T00:00:00Z to // 9999-12-31T23:59:59Z inclusive. @@ -380,9 +387,7 @@ type Timestamp struct { // second values with fractions must still have non-negative nanos values // that count forward in time. Must be from 0 to 999,999,999 // inclusive. - Nanos int32 `protobuf:"varint,2,opt,name=nanos,proto3" json:"nanos,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache + Nanos int32 `protobuf:"varint,2,opt,name=nanos,proto3" json:"nanos,omitempty"` } func (x *Timestamp) Reset() { @@ -431,7 +436,7 @@ func (x *Timestamp) GetNanos() int32 { var File_mercury_proto protoreflect.FileDescriptor -var file_mercury_proto_rawDesc = string([]byte{ +var file_mercury_proto_rawDesc = []byte{ 0x0a, 0x0d, 0x6d, 0x65, 0x72, 0x63, 0x75, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x02, 0x70, 0x62, 0x22, 0x4f, 0x0a, 0x0f, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, @@ -503,16 +508,16 @@ var file_mercury_proto_rawDesc = string([]byte{ 0x72, 0x65, 0x6c, 0x61, 0x79, 0x2f, 0x65, 0x76, 0x6d, 0x2f, 0x6d, 0x65, 0x72, 0x63, 0x75, 0x72, 0x79, 0x2f, 0x77, 0x73, 0x72, 0x70, 0x63, 0x2f, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -}) +} var ( file_mercury_proto_rawDescOnce sync.Once - file_mercury_proto_rawDescData []byte + file_mercury_proto_rawDescData = file_mercury_proto_rawDesc ) func file_mercury_proto_rawDescGZIP() []byte { file_mercury_proto_rawDescOnce.Do(func() { - file_mercury_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_mercury_proto_rawDesc), len(file_mercury_proto_rawDesc))) + file_mercury_proto_rawDescData = protoimpl.X.CompressGZIP(file_mercury_proto_rawDescData) }) return file_mercury_proto_rawDescData } @@ -549,7 +554,7 @@ func file_mercury_proto_init() { out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: unsafe.Slice(unsafe.StringData(file_mercury_proto_rawDesc), len(file_mercury_proto_rawDesc)), + RawDescriptor: file_mercury_proto_rawDesc, NumEnums: 0, NumMessages: 6, NumExtensions: 0, @@ -560,6 +565,7 @@ func file_mercury_proto_init() { MessageInfos: file_mercury_proto_msgTypes, }.Build() File_mercury_proto = out.File + file_mercury_proto_rawDesc = nil file_mercury_proto_goTypes = nil file_mercury_proto_depIdxs = nil }