queue

type Command struct {
	SagaID uuid.UUID `json:"saga_id"`
	Name   string    `json:"name"`
}

type Message interface {
	Command | Response
}

type Poll[M Message] struct {
	// contains filtered or unexported fields
}

type Processor interface {
	ProcessMessage(context.Context, any) error
}

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

type Response struct {
	SagaID  uuid.UUID `json:"saga_id"`
	Service string    `json:"service"`
	Status  string    `json:"status"`
}

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