v1

package
v0.89.0 Latest Latest
Warning

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

Go to latest
Published: Nov 15, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

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_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) Descriptor() ([]byte, []int)

Deprecated: Use SpanData.ProtoReflect.Descriptor instead.

func (*SpanData) GetEgressSpans

func (x *SpanData) GetEgressSpans() []*SpanData_EgressSpan

func (*SpanData) GetMessageVpnName

func (x *SpanData) GetMessageVpnName() string

func (*SpanData) GetRouterName

func (x *SpanData) GetRouterName() string

func (*SpanData) GetSolosVersion

func (x *SpanData) GetSolosVersion() string

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_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 (*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) Enum

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 (SpanData_SendSpan_Outcome) String

func (x SpanData_SendSpan_Outcome) String() string

func (SpanData_SendSpan_Outcome) Type

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 (*SpanData_TransactionEvent) GetLocalId

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 (*SpanData_TransactionEvent) GetXid

func (*SpanData_TransactionEvent) ProtoMessage

func (*SpanData_TransactionEvent) ProtoMessage()

func (*SpanData_TransactionEvent) ProtoReflect

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) Enum

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 (SpanData_TransactionEvent_Initiator) String

func (SpanData_TransactionEvent_Initiator) Type

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

Deprecated: Use SpanData_TransactionEvent_LocalTransactionId.ProtoReflect.Descriptor instead.

func (*SpanData_TransactionEvent_LocalTransactionId) GetSessionId

func (*SpanData_TransactionEvent_LocalTransactionId) GetSessionName

func (*SpanData_TransactionEvent_LocalTransactionId) GetTransactionId

func (*SpanData_TransactionEvent_LocalTransactionId) ProtoMessage

func (*SpanData_TransactionEvent_LocalTransactionId) ProtoReflect

func (*SpanData_TransactionEvent_LocalTransactionId) Reset

func (*SpanData_TransactionEvent_LocalTransactionId) 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) Enum

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 (SpanData_TransactionEvent_Type) String

func (SpanData_TransactionEvent_Type) Type

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 (*SpanData_TransactionEvent_Xid) Reset

func (x *SpanData_TransactionEvent_Xid) Reset()

func (*SpanData_TransactionEvent_Xid) String

type SpanData_TransactionEvent_Xid_

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL