repository

package

v0.0.0-...-8e5e344 Latest Latest Go to latest Published: Jul 18, 2024 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Message struct {
	ID      int    `db:"id"`
	Content string `db:"content"`
	Status  string `db:"status"`
}

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

func NewRepository(db *sqlx.DB, logger *zap.Logger) *Repository

func (r *Repository) GetProcessedMessagesCount(ctx context.Context) (int, error)

func (r *Repository) SaveMessage(ctx context.Context, msg *Message) error

func (r *Repository) UpdateMessageStatus(ctx context.Context, id int, status string) error

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

func NewRepositoryMock() *RepositoryMock

func (r *RepositoryMock) GetProcessedMessageCount() (int, error)

func (r *RepositoryMock) MarkMessageAsProcessed(id int) error

func (r *RepositoryMock) SaveMessage(content string) (int, error)