core/karya.core.queues.entities/QueueMessage

QueueMessage

@Serializable

sealed class QueueMessage

Sealed class representing different types of queue messages.

Inheritors

ExecutorMessage

Types

ExecutorMessage

@Serializable

data class ExecutorMessage(val planId: UUID, val taskId: UUID, val action: Action, val maxFailureRetry: Int, val toBeExecutedAt: Long) : QueueMessage

Data class representing a message for the executor.

@Serializable

data class HookMessage(val planId: UUID, val hook: Hook) : QueueMessage

Data class representing a message for the hook.

Functions

encodeToByteArray

fun QueueMessage.encodeToByteArray(json: Json): ByteArray

Extension function to encode a QueueMessage to a ByteArray using the provided Json instance.

fun QueueMessage.encodeToString(json: Json): String

Extension function to encode a QueueMessage to a String using the provided Json instance.