queue

type BaseMessage struct {
	Type string `json:"type"`
}

type CompositionProcessingMessage struct {
	BaseMessage
	ArtID         string `json:"art_id"`
	CompositionID string `json:"composition_id"`
}

type Handler func(ctx context.Context, body []byte) error

type PostgresOptions struct {
	MaxAttempts       int
	PollInterval      time.Duration
	VisibilityTimeout time.Duration
	BaseBackoff       time.Duration
}

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

type Queue interface {
	Publish(ctx context.Context, topic string, body []byte) error
	Subscribe(ctx context.Context, topic, consumer string, h Handler) error
	Close() error
}