v1

package
v0.119.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 4, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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,
	}
)

Enum value maps for SpanData_DeliveryMode.

View Source 
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,
	}
)

Enum value maps for SpanData_TransactionEvent_Type.

View Source 
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,
	}
)

Enum value maps for SpanData_TransactionEvent_Initiator.

View Source 
var File_receive_v1_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type SpanData 

type SpanData struct {

	// 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 `` /* 145-byte string literal not displayed */
	// 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 `` /* 173-byte string literal not displayed */
	// 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 `` /* 147-byte string literal not displayed */
	// 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 `` /* 130-byte string literal not displayed */
	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 `` /* 192-byte string literal not displayed */
	// 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 `` /* 172-byte string literal not displayed */
	// 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 `` /* 148-byte string literal not displayed */
	DroppedEnqueueEventsFailed  uint32 `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

func (*SpanData) Descriptor deprecated 

func (*SpanData) Descriptor() ([]byte, []int)

Deprecated: Use SpanData.ProtoReflect.Descriptor instead.

func (*SpanData) GetApplicationMessageId 

func (x *SpanData) GetApplicationMessageId() string

func (*SpanData) GetBaggage 

func (x *SpanData) GetBaggage() string

func (*SpanData) GetBinaryAttachmentSize 

func (x *SpanData) GetBinaryAttachmentSize() uint32

func (*SpanData) GetBrokerReceiveTimeUnixNano 

func (x *SpanData) GetBrokerReceiveTimeUnixNano() int64

func (*SpanData) GetClientName 

func (x *SpanData) GetClientName() string

func (*SpanData) GetClientUsername 

func (x *SpanData) GetClientUsername() string

func (*SpanData) GetCorrelationId 

func (x *SpanData) GetCorrelationId() string

func (*SpanData) GetDeliveryMode 

func (x *SpanData) GetDeliveryMode() SpanData_DeliveryMode

func (*SpanData) GetDmqEligible 

func (x *SpanData) GetDmqEligible() bool

func (*SpanData) GetDroppedApplicationMessageProperties 

func (x *SpanData) GetDroppedApplicationMessageProperties() bool

func (*SpanData) GetDroppedEnqueueEventsFailed 

func (x *SpanData) GetDroppedEnqueueEventsFailed() uint32

func (*SpanData) GetDroppedEnqueueEventsSuccess 

func (x *SpanData) GetDroppedEnqueueEventsSuccess() uint32

func (*SpanData) GetEndTimeUnixNano 

func (x *SpanData) GetEndTimeUnixNano() int64

func (*SpanData) GetEnqueueEvents 

func (x *SpanData) GetEnqueueEvents() []*SpanData_EnqueueEvent

func (*SpanData) GetErrorDescription 

func (x *SpanData) GetErrorDescription() string

func (*SpanData) GetHostIp 

func (x *SpanData) GetHostIp() []byte

func (*SpanData) GetHostPort 

func (x *SpanData) GetHostPort() uint32

func (*SpanData) GetMessageVpnName 

func (x *SpanData) GetMessageVpnName() string

func (*SpanData) GetMetadataSize 

func (x *SpanData) GetMetadataSize() uint32

func (*SpanData) GetParentSpanId 

func (x *SpanData) GetParentSpanId() []byte

func (*SpanData) GetPeerIp 

func (x *SpanData) GetPeerIp() []byte

func (*SpanData) GetPeerPort 

func (x *SpanData) GetPeerPort() uint32

func (*SpanData) GetPriority 

func (x *SpanData) GetPriority() uint32

func (*SpanData) GetProtocol 

func (x *SpanData) GetProtocol() string

func (*SpanData) GetProtocolVersion 

func (x *SpanData) GetProtocolVersion() string

func (*SpanData) GetReplicationGroupMessageId 

func (x *SpanData) GetReplicationGroupMessageId() []byte

func (*SpanData) GetReplyToTopic 

func (x *SpanData) GetReplyToTopic() string

func (*SpanData) GetRouterName 

func (x *SpanData) GetRouterName() string

func (*SpanData) GetSolosVersion 

func (x *SpanData) GetSolosVersion() string

func (*SpanData) GetSpanId 

func (x *SpanData) GetSpanId() []byte

func (*SpanData) GetStartTimeUnixNano 

func (x *SpanData) GetStartTimeUnixNano() int64

func (*SpanData) GetTopic 

func (x *SpanData) GetTopic() string

func (*SpanData) GetTraceId 

func (x *SpanData) GetTraceId() []byte

func (*SpanData) GetTraceState 

func (x *SpanData) GetTraceState() string

func (*SpanData) GetTransactionEvent 

func (x *SpanData) GetTransactionEvent() *SpanData_TransactionEvent

func (*SpanData) GetTtl 

func (x *SpanData) GetTtl() int64

func (*SpanData) GetUserProperties 

func (x *SpanData) GetUserProperties() map[string]*SpanData_UserPropertyValue

func (*SpanData) GetXmlAttachmentSize 

func (x *SpanData) GetXmlAttachmentSize() uint32

func (*SpanData) ProtoMessage 

func (*SpanData) ProtoMessage()

func (*SpanData) ProtoReflect 

func (x *SpanData) ProtoReflect() protoreflect.Message

func (*SpanData) Reset 

func (x *SpanData) Reset()

func (*SpanData) String 

func (x *SpanData) String() string

type SpanData_DeliveryMode 

type SpanData_DeliveryMode int32
const (
	SpanData_PERSISTENT     SpanData_DeliveryMode = 0
	SpanData_NON_PERSISTENT SpanData_DeliveryMode = 1
	SpanData_DIRECT         SpanData_DeliveryMode = 2
)

func (SpanData_DeliveryMode) Descriptor 

func (SpanData_DeliveryMode) Descriptor() protoreflect.EnumDescriptor

func (SpanData_DeliveryMode) Enum 

func (x SpanData_DeliveryMode) Enum() *SpanData_DeliveryMode

func (SpanData_DeliveryMode) EnumDescriptor deprecated 

func (SpanData_DeliveryMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use SpanData_DeliveryMode.Descriptor instead.

func (SpanData_DeliveryMode) Number 

func (x SpanData_DeliveryMode) Number() protoreflect.EnumNumber

func (SpanData_DeliveryMode) String 

func (x SpanData_DeliveryMode) String() string

func (SpanData_DeliveryMode) Type 

func (SpanData_DeliveryMode) Type() protoreflect.EnumType

type SpanData_EnqueueEvent 

type SpanData_EnqueueEvent struct {

	// 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"`
	// contains filtered or unexported fields
}

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.

func (*SpanData_EnqueueEvent) Descriptor deprecated 

func (*SpanData_EnqueueEvent) Descriptor() ([]byte, []int)

Deprecated: Use SpanData_EnqueueEvent.ProtoReflect.Descriptor instead.

func (*SpanData_EnqueueEvent) GetDest 

func (m *SpanData_EnqueueEvent) GetDest() isSpanData_EnqueueEvent_Dest

func (*SpanData_EnqueueEvent) GetErrorDescription 

func (x *SpanData_EnqueueEvent) GetErrorDescription() string

func (*SpanData_EnqueueEvent) GetPartitionNumber 

func (x *SpanData_EnqueueEvent) GetPartitionNumber() uint32

func (*SpanData_EnqueueEvent) GetQueueName 

func (x *SpanData_EnqueueEvent) GetQueueName() string

func (*SpanData_EnqueueEvent) GetRejectsAllEnqueues 

func (x *SpanData_EnqueueEvent) GetRejectsAllEnqueues() bool

func (*SpanData_EnqueueEvent) GetTimeUnixNano 

func (x *SpanData_EnqueueEvent) GetTimeUnixNano() int64

func (*SpanData_EnqueueEvent) GetTopicEndpointName 

func (x *SpanData_EnqueueEvent) GetTopicEndpointName() string

func (*SpanData_EnqueueEvent) GetTtl added in v0.113.0 

func (x *SpanData_EnqueueEvent) GetTtl() int64

func (*SpanData_EnqueueEvent) ProtoMessage 

func (*SpanData_EnqueueEvent) ProtoMessage()

func (*SpanData_EnqueueEvent) ProtoReflect 

func (x *SpanData_EnqueueEvent) ProtoReflect() protoreflect.Message

func (*SpanData_EnqueueEvent) Reset 

func (x *SpanData_EnqueueEvent) Reset()

func (*SpanData_EnqueueEvent) String 

func (x *SpanData_EnqueueEvent) String() string

type SpanData_EnqueueEvent_QueueName 

type SpanData_EnqueueEvent_QueueName struct {
	QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3,oneof"`
}

type SpanData_EnqueueEvent_TopicEndpointName 

type SpanData_EnqueueEvent_TopicEndpointName struct {
	TopicEndpointName string `protobuf:"bytes,3,opt,name=topic_endpoint_name,json=topicEndpointName,proto3,oneof"`
}

type SpanData_TransactionEvent 

type SpanData_TransactionEvent struct {
	TimeUnixNano int64                               `protobuf:"fixed64,1,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"`
	Type         SpanData_TransactionEvent_Type      `` /* 145-byte string literal not displayed */
	Initiator    SpanData_TransactionEvent_Initiator `` /* 160-byte string literal not displayed */
	// 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"`
	// contains filtered or unexported fields
}

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.

func (*SpanData_TransactionEvent) Descriptor deprecated 

func (*SpanData_TransactionEvent) Descriptor() ([]byte, []int)

Deprecated: Use SpanData_TransactionEvent.ProtoReflect.Descriptor instead.

func (*SpanData_TransactionEvent) GetErrorDescription 

func (x *SpanData_TransactionEvent) GetErrorDescription() string

func (*SpanData_TransactionEvent) GetInitiator 

func (x *SpanData_TransactionEvent) GetInitiator() SpanData_TransactionEvent_Initiator

func (*SpanData_TransactionEvent) GetLocalId 

func (x *SpanData_TransactionEvent) GetLocalId() *SpanData_TransactionEvent_LocalTransactionId

func (*SpanData_TransactionEvent) GetTimeUnixNano 

func (x *SpanData_TransactionEvent) GetTimeUnixNano() int64

func (*SpanData_TransactionEvent) GetTransactionId 

func (m *SpanData_TransactionEvent) GetTransactionId() isSpanData_TransactionEvent_TransactionId

func (*SpanData_TransactionEvent) GetType 

func (x *SpanData_TransactionEvent) GetType() SpanData_TransactionEvent_Type

func (*SpanData_TransactionEvent) GetXid 

func (x *SpanData_TransactionEvent) GetXid() *SpanData_TransactionEvent_Xid

func (*SpanData_TransactionEvent) ProtoMessage 

func (*SpanData_TransactionEvent) ProtoMessage()

func (*SpanData_TransactionEvent) ProtoReflect 

func (x *SpanData_TransactionEvent) ProtoReflect() protoreflect.Message

func (*SpanData_TransactionEvent) Reset 

func (x *SpanData_TransactionEvent) Reset()

func (*SpanData_TransactionEvent) String 

func (x *SpanData_TransactionEvent) String() string

type SpanData_TransactionEvent_Initiator 

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
)

func (SpanData_TransactionEvent_Initiator) Descriptor 

func (SpanData_TransactionEvent_Initiator) Descriptor() protoreflect.EnumDescriptor

func (SpanData_TransactionEvent_Initiator) Enum 

func (x SpanData_TransactionEvent_Initiator) Enum() *SpanData_TransactionEvent_Initiator

func (SpanData_TransactionEvent_Initiator) EnumDescriptor deprecated 

func (SpanData_TransactionEvent_Initiator) EnumDescriptor() ([]byte, []int)

Deprecated: Use SpanData_TransactionEvent_Initiator.Descriptor instead.

func (SpanData_TransactionEvent_Initiator) Number 

func (x SpanData_TransactionEvent_Initiator) Number() protoreflect.EnumNumber

func (SpanData_TransactionEvent_Initiator) String 

func (x SpanData_TransactionEvent_Initiator) String() string

func (SpanData_TransactionEvent_Initiator) Type 

func (SpanData_TransactionEvent_Initiator) Type() protoreflect.EnumType

type SpanData_TransactionEvent_LocalId 

type SpanData_TransactionEvent_LocalId struct {
	LocalId *SpanData_TransactionEvent_LocalTransactionId `protobuf:"bytes,5,opt,name=local_id,json=localId,proto3,oneof"`
}

type SpanData_TransactionEvent_LocalTransactionId 

type SpanData_TransactionEvent_LocalTransactionId struct {
	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"`
	// contains filtered or unexported fields
}

func (*SpanData_TransactionEvent_LocalTransactionId) Descriptor deprecated 

func (*SpanData_TransactionEvent_LocalTransactionId) Descriptor() ([]byte, []int)

Deprecated: Use SpanData_TransactionEvent_LocalTransactionId.ProtoReflect.Descriptor instead.

func (*SpanData_TransactionEvent_LocalTransactionId) GetSessionId 

func (x *SpanData_TransactionEvent_LocalTransactionId) GetSessionId() uint32

func (*SpanData_TransactionEvent_LocalTransactionId) GetSessionName 

func (x *SpanData_TransactionEvent_LocalTransactionId) GetSessionName() string

func (*SpanData_TransactionEvent_LocalTransactionId) GetTransactionId 

func (x *SpanData_TransactionEvent_LocalTransactionId) GetTransactionId() uint32

func (*SpanData_TransactionEvent_LocalTransactionId) ProtoMessage 

func (*SpanData_TransactionEvent_LocalTransactionId) ProtoMessage()

func (*SpanData_TransactionEvent_LocalTransactionId) ProtoReflect 

func (x *SpanData_TransactionEvent_LocalTransactionId) ProtoReflect() protoreflect.Message

func (*SpanData_TransactionEvent_LocalTransactionId) Reset 

func (x *SpanData_TransactionEvent_LocalTransactionId) Reset()

func (*SpanData_TransactionEvent_LocalTransactionId) String 

func (x *SpanData_TransactionEvent_LocalTransactionId) String() string

type SpanData_TransactionEvent_Type 

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
)

func (SpanData_TransactionEvent_Type) Descriptor 

func (SpanData_TransactionEvent_Type) Descriptor() protoreflect.EnumDescriptor

func (SpanData_TransactionEvent_Type) Enum 

func (x SpanData_TransactionEvent_Type) Enum() *SpanData_TransactionEvent_Type

func (SpanData_TransactionEvent_Type) EnumDescriptor deprecated 

func (SpanData_TransactionEvent_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use SpanData_TransactionEvent_Type.Descriptor instead.

func (SpanData_TransactionEvent_Type) Number 

func (x SpanData_TransactionEvent_Type) Number() protoreflect.EnumNumber

func (SpanData_TransactionEvent_Type) String 

func (x SpanData_TransactionEvent_Type) String() string

func (SpanData_TransactionEvent_Type) Type 

func (SpanData_TransactionEvent_Type) Type() protoreflect.EnumType

type SpanData_TransactionEvent_Xid 

type SpanData_TransactionEvent_Xid struct {
	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"`
	// contains filtered or unexported fields
}

func (*SpanData_TransactionEvent_Xid) Descriptor deprecated 

func (*SpanData_TransactionEvent_Xid) Descriptor() ([]byte, []int)

Deprecated: Use SpanData_TransactionEvent_Xid.ProtoReflect.Descriptor instead.

func (*SpanData_TransactionEvent_Xid) GetBranchQualifier 

func (x *SpanData_TransactionEvent_Xid) GetBranchQualifier() []byte

func (*SpanData_TransactionEvent_Xid) GetFormatId 

func (x *SpanData_TransactionEvent_Xid) GetFormatId() int32

func (*SpanData_TransactionEvent_Xid) GetGlobalId 

func (x *SpanData_TransactionEvent_Xid) GetGlobalId() []byte

func (*SpanData_TransactionEvent_Xid) ProtoMessage 

func (*SpanData_TransactionEvent_Xid) ProtoMessage()

func (*SpanData_TransactionEvent_Xid) ProtoReflect 

func (x *SpanData_TransactionEvent_Xid) ProtoReflect() protoreflect.Message

func (*SpanData_TransactionEvent_Xid) Reset 

func (x *SpanData_TransactionEvent_Xid) Reset()

func (*SpanData_TransactionEvent_Xid) String 

func (x *SpanData_TransactionEvent_Xid) String() string

type SpanData_TransactionEvent_Xid_ 

type SpanData_TransactionEvent_Xid_ struct {
	Xid *SpanData_TransactionEvent_Xid `protobuf:"bytes,4,opt,name=xid,proto3,oneof"`
}

type SpanData_UserPropertyValue 

type SpanData_UserPropertyValue struct {

	// 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"`
	// contains filtered or unexported fields
}

func (*SpanData_UserPropertyValue) Descriptor deprecated 

func (*SpanData_UserPropertyValue) Descriptor() ([]byte, []int)

Deprecated: Use SpanData_UserPropertyValue.ProtoReflect.Descriptor instead.

func (*SpanData_UserPropertyValue) GetBoolValue 

func (x *SpanData_UserPropertyValue) GetBoolValue() bool

func (*SpanData_UserPropertyValue) GetByteArrayValue 

func (x *SpanData_UserPropertyValue) GetByteArrayValue() []byte

func (*SpanData_UserPropertyValue) GetCharacterValue 

func (x *SpanData_UserPropertyValue) GetCharacterValue() uint32

func (*SpanData_UserPropertyValue) GetDestinationValue 

func (x *SpanData_UserPropertyValue) GetDestinationValue() string

func (*SpanData_UserPropertyValue) GetDoubleValue 

func (x *SpanData_UserPropertyValue) GetDoubleValue() float64

func (*SpanData_UserPropertyValue) GetFloatValue 

func (x *SpanData_UserPropertyValue) GetFloatValue() float32

func (*SpanData_UserPropertyValue) GetInt16Value 

func (x *SpanData_UserPropertyValue) GetInt16Value() int32

func (*SpanData_UserPropertyValue) GetInt32Value 

func (x *SpanData_UserPropertyValue) GetInt32Value() int32

func (*SpanData_UserPropertyValue) GetInt64Value 

func (x *SpanData_UserPropertyValue) GetInt64Value() int64

func (*SpanData_UserPropertyValue) GetInt8Value 

func (x *SpanData_UserPropertyValue) GetInt8Value() int32

func (*SpanData_UserPropertyValue) GetNullValue 

func (x *SpanData_UserPropertyValue) GetNullValue() []byte

func (*SpanData_UserPropertyValue) GetStringValue 

func (x *SpanData_UserPropertyValue) GetStringValue() string

func (*SpanData_UserPropertyValue) GetUint16Value 

func (x *SpanData_UserPropertyValue) GetUint16Value() uint32

func (*SpanData_UserPropertyValue) GetUint32Value 

func (x *SpanData_UserPropertyValue) GetUint32Value() uint32

func (*SpanData_UserPropertyValue) GetUint64Value 

func (x *SpanData_UserPropertyValue) GetUint64Value() uint64

func (*SpanData_UserPropertyValue) GetUint8Value 

func (x *SpanData_UserPropertyValue) GetUint8Value() uint32

func (*SpanData_UserPropertyValue) GetValue 

func (m *SpanData_UserPropertyValue) GetValue() isSpanData_UserPropertyValue_Value

func (*SpanData_UserPropertyValue) ProtoMessage 

func (*SpanData_UserPropertyValue) ProtoMessage()

func (*SpanData_UserPropertyValue) ProtoReflect 

func (x *SpanData_UserPropertyValue) ProtoReflect() protoreflect.Message

func (*SpanData_UserPropertyValue) Reset 

func (x *SpanData_UserPropertyValue) Reset()

func (*SpanData_UserPropertyValue) String 

func (x *SpanData_UserPropertyValue) String() string

type SpanData_UserPropertyValue_BoolValue 

type SpanData_UserPropertyValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type SpanData_UserPropertyValue_ByteArrayValue 

type SpanData_UserPropertyValue_ByteArrayValue struct {
	ByteArrayValue []byte `protobuf:"bytes,13,opt,name=byteArray_value,json=byteArrayValue,proto3,oneof"`
}

type SpanData_UserPropertyValue_CharacterValue 

type SpanData_UserPropertyValue_CharacterValue struct {
	CharacterValue uint32 `protobuf:"varint,11,opt,name=character_value,json=characterValue,proto3,oneof"`
}

type SpanData_UserPropertyValue_DestinationValue 

type SpanData_UserPropertyValue_DestinationValue struct {
	DestinationValue string `protobuf:"bytes,16,opt,name=destination_value,json=destinationValue,proto3,oneof"`
}

type SpanData_UserPropertyValue_DoubleValue 

type SpanData_UserPropertyValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,15,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type SpanData_UserPropertyValue_FloatValue 

type SpanData_UserPropertyValue_FloatValue struct {
	FloatValue float32 `protobuf:"fixed32,14,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type SpanData_UserPropertyValue_Int16Value 

type SpanData_UserPropertyValue_Int16Value struct {
	Int16Value int32 `protobuf:"zigzag32,8,opt,name=int16_value,json=int16Value,proto3,oneof"`
}

type SpanData_UserPropertyValue_Int32Value 

type SpanData_UserPropertyValue_Int32Value struct {
	Int32Value int32 `protobuf:"zigzag32,9,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

type SpanData_UserPropertyValue_Int64Value 

type SpanData_UserPropertyValue_Int64Value struct {
	Int64Value int64 `protobuf:"zigzag64,10,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type SpanData_UserPropertyValue_Int8Value 

type SpanData_UserPropertyValue_Int8Value struct {
	Int8Value int32 `protobuf:"zigzag32,7,opt,name=int8_value,json=int8Value,proto3,oneof"`
}

type SpanData_UserPropertyValue_NullValue 

type SpanData_UserPropertyValue_NullValue struct {
	NullValue []byte `protobuf:"bytes,1,opt,name=null_value,json=nullValue,proto3,oneof"`
}

type SpanData_UserPropertyValue_StringValue 

type SpanData_UserPropertyValue_StringValue struct {
	StringValue string `protobuf:"bytes,12,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type SpanData_UserPropertyValue_Uint16Value 

type SpanData_UserPropertyValue_Uint16Value struct {
	Uint16Value uint32 `protobuf:"varint,4,opt,name=uint16_value,json=uint16Value,proto3,oneof"`
}

type SpanData_UserPropertyValue_Uint32Value 

type SpanData_UserPropertyValue_Uint32Value struct {
	Uint32Value uint32 `protobuf:"varint,5,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
}

type SpanData_UserPropertyValue_Uint64Value 

type SpanData_UserPropertyValue_Uint64Value struct {
	Uint64Value uint64 `protobuf:"varint,6,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
}

type SpanData_UserPropertyValue_Uint8Value 

type SpanData_UserPropertyValue_Uint8Value struct {
	Uint8Value uint32 `protobuf:"varint,3,opt,name=uint8_value,json=uint8Value,proto3,oneof"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.