postgres

Documentation

Index

• type PostgresRepository
  • func NewPostgresRepository(ctx context.Context, db *sqlx.DB) *PostgresRepository
  • func (r *PostgresRepository) CreateChannel(ctx context.Context, channel domain.Channel) (*domain.Channel, domain.Error)
  • func (r *PostgresRepository) GetChannelByExternalID(ctx context.Context, externalChannelID string) (*domain.Channel, domain.Error)
  • func (r *PostgresRepository) GetChannelByID(ctx context.Context, channelID int) (*domain.Channel, domain.Error)
  • func (r *PostgresRepository) GetEnabledSlideURL(ctx context.Context, channelID int) (string, domain.Error)
  • func (r *PostgresRepository) GetLastPageNumber(ctx context.Context, channelID int) (int, domain.Error)
  • func (r *PostgresRepository) GetSlideURLByPage(ctx context.Context, channelID, page int) (url string, p int, err domain.Error)
  • func (r *PostgresRepository) UpdateCurrentPage(ctx context.Context, channelID, page int) domain.Error

Types

type PostgresRepository

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

func NewPostgresRepository

func NewPostgresRepository(ctx context.Context, db *sqlx.DB) *PostgresRepository

func (*PostgresRepository) CreateChannel

func (r *PostgresRepository) CreateChannel(ctx context.Context, channel domain.Channel) (*domain.Channel, domain.Error)

func (*PostgresRepository) GetChannelByExternalID

func (r *PostgresRepository) GetChannelByExternalID(ctx context.Context, externalChannelID string) (*domain.Channel, domain.Error)

func (*PostgresRepository) GetChannelByID

func (r *PostgresRepository) GetChannelByID(ctx context.Context, channelID int) (*domain.Channel, domain.Error)

func (*PostgresRepository) GetEnabledSlideURL

func (r *PostgresRepository) GetEnabledSlideURL(ctx context.Context, channelID int) (string, domain.Error)

func (*PostgresRepository) GetLastPageNumber

func (r *PostgresRepository) GetLastPageNumber(ctx context.Context, channelID int) (int, domain.Error)

func (*PostgresRepository) GetSlideURLByPage

func (r *PostgresRepository) GetSlideURLByPage(ctx context.Context, channelID, page int) (url string, p int, err domain.Error)

func (*PostgresRepository) UpdateCurrentPage

func (r *PostgresRepository) UpdateCurrentPage(ctx context.Context, channelID, page int) domain.Error