receiver/solacereceiver/internal/model/egress/v1/egress_v1.pb.go (1,779 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: egress_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_SendSpan_Outcome int32 const ( SpanData_SendSpan_ACCEPTED SpanData_SendSpan_Outcome = 0 SpanData_SendSpan_REJECTED SpanData_SendSpan_Outcome = 1 SpanData_SendSpan_RELEASED SpanData_SendSpan_Outcome = 2 SpanData_SendSpan_DELIVERY_FAILED SpanData_SendSpan_Outcome = 3 SpanData_SendSpan_FLOW_UNBOUND SpanData_SendSpan_Outcome = 4 SpanData_SendSpan_TRANSACTION_COMMIT SpanData_SendSpan_Outcome = 5 SpanData_SendSpan_TRANSACTION_COMMIT_FAILED SpanData_SendSpan_Outcome = 6 SpanData_SendSpan_TRANSACTION_ROLLBACK SpanData_SendSpan_Outcome = 7 ) // Enum value maps for SpanData_SendSpan_Outcome. var ( SpanData_SendSpan_Outcome_name = map[int32]string{ 0: "ACCEPTED", 1: "REJECTED", 2: "RELEASED", 3: "DELIVERY_FAILED", 4: "FLOW_UNBOUND", 5: "TRANSACTION_COMMIT", 6: "TRANSACTION_COMMIT_FAILED", 7: "TRANSACTION_ROLLBACK", } SpanData_SendSpan_Outcome_value = map[string]int32{ "ACCEPTED": 0, "REJECTED": 1, "RELEASED": 2, "DELIVERY_FAILED": 3, "FLOW_UNBOUND": 4, "TRANSACTION_COMMIT": 5, "TRANSACTION_COMMIT_FAILED": 6, "TRANSACTION_ROLLBACK": 7, } ) func (x SpanData_SendSpan_Outcome) Enum() *SpanData_SendSpan_Outcome { p := new(SpanData_SendSpan_Outcome) *p = x return p } func (x SpanData_SendSpan_Outcome) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (SpanData_SendSpan_Outcome) Descriptor() protoreflect.EnumDescriptor { return file_egress_v1_proto_enumTypes[0].Descriptor() } func (SpanData_SendSpan_Outcome) Type() protoreflect.EnumType { return &file_egress_v1_proto_enumTypes[0] } func (x SpanData_SendSpan_Outcome) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use SpanData_SendSpan_Outcome.Descriptor instead. func (SpanData_SendSpan_Outcome) EnumDescriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 1, 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_egress_v1_proto_enumTypes[1].Descriptor() } func (SpanData_TransactionEvent_Type) Type() protoreflect.EnumType { return &file_egress_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_egress_v1_proto_rawDescGZIP(), []int{0, 13, 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_egress_v1_proto_enumTypes[2].Descriptor() } func (SpanData_TransactionEvent_Initiator) Type() protoreflect.EnumType { return &file_egress_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_egress_v1_proto_rawDescGZIP(), []int{0, 13, 1} } // Messages with the following topic contain a message matching this // specification: // _telemetry/broker/trace/egress/v1[/additional/topic/levels] // Note that the topic 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 // in the egress portion of its data path. // // Fields with names that end in "time_unix_nano" are 64-bit timestamps, in // nanoseconds, since midnight, Jan. 1, 1970 UTC. type SpanData struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields EgressSpans []*SpanData_EgressSpan `protobuf:"bytes,1,rep,name=egress_spans,json=egressSpans,proto3" json:"egress_spans,omitempty"` // The router-name of the broker generating this message at the time the // message was generated. RouterName string `protobuf:"bytes,2,opt,name=router_name,json=routerName,proto3" json:"router_name,omitempty"` // The 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,3,opt,name=message_vpn_name,json=messageVpnName,proto3,oneof" json:"message_vpn_name,omitempty"` // The SolOS version of the broker generating the message. All elements of // egress_spans will always have been created by the same broker version. SolosVersion string `protobuf:"bytes,4,opt,name=solos_version,json=solosVersion,proto3" json:"solos_version,omitempty"` } func (x *SpanData) Reset() { *x = SpanData{} if protoimpl.UnsafeEnabled { mi := &file_egress_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_egress_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_egress_v1_proto_rawDescGZIP(), []int{0} } func (x *SpanData) GetEgressSpans() []*SpanData_EgressSpan { if x != nil { return x.EgressSpans } return nil } 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 "" } type SpanData_EgressSpan 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,3,opt,name=parent_span_id,json=parentSpanId,proto3,oneof" json:"parent_span_id,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,4,opt,name=start_time_unix_nano,json=startTimeUnixNano,proto3" json:"start_time_unix_nano,omitempty"` EndTimeUnixNano int64 `protobuf:"fixed64,5,opt,name=end_time_unix_nano,json=endTimeUnixNano,proto3" json:"end_time_unix_nano,omitempty"` TransactionEvent *SpanData_TransactionEvent `protobuf:"bytes,6,opt,name=transaction_event,json=transactionEvent,proto3,oneof" json:"transaction_event,omitempty"` ErrorDescription *string `protobuf:"bytes,7,opt,name=error_description,json=errorDescription,proto3,oneof" json:"error_description,omitempty"` // Types that are assignable to TypeData: // // *SpanData_EgressSpan_SendSpan // *SpanData_EgressSpan_DeleteSpan TypeData isSpanData_EgressSpan_TypeData `protobuf_oneof:"type_data"` } func (x *SpanData_EgressSpan) Reset() { *x = SpanData_EgressSpan{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_EgressSpan) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_EgressSpan) ProtoMessage() {} func (x *SpanData_EgressSpan) ProtoReflect() protoreflect.Message { mi := &file_egress_v1_proto_msgTypes[1] 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_EgressSpan.ProtoReflect.Descriptor instead. func (*SpanData_EgressSpan) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 0} } func (x *SpanData_EgressSpan) GetTraceId() []byte { if x != nil { return x.TraceId } return nil } func (x *SpanData_EgressSpan) GetSpanId() []byte { if x != nil { return x.SpanId } return nil } func (x *SpanData_EgressSpan) GetParentSpanId() []byte { if x != nil { return x.ParentSpanId } return nil } func (x *SpanData_EgressSpan) GetStartTimeUnixNano() int64 { if x != nil { return x.StartTimeUnixNano } return 0 } func (x *SpanData_EgressSpan) GetEndTimeUnixNano() int64 { if x != nil { return x.EndTimeUnixNano } return 0 } func (x *SpanData_EgressSpan) GetTransactionEvent() *SpanData_TransactionEvent { if x != nil { return x.TransactionEvent } return nil } func (x *SpanData_EgressSpan) GetErrorDescription() string { if x != nil && x.ErrorDescription != nil { return *x.ErrorDescription } return "" } func (m *SpanData_EgressSpan) GetTypeData() isSpanData_EgressSpan_TypeData { if m != nil { return m.TypeData } return nil } func (x *SpanData_EgressSpan) GetSendSpan() *SpanData_SendSpan { if x, ok := x.GetTypeData().(*SpanData_EgressSpan_SendSpan); ok { return x.SendSpan } return nil } func (x *SpanData_EgressSpan) GetDeleteSpan() *SpanData_DeleteSpan { if x, ok := x.GetTypeData().(*SpanData_EgressSpan_DeleteSpan); ok { return x.DeleteSpan } return nil } type isSpanData_EgressSpan_TypeData interface { isSpanData_EgressSpan_TypeData() } type SpanData_EgressSpan_SendSpan struct { SendSpan *SpanData_SendSpan `protobuf:"bytes,8,opt,name=send_span,json=sendSpan,proto3,oneof"` } type SpanData_EgressSpan_DeleteSpan struct { DeleteSpan *SpanData_DeleteSpan `protobuf:"bytes,9,opt,name=delete_span,json=deleteSpan,proto3,oneof"` } func (*SpanData_EgressSpan_SendSpan) isSpanData_EgressSpan_TypeData() {} func (*SpanData_EgressSpan_DeleteSpan) isSpanData_EgressSpan_TypeData() {} // This message contains information unique to a SendSpan. type SpanData_SendSpan struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // The name of the queue or topic endpoint the message is being delivered // from. // // Types that are assignable to Source: // // *SpanData_SendSpan_QueueName // *SpanData_SendSpan_TopicEndpointName Source isSpanData_SendSpan_Source `protobuf_oneof:"source"` Outcome SpanData_SendSpan_Outcome `protobuf:"varint,3,opt,name=outcome,proto3,enum=solace.messaging.proto.broker.trace.egress.v1.SpanData_SendSpan_Outcome" json:"outcome,omitempty"` ReplayedMsg bool `protobuf:"varint,4,opt,name=replayed_msg,json=replayedMsg,proto3" json:"replayed_msg,omitempty"` ConsumerClientUsername string `protobuf:"bytes,5,opt,name=consumer_client_username,json=consumerClientUsername,proto3" json:"consumer_client_username,omitempty"` ConsumerClientName string `protobuf:"bytes,6,opt,name=consumer_client_name,json=consumerClientName,proto3" json:"consumer_client_name,omitempty"` Protocol string `protobuf:"bytes,7,opt,name=protocol,proto3" json:"protocol,omitempty"` ProtocolVersion *string `protobuf:"bytes,8,opt,name=protocol_version,json=protocolVersion,proto3,oneof" json:"protocol_version,omitempty"` // Partition number of the queue the message is being delivered from, // if the associated queue is a partitioned queue PartitionNumber *uint32 `protobuf:"varint,9,opt,name=partition_number,json=partitionNumber,proto3,oneof" json:"partition_number,omitempty"` } func (x *SpanData_SendSpan) Reset() { *x = SpanData_SendSpan{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_SendSpan) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_SendSpan) ProtoMessage() {} func (x *SpanData_SendSpan) ProtoReflect() protoreflect.Message { mi := &file_egress_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_SendSpan.ProtoReflect.Descriptor instead. func (*SpanData_SendSpan) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 1} } func (m *SpanData_SendSpan) GetSource() isSpanData_SendSpan_Source { if m != nil { return m.Source } return nil } func (x *SpanData_SendSpan) GetQueueName() string { if x, ok := x.GetSource().(*SpanData_SendSpan_QueueName); ok { return x.QueueName } return "" } func (x *SpanData_SendSpan) GetTopicEndpointName() string { if x, ok := x.GetSource().(*SpanData_SendSpan_TopicEndpointName); ok { return x.TopicEndpointName } return "" } func (x *SpanData_SendSpan) GetOutcome() SpanData_SendSpan_Outcome { if x != nil { return x.Outcome } return SpanData_SendSpan_ACCEPTED } func (x *SpanData_SendSpan) GetReplayedMsg() bool { if x != nil { return x.ReplayedMsg } return false } func (x *SpanData_SendSpan) GetConsumerClientUsername() string { if x != nil { return x.ConsumerClientUsername } return "" } func (x *SpanData_SendSpan) GetConsumerClientName() string { if x != nil { return x.ConsumerClientName } return "" } func (x *SpanData_SendSpan) GetProtocol() string { if x != nil { return x.Protocol } return "" } func (x *SpanData_SendSpan) GetProtocolVersion() string { if x != nil && x.ProtocolVersion != nil { return *x.ProtocolVersion } return "" } func (x *SpanData_SendSpan) GetPartitionNumber() uint32 { if x != nil && x.PartitionNumber != nil { return *x.PartitionNumber } return 0 } type isSpanData_SendSpan_Source interface { isSpanData_SendSpan_Source() } type SpanData_SendSpan_QueueName struct { QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3,oneof"` } type SpanData_SendSpan_TopicEndpointName struct { TopicEndpointName string `protobuf:"bytes,2,opt,name=topic_endpoint_name,json=topicEndpointName,proto3,oneof"` } func (*SpanData_SendSpan_QueueName) isSpanData_SendSpan_Source() {} func (*SpanData_SendSpan_TopicEndpointName) isSpanData_SendSpan_Source() {} // This message contains information unique to a DeleteSpan. type SpanData_DeleteSpan struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // The name of the queue or topic endpoint the message is being deleted // from. // // Types that are assignable to EndpointName: // // *SpanData_DeleteSpan_QueueName // *SpanData_DeleteSpan_TopicEndpointName EndpointName isSpanData_DeleteSpan_EndpointName `protobuf_oneof:"endpoint_name"` // The nested "info" message below provides the following information: // - The reason for the message being deleted. // - Any additional information associated with that particular reason. // Some reasons have no additional information, so their associated info // messages have no fields within them. // // Types that are assignable to TypeInfo: // // *SpanData_DeleteSpan_MaxRedeliveriesInfo // *SpanData_DeleteSpan_TtlExpiredInfo // *SpanData_DeleteSpan_RejectedOutcomeInfo // *SpanData_DeleteSpan_HopCountExceededInfo // *SpanData_DeleteSpan_IngressSelectorInfo // *SpanData_DeleteSpan_AdminActionInfo TypeInfo isSpanData_DeleteSpan_TypeInfo `protobuf_oneof:"type_info"` // Partition number of the queue the message is being deleted from, // if the associated queue is a partitioned queue PartitionNumber *uint32 `protobuf:"varint,9,opt,name=partition_number,json=partitionNumber,proto3,oneof" json:"partition_number,omitempty"` } func (x *SpanData_DeleteSpan) Reset() { *x = SpanData_DeleteSpan{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_DeleteSpan) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_DeleteSpan) ProtoMessage() {} func (x *SpanData_DeleteSpan) ProtoReflect() protoreflect.Message { mi := &file_egress_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_DeleteSpan.ProtoReflect.Descriptor instead. func (*SpanData_DeleteSpan) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 2} } func (m *SpanData_DeleteSpan) GetEndpointName() isSpanData_DeleteSpan_EndpointName { if m != nil { return m.EndpointName } return nil } func (x *SpanData_DeleteSpan) GetQueueName() string { if x, ok := x.GetEndpointName().(*SpanData_DeleteSpan_QueueName); ok { return x.QueueName } return "" } func (x *SpanData_DeleteSpan) GetTopicEndpointName() string { if x, ok := x.GetEndpointName().(*SpanData_DeleteSpan_TopicEndpointName); ok { return x.TopicEndpointName } return "" } func (m *SpanData_DeleteSpan) GetTypeInfo() isSpanData_DeleteSpan_TypeInfo { if m != nil { return m.TypeInfo } return nil } func (x *SpanData_DeleteSpan) GetMaxRedeliveriesInfo() *SpanData_MaxRedeliveriesInfo { if x, ok := x.GetTypeInfo().(*SpanData_DeleteSpan_MaxRedeliveriesInfo); ok { return x.MaxRedeliveriesInfo } return nil } func (x *SpanData_DeleteSpan) GetTtlExpiredInfo() *SpanData_TtlExpiredInfo { if x, ok := x.GetTypeInfo().(*SpanData_DeleteSpan_TtlExpiredInfo); ok { return x.TtlExpiredInfo } return nil } func (x *SpanData_DeleteSpan) GetRejectedOutcomeInfo() *SpanData_RejectedOutcomeInfo { if x, ok := x.GetTypeInfo().(*SpanData_DeleteSpan_RejectedOutcomeInfo); ok { return x.RejectedOutcomeInfo } return nil } func (x *SpanData_DeleteSpan) GetHopCountExceededInfo() *SpanData_HopCountExceededInfo { if x, ok := x.GetTypeInfo().(*SpanData_DeleteSpan_HopCountExceededInfo); ok { return x.HopCountExceededInfo } return nil } func (x *SpanData_DeleteSpan) GetIngressSelectorInfo() *SpanData_IngressSelectorInfo { if x, ok := x.GetTypeInfo().(*SpanData_DeleteSpan_IngressSelectorInfo); ok { return x.IngressSelectorInfo } return nil } func (x *SpanData_DeleteSpan) GetAdminActionInfo() *SpanData_AdminActionInfo { if x, ok := x.GetTypeInfo().(*SpanData_DeleteSpan_AdminActionInfo); ok { return x.AdminActionInfo } return nil } func (x *SpanData_DeleteSpan) GetPartitionNumber() uint32 { if x != nil && x.PartitionNumber != nil { return *x.PartitionNumber } return 0 } type isSpanData_DeleteSpan_EndpointName interface { isSpanData_DeleteSpan_EndpointName() } type SpanData_DeleteSpan_QueueName struct { QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3,oneof"` } type SpanData_DeleteSpan_TopicEndpointName struct { TopicEndpointName string `protobuf:"bytes,2,opt,name=topic_endpoint_name,json=topicEndpointName,proto3,oneof"` } func (*SpanData_DeleteSpan_QueueName) isSpanData_DeleteSpan_EndpointName() {} func (*SpanData_DeleteSpan_TopicEndpointName) isSpanData_DeleteSpan_EndpointName() {} type isSpanData_DeleteSpan_TypeInfo interface { isSpanData_DeleteSpan_TypeInfo() } type SpanData_DeleteSpan_MaxRedeliveriesInfo struct { MaxRedeliveriesInfo *SpanData_MaxRedeliveriesInfo `protobuf:"bytes,3,opt,name=max_redeliveries_info,json=maxRedeliveriesInfo,proto3,oneof"` } type SpanData_DeleteSpan_TtlExpiredInfo struct { TtlExpiredInfo *SpanData_TtlExpiredInfo `protobuf:"bytes,4,opt,name=ttl_expired_info,json=ttlExpiredInfo,proto3,oneof"` } type SpanData_DeleteSpan_RejectedOutcomeInfo struct { RejectedOutcomeInfo *SpanData_RejectedOutcomeInfo `protobuf:"bytes,5,opt,name=rejected_outcome_info,json=rejectedOutcomeInfo,proto3,oneof"` } type SpanData_DeleteSpan_HopCountExceededInfo struct { HopCountExceededInfo *SpanData_HopCountExceededInfo `protobuf:"bytes,6,opt,name=hop_count_exceeded_info,json=hopCountExceededInfo,proto3,oneof"` } type SpanData_DeleteSpan_IngressSelectorInfo struct { IngressSelectorInfo *SpanData_IngressSelectorInfo `protobuf:"bytes,7,opt,name=ingress_selector_info,json=ingressSelectorInfo,proto3,oneof"` } type SpanData_DeleteSpan_AdminActionInfo struct { AdminActionInfo *SpanData_AdminActionInfo `protobuf:"bytes,8,opt,name=admin_action_info,json=adminActionInfo,proto3,oneof"` } func (*SpanData_DeleteSpan_MaxRedeliveriesInfo) isSpanData_DeleteSpan_TypeInfo() {} func (*SpanData_DeleteSpan_TtlExpiredInfo) isSpanData_DeleteSpan_TypeInfo() {} func (*SpanData_DeleteSpan_RejectedOutcomeInfo) isSpanData_DeleteSpan_TypeInfo() {} func (*SpanData_DeleteSpan_HopCountExceededInfo) isSpanData_DeleteSpan_TypeInfo() {} func (*SpanData_DeleteSpan_IngressSelectorInfo) isSpanData_DeleteSpan_TypeInfo() {} func (*SpanData_DeleteSpan_AdminActionInfo) isSpanData_DeleteSpan_TypeInfo() {} // The presence of this message implies the reason for the span is that a // message exceeded the maximum number of redeliveries. type SpanData_MaxRedeliveriesInfo struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields } func (x *SpanData_MaxRedeliveriesInfo) Reset() { *x = SpanData_MaxRedeliveriesInfo{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_MaxRedeliveriesInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_MaxRedeliveriesInfo) ProtoMessage() {} func (x *SpanData_MaxRedeliveriesInfo) ProtoReflect() protoreflect.Message { mi := &file_egress_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_MaxRedeliveriesInfo.ProtoReflect.Descriptor instead. func (*SpanData_MaxRedeliveriesInfo) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 3} } // The presence of this message implies the reason for the span is that the // message's TTL has expired. type SpanData_TtlExpiredInfo struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields } func (x *SpanData_TtlExpiredInfo) Reset() { *x = SpanData_TtlExpiredInfo{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[5] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_TtlExpiredInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_TtlExpiredInfo) ProtoMessage() {} func (x *SpanData_TtlExpiredInfo) ProtoReflect() protoreflect.Message { mi := &file_egress_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_TtlExpiredInfo.ProtoReflect.Descriptor instead. func (*SpanData_TtlExpiredInfo) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 4} } // The presence of this message implies the reason for the span is that a // consuming client settled the message with an outcome of "rejected". type SpanData_RejectedOutcomeInfo struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields } func (x *SpanData_RejectedOutcomeInfo) Reset() { *x = SpanData_RejectedOutcomeInfo{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[6] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_RejectedOutcomeInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_RejectedOutcomeInfo) ProtoMessage() {} func (x *SpanData_RejectedOutcomeInfo) ProtoReflect() protoreflect.Message { mi := &file_egress_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_RejectedOutcomeInfo.ProtoReflect.Descriptor instead. func (*SpanData_RejectedOutcomeInfo) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 5} } // The presence of this message implies the reason for the span is that the // message exceeded its maximum hop count. Hop count limits are used to // prevent messages from cycling through a loop indefinitely in a network of // brokers. This could be caused by certain bridge configurations. In some // documentation an interfaces, this may be referred to as SMF TTL or bridge // TTL. Here the term TTL is being avoided to avoid confusion with the // Guaranteed Messaging TTL, which is specified as a time duration. type SpanData_HopCountExceededInfo struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields } func (x *SpanData_HopCountExceededInfo) Reset() { *x = SpanData_HopCountExceededInfo{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[7] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_HopCountExceededInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_HopCountExceededInfo) ProtoMessage() {} func (x *SpanData_HopCountExceededInfo) ProtoReflect() protoreflect.Message { mi := &file_egress_v1_proto_msgTypes[7] 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_HopCountExceededInfo.ProtoReflect.Descriptor instead. func (*SpanData_HopCountExceededInfo) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 6} } // The presence of this message implies the reason for the span is that the // message did not match a topic endpoint's ingress selector. The message's // receive span would have indicated it was being enqueued on the topic // endpoint, but before the message is eligible to be delivered to a // consumer, the message was discarded because it did not match the ingress // selector. type SpanData_IngressSelectorInfo struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields } func (x *SpanData_IngressSelectorInfo) Reset() { *x = SpanData_IngressSelectorInfo{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[8] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_IngressSelectorInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_IngressSelectorInfo) ProtoMessage() {} func (x *SpanData_IngressSelectorInfo) ProtoReflect() protoreflect.Message { mi := &file_egress_v1_proto_msgTypes[8] 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_IngressSelectorInfo.ProtoReflect.Descriptor instead. func (*SpanData_IngressSelectorInfo) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 7} } // The presence of this message implies the reason for the discard was an // administrative delete message command. These spans are only generated // when the command deletes a single message. type SpanData_AdminActionInfo struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // The authenticated username of the administrator that requested the // operation. Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` // Information identifying the user's session. // // Types that are assignable to SessionInfo: // // *SpanData_AdminActionInfo_CliSessionInfo // *SpanData_AdminActionInfo_SempSessionInfo SessionInfo isSpanData_AdminActionInfo_SessionInfo `protobuf_oneof:"session_info"` } func (x *SpanData_AdminActionInfo) Reset() { *x = SpanData_AdminActionInfo{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[9] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_AdminActionInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_AdminActionInfo) ProtoMessage() {} func (x *SpanData_AdminActionInfo) ProtoReflect() protoreflect.Message { mi := &file_egress_v1_proto_msgTypes[9] 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_AdminActionInfo.ProtoReflect.Descriptor instead. func (*SpanData_AdminActionInfo) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 8} } func (x *SpanData_AdminActionInfo) GetUsername() string { if x != nil { return x.Username } return "" } func (m *SpanData_AdminActionInfo) GetSessionInfo() isSpanData_AdminActionInfo_SessionInfo { if m != nil { return m.SessionInfo } return nil } func (x *SpanData_AdminActionInfo) GetCliSessionInfo() *SpanData_CliSessionInfo { if x, ok := x.GetSessionInfo().(*SpanData_AdminActionInfo_CliSessionInfo); ok { return x.CliSessionInfo } return nil } func (x *SpanData_AdminActionInfo) GetSempSessionInfo() *SpanData_SempSessionInfo { if x, ok := x.GetSessionInfo().(*SpanData_AdminActionInfo_SempSessionInfo); ok { return x.SempSessionInfo } return nil } type isSpanData_AdminActionInfo_SessionInfo interface { isSpanData_AdminActionInfo_SessionInfo() } type SpanData_AdminActionInfo_CliSessionInfo struct { CliSessionInfo *SpanData_CliSessionInfo `protobuf:"bytes,2,opt,name=cli_session_info,json=cliSessionInfo,proto3,oneof"` } type SpanData_AdminActionInfo_SempSessionInfo struct { SempSessionInfo *SpanData_SempSessionInfo `protobuf:"bytes,3,opt,name=semp_session_info,json=sempSessionInfo,proto3,oneof"` } func (*SpanData_AdminActionInfo_CliSessionInfo) isSpanData_AdminActionInfo_SessionInfo() {} func (*SpanData_AdminActionInfo_SempSessionInfo) isSpanData_AdminActionInfo_SessionInfo() {} type SpanData_CliSessionInfo struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // CLI Sessions are identified as coming from either a remote SSH connection // or from a local terminal. The information provided differs in each case. // // Types that are assignable to Descriptor_: // // *SpanData_CliSessionInfo_LocalSession // *SpanData_CliSessionInfo_RemoteSession Descriptor_ isSpanData_CliSessionInfo_Descriptor_ `protobuf_oneof:"descriptor"` // The session number the broker uses to identify a CLI session. SessionNumber uint32 `protobuf:"varint,3,opt,name=sessionNumber,proto3" json:"sessionNumber,omitempty"` } func (x *SpanData_CliSessionInfo) Reset() { *x = SpanData_CliSessionInfo{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[10] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_CliSessionInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_CliSessionInfo) ProtoMessage() {} func (x *SpanData_CliSessionInfo) ProtoReflect() protoreflect.Message { mi := &file_egress_v1_proto_msgTypes[10] 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_CliSessionInfo.ProtoReflect.Descriptor instead. func (*SpanData_CliSessionInfo) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 9} } func (m *SpanData_CliSessionInfo) GetDescriptor_() isSpanData_CliSessionInfo_Descriptor_ { if m != nil { return m.Descriptor_ } return nil } func (x *SpanData_CliSessionInfo) GetLocalSession() *SpanData_TerminalCliSessionDescriptor { if x, ok := x.GetDescriptor_().(*SpanData_CliSessionInfo_LocalSession); ok { return x.LocalSession } return nil } func (x *SpanData_CliSessionInfo) GetRemoteSession() *SpanData_SshCliSessionDescriptor { if x, ok := x.GetDescriptor_().(*SpanData_CliSessionInfo_RemoteSession); ok { return x.RemoteSession } return nil } func (x *SpanData_CliSessionInfo) GetSessionNumber() uint32 { if x != nil { return x.SessionNumber } return 0 } type isSpanData_CliSessionInfo_Descriptor_ interface { isSpanData_CliSessionInfo_Descriptor_() } type SpanData_CliSessionInfo_LocalSession struct { LocalSession *SpanData_TerminalCliSessionDescriptor `protobuf:"bytes,1,opt,name=local_session,json=localSession,proto3,oneof"` } type SpanData_CliSessionInfo_RemoteSession struct { RemoteSession *SpanData_SshCliSessionDescriptor `protobuf:"bytes,2,opt,name=remote_session,json=remoteSession,proto3,oneof"` } func (*SpanData_CliSessionInfo_LocalSession) isSpanData_CliSessionInfo_Descriptor_() {} func (*SpanData_CliSessionInfo_RemoteSession) isSpanData_CliSessionInfo_Descriptor_() {} type SpanData_TerminalCliSessionDescriptor struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields TerminalName string `protobuf:"bytes,1,opt,name=terminal_name,json=terminalName,proto3" json:"terminal_name,omitempty"` } func (x *SpanData_TerminalCliSessionDescriptor) Reset() { *x = SpanData_TerminalCliSessionDescriptor{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_TerminalCliSessionDescriptor) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_TerminalCliSessionDescriptor) ProtoMessage() {} func (x *SpanData_TerminalCliSessionDescriptor) ProtoReflect() protoreflect.Message { mi := &file_egress_v1_proto_msgTypes[11] 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_TerminalCliSessionDescriptor.ProtoReflect.Descriptor instead. func (*SpanData_TerminalCliSessionDescriptor) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 10} } func (x *SpanData_TerminalCliSessionDescriptor) GetTerminalName() string { if x != nil { return x.TerminalName } return "" } type SpanData_SshCliSessionDescriptor struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // A valid IP will be 4 or 16 bytes in length. If the length is 4 bytes, // the address is an IPv4 address. If it is 16 bytes, it is an IPv6 // address. PeerIp []byte `protobuf:"bytes,1,opt,name=peer_ip,json=peerIp,proto3" json:"peer_ip,omitempty"` } func (x *SpanData_SshCliSessionDescriptor) Reset() { *x = SpanData_SshCliSessionDescriptor{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_SshCliSessionDescriptor) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_SshCliSessionDescriptor) ProtoMessage() {} func (x *SpanData_SshCliSessionDescriptor) ProtoReflect() protoreflect.Message { mi := &file_egress_v1_proto_msgTypes[12] 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_SshCliSessionDescriptor.ProtoReflect.Descriptor instead. func (*SpanData_SshCliSessionDescriptor) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 11} } func (x *SpanData_SshCliSessionDescriptor) GetPeerIp() []byte { if x != nil { return x.PeerIp } return nil } type SpanData_SempSessionInfo struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields SempVersion uint32 `protobuf:"varint,1,opt,name=sempVersion,proto3" json:"sempVersion,omitempty"` // A valid IP will be 4 or 16 bytes in length. If the length is 4 bytes, // the address is an IPv4 address. If it is 16 bytes, it is an IPv6 // address. PeerIp []byte `protobuf:"bytes,2,opt,name=peer_ip,json=peerIp,proto3" json:"peer_ip,omitempty"` } func (x *SpanData_SempSessionInfo) Reset() { *x = SpanData_SempSessionInfo{} if protoimpl.UnsafeEnabled { mi := &file_egress_v1_proto_msgTypes[13] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *SpanData_SempSessionInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*SpanData_SempSessionInfo) ProtoMessage() {} func (x *SpanData_SempSessionInfo) ProtoReflect() protoreflect.Message { mi := &file_egress_v1_proto_msgTypes[13] 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_SempSessionInfo.ProtoReflect.Descriptor instead. func (*SpanData_SempSessionInfo) Descriptor() ([]byte, []int) { return file_egress_v1_proto_rawDescGZIP(), []int{0, 12} } func (x *SpanData_SempSessionInfo) GetSempVersion() uint32 { if x != nil { return x.SempVersion } return 0 } func (x *SpanData_SempSessionInfo) GetPeerIp() []byte { if x != nil { return x.PeerIp } return nil } // When a span has a transaction event, it indicates the span occurs as part // of processing a transaction, and includes the *current* state of of the // transaction when the event was generated. The state can change as // subsequent events occur as part of the transaction. 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.egress.v1.SpanData_TransactionEvent_Type" json:"type,omitempty"` Initiator SpanData_TransactionEvent_Initiator `protobuf:"varint,3,opt,name=initiator,proto3,enum=solace.messaging.proto.broker.trace.egress.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_egress_v1_proto_msgTypes[14] 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_egress_v1_proto_msgTypes[14] 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_egress_v1_proto_rawDescGZIP(), []int{0, 13} } 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() {} 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_egress_v1_proto_msgTypes[15] 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_egress_v1_proto_msgTypes[15] 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_egress_v1_proto_rawDescGZIP(), []int{0, 13, 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_egress_v1_proto_msgTypes[16] 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_egress_v1_proto_msgTypes[16] 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_egress_v1_proto_rawDescGZIP(), []int{0, 13, 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_egress_v1_proto protoreflect.FileDescriptor var file_egress_v1_proto_rawDesc = []byte{ 0x0a, 0x0f, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x5f, 0x76, 0x31, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x2d, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x22, 0xde, 0x22, 0x0a, 0x08, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x12, 0x65, 0x0a, 0x0c, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x5f, 0x73, 0x70, 0x61, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x42, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x45, 0x67, 0x72, 0x65, 0x73, 0x73, 0x53, 0x70, 0x61, 0x6e, 0x52, 0x0b, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x53, 0x70, 0x61, 0x6e, 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x72, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 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, 0x03, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 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, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x6f, 0x6c, 0x6f, 0x73, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x1a, 0x8b, 0x05, 0x0a, 0x0a, 0x45, 0x67, 0x72, 0x65, 0x73, 0x73, 0x53, 0x70, 0x61, 0x6e, 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, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x01, 0x52, 0x0c, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x53, 0x70, 0x61, 0x6e, 0x49, 0x64, 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, 0x04, 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, 0x05, 0x20, 0x01, 0x28, 0x10, 0x52, 0x0f, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x55, 0x6e, 0x69, 0x78, 0x4e, 0x61, 0x6e, 0x6f, 0x12, 0x7a, 0x0a, 0x11, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x48, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 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, 0x02, 0x52, 0x10, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x88, 0x01, 0x01, 0x12, 0x30, 0x0a, 0x11, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x48, 0x03, 0x52, 0x10, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x88, 0x01, 0x01, 0x12, 0x5f, 0x0a, 0x09, 0x73, 0x65, 0x6e, 0x64, 0x5f, 0x73, 0x70, 0x61, 0x6e, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x40, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x53, 0x70, 0x61, 0x6e, 0x48, 0x00, 0x52, 0x08, 0x73, 0x65, 0x6e, 0x64, 0x53, 0x70, 0x61, 0x6e, 0x12, 0x65, 0x0a, 0x0b, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x5f, 0x73, 0x70, 0x61, 0x6e, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x42, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x70, 0x61, 0x6e, 0x48, 0x00, 0x52, 0x0a, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x70, 0x61, 0x6e, 0x42, 0x0b, 0x0a, 0x09, 0x74, 0x79, 0x70, 0x65, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x42, 0x11, 0x0a, 0x0f, 0x5f, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x70, 0x61, 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, 0x42, 0x14, 0x0a, 0x12, 0x5f, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x1a, 0xae, 0x05, 0x0a, 0x08, 0x53, 0x65, 0x6e, 0x64, 0x53, 0x70, 0x61, 0x6e, 0x12, 0x1f, 0x0a, 0x0a, 0x71, 0x75, 0x65, 0x75, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 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, 0x02, 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, 0x62, 0x0a, 0x07, 0x6f, 0x75, 0x74, 0x63, 0x6f, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x48, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x53, 0x70, 0x61, 0x6e, 0x2e, 0x4f, 0x75, 0x74, 0x63, 0x6f, 0x6d, 0x65, 0x52, 0x07, 0x6f, 0x75, 0x74, 0x63, 0x6f, 0x6d, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x72, 0x65, 0x70, 0x6c, 0x61, 0x79, 0x65, 0x64, 0x5f, 0x6d, 0x73, 0x67, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0b, 0x72, 0x65, 0x70, 0x6c, 0x61, 0x79, 0x65, 0x64, 0x4d, 0x73, 0x67, 0x12, 0x38, 0x0a, 0x18, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x72, 0x5f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x16, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x72, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x55, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x30, 0x0a, 0x14, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x72, 0x5f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x12, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x72, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x18, 0x07, 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, 0x08, 0x20, 0x01, 0x28, 0x09, 0x48, 0x01, 0x52, 0x0f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x88, 0x01, 0x01, 0x12, 0x2e, 0x0a, 0x10, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x09, 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, 0x22, 0xab, 0x01, 0x0a, 0x07, 0x4f, 0x75, 0x74, 0x63, 0x6f, 0x6d, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x41, 0x43, 0x43, 0x45, 0x50, 0x54, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x52, 0x45, 0x4a, 0x45, 0x43, 0x54, 0x45, 0x44, 0x10, 0x01, 0x12, 0x0c, 0x0a, 0x08, 0x52, 0x45, 0x4c, 0x45, 0x41, 0x53, 0x45, 0x44, 0x10, 0x02, 0x12, 0x13, 0x0a, 0x0f, 0x44, 0x45, 0x4c, 0x49, 0x56, 0x45, 0x52, 0x59, 0x5f, 0x46, 0x41, 0x49, 0x4c, 0x45, 0x44, 0x10, 0x03, 0x12, 0x10, 0x0a, 0x0c, 0x46, 0x4c, 0x4f, 0x57, 0x5f, 0x55, 0x4e, 0x42, 0x4f, 0x55, 0x4e, 0x44, 0x10, 0x04, 0x12, 0x16, 0x0a, 0x12, 0x54, 0x52, 0x41, 0x4e, 0x53, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x43, 0x4f, 0x4d, 0x4d, 0x49, 0x54, 0x10, 0x05, 0x12, 0x1d, 0x0a, 0x19, 0x54, 0x52, 0x41, 0x4e, 0x53, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x43, 0x4f, 0x4d, 0x4d, 0x49, 0x54, 0x5f, 0x46, 0x41, 0x49, 0x4c, 0x45, 0x44, 0x10, 0x06, 0x12, 0x18, 0x0a, 0x14, 0x54, 0x52, 0x41, 0x4e, 0x53, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x52, 0x4f, 0x4c, 0x4c, 0x42, 0x41, 0x43, 0x4b, 0x10, 0x07, 0x42, 0x08, 0x0a, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x42, 0x13, 0x0a, 0x11, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x13, 0x0a, 0x11, 0x5f, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x1a, 0xc1, 0x07, 0x0a, 0x0a, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x70, 0x61, 0x6e, 0x12, 0x1f, 0x0a, 0x0a, 0x71, 0x75, 0x65, 0x75, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 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, 0x02, 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, 0x81, 0x01, 0x0a, 0x15, 0x6d, 0x61, 0x78, 0x5f, 0x72, 0x65, 0x64, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x69, 0x65, 0x73, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x4b, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x4d, 0x61, 0x78, 0x52, 0x65, 0x64, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x69, 0x65, 0x73, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x01, 0x52, 0x13, 0x6d, 0x61, 0x78, 0x52, 0x65, 0x64, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x69, 0x65, 0x73, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x72, 0x0a, 0x10, 0x74, 0x74, 0x6c, 0x5f, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x64, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x46, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x54, 0x74, 0x6c, 0x45, 0x78, 0x70, 0x69, 0x72, 0x65, 0x64, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x01, 0x52, 0x0e, 0x74, 0x74, 0x6c, 0x45, 0x78, 0x70, 0x69, 0x72, 0x65, 0x64, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x81, 0x01, 0x0a, 0x15, 0x72, 0x65, 0x6a, 0x65, 0x63, 0x74, 0x65, 0x64, 0x5f, 0x6f, 0x75, 0x74, 0x63, 0x6f, 0x6d, 0x65, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x4b, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x6a, 0x65, 0x63, 0x74, 0x65, 0x64, 0x4f, 0x75, 0x74, 0x63, 0x6f, 0x6d, 0x65, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x01, 0x52, 0x13, 0x72, 0x65, 0x6a, 0x65, 0x63, 0x74, 0x65, 0x64, 0x4f, 0x75, 0x74, 0x63, 0x6f, 0x6d, 0x65, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x85, 0x01, 0x0a, 0x17, 0x68, 0x6f, 0x70, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x65, 0x78, 0x63, 0x65, 0x65, 0x64, 0x65, 0x64, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x06, 0x20, 0x01, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x48, 0x6f, 0x70, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x45, 0x78, 0x63, 0x65, 0x65, 0x64, 0x65, 0x64, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x01, 0x52, 0x14, 0x68, 0x6f, 0x70, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x45, 0x78, 0x63, 0x65, 0x65, 0x64, 0x65, 0x64, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x81, 0x01, 0x0a, 0x15, 0x69, 0x6e, 0x67, 0x72, 0x65, 0x73, 0x73, 0x5f, 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x4b, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x49, 0x6e, 0x67, 0x72, 0x65, 0x73, 0x73, 0x53, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x01, 0x52, 0x13, 0x69, 0x6e, 0x67, 0x72, 0x65, 0x73, 0x73, 0x53, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x75, 0x0a, 0x11, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x5f, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x47, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x01, 0x52, 0x0f, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x2e, 0x0a, 0x10, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x09, 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, 0x42, 0x0f, 0x0a, 0x0d, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x42, 0x0b, 0x0a, 0x09, 0x74, 0x79, 0x70, 0x65, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x42, 0x13, 0x0a, 0x11, 0x5f, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x1a, 0x15, 0x0a, 0x13, 0x4d, 0x61, 0x78, 0x52, 0x65, 0x64, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x69, 0x65, 0x73, 0x49, 0x6e, 0x66, 0x6f, 0x1a, 0x10, 0x0a, 0x0e, 0x54, 0x74, 0x6c, 0x45, 0x78, 0x70, 0x69, 0x72, 0x65, 0x64, 0x49, 0x6e, 0x66, 0x6f, 0x1a, 0x15, 0x0a, 0x13, 0x52, 0x65, 0x6a, 0x65, 0x63, 0x74, 0x65, 0x64, 0x4f, 0x75, 0x74, 0x63, 0x6f, 0x6d, 0x65, 0x49, 0x6e, 0x66, 0x6f, 0x1a, 0x16, 0x0a, 0x14, 0x48, 0x6f, 0x70, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x45, 0x78, 0x63, 0x65, 0x65, 0x64, 0x65, 0x64, 0x49, 0x6e, 0x66, 0x6f, 0x1a, 0x15, 0x0a, 0x13, 0x49, 0x6e, 0x67, 0x72, 0x65, 0x73, 0x73, 0x53, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x1a, 0xa8, 0x02, 0x0a, 0x0f, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x72, 0x0a, 0x10, 0x63, 0x6c, 0x69, 0x5f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x46, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x43, 0x6c, 0x69, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x00, 0x52, 0x0e, 0x63, 0x6c, 0x69, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x75, 0x0a, 0x11, 0x73, 0x65, 0x6d, 0x70, 0x5f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x47, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x53, 0x65, 0x6d, 0x70, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x00, 0x52, 0x0f, 0x73, 0x65, 0x6d, 0x70, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x0e, 0x0a, 0x0c, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x1a, 0xbb, 0x02, 0x0a, 0x0e, 0x43, 0x6c, 0x69, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x7b, 0x0a, 0x0d, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x5f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x54, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x6c, 0x43, 0x6c, 0x69, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x48, 0x00, 0x52, 0x0c, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x78, 0x0a, 0x0e, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x5f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x4f, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x2e, 0x53, 0x73, 0x68, 0x43, 0x6c, 0x69, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x48, 0x00, 0x52, 0x0d, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x24, 0x0a, 0x0d, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x42, 0x0c, 0x0a, 0x0a, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x1a, 0x43, 0x0a, 0x1c, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x6c, 0x43, 0x6c, 0x69, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x12, 0x23, 0x0a, 0x0d, 0x74, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x6c, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x74, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x6c, 0x4e, 0x61, 0x6d, 0x65, 0x1a, 0x32, 0x0a, 0x17, 0x53, 0x73, 0x68, 0x43, 0x6c, 0x69, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x12, 0x17, 0x0a, 0x07, 0x70, 0x65, 0x65, 0x72, 0x5f, 0x69, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x70, 0x65, 0x65, 0x72, 0x49, 0x70, 0x1a, 0x4c, 0x0a, 0x0f, 0x53, 0x65, 0x6d, 0x70, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x20, 0x0a, 0x0b, 0x73, 0x65, 0x6d, 0x70, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, 0x73, 0x65, 0x6d, 0x70, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x17, 0x0a, 0x07, 0x70, 0x65, 0x65, 0x72, 0x5f, 0x69, 0x70, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x70, 0x65, 0x65, 0x72, 0x49, 0x70, 0x1a, 0xbe, 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, 0x61, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 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, 0x70, 0x0a, 0x09, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x74, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x52, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 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, 0x60, 0x0a, 0x03, 0x78, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 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, 0x78, 0x0a, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x5b, 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, 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 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, 0x42, 0x13, 0x0a, 0x11, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x76, 0x70, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( file_egress_v1_proto_rawDescOnce sync.Once file_egress_v1_proto_rawDescData = file_egress_v1_proto_rawDesc ) func file_egress_v1_proto_rawDescGZIP() []byte { file_egress_v1_proto_rawDescOnce.Do(func() { file_egress_v1_proto_rawDescData = protoimpl.X.CompressGZIP(file_egress_v1_proto_rawDescData) }) return file_egress_v1_proto_rawDescData } var file_egress_v1_proto_enumTypes = make([]protoimpl.EnumInfo, 3) var file_egress_v1_proto_msgTypes = make([]protoimpl.MessageInfo, 17) var file_egress_v1_proto_goTypes = []interface{}{ (SpanData_SendSpan_Outcome)(0), // 0: solace.messaging.proto.broker.trace.egress.v1.SpanData.SendSpan.Outcome (SpanData_TransactionEvent_Type)(0), // 1: solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.Type (SpanData_TransactionEvent_Initiator)(0), // 2: solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.Initiator (*SpanData)(nil), // 3: solace.messaging.proto.broker.trace.egress.v1.SpanData (*SpanData_EgressSpan)(nil), // 4: solace.messaging.proto.broker.trace.egress.v1.SpanData.EgressSpan (*SpanData_SendSpan)(nil), // 5: solace.messaging.proto.broker.trace.egress.v1.SpanData.SendSpan (*SpanData_DeleteSpan)(nil), // 6: solace.messaging.proto.broker.trace.egress.v1.SpanData.DeleteSpan (*SpanData_MaxRedeliveriesInfo)(nil), // 7: solace.messaging.proto.broker.trace.egress.v1.SpanData.MaxRedeliveriesInfo (*SpanData_TtlExpiredInfo)(nil), // 8: solace.messaging.proto.broker.trace.egress.v1.SpanData.TtlExpiredInfo (*SpanData_RejectedOutcomeInfo)(nil), // 9: solace.messaging.proto.broker.trace.egress.v1.SpanData.RejectedOutcomeInfo (*SpanData_HopCountExceededInfo)(nil), // 10: solace.messaging.proto.broker.trace.egress.v1.SpanData.HopCountExceededInfo (*SpanData_IngressSelectorInfo)(nil), // 11: solace.messaging.proto.broker.trace.egress.v1.SpanData.IngressSelectorInfo (*SpanData_AdminActionInfo)(nil), // 12: solace.messaging.proto.broker.trace.egress.v1.SpanData.AdminActionInfo (*SpanData_CliSessionInfo)(nil), // 13: solace.messaging.proto.broker.trace.egress.v1.SpanData.CliSessionInfo (*SpanData_TerminalCliSessionDescriptor)(nil), // 14: solace.messaging.proto.broker.trace.egress.v1.SpanData.TerminalCliSessionDescriptor (*SpanData_SshCliSessionDescriptor)(nil), // 15: solace.messaging.proto.broker.trace.egress.v1.SpanData.SshCliSessionDescriptor (*SpanData_SempSessionInfo)(nil), // 16: solace.messaging.proto.broker.trace.egress.v1.SpanData.SempSessionInfo (*SpanData_TransactionEvent)(nil), // 17: solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent (*SpanData_TransactionEvent_Xid)(nil), // 18: solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.Xid (*SpanData_TransactionEvent_LocalTransactionId)(nil), // 19: solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.LocalTransactionId } var file_egress_v1_proto_depIdxs = []int32{ 4, // 0: solace.messaging.proto.broker.trace.egress.v1.SpanData.egress_spans:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.EgressSpan 17, // 1: solace.messaging.proto.broker.trace.egress.v1.SpanData.EgressSpan.transaction_event:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent 5, // 2: solace.messaging.proto.broker.trace.egress.v1.SpanData.EgressSpan.send_span:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.SendSpan 6, // 3: solace.messaging.proto.broker.trace.egress.v1.SpanData.EgressSpan.delete_span:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.DeleteSpan 0, // 4: solace.messaging.proto.broker.trace.egress.v1.SpanData.SendSpan.outcome:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.SendSpan.Outcome 7, // 5: solace.messaging.proto.broker.trace.egress.v1.SpanData.DeleteSpan.max_redeliveries_info:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.MaxRedeliveriesInfo 8, // 6: solace.messaging.proto.broker.trace.egress.v1.SpanData.DeleteSpan.ttl_expired_info:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.TtlExpiredInfo 9, // 7: solace.messaging.proto.broker.trace.egress.v1.SpanData.DeleteSpan.rejected_outcome_info:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.RejectedOutcomeInfo 10, // 8: solace.messaging.proto.broker.trace.egress.v1.SpanData.DeleteSpan.hop_count_exceeded_info:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.HopCountExceededInfo 11, // 9: solace.messaging.proto.broker.trace.egress.v1.SpanData.DeleteSpan.ingress_selector_info:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.IngressSelectorInfo 12, // 10: solace.messaging.proto.broker.trace.egress.v1.SpanData.DeleteSpan.admin_action_info:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.AdminActionInfo 13, // 11: solace.messaging.proto.broker.trace.egress.v1.SpanData.AdminActionInfo.cli_session_info:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.CliSessionInfo 16, // 12: solace.messaging.proto.broker.trace.egress.v1.SpanData.AdminActionInfo.semp_session_info:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.SempSessionInfo 14, // 13: solace.messaging.proto.broker.trace.egress.v1.SpanData.CliSessionInfo.local_session:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.TerminalCliSessionDescriptor 15, // 14: solace.messaging.proto.broker.trace.egress.v1.SpanData.CliSessionInfo.remote_session:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.SshCliSessionDescriptor 1, // 15: solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.type:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.Type 2, // 16: solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.initiator:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.Initiator 18, // 17: solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.xid:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.Xid 19, // 18: solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.local_id:type_name -> solace.messaging.proto.broker.trace.egress.v1.SpanData.TransactionEvent.LocalTransactionId 19, // [19:19] is the sub-list for method output_type 19, // [19:19] is the sub-list for method input_type 19, // [19:19] is the sub-list for extension type_name 19, // [19:19] is the sub-list for extension extendee 0, // [0:19] is the sub-list for field type_name } func init() { file_egress_v1_proto_init() } func file_egress_v1_proto_init() { if File_egress_v1_proto != nil { return } if !protoimpl.UnsafeEnabled { file_egress_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_egress_v1_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_EgressSpan); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_SendSpan); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_DeleteSpan); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_MaxRedeliveriesInfo); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_TtlExpiredInfo); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_RejectedOutcomeInfo); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_HopCountExceededInfo); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_IngressSelectorInfo); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_AdminActionInfo); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_CliSessionInfo); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_TerminalCliSessionDescriptor); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_SshCliSessionDescriptor); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SpanData_SempSessionInfo); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_egress_v1_proto_msgTypes[14].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_egress_v1_proto_msgTypes[15].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_egress_v1_proto_msgTypes[16].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_egress_v1_proto_msgTypes[0].OneofWrappers = []interface{}{} file_egress_v1_proto_msgTypes[1].OneofWrappers = []interface{}{ (*SpanData_EgressSpan_SendSpan)(nil), (*SpanData_EgressSpan_DeleteSpan)(nil), } file_egress_v1_proto_msgTypes[2].OneofWrappers = []interface{}{ (*SpanData_SendSpan_QueueName)(nil), (*SpanData_SendSpan_TopicEndpointName)(nil), } file_egress_v1_proto_msgTypes[3].OneofWrappers = []interface{}{ (*SpanData_DeleteSpan_QueueName)(nil), (*SpanData_DeleteSpan_TopicEndpointName)(nil), (*SpanData_DeleteSpan_MaxRedeliveriesInfo)(nil), (*SpanData_DeleteSpan_TtlExpiredInfo)(nil), (*SpanData_DeleteSpan_RejectedOutcomeInfo)(nil), (*SpanData_DeleteSpan_HopCountExceededInfo)(nil), (*SpanData_DeleteSpan_IngressSelectorInfo)(nil), (*SpanData_DeleteSpan_AdminActionInfo)(nil), } file_egress_v1_proto_msgTypes[9].OneofWrappers = []interface{}{ (*SpanData_AdminActionInfo_CliSessionInfo)(nil), (*SpanData_AdminActionInfo_SempSessionInfo)(nil), } file_egress_v1_proto_msgTypes[10].OneofWrappers = []interface{}{ (*SpanData_CliSessionInfo_LocalSession)(nil), (*SpanData_CliSessionInfo_RemoteSession)(nil), } file_egress_v1_proto_msgTypes[14].OneofWrappers = []interface{}{ (*SpanData_TransactionEvent_Xid_)(nil), (*SpanData_TransactionEvent_LocalId)(nil), } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_egress_v1_proto_rawDesc, NumEnums: 3, NumMessages: 17, NumExtensions: 0, NumServices: 0, }, GoTypes: file_egress_v1_proto_goTypes, DependencyIndexes: file_egress_v1_proto_depIdxs, EnumInfos: file_egress_v1_proto_enumTypes, MessageInfos: file_egress_v1_proto_msgTypes, }.Build() File_egress_v1_proto = out.File file_egress_v1_proto_rawDesc = nil file_egress_v1_proto_goTypes = nil file_egress_v1_proto_depIdxs = nil }