receiver/solacereceiver/internal/model/receive/v1/receive_v1.pb.go (1,364 lines of code) (raw):

// Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.1 // protoc v5.26.1 // source: receive_v1.proto package v1 import ( reflect "reflect" sync "sync" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" ) const ( // Verify that this generated code is sufficiently up-to-date. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) // Verify that runtime/protoimpl is sufficiently up-to-date. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) ) type SpanData_DeliveryMode int32 const ( SpanData_PERSISTENT SpanData_DeliveryMode = 0 SpanData_NON_PERSISTENT SpanData_DeliveryMode = 1 SpanData_DIRECT SpanData_DeliveryMode = 2 ) // Enum value maps for SpanData_DeliveryMode. var ( SpanData_DeliveryMode_name = map[int32]string{ 0: "PERSISTENT", 1: "NON_PERSISTENT", 2: "DIRECT", } SpanData_DeliveryMode_value = map[string]int32{ "PERSISTENT": 0, "NON_PERSISTENT": 1, "DIRECT": 2, } ) func (x SpanData_DeliveryMode) Enum() *SpanData_DeliveryMode { p := new(SpanData_DeliveryMode) *p = x return p } func (x SpanData_DeliveryMode) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (SpanData_DeliveryMode) Descriptor() protoreflect.EnumDescriptor { return file_receive_v1_proto_enumTypes[0].Descriptor() } func (SpanData_DeliveryMode) Type() protoreflect.EnumType { return &file_receive_v1_proto_enumTypes[0] } func (x SpanData_DeliveryMode) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use SpanData_DeliveryMode.Descriptor instead. func (SpanData_DeliveryMode) EnumDescriptor() ([]byte, []int) { return file_receive_v1_proto_rawDescGZIP(), []int{0, 0} } type SpanData_TransactionEvent_Type int32 const ( // COMMIT and ROLLBACK are always initiated by either a CLIENT or ADMIN. // The initiator is ADMIN when the management interface is used to // to perform a heuristic commit or rollback. SpanData_TransactionEvent_COMMIT SpanData_TransactionEvent_Type = 0 SpanData_TransactionEvent_ROLLBACK SpanData_TransactionEvent_Type = 1 // PREPARE and END can only occur with a CLIENT initiator, and spans for // these operations are only generated if the operation fails. Therefore, // the error_description of the TransactionEvent will always be present // for END and PREPARE. SpanData_TransactionEvent_END SpanData_TransactionEvent_Type = 2 SpanData_TransactionEvent_PREPARE SpanData_TransactionEvent_Type = 3 // The initiator of a SESSION_TIMEOUT is always BROKER. All messages // received as part of the transaction are discarded. SpanData_TransactionEvent_SESSION_TIMEOUT SpanData_TransactionEvent_Type = 4 // The initiator of ROLLBACK_ONLY is always BROKER. The first such event // in a transaction always has an error_description in the span, // indicating there was a problem processing the message when it was // received, and the message is being discarded. This also transitions // the transaction itself to a "rollback only" state, which causes // all subsequent messages received as part of the transaction to also // be discarded. Spans generated by these subsequent discards will not // have the span's error_description set, but all ROLLBACK_ONLY // transaction events will have an error_description set, which indicate // the transaction's error. // // Since the only record of these messages in the context of the // transaction has been discarded, no further span can be generated in // the context of a client, admin, or session timeout operation. When a // subsequent operation such as rollback or commit occurs on a // transaction marked rollback only, only messages received prior to the // error triggering the transition to rollback only will generate // receive spans. SpanData_TransactionEvent_ROLLBACK_ONLY SpanData_TransactionEvent_Type = 5 ) // Enum value maps for SpanData_TransactionEvent_Type. var ( SpanData_TransactionEvent_Type_name = map[int32]string{ 0: "COMMIT", 1: "ROLLBACK", 2: "END", 3: "PREPARE", 4: "SESSION_TIMEOUT", 5: "ROLLBACK_ONLY", } SpanData_TransactionEvent_Type_value = map[string]int32{ "COMMIT": 0, "ROLLBACK": 1, "END": 2, "PREPARE": 3, "SESSION_TIMEOUT": 4, "ROLLBACK_ONLY": 5, } ) func (x SpanData_TransactionEvent_Type) Enum() *SpanData_TransactionEvent_Type { p := new(SpanData_TransactionEvent_Type) *p = x return p } func (x SpanData_TransactionEvent_Type) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (SpanData_TransactionEvent_Type) Descriptor() protoreflect.EnumDescriptor { return file_receive_v1_proto_enumTypes[1].Descriptor() } func (SpanData_TransactionEvent_Type) Type() protoreflect.EnumType { return &file_receive_v1_proto_enumTypes[1] } func (x SpanData_TransactionEvent_Type) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use SpanData_TransactionEvent_Type.Descriptor instead. func (SpanData_TransactionEvent_Type) EnumDescriptor() ([]byte, []int) { return file_receive_v1_proto_rawDescGZIP(), []int{0, 2, 0} } type SpanData_TransactionEvent_Initiator int32 const ( SpanData_TransactionEvent_CLIENT SpanData_TransactionEvent_Initiator = 0 SpanData_TransactionEvent_ADMIN SpanData_TransactionEvent_Initiator = 1 SpanData_TransactionEvent_BROKER SpanData_TransactionEvent_Initiator = 2 ) // Enum value maps for SpanData_TransactionEvent_Initiator. var ( SpanData_TransactionEvent_Initiator_name = map[int32]string{ 0: "CLIENT", 1: "ADMIN", 2: "BROKER", } SpanData_TransactionEvent_Initiator_value = map[string]int32{ "CLIENT": 0, "ADMIN": 1, "BROKER": 2, } ) func (x SpanData_TransactionEvent_Initiator) Enum() *SpanData_TransactionEvent_Initiator { p := new(SpanData_TransactionEvent_Initiator) *p = x return p } func (x SpanData_TransactionEvent_Initiator) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (SpanData_TransactionEvent_Initiator) Descriptor() protoreflect.EnumDescriptor { return file_receive_v1_proto_enumTypes[2].Descriptor() } func (SpanData_TransactionEvent_Initiator) Type() protoreflect.EnumType { return &file_receive_v1_proto_enumTypes[2] } func (x SpanData_TransactionEvent_Initiator) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use SpanData_TransactionEvent_Initiator.Descriptor instead. func (SpanData_TransactionEvent_Initiator) EnumDescriptor() ([]byte, []int) { return file_receive_v1_proto_rawDescGZIP(), []int{0, 2, 1} } // A message will be compatible with this specification if its topic matches: // _telemetry/broker/trace/receive/v1[/additional/topic/levels] // // Note that the topic above allows for additional topic levels to be added in // the future. Receiving clients must not assume there are no additional topic // levels. // // This message describes telemetry data that a Solace PubSub+ broker captures // when a received message is identified as a message to be traced. // // Fields with names that end in "time_unix_nano" are 64-bit timestamps, in // nanoseconds, since midnight, Jan. 1, 1970 UTC. // // Notes on the field numbers used: // - Field numbers 1-15 are used for attributes that are expected to be present // on the wire with every single message not containing an error_description. // Special priority is given to fields that can be repeated. // - Field numbers 16+ are used for other attributes. // // Next available field ID: 40 type SpanData struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // 16-byte globally unique trace ID. Any two spans with the same trace ID are // part of the same trace. TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // 8-byte span ID, unique within the scope of a trace. SpanId []byte `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // If not present, this is a root span. If present, this is an 8-byte span ID // of the parent span. ParentSpanId []byte `protobuf:"bytes,16,opt,name=parent_span_id,json=parentSpanId,proto3,oneof" json:"parent_span_id,omitempty"` // tracestate string value, as per // <https://www.w3.org/TR/trace-context/#tracestate-header> TraceState *string `protobuf:"bytes,17,opt,name=trace_state,json=traceState,proto3,oneof" json:"trace_state,omitempty"` // A baggage string formatted as described here: // https://www.w3.org/TR/baggage/#x3-2-1-1-baggage-string // This string may be truncated if the complete string, as received, would // cause the broker's limit for application message properties to be exceeded. // See dropped_application_message_properties for more details. Baggage *string `protobuf:"bytes,39,opt,name=baggage,proto3,oneof" json:"baggage,omitempty"` // The start and end timestamps of the receive span. The start of the span is // when Guaranteed Messaging processing begins in the broker. StartTimeUnixNano int64 `protobuf:"fixed64,3,opt,name=start_time_unix_nano,json=startTimeUnixNano,proto3" json:"start_time_unix_nano,omitempty"` EndTimeUnixNano int64 `protobuf:"fixed64,4,opt,name=end_time_unix_nano,json=endTimeUnixNano,proto3" json:"end_time_unix_nano,omitempty"` // The broker receive timestamp is when the broker first identified the // message as a message that is to be traced. This is always before the start // of the span (the span starts when Guaranteed Message processing beings on the // message later in the processing pipeline). However, in some broker // implementations this timestamp is generated from a different clock and // therefore not guaranteed to be numerically smaller than // start_time_unix_nano, even though it represents an earlier time. BrokerReceiveTimeUnixNano int64 `protobuf:"fixed64,12,opt,name=broker_receive_time_unix_nano,json=brokerReceiveTimeUnixNano,proto3" json:"broker_receive_time_unix_nano,omitempty"` // The topic of the received message, used to determine where to enqueue the // message. Topic string `protobuf:"bytes,5,opt,name=topic,proto3" json:"topic,omitempty"` // The reply-to topic of the received message, if present. ReplyToTopic *string `protobuf:"bytes,18,opt,name=reply_to_topic,json=replyToTopic,proto3,oneof" json:"reply_to_topic,omitempty"` // The delivery mode of the message, when it was received by the broker. Note // that if the delivery mode is DIRECT, the message will be promoted to // NON_PERSISTENT when it is enqueued. DeliveryMode SpanData_DeliveryMode `protobuf:"varint,19,opt,name=delivery_mode,json=deliveryMode,proto3,enum=solace.messaging.proto.broker.trace.receive.v1.SpanData_DeliveryMode" json:"delivery_mode,omitempty"` // The receiving broker's router-name at the time the message was received. RouterName string `protobuf:"bytes,20,opt,name=router_name,json=routerName,proto3" json:"router_name,omitempty"` // The receiving broker's message-vpn name. This field may be removed in the // future without a major version change since the field is specified as // optional. // // Rather than rely on this field, receiving clients should obtain the VPN // by using an SMF API to extract the VPN_NAME_IN_USE from the API's Session // object. The message_vpn_name of all messages received from via an SMF // API's session will match the session's VPN_NAME_IN_USE. MessageVpnName *string `protobuf:"bytes,21,opt,name=message_vpn_name,json=messageVpnName,proto3,oneof" json:"message_vpn_name,omitempty"` // The receiving broker's SolOS version when the message was initially // received. // // It is possible for a consumer to determine the SolOS version of the broker // it is receiving messages from by extracting the PEER_SOFTWARE_VERSION from // an SMF API Session object. However, it may not match this attribute since // the message may have been received when the version was different from the // broker's current SolOS version. SolosVersion string `protobuf:"bytes,38,opt,name=solos_version,json=solosVersion,proto3" json:"solos_version,omitempty"` // The client name of the publishing client, as well as the client-username // they are bound to on the broker. ClientName string `protobuf:"bytes,6,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"` ClientUsername string `protobuf:"bytes,7,opt,name=client_username,json=clientUsername,proto3" json:"client_username,omitempty"` // The IP and port the broker received the message on. // Note: host_ip can be either an IPv4 address, an IPv6 address, or no // address at all. If it is IPv4, the length is 4; an IPv6 address is 16 // bytes; no address is indicated with a 0-length value. When the IP address // is not included, the host_port should not be read. HostIp []byte `protobuf:"bytes,8,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"` HostPort uint32 `protobuf:"varint,9,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"` // The IP and port of the publishing client, from the broker's point of view. // This may not be the client's local IP and port if there is network address // translation involved between the client and the broker. // Note: peer_ip can be either an IPv4 address, an IPv6 address, or no // address at all. If it is IPv4, the length is 4; an IPv6 address is 16 // bytes; no address is indicated with a 0-length value. When the IP address // is not included, the peer_port should not be read. PeerIp []byte `protobuf:"bytes,10,opt,name=peer_ip,json=peerIp,proto3" json:"peer_ip,omitempty"` PeerPort uint32 `protobuf:"varint,11,opt,name=peer_port,json=peerPort,proto3" json:"peer_port,omitempty"` // The message's globally unique Replication Group Message ID, in binary // format. This will not be present if the message is being discarded. // The format of these bytes are: // byte[0]: Version. // byte[1:len-1]: Binary representation of a replication group message ID in // // the specified version. // // This should only be treated as opaque data by applications. If comparing // two ID's and the versions are the same, then the ID's are the same if the // remaining bytes are the same. If the versions are different, no comparison // can be made. ReplicationGroupMessageId []byte `protobuf:"bytes,22,opt,name=replication_group_message_id,json=replicationGroupMessageId,proto3,oneof" json:"replication_group_message_id,omitempty"` // Indicates how the message was received by the broker. Protocol string `protobuf:"bytes,23,opt,name=protocol,proto3" json:"protocol,omitempty"` // The version of the protocol used. This is only present when the protocol is // MQTT. ProtocolVersion *string `protobuf:"bytes,24,opt,name=protocol_version,json=protocolVersion,proto3,oneof" json:"protocol_version,omitempty"` // Indicates properties of the published message, as set by the client. DmqEligible bool `protobuf:"varint,25,opt,name=dmq_eligible,json=dmqEligible,proto3" json:"dmq_eligible,omitempty"` Priority *uint32 `protobuf:"varint,26,opt,name=priority,proto3,oneof" json:"priority,omitempty"` Ttl *int64 `protobuf:"varint,27,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"` // The sizes of various types of message payload, which are not mutually // exclusive. BinaryAttachmentSize uint32 `protobuf:"varint,28,opt,name=binary_attachment_size,json=binaryAttachmentSize,proto3" json:"binary_attachment_size,omitempty"` XmlAttachmentSize uint32 `protobuf:"varint,29,opt,name=xml_attachment_size,json=xmlAttachmentSize,proto3" json:"xml_attachment_size,omitempty"` MetadataSize uint32 `protobuf:"varint,30,opt,name=metadata_size,json=metadataSize,proto3" json:"metadata_size,omitempty"` // These properties may or may not have been set on a message by the // application. ApplicationMessageId *string `protobuf:"bytes,31,opt,name=application_message_id,json=applicationMessageId,proto3,oneof" json:"application_message_id,omitempty"` CorrelationId *string `protobuf:"bytes,32,opt,name=correlation_id,json=correlationId,proto3,oneof" json:"correlation_id,omitempty"` // If the applications set user properties on the message, they are captured // here. See the UserPropertyValue for restrictions on which values will be // captured. UserProperties map[string]*SpanData_UserPropertyValue `protobuf:"bytes,14,rep,name=user_properties,json=userProperties,proto3" json:"user_properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` // Application message properties refers to the collection of: // * trace_state // * application_message_id // * correlation_id // * baggage // * user_properties // The broker supports up to a total of 8KiB of application message // properties. If the total amount of application message properties in the // message being traced exceeds this limit, this flag is used to indicate // some properties were dropped. DroppedApplicationMessageProperties bool `protobuf:"varint,37,opt,name=dropped_application_message_properties,json=droppedApplicationMessageProperties,proto3" json:"dropped_application_message_properties,omitempty"` // If present, this indicates the message is being rejected to the publisher // and matches the error string provided back to the publisher as an error. // // For transacted messages, the individual messages are not rejected to the // publisher. However, a message with an error_description indicates that it // is one of the messages that caused the operation on the transacted session // to fail. See transaction_event for more information on the failed // operation. // // This string is informational only and not intended to be parsed by // applications. ErrorDescription string `protobuf:"bytes,33,opt,name=error_description,json=errorDescription,proto3" json:"error_description,omitempty"` // If the message is part of a transaction, transaction_event provides details // on the transaction. TransactionEvent *SpanData_TransactionEvent `protobuf:"bytes,34,opt,name=transaction_event,json=transactionEvent,proto3,oneof" json:"transaction_event,omitempty"` // Each EnqueueEvent represents an attempt to enqueue the message to the // described destination. EnqueueEvents []*SpanData_EnqueueEvent `protobuf:"bytes,15,rep,name=enqueue_events,json=enqueueEvents,proto3" json:"enqueue_events,omitempty"` // There is a limit to the number of enqueue events the broker will generate // for a received message. The following two fields indicate the number of // successful and failed enqueue events that were dropped. DroppedEnqueueEventsSuccess uint32 `protobuf:"varint,35,opt,name=dropped_enqueue_events_success,json=droppedEnqueueEventsSuccess,proto3" json:"dropped_enqueue_events_success,omitempty"` DroppedEnqueueEventsFailed uint32 `protobuf:"varint,36,opt,name=dropped_enqueue_events_failed,json=droppedEnqueueEventsFailed,proto3" json:"dropped_enqueue_events_failed,omitempty"` } func (x *SpanData) Reset() { *x = SpanData{} if protoimpl.UnsafeEnabled { mi := &file_receive_v1_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData) ProtoMessage() {} func (x *SpanData) ProtoReflect() protoreflect.Message { mi := &file_receive_v1_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use SpanData.ProtoReflect.Descriptor instead. func (*SpanData) Descriptor() ([]byte, []int) { return file_receive_v1_proto_rawDescGZIP(), []int{0} } func (x *SpanData) GetTraceId() []byte { if x != nil { return x.TraceId } return nil } func (x *SpanData) GetSpanId() []byte { if x != nil { return x.SpanId } return nil } func (x *SpanData) GetParentSpanId() []byte { if x != nil { return x.ParentSpanId } return nil } func (x *SpanData) GetTraceState() string { if x != nil && x.TraceState != nil { return *x.TraceState } return "" } func (x *SpanData) GetBaggage() string { if x != nil && x.Baggage != nil { return *x.Baggage } return "" } func (x *SpanData) GetStartTimeUnixNano() int64 { if x != nil { return x.StartTimeUnixNano } return 0 } func (x *SpanData) GetEndTimeUnixNano() int64 { if x != nil { return x.EndTimeUnixNano } return 0 } func (x *SpanData) GetBrokerReceiveTimeUnixNano() int64 { if x != nil { return x.BrokerReceiveTimeUnixNano } return 0 } func (x *SpanData) GetTopic() string { if x != nil { return x.Topic } return "" } func (x *SpanData) GetReplyToTopic() string { if x != nil && x.ReplyToTopic != nil { return *x.ReplyToTopic } return "" } func (x *SpanData) GetDeliveryMode() SpanData_DeliveryMode { if x != nil { return x.DeliveryMode } return SpanData_PERSISTENT } func (x *SpanData) GetRouterName() string { if x != nil { return x.RouterName } return "" } func (x *SpanData) GetMessageVpnName() string { if x != nil && x.MessageVpnName != nil { return *x.MessageVpnName } return "" } func (x *SpanData) GetSolosVersion() string { if x != nil { return x.SolosVersion } return "" } func (x *SpanData) GetClientName() string { if x != nil { return x.ClientName } return "" } func (x *SpanData) GetClientUsername() string { if x != nil { return x.ClientUsername } return "" } func (x *SpanData) GetHostIp() []byte { if x != nil { return x.HostIp } return nil } func (x *SpanData) GetHostPort() uint32 { if x != nil { return x.HostPort } return 0 } func (x *SpanData) GetPeerIp() []byte { if x != nil { return x.PeerIp } return nil } func (x *SpanData) GetPeerPort() uint32 { if x != nil { return x.PeerPort } return 0 } func (x *SpanData) GetReplicationGroupMessageId() []byte { if x != nil { return x.ReplicationGroupMessageId } return nil } func (x *SpanData) GetProtocol() string { if x != nil { return x.Protocol } return "" } func (x *SpanData) GetProtocolVersion() string { if x != nil && x.ProtocolVersion != nil { return *x.ProtocolVersion } return "" } func (x *SpanData) GetDmqEligible() bool { if x != nil { return x.DmqEligible } return false } func (x *SpanData) GetPriority() uint32 { if x != nil && x.Priority != nil { return *x.Priority } return 0 } func (x *SpanData) GetTtl() int64 { if x != nil && x.Ttl != nil { return *x.Ttl } return 0 } func (x *SpanData) GetBinaryAttachmentSize() uint32 { if x != nil { return x.BinaryAttachmentSize } return 0 } func (x *SpanData) GetXmlAttachmentSize() uint32 { if x != nil { return x.XmlAttachmentSize } return 0 } func (x *SpanData) GetMetadataSize() uint32 { if x != nil { return x.MetadataSize } return 0 } func (x *SpanData) GetApplicationMessageId() string { if x != nil && x.ApplicationMessageId != nil { return *x.ApplicationMessageId } return "" } func (x *SpanData) GetCorrelationId() string { if x != nil && x.CorrelationId != nil { return *x.CorrelationId } return "" } func (x *SpanData) GetUserProperties() map[string]*SpanData_UserPropertyValue { if x != nil { return x.UserProperties } return nil } func (x *SpanData) GetDroppedApplicationMessageProperties() bool { if x != nil { return x.DroppedApplicationMessageProperties } return false } func (x *SpanData) GetErrorDescription() string { if x != nil { return x.ErrorDescription } return "" } func (x *SpanData) GetTransactionEvent() *SpanData_TransactionEvent { if x != nil { return x.TransactionEvent } return nil } func (x *SpanData) GetEnqueueEvents() []*SpanData_EnqueueEvent { if x != nil { return x.EnqueueEvents } return nil } func (x *SpanData) GetDroppedEnqueueEventsSuccess() uint32 { if x != nil { return x.DroppedEnqueueEventsSuccess } return 0 } func (x *SpanData) GetDroppedEnqueueEventsFailed() uint32 { if x != nil { return x.DroppedEnqueueEventsFailed } return 0 } type SpanData_UserPropertyValue struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // This expresses a mapping from a Solace SDT type to a protobuf type. // The Solace SDT Types Map, Stream, and SMF are not supported. Other SDT // types from other protocols, such as AMQP symbol, timestamp, UUID, and // decimal types are not supported. // // Types that are assignable to Value: // // *SpanData_UserPropertyValue_NullValue // *SpanData_UserPropertyValue_BoolValue // *SpanData_UserPropertyValue_Uint8Value // *SpanData_UserPropertyValue_Uint16Value // *SpanData_UserPropertyValue_Uint32Value // *SpanData_UserPropertyValue_Uint64Value // *SpanData_UserPropertyValue_Int8Value // *SpanData_UserPropertyValue_Int16Value // *SpanData_UserPropertyValue_Int32Value // *SpanData_UserPropertyValue_Int64Value // *SpanData_UserPropertyValue_CharacterValue // *SpanData_UserPropertyValue_StringValue // *SpanData_UserPropertyValue_ByteArrayValue // *SpanData_UserPropertyValue_FloatValue // *SpanData_UserPropertyValue_DoubleValue // *SpanData_UserPropertyValue_DestinationValue Value isSpanData_UserPropertyValue_Value `protobuf_oneof:"value"` } func (x *SpanData_UserPropertyValue) Reset() { *x = SpanData_UserPropertyValue{} if protoimpl.UnsafeEnabled { mi := &file_receive_v1_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_UserPropertyValue) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_UserPropertyValue) ProtoMessage() {} func (x *SpanData_UserPropertyValue) ProtoReflect() protoreflect.Message { mi := &file_receive_v1_proto_msgTypes[2] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use SpanData_UserPropertyValue.ProtoReflect.Descriptor instead. func (*SpanData_UserPropertyValue) Descriptor() ([]byte, []int) { return file_receive_v1_proto_rawDescGZIP(), []int{0, 1} } func (m *SpanData_UserPropertyValue) GetValue() isSpanData_UserPropertyValue_Value { if m != nil { return m.Value } return nil } func (x *SpanData_UserPropertyValue) GetNullValue() []byte { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_NullValue); ok { return x.NullValue } return nil } func (x *SpanData_UserPropertyValue) GetBoolValue() bool { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_BoolValue); ok { return x.BoolValue } return false } func (x *SpanData_UserPropertyValue) GetUint8Value() uint32 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_Uint8Value); ok { return x.Uint8Value } return 0 } func (x *SpanData_UserPropertyValue) GetUint16Value() uint32 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_Uint16Value); ok { return x.Uint16Value } return 0 } func (x *SpanData_UserPropertyValue) GetUint32Value() uint32 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_Uint32Value); ok { return x.Uint32Value } return 0 } func (x *SpanData_UserPropertyValue) GetUint64Value() uint64 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_Uint64Value); ok { return x.Uint64Value } return 0 } func (x *SpanData_UserPropertyValue) GetInt8Value() int32 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_Int8Value); ok { return x.Int8Value } return 0 } func (x *SpanData_UserPropertyValue) GetInt16Value() int32 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_Int16Value); ok { return x.Int16Value } return 0 } func (x *SpanData_UserPropertyValue) GetInt32Value() int32 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_Int32Value); ok { return x.Int32Value } return 0 } func (x *SpanData_UserPropertyValue) GetInt64Value() int64 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_Int64Value); ok { return x.Int64Value } return 0 } func (x *SpanData_UserPropertyValue) GetCharacterValue() uint32 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_CharacterValue); ok { return x.CharacterValue } return 0 } func (x *SpanData_UserPropertyValue) GetStringValue() string { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_StringValue); ok { return x.StringValue } return "" } func (x *SpanData_UserPropertyValue) GetByteArrayValue() []byte { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_ByteArrayValue); ok { return x.ByteArrayValue } return nil } func (x *SpanData_UserPropertyValue) GetFloatValue() float32 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_FloatValue); ok { return x.FloatValue } return 0 } func (x *SpanData_UserPropertyValue) GetDoubleValue() float64 { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_DoubleValue); ok { return x.DoubleValue } return 0 } func (x *SpanData_UserPropertyValue) GetDestinationValue() string { if x, ok := x.GetValue().(*SpanData_UserPropertyValue_DestinationValue); ok { return x.DestinationValue } return "" } type isSpanData_UserPropertyValue_Value interface { isSpanData_UserPropertyValue_Value() } type SpanData_UserPropertyValue_NullValue struct { NullValue []byte `protobuf:"bytes,1,opt,name=null_value,json=nullValue,proto3,oneof"` } type SpanData_UserPropertyValue_BoolValue struct { BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3,oneof"` } type SpanData_UserPropertyValue_Uint8Value struct { Uint8Value uint32 `protobuf:"varint,3,opt,name=uint8_value,json=uint8Value,proto3,oneof"` } type SpanData_UserPropertyValue_Uint16Value struct { Uint16Value uint32 `protobuf:"varint,4,opt,name=uint16_value,json=uint16Value,proto3,oneof"` } type SpanData_UserPropertyValue_Uint32Value struct { Uint32Value uint32 `protobuf:"varint,5,opt,name=uint32_value,json=uint32Value,proto3,oneof"` } type SpanData_UserPropertyValue_Uint64Value struct { Uint64Value uint64 `protobuf:"varint,6,opt,name=uint64_value,json=uint64Value,proto3,oneof"` } type SpanData_UserPropertyValue_Int8Value struct { Int8Value int32 `protobuf:"zigzag32,7,opt,name=int8_value,json=int8Value,proto3,oneof"` } type SpanData_UserPropertyValue_Int16Value struct { Int16Value int32 `protobuf:"zigzag32,8,opt,name=int16_value,json=int16Value,proto3,oneof"` } type SpanData_UserPropertyValue_Int32Value struct { Int32Value int32 `protobuf:"zigzag32,9,opt,name=int32_value,json=int32Value,proto3,oneof"` } type SpanData_UserPropertyValue_Int64Value struct { Int64Value int64 `protobuf:"zigzag64,10,opt,name=int64_value,json=int64Value,proto3,oneof"` } type SpanData_UserPropertyValue_CharacterValue struct { CharacterValue uint32 `protobuf:"varint,11,opt,name=character_value,json=characterValue,proto3,oneof"` } type SpanData_UserPropertyValue_StringValue struct { StringValue string `protobuf:"bytes,12,opt,name=string_value,json=stringValue,proto3,oneof"` } type SpanData_UserPropertyValue_ByteArrayValue struct { ByteArrayValue []byte `protobuf:"bytes,13,opt,name=byteArray_value,json=byteArrayValue,proto3,oneof"` } type SpanData_UserPropertyValue_FloatValue struct { FloatValue float32 `protobuf:"fixed32,14,opt,name=float_value,json=floatValue,proto3,oneof"` } type SpanData_UserPropertyValue_DoubleValue struct { DoubleValue float64 `protobuf:"fixed64,15,opt,name=double_value,json=doubleValue,proto3,oneof"` } type SpanData_UserPropertyValue_DestinationValue struct { DestinationValue string `protobuf:"bytes,16,opt,name=destination_value,json=destinationValue,proto3,oneof"` } func (*SpanData_UserPropertyValue_NullValue) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_BoolValue) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_Uint8Value) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_Uint16Value) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_Uint32Value) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_Uint64Value) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_Int8Value) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_Int16Value) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_Int32Value) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_Int64Value) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_CharacterValue) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_StringValue) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_ByteArrayValue) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_FloatValue) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_DoubleValue) isSpanData_UserPropertyValue_Value() {} func (*SpanData_UserPropertyValue_DestinationValue) isSpanData_UserPropertyValue_Value() {} // When a message has a transaction event, it indicates the message is part of // a transaction. The timestamp indicates when the *initial* decision was made // for this particular message as part of the transaction operation. It // doesn't indicate the final state of the transaction. This isn't known until // all messages that are part of the transaction have been processed. // // Note it is possible that, for example, after deciding a message will be // committed that a subsequent message in the transaction will cause the // transaction to fail. This will result in a successful receive span with a // COMMIT transaction event with no error. The fact that the message is not // successfully processed will be indicated by a child span of this span. At // the current time, these subsequent spans are not yet generated and will be // added in a future release. In the meantime, the transaction_id can be used // to find out if there were any errored messages in the transaction. A single // errored message indicates the entire transaction failed. // // Also note that since the receive span is only generated either on commit or // when the message is discarded, certain transaction operations are only // observed in failed receive spans. For example, when XA End or XA Prepare // operations succeed, the message is neither discarded nor committed. It is // only if these operations fail that the transaction is rolled back and an // errored receive span is generated. type SpanData_TransactionEvent struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields TimeUnixNano int64 `protobuf:"fixed64,1,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` Type SpanData_TransactionEvent_Type `protobuf:"varint,2,opt,name=type,proto3,enum=solace.messaging.proto.broker.trace.receive.v1.SpanData_TransactionEvent_Type" json:"type,omitempty"` Initiator SpanData_TransactionEvent_Initiator `protobuf:"varint,3,opt,name=initiator,proto3,enum=solace.messaging.proto.broker.trace.receive.v1.SpanData_TransactionEvent_Initiator" json:"initiator,omitempty"` // Types that are assignable to TransactionId: // // *SpanData_TransactionEvent_Xid_ // *SpanData_TransactionEvent_LocalId TransactionId isSpanData_TransactionEvent_TransactionId `protobuf_oneof:"transaction_id"` ErrorDescription *string `protobuf:"bytes,6,opt,name=error_description,json=errorDescription,proto3,oneof" json:"error_description,omitempty"` } func (x *SpanData_TransactionEvent) Reset() { *x = SpanData_TransactionEvent{} if protoimpl.UnsafeEnabled { mi := &file_receive_v1_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_TransactionEvent) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_TransactionEvent) ProtoMessage() {} func (x *SpanData_TransactionEvent) ProtoReflect() protoreflect.Message { mi := &file_receive_v1_proto_msgTypes[3] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use SpanData_TransactionEvent.ProtoReflect.Descriptor instead. func (*SpanData_TransactionEvent) Descriptor() ([]byte, []int) { return file_receive_v1_proto_rawDescGZIP(), []int{0, 2} } func (x *SpanData_TransactionEvent) GetTimeUnixNano() int64 { if x != nil { return x.TimeUnixNano } return 0 } func (x *SpanData_TransactionEvent) GetType() SpanData_TransactionEvent_Type { if x != nil { return x.Type } return SpanData_TransactionEvent_COMMIT } func (x *SpanData_TransactionEvent) GetInitiator() SpanData_TransactionEvent_Initiator { if x != nil { return x.Initiator } return SpanData_TransactionEvent_CLIENT } func (m *SpanData_TransactionEvent) GetTransactionId() isSpanData_TransactionEvent_TransactionId { if m != nil { return m.TransactionId } return nil } func (x *SpanData_TransactionEvent) GetXid() *SpanData_TransactionEvent_Xid { if x, ok := x.GetTransactionId().(*SpanData_TransactionEvent_Xid_); ok { return x.Xid } return nil } func (x *SpanData_TransactionEvent) GetLocalId() *SpanData_TransactionEvent_LocalTransactionId { if x, ok := x.GetTransactionId().(*SpanData_TransactionEvent_LocalId); ok { return x.LocalId } return nil } func (x *SpanData_TransactionEvent) GetErrorDescription() string { if x != nil && x.ErrorDescription != nil { return *x.ErrorDescription } return "" } type isSpanData_TransactionEvent_TransactionId interface { isSpanData_TransactionEvent_TransactionId() } type SpanData_TransactionEvent_Xid_ struct { Xid *SpanData_TransactionEvent_Xid `protobuf:"bytes,4,opt,name=xid,proto3,oneof"` } type SpanData_TransactionEvent_LocalId struct { LocalId *SpanData_TransactionEvent_LocalTransactionId `protobuf:"bytes,5,opt,name=local_id,json=localId,proto3,oneof"` } func (*SpanData_TransactionEvent_Xid_) isSpanData_TransactionEvent_TransactionId() {} func (*SpanData_TransactionEvent_LocalId) isSpanData_TransactionEvent_TransactionId() {} // An enqueue event represents the broker's decision to enqueue a message // when processing a received message. If there is no error_description, // the broker has successfully processed the message and the enqueue events // indicate where the message has been enqueued. The presence of an // error_description indicates the message will not be enqueued to dest even // though the message matched the destination. If rejects_all_enqueues is set, // it means the message is not enqueued to any destinations, regardless of // what other enqueue events may indicate and the message is rejected. type SpanData_EnqueueEvent struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // The timestamp when the enqueue decision was made TimeUnixNano int64 `protobuf:"fixed64,1,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // Queues and Topic Endpoints with the same name can simultaneously co-exist // on the broker, so there needs to be a way of disambiguating the type of // the enqueue destination. The "oneof" construct here addresses this. // // Types that are assignable to Dest: // // *SpanData_EnqueueEvent_QueueName // *SpanData_EnqueueEvent_TopicEndpointName Dest isSpanData_EnqueueEvent_Dest `protobuf_oneof:"dest"` // The presence of an error_description indicates the message matched the // destination, but it is not being enqueued due to the description. ErrorDescription *string `protobuf:"bytes,4,opt,name=error_description,json=errorDescription,proto3,oneof" json:"error_description,omitempty"` // This flag being set on one or more enqueue events for a message implies // that the message is not enqueued to any destination, regardless of the // presence of successful enqueue events in the span. // // This will never be set when there is not an error_description present. If // this is set, it indicates that the error described by error_description // is a cause for the message to be rejected. // // Rejected non-transacted messages cause the message to be nacked to the // publisher and rejected transacted messages result in a change in // transacted session state that will cause a future commit attempt to fail. // // The cause for message rejection indicated to the client in either a // message nack or commit failure response is the error_description of the // first enqueue event that has this flag set. RejectsAllEnqueues bool `protobuf:"varint,5,opt,name=rejects_all_enqueues,json=rejectsAllEnqueues,proto3" json:"rejects_all_enqueues,omitempty"` // If the message is enqueued to a partitioned queue, this field indicates // the partition number the message is enqueued to. PartitionNumber *uint32 `protobuf:"varint,6,opt,name=partition_number,json=partitionNumber,proto3,oneof" json:"partition_number,omitempty"` // If the message will have a TTL other than the value indicated by the // receive span containing this event, it is indicated with this value. Ttl *int64 `protobuf:"varint,7,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"` } func (x *SpanData_EnqueueEvent) Reset() { *x = SpanData_EnqueueEvent{} if protoimpl.UnsafeEnabled { mi := &file_receive_v1_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_EnqueueEvent) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_EnqueueEvent) ProtoMessage() {} func (x *SpanData_EnqueueEvent) ProtoReflect() protoreflect.Message { mi := &file_receive_v1_proto_msgTypes[4] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use SpanData_EnqueueEvent.ProtoReflect.Descriptor instead. func (*SpanData_EnqueueEvent) Descriptor() ([]byte, []int) { return file_receive_v1_proto_rawDescGZIP(), []int{0, 3} } func (x *SpanData_EnqueueEvent) GetTimeUnixNano() int64 { if x != nil { return x.TimeUnixNano } return 0 } func (m *SpanData_EnqueueEvent) GetDest() isSpanData_EnqueueEvent_Dest { if m != nil { return m.Dest } return nil } func (x *SpanData_EnqueueEvent) GetQueueName() string { if x, ok := x.GetDest().(*SpanData_EnqueueEvent_QueueName); ok { return x.QueueName } return "" } func (x *SpanData_EnqueueEvent) GetTopicEndpointName() string { if x, ok := x.GetDest().(*SpanData_EnqueueEvent_TopicEndpointName); ok { return x.TopicEndpointName } return "" } func (x *SpanData_EnqueueEvent) GetErrorDescription() string { if x != nil && x.ErrorDescription != nil { return *x.ErrorDescription } return "" } func (x *SpanData_EnqueueEvent) GetRejectsAllEnqueues() bool { if x != nil { return x.RejectsAllEnqueues } return false } func (x *SpanData_EnqueueEvent) GetPartitionNumber() uint32 { if x != nil && x.PartitionNumber != nil { return *x.PartitionNumber } return 0 } func (x *SpanData_EnqueueEvent) GetTtl() int64 { if x != nil && x.Ttl != nil { return *x.Ttl } return 0 } type isSpanData_EnqueueEvent_Dest interface { isSpanData_EnqueueEvent_Dest() } type SpanData_EnqueueEvent_QueueName struct { QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3,oneof"` } type SpanData_EnqueueEvent_TopicEndpointName struct { TopicEndpointName string `protobuf:"bytes,3,opt,name=topic_endpoint_name,json=topicEndpointName,proto3,oneof"` } func (*SpanData_EnqueueEvent_QueueName) isSpanData_EnqueueEvent_Dest() {} func (*SpanData_EnqueueEvent_TopicEndpointName) isSpanData_EnqueueEvent_Dest() {} type SpanData_TransactionEvent_Xid struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields FormatId int32 `protobuf:"varint,1,opt,name=format_id,json=formatId,proto3" json:"format_id,omitempty"` BranchQualifier []byte `protobuf:"bytes,2,opt,name=branch_qualifier,json=branchQualifier,proto3" json:"branch_qualifier,omitempty"` GlobalId []byte `protobuf:"bytes,3,opt,name=global_id,json=globalId,proto3" json:"global_id,omitempty"` } func (x *SpanData_TransactionEvent_Xid) Reset() { *x = SpanData_TransactionEvent_Xid{} if protoimpl.UnsafeEnabled { mi := &file_receive_v1_proto_msgTypes[5] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_TransactionEvent_Xid) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_TransactionEvent_Xid) ProtoMessage() {} func (x *SpanData_TransactionEvent_Xid) ProtoReflect() protoreflect.Message { mi := &file_receive_v1_proto_msgTypes[5] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use SpanData_TransactionEvent_Xid.ProtoReflect.Descriptor instead. func (*SpanData_TransactionEvent_Xid) Descriptor() ([]byte, []int) { return file_receive_v1_proto_rawDescGZIP(), []int{0, 2, 0} } func (x *SpanData_TransactionEvent_Xid) GetFormatId() int32 { if x != nil { return x.FormatId } return 0 } func (x *SpanData_TransactionEvent_Xid) GetBranchQualifier() []byte { if x != nil { return x.BranchQualifier } return nil } func (x *SpanData_TransactionEvent_Xid) GetGlobalId() []byte { if x != nil { return x.GlobalId } return nil } type SpanData_TransactionEvent_LocalTransactionId struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields TransactionId uint32 `protobuf:"varint,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` SessionId uint32 `protobuf:"varint,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` SessionName string `protobuf:"bytes,3,opt,name=session_name,json=sessionName,proto3" json:"session_name,omitempty"` } func (x *SpanData_TransactionEvent_LocalTransactionId) Reset() { *x = SpanData_TransactionEvent_LocalTransactionId{} if protoimpl.UnsafeEnabled { mi := &file_receive_v1_proto_msgTypes[6] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_TransactionEvent_LocalTransactionId) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_TransactionEvent_LocalTransactionId) ProtoMessage() {} func (x *SpanData_TransactionEvent_LocalTransactionId) ProtoReflect() protoreflect.Message { mi := &file_receive_v1_proto_msgTypes[6] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use SpanData_TransactionEvent_LocalTransactionId.ProtoReflect.Descriptor instead. func (*SpanData_TransactionEvent_LocalTransactionId) Descriptor() ([]byte, []int) { return file_receive_v1_proto_rawDescGZIP(), []int{0, 2, 1} } func (x *SpanData_TransactionEvent_LocalTransactionId) GetTransactionId() uint32 { if x != nil { return x.TransactionId } return 0 } func (x *SpanData_TransactionEvent_LocalTransactionId) GetSessionId() uint32 { if x != nil { return x.SessionId } return 0 } func (x *SpanData_TransactionEvent_LocalTransactionId) GetSessionName() string { if x != nil { return x.SessionName } return "" } var File_receive_v1_proto protoreflect.FileDescriptor var file_receive_v1_proto_rawDesc = []byte{ 0x0a, 0x10, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x5f, 0x76, 0x31, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x22, 0xcb, 0x21, 0x0a, 0x08, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x74, 0x72, 0x61, 0x63, 0x65, 0x49, 0x64, 0x12, 0x17, 0x0a, 0x07, 0x73, 0x70, 0x61, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x73, 0x70, 0x61, 0x6e, 0x49, 0x64, 0x12, 0x29, 0x0a, 0x0e, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x70, 0x61, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x10, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x0c, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x53, 0x70, 0x61, 0x6e, 0x49, 0x64, 0x88, 0x01, 0x01, 0x12, 0x24, 0x0a, 0x0b, 0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x11, 0x20, 0x01, 0x28, 0x09, 0x48, 0x01, 0x52, 0x0a, 0x74, 0x72, 0x61, 0x63, 0x65, 0x53, 0x74, 0x61, 0x74, 0x65, 0x88, 0x01, 0x01, 0x12, 0x1d, 0x0a, 0x07, 0x62, 0x61, 0x67, 0x67, 0x61, 0x67, 0x65, 0x18, 0x27, 0x20, 0x01, 0x28, 0x09, 0x48, 0x02, 0x52, 0x07, 0x62, 0x61, 0x67, 0x67, 0x61, 0x67, 0x65, 0x88, 0x01, 0x01, 0x12, 0x2f, 0x0a, 0x14, 0x73, 0x74, 0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x75, 0x6e, 0x69, 0x78, 0x5f, 0x6e, 0x61, 0x6e, 0x6f, 0x18, 0x03, 0x20, 0x01, 0x28, 0x10, 0x52, 0x11, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x55, 0x6e, 0x69, 0x78, 0x4e, 0x61, 0x6e, 0x6f, 0x12, 0x2b, 0x0a, 0x12, 0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x75, 0x6e, 0x69, 0x78, 0x5f, 0x6e, 0x61, 0x6e, 0x6f, 0x18, 0x04, 0x20, 0x01, 0x28, 0x10, 0x52, 0x0f, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x55, 0x6e, 0x69, 0x78, 0x4e, 0x61, 0x6e, 0x6f, 0x12, 0x40, 0x0a, 0x1d, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x5f, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x75, 0x6e, 0x69, 0x78, 0x5f, 0x6e, 0x61, 0x6e, 0x6f, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x10, 0x52, 0x19, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x55, 0x6e, 0x69, 0x78, 0x4e, 0x61, 0x6e, 0x6f, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x29, 0x0a, 0x0e, 0x72, 0x65, 0x70, 0x6c, 0x79, 0x5f, 0x74, 0x6f, 0x5f, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x12, 0x20, 0x01, 0x28, 0x09, 0x48, 0x03, 0x52, 0x0c, 0x72, 0x65, 0x70, 0x6c, 0x79, 0x54, 0x6f, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x88, 0x01, 0x01, 0x12, 0x6a, 0x0a, 0x0d, 0x64, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x79, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x13, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x45, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x44, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x79, 0x4d, 0x6f, 0x64, 0x65, 0x52, 0x0c, 0x64, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x79, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x72, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x14, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x2d, 0x0a, 0x10, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x76, 0x70, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x15, 0x20, 0x01, 0x28, 0x09, 0x48, 0x04, 0x52, 0x0e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x56, 0x70, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x88, 0x01, 0x01, 0x12, 0x23, 0x0a, 0x0d, 0x73, 0x6f, 0x6c, 0x6f, 0x73, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x26, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x6f, 0x6c, 0x6f, 0x73, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x27, 0x0a, 0x0f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x55, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x17, 0x0a, 0x07, 0x68, 0x6f, 0x73, 0x74, 0x5f, 0x69, 0x70, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x12, 0x1b, 0x0a, 0x09, 0x68, 0x6f, 0x73, 0x74, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x68, 0x6f, 0x73, 0x74, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x17, 0x0a, 0x07, 0x70, 0x65, 0x65, 0x72, 0x5f, 0x69, 0x70, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x70, 0x65, 0x65, 0x72, 0x49, 0x70, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x65, 0x65, 0x72, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x70, 0x65, 0x65, 0x72, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x44, 0x0a, 0x1c, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x16, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x05, 0x52, 0x19, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, 0x64, 0x88, 0x01, 0x01, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x18, 0x17, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x2e, 0x0a, 0x10, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x18, 0x20, 0x01, 0x28, 0x09, 0x48, 0x06, 0x52, 0x0f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x88, 0x01, 0x01, 0x12, 0x21, 0x0a, 0x0c, 0x64, 0x6d, 0x71, 0x5f, 0x65, 0x6c, 0x69, 0x67, 0x69, 0x62, 0x6c, 0x65, 0x18, 0x19, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0b, 0x64, 0x6d, 0x71, 0x45, 0x6c, 0x69, 0x67, 0x69, 0x62, 0x6c, 0x65, 0x12, 0x1f, 0x0a, 0x08, 0x70, 0x72, 0x69, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x18, 0x1a, 0x20, 0x01, 0x28, 0x0d, 0x48, 0x07, 0x52, 0x08, 0x70, 0x72, 0x69, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x88, 0x01, 0x01, 0x12, 0x15, 0x0a, 0x03, 0x74, 0x74, 0x6c, 0x18, 0x1b, 0x20, 0x01, 0x28, 0x03, 0x48, 0x08, 0x52, 0x03, 0x74, 0x74, 0x6c, 0x88, 0x01, 0x01, 0x12, 0x34, 0x0a, 0x16, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x5f, 0x61, 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x1c, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x14, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x41, 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, 0x65, 0x6e, 0x74, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x2e, 0x0a, 0x13, 0x78, 0x6d, 0x6c, 0x5f, 0x61, 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x1d, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x11, 0x78, 0x6d, 0x6c, 0x41, 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, 0x65, 0x6e, 0x74, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x23, 0x0a, 0x0d, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x1e, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x39, 0x0a, 0x16, 0x61, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x1f, 0x20, 0x01, 0x28, 0x09, 0x48, 0x09, 0x52, 0x14, 0x61, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, 0x64, 0x88, 0x01, 0x01, 0x12, 0x2a, 0x0a, 0x0e, 0x63, 0x6f, 0x72, 0x72, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x20, 0x20, 0x01, 0x28, 0x09, 0x48, 0x0a, 0x52, 0x0d, 0x63, 0x6f, 0x72, 0x72, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x88, 0x01, 0x01, 0x12, 0x75, 0x0a, 0x0f, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x70, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x18, 0x0e, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x4c, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0e, 0x75, 0x73, 0x65, 0x72, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x12, 0x53, 0x0a, 0x26, 0x64, 0x72, 0x6f, 0x70, 0x70, 0x65, 0x64, 0x5f, 0x61, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x70, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x18, 0x25, 0x20, 0x01, 0x28, 0x08, 0x52, 0x23, 0x64, 0x72, 0x6f, 0x70, 0x70, 0x65, 0x64, 0x41, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x21, 0x20, 0x01, 0x28, 0x09, 0x52, 0x10, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x7b, 0x0a, 0x11, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x18, 0x22, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x49, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x48, 0x0b, 0x52, 0x10, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x88, 0x01, 0x01, 0x12, 0x6c, 0x0a, 0x0e, 0x65, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x0f, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x45, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x45, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x0d, 0x65, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x43, 0x0a, 0x1e, 0x64, 0x72, 0x6f, 0x70, 0x70, 0x65, 0x64, 0x5f, 0x65, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x5f, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x23, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x1b, 0x64, 0x72, 0x6f, 0x70, 0x70, 0x65, 0x64, 0x45, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x41, 0x0a, 0x1d, 0x64, 0x72, 0x6f, 0x70, 0x70, 0x65, 0x64, 0x5f, 0x65, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x5f, 0x66, 0x61, 0x69, 0x6c, 0x65, 0x64, 0x18, 0x24, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x1a, 0x64, 0x72, 0x6f, 0x70, 0x70, 0x65, 0x64, 0x45, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x46, 0x61, 0x69, 0x6c, 0x65, 0x64, 0x1a, 0x8d, 0x01, 0x0a, 0x13, 0x55, 0x73, 0x65, 0x72, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x60, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x4a, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0xec, 0x04, 0x0a, 0x11, 0x55, 0x73, 0x65, 0x72, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x6e, 0x75, 0x6c, 0x6c, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x09, 0x6e, 0x75, 0x6c, 0x6c, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x62, 0x6f, 0x6f, 0x6c, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x09, 0x62, 0x6f, 0x6f, 0x6c, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x21, 0x0a, 0x0b, 0x75, 0x69, 0x6e, 0x74, 0x38, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x48, 0x00, 0x52, 0x0a, 0x75, 0x69, 0x6e, 0x74, 0x38, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x23, 0x0a, 0x0c, 0x75, 0x69, 0x6e, 0x74, 0x31, 0x36, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x48, 0x00, 0x52, 0x0b, 0x75, 0x69, 0x6e, 0x74, 0x31, 0x36, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x23, 0x0a, 0x0c, 0x75, 0x69, 0x6e, 0x74, 0x33, 0x32, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0d, 0x48, 0x00, 0x52, 0x0b, 0x75, 0x69, 0x6e, 0x74, 0x33, 0x32, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x23, 0x0a, 0x0c, 0x75, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x04, 0x48, 0x00, 0x52, 0x0b, 0x75, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x69, 0x6e, 0x74, 0x38, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x11, 0x48, 0x00, 0x52, 0x09, 0x69, 0x6e, 0x74, 0x38, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x21, 0x0a, 0x0b, 0x69, 0x6e, 0x74, 0x31, 0x36, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x11, 0x48, 0x00, 0x52, 0x0a, 0x69, 0x6e, 0x74, 0x31, 0x36, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x21, 0x0a, 0x0b, 0x69, 0x6e, 0x74, 0x33, 0x32, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x11, 0x48, 0x00, 0x52, 0x0a, 0x69, 0x6e, 0x74, 0x33, 0x32, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x21, 0x0a, 0x0b, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x12, 0x48, 0x00, 0x52, 0x0a, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x29, 0x0a, 0x0f, 0x63, 0x68, 0x61, 0x72, 0x61, 0x63, 0x74, 0x65, 0x72, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0d, 0x48, 0x00, 0x52, 0x0e, 0x63, 0x68, 0x61, 0x72, 0x61, 0x63, 0x74, 0x65, 0x72, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x23, 0x0a, 0x0c, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x0b, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x29, 0x0a, 0x0f, 0x62, 0x79, 0x74, 0x65, 0x41, 0x72, 0x72, 0x61, 0x79, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x0e, 0x62, 0x79, 0x74, 0x65, 0x41, 0x72, 0x72, 0x61, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x21, 0x0a, 0x0b, 0x66, 0x6c, 0x6f, 0x61, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x02, 0x48, 0x00, 0x52, 0x0a, 0x66, 0x6c, 0x6f, 0x61, 0x74, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x23, 0x0a, 0x0c, 0x64, 0x6f, 0x75, 0x62, 0x6c, 0x65, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x01, 0x48, 0x00, 0x52, 0x0b, 0x64, 0x6f, 0x75, 0x62, 0x6c, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x2d, 0x0a, 0x11, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x10, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x10, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x42, 0x07, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x1a, 0xc2, 0x07, 0x0a, 0x10, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x24, 0x0a, 0x0e, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x75, 0x6e, 0x69, 0x78, 0x5f, 0x6e, 0x61, 0x6e, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x10, 0x52, 0x0c, 0x74, 0x69, 0x6d, 0x65, 0x55, 0x6e, 0x69, 0x78, 0x4e, 0x61, 0x6e, 0x6f, 0x12, 0x62, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x4e, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x71, 0x0a, 0x09, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x74, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x53, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x49, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x74, 0x6f, 0x72, 0x52, 0x09, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x74, 0x6f, 0x72, 0x12, 0x61, 0x0a, 0x03, 0x78, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x4d, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x58, 0x69, 0x64, 0x48, 0x00, 0x52, 0x03, 0x78, 0x69, 0x64, 0x12, 0x79, 0x0a, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x5c, 0x2e, 0x73, 0x6f, 0x6c, 0x61, 0x63, 0x65, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x62, 0x72, 0x6f, 0x6b, 0x65, 0x72, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x6c, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x48, 0x00, 0x52, 0x07, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x49, 0x64, 0x12, 0x30, 0x0a, 0x11, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x48, 0x01, 0x52, 0x10, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x88, 0x01, 0x01, 0x1a, 0x6a, 0x0a, 0x03, 0x58, 0x69, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x66, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x66, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x49, 0x64, 0x12, 0x29, 0x0a, 0x10, 0x62, 0x72, 0x61, 0x6e, 0x63, 0x68, 0x5f, 0x71, 0x75, 0x61, 0x6c, 0x69, 0x66, 0x69, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0f, 0x62, 0x72, 0x61, 0x6e, 0x63, 0x68, 0x51, 0x75, 0x61, 0x6c, 0x69, 0x66, 0x69, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x67, 0x6c, 0x6f, 0x62, 0x61, 0x6c, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x08, 0x67, 0x6c, 0x6f, 0x62, 0x61, 0x6c, 0x49, 0x64, 0x1a, 0x7d, 0x0a, 0x12, 0x4c, 0x6f, 0x63, 0x61, 0x6c, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x25, 0x0a, 0x0e, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x1d, 0x0a, 0x0a, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x5e, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x43, 0x4f, 0x4d, 0x4d, 0x49, 0x54, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x52, 0x4f, 0x4c, 0x4c, 0x42, 0x41, 0x43, 0x4b, 0x10, 0x01, 0x12, 0x07, 0x0a, 0x03, 0x45, 0x4e, 0x44, 0x10, 0x02, 0x12, 0x0b, 0x0a, 0x07, 0x50, 0x52, 0x45, 0x50, 0x41, 0x52, 0x45, 0x10, 0x03, 0x12, 0x13, 0x0a, 0x0f, 0x53, 0x45, 0x53, 0x53, 0x49, 0x4f, 0x4e, 0x5f, 0x54, 0x49, 0x4d, 0x45, 0x4f, 0x55, 0x54, 0x10, 0x04, 0x12, 0x11, 0x0a, 0x0d, 0x52, 0x4f, 0x4c, 0x4c, 0x42, 0x41, 0x43, 0x4b, 0x5f, 0x4f, 0x4e, 0x4c, 0x59, 0x10, 0x05, 0x22, 0x2e, 0x0a, 0x09, 0x49, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x74, 0x6f, 0x72, 0x12, 0x0a, 0x0a, 0x06, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x44, 0x4d, 0x49, 0x4e, 0x10, 0x01, 0x12, 0x0a, 0x0a, 0x06, 0x42, 0x52, 0x4f, 0x4b, 0x45, 0x52, 0x10, 0x02, 0x42, 0x10, 0x0a, 0x0e, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x42, 0x14, 0x0a, 0x12, 0x5f, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x1a, 0xed, 0x02, 0x0a, 0x0c, 0x45, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x24, 0x0a, 0x0e, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x75, 0x6e, 0x69, 0x78, 0x5f, 0x6e, 0x61, 0x6e, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x10, 0x52, 0x0c, 0x74, 0x69, 0x6d, 0x65, 0x55, 0x6e, 0x69, 0x78, 0x4e, 0x61, 0x6e, 0x6f, 0x12, 0x1f, 0x0a, 0x0a, 0x71, 0x75, 0x65, 0x75, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x09, 0x71, 0x75, 0x65, 0x75, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x30, 0x0a, 0x13, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x5f, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x11, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x30, 0x0a, 0x11, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x48, 0x01, 0x52, 0x10, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x88, 0x01, 0x01, 0x12, 0x30, 0x0a, 0x14, 0x72, 0x65, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x5f, 0x61, 0x6c, 0x6c, 0x5f, 0x65, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x08, 0x52, 0x12, 0x72, 0x65, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x41, 0x6c, 0x6c, 0x45, 0x6e, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x12, 0x2e, 0x0a, 0x10, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0d, 0x48, 0x02, 0x52, 0x0f, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x88, 0x01, 0x01, 0x12, 0x15, 0x0a, 0x03, 0x74, 0x74, 0x6c, 0x18, 0x07, 0x20, 0x01, 0x28, 0x03, 0x48, 0x03, 0x52, 0x03, 0x74, 0x74, 0x6c, 0x88, 0x01, 0x01, 0x42, 0x06, 0x0a, 0x04, 0x64, 0x65, 0x73, 0x74, 0x42, 0x14, 0x0a, 0x12, 0x5f, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x13, 0x0a, 0x11, 0x5f, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x42, 0x06, 0x0a, 0x04, 0x5f, 0x74, 0x74, 0x6c, 0x22, 0x3e, 0x0a, 0x0c, 0x44, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x79, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x0e, 0x0a, 0x0a, 0x50, 0x45, 0x52, 0x53, 0x49, 0x53, 0x54, 0x45, 0x4e, 0x54, 0x10, 0x00, 0x12, 0x12, 0x0a, 0x0e, 0x4e, 0x4f, 0x4e, 0x5f, 0x50, 0x45, 0x52, 0x53, 0x49, 0x53, 0x54, 0x45, 0x4e, 0x54, 0x10, 0x01, 0x12, 0x0a, 0x0a, 0x06, 0x44, 0x49, 0x52, 0x45, 0x43, 0x54, 0x10, 0x02, 0x42, 0x11, 0x0a, 0x0f, 0x5f, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x70, 0x61, 0x6e, 0x5f, 0x69, 0x64, 0x42, 0x0e, 0x0a, 0x0c, 0x5f, 0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x65, 0x42, 0x0a, 0x0a, 0x08, 0x5f, 0x62, 0x61, 0x67, 0x67, 0x61, 0x67, 0x65, 0x42, 0x11, 0x0a, 0x0f, 0x5f, 0x72, 0x65, 0x70, 0x6c, 0x79, 0x5f, 0x74, 0x6f, 0x5f, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x42, 0x13, 0x0a, 0x11, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x76, 0x70, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x42, 0x1f, 0x0a, 0x1d, 0x5f, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x69, 0x64, 0x42, 0x13, 0x0a, 0x11, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x0b, 0x0a, 0x09, 0x5f, 0x70, 0x72, 0x69, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x42, 0x06, 0x0a, 0x04, 0x5f, 0x74, 0x74, 0x6c, 0x42, 0x19, 0x0a, 0x17, 0x5f, 0x61, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x69, 0x64, 0x42, 0x11, 0x0a, 0x0f, 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x42, 0x14, 0x0a, 0x12, 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( file_receive_v1_proto_rawDescOnce sync.Once file_receive_v1_proto_rawDescData = file_receive_v1_proto_rawDesc ) func file_receive_v1_proto_rawDescGZIP() []byte { file_receive_v1_proto_rawDescOnce.Do(func() { file_receive_v1_proto_rawDescData = protoimpl.X.CompressGZIP(file_receive_v1_proto_rawDescData) }) return file_receive_v1_proto_rawDescData } var file_receive_v1_proto_enumTypes = make([]protoimpl.EnumInfo, 3) var file_receive_v1_proto_msgTypes = make([]protoimpl.MessageInfo, 7) var file_receive_v1_proto_goTypes = []interface{}{ (SpanData_DeliveryMode)(0), // 0: solace.messaging.proto.broker.trace.receive.v1.SpanData.DeliveryMode (SpanData_TransactionEvent_Type)(0), // 1: solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.Type (SpanData_TransactionEvent_Initiator)(0), // 2: solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.Initiator (*SpanData)(nil), // 3: solace.messaging.proto.broker.trace.receive.v1.SpanData nil, // 4: solace.messaging.proto.broker.trace.receive.v1.SpanData.UserPropertiesEntry (*SpanData_UserPropertyValue)(nil), // 5: solace.messaging.proto.broker.trace.receive.v1.SpanData.UserPropertyValue (*SpanData_TransactionEvent)(nil), // 6: solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent (*SpanData_EnqueueEvent)(nil), // 7: solace.messaging.proto.broker.trace.receive.v1.SpanData.EnqueueEvent (*SpanData_TransactionEvent_Xid)(nil), // 8: solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.Xid (*SpanData_TransactionEvent_LocalTransactionId)(nil), // 9: solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.LocalTransactionId } var file_receive_v1_proto_depIdxs = []int32{ 0, // 0: solace.messaging.proto.broker.trace.receive.v1.SpanData.delivery_mode:type_name -> solace.messaging.proto.broker.trace.receive.v1.SpanData.DeliveryMode 4, // 1: solace.messaging.proto.broker.trace.receive.v1.SpanData.user_properties:type_name -> solace.messaging.proto.broker.trace.receive.v1.SpanData.UserPropertiesEntry 6, // 2: solace.messaging.proto.broker.trace.receive.v1.SpanData.transaction_event:type_name -> solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent 7, // 3: solace.messaging.proto.broker.trace.receive.v1.SpanData.enqueue_events:type_name -> solace.messaging.proto.broker.trace.receive.v1.SpanData.EnqueueEvent 5, // 4: solace.messaging.proto.broker.trace.receive.v1.SpanData.UserPropertiesEntry.value:type_name -> solace.messaging.proto.broker.trace.receive.v1.SpanData.UserPropertyValue 1, // 5: solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.type:type_name -> solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.Type 2, // 6: solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.initiator:type_name -> solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.Initiator 8, // 7: solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.xid:type_name -> solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.Xid 9, // 8: solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.local_id:type_name -> solace.messaging.proto.broker.trace.receive.v1.SpanData.TransactionEvent.LocalTransactionId 9, // [9:9] is the sub-list for method output_type 9, // [9:9] is the sub-list for method input_type 9, // [9:9] is the sub-list for extension type_name 9, // [9:9] is the sub-list for extension extendee 0, // [0:9] is the sub-list for field type_name } func init() { file_receive_v1_proto_init() } func file_receive_v1_proto_init() { if File_receive_v1_proto != nil { return } if !protoimpl.UnsafeEnabled { file_receive_v1_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_receive_v1_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_UserPropertyValue); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_receive_v1_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_TransactionEvent); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_receive_v1_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_EnqueueEvent); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_receive_v1_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_TransactionEvent_Xid); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_receive_v1_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_TransactionEvent_LocalTransactionId); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } } file_receive_v1_proto_msgTypes[0].OneofWrappers = []interface{}{} file_receive_v1_proto_msgTypes[2].OneofWrappers = []interface{}{ (*SpanData_UserPropertyValue_NullValue)(nil), (*SpanData_UserPropertyValue_BoolValue)(nil), (*SpanData_UserPropertyValue_Uint8Value)(nil), (*SpanData_UserPropertyValue_Uint16Value)(nil), (*SpanData_UserPropertyValue_Uint32Value)(nil), (*SpanData_UserPropertyValue_Uint64Value)(nil), (*SpanData_UserPropertyValue_Int8Value)(nil), (*SpanData_UserPropertyValue_Int16Value)(nil), (*SpanData_UserPropertyValue_Int32Value)(nil), (*SpanData_UserPropertyValue_Int64Value)(nil), (*SpanData_UserPropertyValue_CharacterValue)(nil), (*SpanData_UserPropertyValue_StringValue)(nil), (*SpanData_UserPropertyValue_ByteArrayValue)(nil), (*SpanData_UserPropertyValue_FloatValue)(nil), (*SpanData_UserPropertyValue_DoubleValue)(nil), (*SpanData_UserPropertyValue_DestinationValue)(nil), } file_receive_v1_proto_msgTypes[3].OneofWrappers = []interface{}{ (*SpanData_TransactionEvent_Xid_)(nil), (*SpanData_TransactionEvent_LocalId)(nil), } file_receive_v1_proto_msgTypes[4].OneofWrappers = []interface{}{ (*SpanData_EnqueueEvent_QueueName)(nil), (*SpanData_EnqueueEvent_TopicEndpointName)(nil), } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_receive_v1_proto_rawDesc, NumEnums: 3, NumMessages: 7, NumExtensions: 0, NumServices: 0, }, GoTypes: file_receive_v1_proto_goTypes, DependencyIndexes: file_receive_v1_proto_depIdxs, EnumInfos: file_receive_v1_proto_enumTypes, MessageInfos: file_receive_v1_proto_msgTypes, }.Build() File_receive_v1_proto = out.File file_receive_v1_proto_rawDesc = nil file_receive_v1_proto_goTypes = nil file_receive_v1_proto_depIdxs = nil }