Documentation
¶
Index ¶
- Constants
- func BuildAndInjectProducerSpan(producer pulsar.Producer, message *pulsar.ProducerMessage) oteltrace.Span
- func BuildConsumerSpan(consumer pulsar.Consumer, message pulsar.Message) (context.Context, oteltrace.Span)
- func BuildWorkerSpan(parentSpanCtx, workerCtx context.Context) oteltrace.Span
- func InjectHTTPRequestSpanToProducerMessage(request *http.Request, message *pulsar.ProducerMessage)
- func InjectWorkerSpanToProducerMessage(workerCtx context.Context, message *pulsar.ProducerMessage)
- func LogNTraceEnterExit(c context.Context, msg string) func()
- func LogNTraceError(c context.Context, msg string, err error)
- func LogTrace(c context.Context, msg string)
- func NewConsumerInterceptors(ctx context.Context) []pulsar.ConsumerInterceptor
- func NewProducerInterceptors(ctx context.Context) []pulsar.ProducerInterceptor
- type MessagePropertiesExtractAdapter
- type ProducerMessagePropertiesAdapter
- type TraceConsumerInterceptor
- type TraceProducerInterceptor
Constants ¶
View Source
const TracerName = "github.com/kubescape/messaging"
Variables ¶
This section is empty.
Functions ¶
func BuildConsumerSpan ¶
func BuildWorkerSpan ¶
func InjectHTTPRequestSpanToProducerMessage ¶
func InjectHTTPRequestSpanToProducerMessage(request *http.Request, message *pulsar.ProducerMessage)
func InjectWorkerSpanToProducerMessage ¶
func InjectWorkerSpanToProducerMessage(workerCtx context.Context, message *pulsar.ProducerMessage)
func LogNTraceEnterExit ¶
func NewConsumerInterceptors ¶
func NewConsumerInterceptors(ctx context.Context) []pulsar.ConsumerInterceptor
func NewProducerInterceptors ¶
func NewProducerInterceptors(ctx context.Context) []pulsar.ProducerInterceptor
Types ¶
type MessagePropertiesExtractAdapter ¶
type MessagePropertiesExtractAdapter struct {
// contains filtered or unexported fields
}
func NewMessagePropertiesExtractAdapter ¶
func NewMessagePropertiesExtractAdapter(message pulsar.Message) *MessagePropertiesExtractAdapter
func (*MessagePropertiesExtractAdapter) Get ¶
func (c *MessagePropertiesExtractAdapter) Get(key string) string
implement TextMapCarrier
func (*MessagePropertiesExtractAdapter) Keys ¶
func (c *MessagePropertiesExtractAdapter) Keys() []string
func (*MessagePropertiesExtractAdapter) Set ¶
func (c *MessagePropertiesExtractAdapter) Set(key string, value string)
type ProducerMessagePropertiesAdapter ¶
type ProducerMessagePropertiesAdapter struct {
// contains filtered or unexported fields
}
func NewProducerMessagePropertiesAdapter ¶
func NewProducerMessagePropertiesAdapter(message *pulsar.ProducerMessage) *ProducerMessagePropertiesAdapter
func (*ProducerMessagePropertiesAdapter) Get ¶
func (c *ProducerMessagePropertiesAdapter) Get(key string) string
implement TextMapCarrier
func (*ProducerMessagePropertiesAdapter) Keys ¶
func (c *ProducerMessagePropertiesAdapter) Keys() []string
func (*ProducerMessagePropertiesAdapter) Set ¶
func (c *ProducerMessagePropertiesAdapter) Set(key string, value string)
type TraceConsumerInterceptor ¶
type TraceConsumerInterceptor struct {
// contains filtered or unexported fields
}
func (*TraceConsumerInterceptor) BeforeConsume ¶
func (t *TraceConsumerInterceptor) BeforeConsume(message pulsar.ConsumerMessage)
func (*TraceConsumerInterceptor) OnAcknowledge ¶
func (t *TraceConsumerInterceptor) OnAcknowledge(consumer pulsar.Consumer, msgID pulsar.MessageID)
func (*TraceConsumerInterceptor) OnNegativeAcksSend ¶
func (t *TraceConsumerInterceptor) OnNegativeAcksSend(consumer pulsar.Consumer, msgIDs []pulsar.MessageID)
type TraceProducerInterceptor ¶
type TraceProducerInterceptor struct {
// contains filtered or unexported fields
}
func (*TraceProducerInterceptor) BeforeSend ¶
func (t *TraceProducerInterceptor) BeforeSend(producer pulsar.Producer, message *pulsar.ProducerMessage)
func (*TraceProducerInterceptor) OnSendAcknowledgement ¶
func (t *TraceProducerInterceptor) OnSendAcknowledgement(producer pulsar.Producer, message *pulsar.ProducerMessage, msgID pulsar.MessageID)
Source Files
Click to show internal directories.
Click to hide internal directories.