msgqueue

type CompressionResult struct {
	Payloads       [][]byte
	WasCompressed  bool
	OriginalSize   int
	CompressedSize int

	// CompressionRatio is the ratio of compressed size to original size (compressed / original)
	CompressionRatio float64
}

type Compressor struct {
	Enabled   bool
	Threshold int
}

type DstFunc func(tenantId uuid.UUID, msgId string, payloads [][]byte) error

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

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

type Message struct {
	// ID is the ID of the task.
	ID string `json:"id"`

	// Payloads is the list of payloads.
	Payloads [][]byte `json:"messages"`

	// TenantID is the tenant ID.
	TenantID uuid.UUID `json:"tenant_id"`

	// Whether the message should immediately expire if it reaches the queue without an active consumer.
	ImmediatelyExpire bool `json:"immediately_expire"`

	// Whether the message should be persisted to disk
	Persistent bool `json:"persistent"`

	// OtelCarrier is the OpenTelemetry carrier for the task.
	OtelCarrier map[string]string `json:"otel_carrier"`

	// Retries is the number of retries for the task.
	//
	// Deprecated: retries are set globally at the moment.
	Retries int `json:"retries"`

	// Compressed indicates whether the payloads are gzip compressed
	Compressed bool `json:"compressed,omitempty"`
}

type MessageQueue interface {
	// Clone copies the message queue with a new instance.
	Clone() (func() error, MessageQueue, error)

	// SetQOS sets the quality of service for the message queue.
	SetQOS(prefetchCount int)

	// SendMessage sends a message to the message queue.
	SendMessage(ctx context.Context, queue Queue, msg *Message) error

	// Subscribe subscribes to the task queue. It returns a cleanup function that should be called when the
	// subscription is no longer needed.
	Subscribe(queue Queue, preAck MsgHandler, postAck MsgHandler) (func() error, error)

	// IsReady returns true if the task queue is ready to accept tasks.
	IsReady() bool
}

type MsgHandler func(task *Message) error

type PubFunc func(m *Message) error

type PubSub interface {
	// Pub publishes a message to the topic. Delivery is best-effort: if no
	// subscriber is listening, the message is dropped.
	Pub(ctx context.Context, topic Topic, msg *Message) error

	// Sub subscribes to a topic. Delivery is at-most-once with no ack
	// semantics: handler errors are logged, never redelivered. It returns a
	// cleanup function that should be called when the subscription is no
	// longer needed.
	//
	// Fanout to multiple subscribers of the same topic is backend-dependent:
	// rabbitmq delivers every message to every subscriber, while the postgres
	// implementation delivers messages over 8KB to only one subscriber (see
	// postgres.PubSub.Sub).
	Sub(topic Topic, handler MsgHandler) (func() error, error)

	// IsReady returns true if the pub/sub mechanism is ready to accept messages.
	IsReady() bool
}

type Queue interface {
	// Name returns the name of the queue.
	Name() string

	// Durable returns true if this queue should survive task queue restarts.
	Durable() bool

	// AutoDeleted returns true if this queue should be deleted when the last consumer unsubscribes.
	AutoDeleted() bool

	// Exclusive returns true if this queue should only be accessed by the current connection.
	Exclusive() bool

	// DLQ returns the queue's dead letter queue, if it exists.
	DLQ() Queue

	// IsDLQ returns true if the queue is a dead letter queue.
	IsDLQ() bool

	// We distinguish between a static DLQ or an automatic DLQ. An automatic DLQ will automatically retry messages
	// in a loop with a 5-second backoff, and each subscription to the regular Queue will include a subscription
	// to the DLQ.
	IsAutoDLQ() bool

	// IsExpirable refers to whether the queue itself is expirable
	IsExpirable() bool
}

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

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

type SubBufferKind string

type SubscribeFunc func(preAck MsgHandler, postAck MsgHandler) (func() error, error)

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

type TopicKind string