Documentation ¶
Index ¶
- Variables
- type SpanData
- func (*SpanData) Descriptor() ([]byte, []int)deprecated
- func (x *SpanData) GetEgressSpans() []*SpanData_EgressSpan
- func (x *SpanData) GetMessageVpnName() string
- func (x *SpanData) GetRouterName() string
- func (x *SpanData) GetSolosVersion() string
- func (*SpanData) ProtoMessage()
- func (x *SpanData) ProtoReflect() protoreflect.Message
- func (x *SpanData) Reset()
- func (x *SpanData) String() string
- type SpanData_EgressSpan
- func (*SpanData_EgressSpan) Descriptor() ([]byte, []int)deprecated
- func (x *SpanData_EgressSpan) GetEndTimeUnixNano() int64
- func (x *SpanData_EgressSpan) GetErrorDescription() string
- func (x *SpanData_EgressSpan) GetParentSpanId() []byte
- func (x *SpanData_EgressSpan) GetSendSpan() *SpanData_SendSpan
- func (x *SpanData_EgressSpan) GetSpanId() []byte
- func (x *SpanData_EgressSpan) GetStartTimeUnixNano() int64
- func (x *SpanData_EgressSpan) GetTraceId() []byte
- func (x *SpanData_EgressSpan) GetTransactionEvent() *SpanData_TransactionEvent
- func (m *SpanData_EgressSpan) GetTypeData() isSpanData_EgressSpan_TypeData
- func (*SpanData_EgressSpan) ProtoMessage()
- func (x *SpanData_EgressSpan) ProtoReflect() protoreflect.Message
- func (x *SpanData_EgressSpan) Reset()
- func (x *SpanData_EgressSpan) String() string
- type SpanData_EgressSpan_SendSpan
- type SpanData_SendSpan
- func (*SpanData_SendSpan) Descriptor() ([]byte, []int)deprecated
- func (x *SpanData_SendSpan) GetConsumerClientName() string
- func (x *SpanData_SendSpan) GetConsumerClientUsername() string
- func (x *SpanData_SendSpan) GetOutcome() SpanData_SendSpan_Outcome
- func (x *SpanData_SendSpan) GetProtocol() string
- func (x *SpanData_SendSpan) GetProtocolVersion() string
- func (x *SpanData_SendSpan) GetQueueName() string
- func (x *SpanData_SendSpan) GetReplayedMsg() bool
- func (m *SpanData_SendSpan) GetSource() isSpanData_SendSpan_Source
- func (x *SpanData_SendSpan) GetTopicEndpointName() string
- func (*SpanData_SendSpan) ProtoMessage()
- func (x *SpanData_SendSpan) ProtoReflect() protoreflect.Message
- func (x *SpanData_SendSpan) Reset()
- func (x *SpanData_SendSpan) String() string
- type SpanData_SendSpan_Outcome
- func (SpanData_SendSpan_Outcome) Descriptor() protoreflect.EnumDescriptor
- func (x SpanData_SendSpan_Outcome) Enum() *SpanData_SendSpan_Outcome
- func (SpanData_SendSpan_Outcome) EnumDescriptor() ([]byte, []int)deprecated
- func (x SpanData_SendSpan_Outcome) Number() protoreflect.EnumNumber
- func (x SpanData_SendSpan_Outcome) String() string
- func (SpanData_SendSpan_Outcome) Type() protoreflect.EnumType
- type SpanData_SendSpan_QueueName
- type SpanData_SendSpan_TopicEndpointName
- type SpanData_TransactionEvent
- func (*SpanData_TransactionEvent) Descriptor() ([]byte, []int)deprecated
- func (x *SpanData_TransactionEvent) GetErrorDescription() string
- func (x *SpanData_TransactionEvent) GetInitiator() SpanData_TransactionEvent_Initiator
- func (x *SpanData_TransactionEvent) GetLocalId() *SpanData_TransactionEvent_LocalTransactionId
- func (x *SpanData_TransactionEvent) GetTimeUnixNano() int64
- func (m *SpanData_TransactionEvent) GetTransactionId() isSpanData_TransactionEvent_TransactionId
- func (x *SpanData_TransactionEvent) GetType() SpanData_TransactionEvent_Type
- func (x *SpanData_TransactionEvent) GetXid() *SpanData_TransactionEvent_Xid
- func (*SpanData_TransactionEvent) ProtoMessage()
- func (x *SpanData_TransactionEvent) ProtoReflect() protoreflect.Message
- func (x *SpanData_TransactionEvent) Reset()
- func (x *SpanData_TransactionEvent) String() string
- type SpanData_TransactionEvent_Initiator
- func (SpanData_TransactionEvent_Initiator) Descriptor() protoreflect.EnumDescriptor
- func (x SpanData_TransactionEvent_Initiator) Enum() *SpanData_TransactionEvent_Initiator
- func (SpanData_TransactionEvent_Initiator) EnumDescriptor() ([]byte, []int)deprecated
- func (x SpanData_TransactionEvent_Initiator) Number() protoreflect.EnumNumber
- func (x SpanData_TransactionEvent_Initiator) String() string
- func (SpanData_TransactionEvent_Initiator) Type() protoreflect.EnumType
- type SpanData_TransactionEvent_LocalId
- type SpanData_TransactionEvent_LocalTransactionId
- func (*SpanData_TransactionEvent_LocalTransactionId) Descriptor() ([]byte, []int)deprecated
- func (x *SpanData_TransactionEvent_LocalTransactionId) GetSessionId() uint32
- func (x *SpanData_TransactionEvent_LocalTransactionId) GetSessionName() string
- func (x *SpanData_TransactionEvent_LocalTransactionId) GetTransactionId() uint32
- func (*SpanData_TransactionEvent_LocalTransactionId) ProtoMessage()
- func (x *SpanData_TransactionEvent_LocalTransactionId) ProtoReflect() protoreflect.Message
- func (x *SpanData_TransactionEvent_LocalTransactionId) Reset()
- func (x *SpanData_TransactionEvent_LocalTransactionId) String() string
- type SpanData_TransactionEvent_Type
- func (SpanData_TransactionEvent_Type) Descriptor() protoreflect.EnumDescriptor
- func (x SpanData_TransactionEvent_Type) Enum() *SpanData_TransactionEvent_Type
- func (SpanData_TransactionEvent_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x SpanData_TransactionEvent_Type) Number() protoreflect.EnumNumber
- func (x SpanData_TransactionEvent_Type) String() string
- func (SpanData_TransactionEvent_Type) Type() protoreflect.EnumType
- type SpanData_TransactionEvent_Xid
- func (*SpanData_TransactionEvent_Xid) Descriptor() ([]byte, []int)deprecated
- func (x *SpanData_TransactionEvent_Xid) GetBranchQualifier() []byte
- func (x *SpanData_TransactionEvent_Xid) GetFormatId() int32
- func (x *SpanData_TransactionEvent_Xid) GetGlobalId() []byte
- func (*SpanData_TransactionEvent_Xid) ProtoMessage()
- func (x *SpanData_TransactionEvent_Xid) ProtoReflect() protoreflect.Message
- func (x *SpanData_TransactionEvent_Xid) Reset()
- func (x *SpanData_TransactionEvent_Xid) String() string
- type SpanData_TransactionEvent_Xid_
Constants ¶
This section is empty.
Variables ¶
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, } )
Enum value maps for SpanData_SendSpan_Outcome.
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.
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.
var File_egress_v1_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type SpanData ¶
type SpanData struct { 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"` // contains filtered or unexported fields }
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.
func (*SpanData) Descriptor
deprecated
func (*SpanData) GetEgressSpans ¶
func (x *SpanData) GetEgressSpans() []*SpanData_EgressSpan
func (*SpanData) GetMessageVpnName ¶
func (*SpanData) GetRouterName ¶
func (*SpanData) GetSolosVersion ¶
func (*SpanData) ProtoMessage ¶
func (*SpanData) ProtoMessage()
func (*SpanData) ProtoReflect ¶
func (x *SpanData) ProtoReflect() protoreflect.Message
type SpanData_EgressSpan ¶
type SpanData_EgressSpan 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,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 TypeData isSpanData_EgressSpan_TypeData `protobuf_oneof:"type_data"` // contains filtered or unexported fields }
func (*SpanData_EgressSpan) Descriptor
deprecated
func (*SpanData_EgressSpan) Descriptor() ([]byte, []int)
Deprecated: Use SpanData_EgressSpan.ProtoReflect.Descriptor instead.
func (*SpanData_EgressSpan) GetEndTimeUnixNano ¶
func (x *SpanData_EgressSpan) GetEndTimeUnixNano() int64
func (*SpanData_EgressSpan) GetErrorDescription ¶
func (x *SpanData_EgressSpan) GetErrorDescription() string
func (*SpanData_EgressSpan) GetParentSpanId ¶
func (x *SpanData_EgressSpan) GetParentSpanId() []byte
func (*SpanData_EgressSpan) GetSendSpan ¶
func (x *SpanData_EgressSpan) GetSendSpan() *SpanData_SendSpan
func (*SpanData_EgressSpan) GetSpanId ¶
func (x *SpanData_EgressSpan) GetSpanId() []byte
func (*SpanData_EgressSpan) GetStartTimeUnixNano ¶
func (x *SpanData_EgressSpan) GetStartTimeUnixNano() int64
func (*SpanData_EgressSpan) GetTraceId ¶
func (x *SpanData_EgressSpan) GetTraceId() []byte
func (*SpanData_EgressSpan) GetTransactionEvent ¶
func (x *SpanData_EgressSpan) GetTransactionEvent() *SpanData_TransactionEvent
func (*SpanData_EgressSpan) GetTypeData ¶
func (m *SpanData_EgressSpan) GetTypeData() isSpanData_EgressSpan_TypeData
func (*SpanData_EgressSpan) ProtoMessage ¶
func (*SpanData_EgressSpan) ProtoMessage()
func (*SpanData_EgressSpan) ProtoReflect ¶
func (x *SpanData_EgressSpan) ProtoReflect() protoreflect.Message
func (*SpanData_EgressSpan) Reset ¶
func (x *SpanData_EgressSpan) Reset()
func (*SpanData_EgressSpan) String ¶
func (x *SpanData_EgressSpan) String() string
type SpanData_EgressSpan_SendSpan ¶
type SpanData_EgressSpan_SendSpan struct {
SendSpan *SpanData_SendSpan `protobuf:"bytes,8,opt,name=send_span,json=sendSpan,proto3,oneof"`
}
type SpanData_SendSpan ¶
type SpanData_SendSpan struct { // 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 `` /* 145-byte string literal not displayed */ ReplayedMsg bool `protobuf:"varint,4,opt,name=replayed_msg,json=replayedMsg,proto3" json:"replayed_msg,omitempty"` ConsumerClientUsername string `` /* 129-byte string literal not displayed */ 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"` // contains filtered or unexported fields }
This message contains information unique to a SendSpan.
func (*SpanData_SendSpan) Descriptor
deprecated
func (*SpanData_SendSpan) Descriptor() ([]byte, []int)
Deprecated: Use SpanData_SendSpan.ProtoReflect.Descriptor instead.
func (*SpanData_SendSpan) GetConsumerClientName ¶
func (x *SpanData_SendSpan) GetConsumerClientName() string
func (*SpanData_SendSpan) GetConsumerClientUsername ¶
func (x *SpanData_SendSpan) GetConsumerClientUsername() string
func (*SpanData_SendSpan) GetOutcome ¶
func (x *SpanData_SendSpan) GetOutcome() SpanData_SendSpan_Outcome
func (*SpanData_SendSpan) GetProtocol ¶
func (x *SpanData_SendSpan) GetProtocol() string
func (*SpanData_SendSpan) GetProtocolVersion ¶
func (x *SpanData_SendSpan) GetProtocolVersion() string
func (*SpanData_SendSpan) GetQueueName ¶
func (x *SpanData_SendSpan) GetQueueName() string
func (*SpanData_SendSpan) GetReplayedMsg ¶
func (x *SpanData_SendSpan) GetReplayedMsg() bool
func (*SpanData_SendSpan) GetSource ¶
func (m *SpanData_SendSpan) GetSource() isSpanData_SendSpan_Source
func (*SpanData_SendSpan) GetTopicEndpointName ¶
func (x *SpanData_SendSpan) GetTopicEndpointName() string
func (*SpanData_SendSpan) ProtoMessage ¶
func (*SpanData_SendSpan) ProtoMessage()
func (*SpanData_SendSpan) ProtoReflect ¶
func (x *SpanData_SendSpan) ProtoReflect() protoreflect.Message
func (*SpanData_SendSpan) Reset ¶
func (x *SpanData_SendSpan) Reset()
func (*SpanData_SendSpan) String ¶
func (x *SpanData_SendSpan) String() string
type SpanData_SendSpan_Outcome ¶
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 )
func (SpanData_SendSpan_Outcome) Descriptor ¶
func (SpanData_SendSpan_Outcome) Descriptor() protoreflect.EnumDescriptor
func (SpanData_SendSpan_Outcome) Enum ¶
func (x SpanData_SendSpan_Outcome) Enum() *SpanData_SendSpan_Outcome
func (SpanData_SendSpan_Outcome) EnumDescriptor
deprecated
func (SpanData_SendSpan_Outcome) EnumDescriptor() ([]byte, []int)
Deprecated: Use SpanData_SendSpan_Outcome.Descriptor instead.
func (SpanData_SendSpan_Outcome) Number ¶
func (x SpanData_SendSpan_Outcome) Number() protoreflect.EnumNumber
func (SpanData_SendSpan_Outcome) String ¶
func (x SpanData_SendSpan_Outcome) String() string
func (SpanData_SendSpan_Outcome) Type ¶
func (SpanData_SendSpan_Outcome) Type() protoreflect.EnumType
type SpanData_SendSpan_QueueName ¶
type SpanData_SendSpan_QueueName struct {
QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3,oneof"`
}
type SpanData_SendSpan_TopicEndpointName ¶
type SpanData_SendSpan_TopicEndpointName struct {
TopicEndpointName string `protobuf:"bytes,2,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 `` /* 144-byte string literal not displayed */ Initiator SpanData_TransactionEvent_Initiator `` /* 159-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 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.
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"`
}