rocketmqOption

package
v1.2.17 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2024 License: MIT Imports: 4 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_OPERATION           = "messaging.rocketmq.operation"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_NAMESPACE           = "messaging.rocketmq.namespace"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_TAG                 = "messaging.rocketmq.message_tag"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_KEYS                = "messaging.rocketmq.message_keys"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_CLIENT_ID           = "messaging.rocketmq.client_id"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_MESSAGE_TYPE        = "messaging.rocketmq.message_type"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_CLIENT_GROUP        = "messaging.rocketmq.client_group"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_ATTEMPT             = "messaging.rocketmq.attempt"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_BATCH_SIZE          = "messaging.rocketmq.batch_size"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_DELIVERY_TIMESTAMP  = "messaging.rocketmq.delivery_timestamp"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_AVAILABLE_TIMESTAMP = "messaging.rocketmq.available_timestamp"
	SPAN_ATTRIBUTE_KEY_ROCKETMQ_ACCESS_KEY          = "messaging.rocketmq.access_key"

	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_MESSAGING_SYSTEM  = "rocketmq"
	SPAN_ATTRIBUTE_VALUE_DESTINATION_KIND           = "topic"
	SPAN_ATTRIBUTE_VALUE_MESSAGING_PROTOCOL         = "RMQ-gRPC"
	SPAN_ATTRIBUTE_VALUE_MESSAGING_PROTOCOL_VERSION = "v1"

	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_NORMAL_MESSAGE      = "normal"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_FIFO_MESSAGE        = "fifo"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_DELAY_MESSAGE       = "delay"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_TRANSACTION_MESSAGE = "transaction"

	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_SEND_OPERATION     = "send"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_RECEIVE_OPERATION  = "receive"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_PULL_OPERATION     = "pull"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_AWAIT_OPERATION    = "await"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_PROCESS_OPERATION  = "process"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_ACK_OPERATION      = "ack"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_NACK_OPERATION     = "nack"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_COMMIT_OPERATION   = "commit"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_ROLLBACK_OPERATION = "rollback"
	SPAN_ATTRIBUTE_VALUE_ROCKETMQ_DLQ_OPERATION      = "dlq"

	// Messaging span attribute name list
	SPAN_ATTRIBUTE_KEY_MESSAGING_SYSTEM             = "messaging.system"
	SPAN_ATTRIBUTE_KEY_MESSAGING_DESTINATION        = "messaging.destination"
	SPAN_ATTRIBUTE_KEY_MESSAGING_DESTINATION_KIND   = "messaging.destination_kind"
	SPAN_ATTRIBUTE_KEY_MESSAGING_PROTOCOL           = "messaging.protocol"
	SPAN_ATTRIBUTE_KEY_MESSAGING_PROTOCOL_VERSION   = "messaging.protocol_version"
	SPAN_ATTRIBUTE_KEY_MESSAGING_URL                = "messaging.url"
	SPAN_ATTRIBUTE_KEY_MESSAGING_ID                 = "messaging.message_id"
	SPAN_ATTRIBUTE_KEY_MESSAGING_PAYLOAD_SIZE_BYTES = "messaging.message_payload_size_bytes"
	SPAN_ATTRIBUTE_KEY_MESSAGING_OPERATION          = "messaging.operation"

	SPAN_ATTRIBUTE_VALUE_MESSAGING_SEND_OPERATION    = "send"
	SPAN_ATTRIBUTE_VALUE_MESSAGING_RECEIVE_OPERATION = "receive"
	SPAN_ATTRIBUTE_VALUE_MESSAGING_PROCESS_OPERATION = "process"

	SPAN_ATTRIBUTE_KEY_TRANSACTION_RESOLUTION = "commitAction"

	// Span annotation
	SPAN_ANNOTATION_AWAIT_CONSUMPTION = "__await_consumption"
	SPAN_ANNOTATION_MESSAGE_KEYS      = "__message_keys"
	SPAN_ANNOTATION_ATTR_START_TIME   = "__start_time"
)

RocketMQ span attribute name list

View Source 
const (
	DefaultAddr = "127.0.0.1:9876"
)

Variables

This section is empty.

Functions

func WithAccessKey 

func WithAccessKey(key string) broker.Option

func WithAwaitDuration 

func WithAwaitDuration(awaitDuration time.Duration) broker.Option

func WithBatch 

func WithBatch(batch bool) broker.PublishOption

func WithCompress 

func WithCompress(compress bool) broker.PublishOption

func WithConsumerModel added in v1.2.3 

func WithConsumerModel(model MessageModel) broker.SubscribeOption

func WithCredentials 

func WithCredentials(accessKey, accessSecret, securityToken string) broker.Option

func WithDelayTimeLevel 

func WithDelayTimeLevel(level int) broker.PublishOption

func WithDeliveryTimestamp 

func WithDeliveryTimestamp(deliveryTimestamp time.Time) broker.PublishOption

func WithEnableTrace 

func WithEnableTrace() broker.Option

func WithGroupName 

func WithGroupName(name string) broker.Option

func WithInstanceName 

func WithInstanceName(name string) broker.Option

func WithInvisibleDuration 

func WithInvisibleDuration(invisibleDuration time.Duration) broker.Option

func WithKeys 

func WithKeys(keys []string) broker.PublishOption

func WithLoggerLevel 

func WithLoggerLevel(level log.Level) broker.Option

func WithMaxMessageNumKey 

func WithMaxMessageNumKey(messageNum int32) broker.Option

func WithMessageGroup 

func WithMessageGroup(group string) broker.PublishOption

func WithNameServer 

func WithNameServer(addrs []string) broker.Option

func WithNameServerDomain 

func WithNameServerDomain(uri string) broker.Option

func WithNamespace 

func WithNamespace(ns string) broker.Option

func WithProperties 

func WithProperties(properties map[string]string) broker.PublishOption

func WithReceiveInterval 

func WithReceiveInterval(receiveInterval time.Duration) broker.Option

func WithRetryCount 

func WithRetryCount(count int) broker.Option

func WithSecretKey 

func WithSecretKey(secret string) broker.Option

func WithSecurityToken 

func WithSecurityToken(token string) broker.Option

func WithSendAsync 

func WithSendAsync(enable bool) broker.PublishOption

func WithSendWithTransaction 

func WithSendWithTransaction(enable bool) broker.PublishOption

func WithShardingKey 

func WithShardingKey(key string) broker.PublishOption

func WithSubscriptionExpressions 

func WithSubscriptionExpressions(subscriptionExpressions map[string]*rmqClient.FilterExpression) broker.Option

func WithSubscriptionFilterExpression 

func WithSubscriptionFilterExpression(filterExpression *rmqClient.FilterExpression) broker.SubscribeOption

func WithTag 

func WithTag(tags string) broker.PublishOption

Types

type AccessKey 

type AccessKey struct{}

type AwaitDurationKey 

type AwaitDurationKey struct{}

type BatchKey 

type BatchKey struct{}

type CompressKey 

type CompressKey struct{}

type ConsumerModelKey added in v1.2.3 

type ConsumerModelKey struct{}

type Credentials 

type Credentials struct {
	AccessKey, AccessSecret, SecurityToken string
}

type CredentialsKey 

type CredentialsKey struct{}

type DelayTimeLevelKey 

type DelayTimeLevelKey struct{}

type DeliveryTimestampKey 

type DeliveryTimestampKey struct{}

type DriverType 

type DriverType string
const (
	DriverTypeAliyun DriverType = "aliyun" // github.com/aliyunmq/mq-http-go-sdk
	DriverTypeV2     DriverType = "v2"     // github.com/apache/rocketmq-client-go/v2
	DriverTypeV5     DriverType = "v5"     // github.com/apache/rocketmq-clients/golang
)

type EnableTraceKey 

type EnableTraceKey struct{}

type GroupNameKey 

type GroupNameKey struct{}

type InstanceNameKey 

type InstanceNameKey struct{}

type InvisibleDurationKey 

type InvisibleDurationKey struct{}

type KeysKey 

type KeysKey struct{}

type LoggerLevelKey 

type LoggerLevelKey struct{}

type MaxMessageNumKey 

type MaxMessageNumKey struct{}

type MessageGroupKey 

type MessageGroupKey struct{}

type MessageModel added in v1.2.3 

type MessageModel string
const (
	MessageModelBroadCasting MessageModel = "BroadCasting"
	MessageModelClustering   MessageModel = "Clustering"
)

type NameServerUrlKey 

type NameServerUrlKey struct{}

type NameServersKey 

type NameServersKey struct{}

type NamespaceKey 

type NamespaceKey struct{}

type PropertiesKey 

type PropertiesKey struct{}

type ReceiveIntervalKey 

type ReceiveIntervalKey struct{}

type RetryCountKey 

type RetryCountKey struct{}

type SecretKey 

type SecretKey struct{}

type SecurityTokenKey 

type SecurityTokenKey struct{}

type SendAsyncKey 

type SendAsyncKey struct{}

type SendWithTransactionKey 

type SendWithTransactionKey struct{}

type ShardingKeyKey 

type ShardingKeyKey struct{}

type SubscriptionExpressionsKey 

type SubscriptionExpressionsKey struct{}

type SubscriptionFilterExpressionKey 

type SubscriptionFilterExpressionKey struct{}

type TagsKey 

type TagsKey struct{}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.