message

Documentation

Index

• type MessageAttrsExtractor
  • func (m *MessageAttrsExtractor[REQUEST, RESPONSE, GETTER]) GetSpanKey() attribute.Key
  • func (m *MessageAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, ...) ([]attribute.KeyValue, context.Context)
  • func (m *MessageAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, ...) ([]attribute.KeyValue, context.Context)
• type MessageAttrsGetter
• type MessageOperation
• type MessageSpanNameExtractor
  • func (m *MessageSpanNameExtractor[REQUEST, RESPONSE]) Extract(request REQUEST) string

Types

type MessageAttrsExtractor

type MessageAttrsExtractor[REQUEST any, RESPONSE any, GETTER MessageAttrsGetter[REQUEST, RESPONSE]] struct {
	// contains filtered or unexported fields
}

func (*MessageAttrsExtractor[REQUEST, RESPONSE, GETTER]) GetSpanKey

func (m *MessageAttrsExtractor[REQUEST, RESPONSE, GETTER]) GetSpanKey() attribute.Key

func (*MessageAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd

func (m *MessageAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, response RESPONSE, err error) ([]attribute.KeyValue, context.Context)

func (*MessageAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart

func (m *MessageAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, request REQUEST) ([]attribute.KeyValue, context.Context)

type MessageAttrsGetter

type MessageAttrsGetter[REQUEST any, RESPONSE any] interface {
	GetSystem(request REQUEST) string
	GetDestination(request REQUEST) string
	GetDestinationTemplate(request REQUEST) string
	IsTemporaryDestination(request REQUEST) bool

	GetConversationId(request REQUEST) string
	GetMessageBodySize(request REQUEST) int64
	GetMessageEnvelopSize(request REQUEST) int64
	GetMessageId(request REQUEST, response RESPONSE) string
	GetClientId(request REQUEST) string
	GetBatchMessageCount(request REQUEST, response RESPONSE) int64
	GetMessageHeader(request REQUEST, name string) []string
	// contains filtered or unexported methods
}

type MessageOperation

type MessageOperation string

const PROCESS MessageOperation = "process"

const PUBLISH MessageOperation = "publish"

const RECEIVE MessageOperation = "receive"

type MessageSpanNameExtractor

type MessageSpanNameExtractor[REQUEST any, RESPONSE any] struct {
	// contains filtered or unexported fields
}

func (*MessageSpanNameExtractor[REQUEST, RESPONSE]) Extract

func (m *MessageSpanNameExtractor[REQUEST, RESPONSE]) Extract(request REQUEST) string