pg

Documentation

Index

• type Repository
  • func NewRepository(ctx context.Context, dbs string) (*Repository, error)
  • func (r *Repository) Close(ctx context.Context) error
  • func (r *Repository) CreateMessage(ctx context.Context, msg *models.Message) error
  • func (r *Repository) GetMessage(ctx context.Context, id string) (*models.Message, error)
  • func (r *Repository) GetUser(ctx context.Context, username string) (*models.User, error)
  • func (r *Repository) ListMessages(ctx context.Context, ownerID string, from, to time.Time) ([]*models.Message, error)
  • func (r *Repository) UpsertUser(ctx context.Context, user *models.User) error

Types

type Repository

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

func NewRepository

func NewRepository(ctx context.Context, dbs string) (*Repository, error)

func (*Repository) Close

func (r *Repository) Close(ctx context.Context) error

func (*Repository) CreateMessage

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

func (*Repository) GetMessage

func (r *Repository) GetMessage(ctx context.Context, id string) (*models.Message, error)

func (*Repository) GetUser

func (r *Repository) GetUser(ctx context.Context, username string) (*models.User, error)

func (*Repository) ListMessages

func (r *Repository) ListMessages(ctx context.Context, ownerID string, from, to time.Time) ([]*models.Message, error)

func (*Repository) UpsertUser

func (r *Repository) UpsertUser(ctx context.Context, user *models.User) error