Documentation
¶
Index ¶
- func DB(ctx context.Context) (*sqlx.DB, error)
- func Migrate(ctx context.Context, db *sqlx.DB, schema fs.FS) error
- type EmailStorage
- func (s *EmailStorage) Create(ctx context.Context, email *model.Email) error
- func (s *EmailStorage) Get(ctx context.Context, id string) (*model.Email, error)
- func (s *EmailStorage) GetFailed(ctx context.Context, limit int) ([]model.Email, error)
- func (s *EmailStorage) GetPending(ctx context.Context, limit int) ([]model.Email, error)
- func (s *EmailStorage) GetSent(ctx context.Context, limit int) ([]model.Email, error)
- func (s *EmailStorage) Update(ctx context.Context, email *model.Email) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type EmailStorage ¶
type EmailStorage struct {
// contains filtered or unexported fields
}
EmailStorage handles database operations for emails
func NewEmailStorage ¶
func NewEmailStorage(handle *sqlx.DB) *EmailStorage
NewEmailStorage creates a new email storage instance
func NewEmailStorageErr ¶
func NewEmailStorageErr(ctx context.Context) (*EmailStorage, error)
NewEmailStorageErr returns a user storage and any error creating the database.
func (*EmailStorage) GetFailed ¶
GetFailed retrieves failed emails from email_failed table (for audit/records)
func (*EmailStorage) GetPending ¶
GetPending retrieves all pending emails from email
Source Files
Click to show internal directories.
Click to hide internal directories.