Vote for transport (Message Queues) you need for Asya🎭

[ghost]

Asya🎭 can use different Message Queues as transport - as long as they implement the interface:

• for sidecar (transport.go):

// QueueMessage represents a message received from a queue
type QueueMessage struct {
	ID            string
	Body          []byte
	ReceiptHandle interface{}       // Transport-specific receipt handle
	Headers       map[string]string // User-defined metadata (protocol-level headers)
}

// Transport defines the interface for queue transport implementations
type Transport interface {
	// Receive receives a message from the specified queue
	Receive(ctx context.Context, queueName string) (QueueMessage, error)

	// Send sends a message to the specified queue
	Send(ctx context.Context, queueName string, body []byte) error

	// Ack acknowledges successful processing of a message
	Ack(ctx context.Context, msg QueueMessage) error

	// Nack negatively acknowledges a message (for retry)
	Nack(ctx context.Context, msg QueueMessage) error

	// Close closes the transport connection
	Close() error
}

• for operator (interface.go):

// QueueReconciler handles queue creation and lifecycle for a specific transport
type QueueReconciler interface {
	// ReconcileQueue creates or updates the queue for an actor
	ReconcileQueue(ctx context.Context, actor *asyav1alpha1.AsyncActor) error

	// DeleteQueue deletes the queue for an actor
	DeleteQueue(ctx context.Context, actor *asyav1alpha1.AsyncActor) error
}

// ServiceAccountReconciler handles ServiceAccount creation for transports that need it (e.g., SQS with IRSA)
type ServiceAccountReconciler interface {
	// ReconcileServiceAccount creates or updates ServiceAccount if needed
	ReconcileServiceAccount(ctx context.Context, actor *asyav1alpha1.AsyncActor) error
}

Currently, Asya🎭 supports:

• SQS - primary transport
• RabbitMQ - Open-Source alternative, currently at alpha testing stage

Our plan is to keep adding support for new transports from the list of 79 KEDA-supported transports: https://keda.sh/docs/2.18/scalers/

Leave your requests below