subscription

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

type NewSubscription struct {
	TopicID uuid.UUID
	UserID  uuid.UUID
}

type Storer interface {
	WithinTran(fn func(s Storer) error) error
	Create(sub Subscription) error
	Delete(sub Subscription) error
	Query(pageNumber int, rowsPerPage int) ([]Subscription, error)
	QueryByID(id uuid.UUID) (Subscription, error)
}

type Subscription struct {
	ID        uuid.UUID
	TopicID   uuid.UUID
	UserID    uuid.UUID
	CreatedAt time.Time
}