tracing.go

// pubsubplus-opentelemetry-go-integration
//
// Copyright 2024 Solace Corporation. All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package opentelemetry // import "solace.dev/go/messaging-trace/opentelemetry"

import (
	"solace.dev/go/messaging-trace/opentelemetry/carrier"
	impl "solace.dev/go/messaging-trace/opentelemetry/internal/impl"
	"solace.dev/go/messaging/pkg/solace/message"
)

// NewInboundMessageCarrier returns an instance of carrier.InboundMessageCarrier that can be used
// with otel integration for extracting tracing information from a received Inbound message.
func NewInboundMessageCarrier(carrier message.InboundMessage) carrier.InboundMessageCarrier {
	return impl.NewInboundMessageCarrier(carrier)
}

// NewOutboundMessageCarrier returns an instance of carrier.OutboundMessageCarrier that can be used
// with otel integration for injecting tracing information before publishing an Outbound message.
func NewOutboundMessageCarrier(carrier message.OutboundMessage) carrier.OutboundMessageCarrier {
	return impl.NewOutboundMessageCarrier(carrier)
}