postgres

Documentation

Index

• func NewPostgresDB(cfg config.Database) (*sql.DB, error)
• type EventQueueRepository
  • func NewEventQueueRepository(db *sql.DB) *EventQueueRepository
  • func (r *EventQueueRepository) Delete(id string) error
  • func (r *EventQueueRepository) FindByEventID(eventID string) ([]*domain.EventQueue, error)
  • func (r *EventQueueRepository) FindByUserID(userID string) ([]*domain.EventQueue, error)
  • func (r *EventQueueRepository) GetByEventID(ctx context.Context, eventID string) ([]*domain.EventQueue, error)
  • func (r *EventQueueRepository) GetNext(eventID string) (*domain.EventQueue, error)
  • func (r *EventQueueRepository) GetPosition(eventID string, userID string) (int, error)
  • func (r *EventQueueRepository) GetUserPosition(ctx context.Context, eventID, userID string) (int, error)
  • func (r *EventQueueRepository) ProcessNext(ctx context.Context, eventID string) (*domain.EventQueue, error)
  • func (r *EventQueueRepository) Save(queue *domain.EventQueue) error
  • func (r *EventQueueRepository) Update(queue *domain.EventQueue) error
• type EventRepository
  • func NewEventRepository(db *sql.DB) *EventRepository
  • func (r *EventRepository) Delete(ctx context.Context, id string) error
  • func (r *EventRepository) GetAll(ctx context.Context) ([]*domain.Event, error)
  • func (r *EventRepository) GetByID(ctx context.Context, id string) (*domain.Event, error)
  • func (r *EventRepository) List(ctx context.Context) ([]*domain.Event, error)
  • func (r *EventRepository) Save(ctx context.Context, event *domain.Event) error
  • func (r *EventRepository) Update(ctx context.Context, event *domain.Event) error
• type Repository
  • func NewRepository(connStr string) (*Repository, error)
  • func (r *Repository) Close() error
  • func (r *Repository) FindByID(id string) (*domain.Event, error)
  • func (r *Repository) Save(event *domain.Event) error
  • func (r *Repository) Update(event *domain.Event) error

Functions

func NewPostgresDB

func NewPostgresDB(cfg config.Database) (*sql.DB, error)

Types

type EventQueueRepository

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

func NewEventQueueRepository

func NewEventQueueRepository(db *sql.DB) *EventQueueRepository

func (*EventQueueRepository) Delete

func (r *EventQueueRepository) Delete(id string) error

func (*EventQueueRepository) FindByEventID

func (r *EventQueueRepository) FindByEventID(eventID string) ([]*domain.EventQueue, error)

func (*EventQueueRepository) FindByUserID

func (r *EventQueueRepository) FindByUserID(userID string) ([]*domain.EventQueue, error)

func (*EventQueueRepository) GetByEventID

func (r *EventQueueRepository) GetByEventID(ctx context.Context, eventID string) ([]*domain.EventQueue, error)

func (*EventQueueRepository) GetNext

func (r *EventQueueRepository) GetNext(eventID string) (*domain.EventQueue, error)

func (*EventQueueRepository) GetPosition

func (r *EventQueueRepository) GetPosition(eventID string, userID string) (int, error)

func (*EventQueueRepository) GetUserPosition

func (r *EventQueueRepository) GetUserPosition(ctx context.Context, eventID, userID string) (int, error)

func (*EventQueueRepository) ProcessNext

func (r *EventQueueRepository) ProcessNext(ctx context.Context, eventID string) (*domain.EventQueue, error)

func (*EventQueueRepository) Save

func (r *EventQueueRepository) Save(queue *domain.EventQueue) error

func (*EventQueueRepository) Update

func (r *EventQueueRepository) Update(queue *domain.EventQueue) error

type EventRepository

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

func NewEventRepository

func NewEventRepository(db *sql.DB) *EventRepository

func (*EventRepository) Delete

func (r *EventRepository) Delete(ctx context.Context, id string) error

func (*EventRepository) GetAll

func (r *EventRepository) GetAll(ctx context.Context) ([]*domain.Event, error)

func (*EventRepository) GetByID

func (r *EventRepository) GetByID(ctx context.Context, id string) (*domain.Event, error)

func (*EventRepository) List

func (r *EventRepository) List(ctx context.Context) ([]*domain.Event, error)

func (*EventRepository) Save

func (r *EventRepository) Save(ctx context.Context, event *domain.Event) error

func (*EventRepository) Update

func (r *EventRepository) Update(ctx context.Context, event *domain.Event) error

type Repository

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

func NewRepository

func NewRepository(connStr string) (*Repository, error)

func (*Repository) Close

func (r *Repository) Close() error

func (*Repository) FindByID

func (r *Repository) FindByID(id string) (*domain.Event, error)

func (*Repository) Save

func (r *Repository) Save(event *domain.Event) error

func (*Repository) Update

func (r *Repository) Update(event *domain.Event) error