confpulsar

type Consumer = mq.Consumer[ConsumerMessage]

type ConsumerMessage interface {
	mq.HasTopic
	mq.HasPayload
	mq.HasExtra
	mq.HasExpiredAt
	mq.HasPartitionKey
	mq.HasOrderingKey
	mq.HasPartitionID
	mq.HasProducer
	mq.HasPublishedAt
	mq.HasConsumedAt
	mq.CanRefreshConsumedAt
	mq.HasLatency
	mq.HasBrokerLatency
	mq.HasRetryCount
	mq.HasUnderlying[pulsar.Message]
}

type Endpoint struct {
	types.Endpoint[Option]

	mq.ResourceManager `env:"-"`
	// contains filtered or unexported fields
}

type Error int8

type Observer = mq.Observer[ConsumerMessage]

type Option struct {
	// DisablePersistence [TOPIC] denotes topic scheme. default is "persistent"
	// eg:
	// persistent://<tenant>/[<cluster>/]<namespace>/topic
	// non-persistent://<tenant>/[<cluster>/]<namespace>/topic
	DisablePersistence bool `url:",default=false"`
	// Tenant [TOPIC] represents the top-level Pulsar tenant.
	Tenant string `url:",default=public"`
	// Cluster [TOPIC] denotes target cluster name of client connection
	Cluster string `url:",default="`
	// Namespace [TOPIC] represents the logical domain under a tenant.
	Namespace string `url:",default=default"`

	// ConnectionTimeout [Client] establishment timeout
	ConnectionTimeout types.Duration `url:",default=1s"`
	// ConnectionMaxIdleTime [Client] release the connection if it is not
	// used for more than ConnectionMaxIdleTime. default is 30 minutes
	ConnectionMaxIdleTime types.Duration `url:",default=30m"`
	// OperationTimeout [Client] producer-create, subscribe and unsubscribe
	// operations will be retried until this interval
	OperationTimeout types.Duration `url:",default=3s"`
	// KeepAliveInterval [Client] the ping send and check interval
	KeepAliveInterval types.Duration `url:",default=1m"`
	// MaxConnectionsPerBroker [Client] max connections to a single broker
	MaxConnectionsPerBroker int `url:",default=10"`

	// SendTimeout [PUB] specifies the timeout for a message from sent to
	// acknowledged by the server
	SendTimeout types.Duration `url:",default=2s"`
	// DisableBlockIfQueueFull [PUB] controls whether Send and SendAsync block
	// when producer's message queue is full.
	DisableBlockIfQueueFull bool `url:",default=false"`
	// MaxPendingMessages [PUB] specifies the max size of the queue holding
	MaxPendingMessages int `url:",default=500"`
	// DisableCompress [PUB] specifies if disable message compression, if it is
	// enabled use LZ4 compress type
	DisableCompress bool `url:",default=false"`
	// BatchingMaxMessages [PUB] specifies the max messages permitted in a batch
	BatchingMaxMessages uint
	// DisablePubShared [PUB] if disabled, publisher is required exclusive access
	// for producer. failed immediately if there's already a producer connected.
	DisablePubShared bool `url:",default=false"`

	// EnableSubShared [SUB] if disabled, there can be only 1 consumer on the same
	// topic with the same subscription name
	EnableSubShared bool `url:",default=true"`
	// EnableRetryNack [SUB] if enabled, NACKed message will be redelivered after
	// NackRetryInterval max MaxNackRetry times. if reached MaxNackRetry times,
	// the message filled to global DLQ
	EnableRetryNack bool `url:",default=true"`
	// NackRetryInterval [SUB] retry nack message interval
	NackRetryInterval types.Duration `url:",default=1m"`
	// MaxNackRetry [SUB] max retry times for nack message
	MaxNackRetry uint32 `url:",default=3"`
	// WorkerSize defines the concurrency level for message consumption.
	// Behavior based on ConsumeMode:
	// eg:
	//	- mq.GlobalOrdered: Forced to 1 to ensure strict sequential processing.
	//	- mq.PartitionOrdered: Messages are dispatched to specific workers based on
	//	  a hash of the partition key, ensuring order within the same key.
	//	- mq.Concurrent: messages are distributed across all workers (e.g., round-robin)
	//	  to maximize throughput.
	WorkerSize uint16 `url:",default=16"`
	// WorkerBufferSize [SUB] will prefetch message from broker for improves
	// consumption throughput and reducing wait
	WorkerBufferSize uint16 `url:",default=64"`
	// contains filtered or unexported fields
}

type Producer = mq.Producer[ProducerMessage]

type ProducerMessage interface {
	mq.HasTopic
	mq.CanSetTopic
	mq.HasPayload
	mq.CanSetPayload
	mq.HasExtra
	mq.CanAppendExtra
	mq.HasExpiredAt
	mq.CanSetExpiredAt
	mq.HasPartitionKey
	mq.CanSetPartitionKey
	mq.HasOrderingKey
	mq.CanSetOrderingKey
	mq.HasPublishedAt
	mq.CanRefreshPublishedAt
	mq.HasDelay
	mq.CanSetDelay
	mq.HasUnderlying[*pulsar.ProducerMessage]
}

type PubOption struct {
	// contains filtered or unexported fields
}

type PubSub = mq.PubSub[Producer, Consumer]

type SubOption struct {
	// contains filtered or unexported fields
}