persistence

Documentation

Index

• type InMemoryMovieRepository
  • func NewInMemoryMovieRepository() *InMemoryMovieRepository
  • func (i *InMemoryMovieRepository) Save(_ context.Context, movie movie.Movie) error
  • func (i InMemoryMovieRepository) Search(_ context.Context, movieId movie.Id) (*movie.Movie, error)
  • func (i InMemoryMovieRepository) SearchByCriteria(_ context.Context, criteria domain.Criteria) ([]*movie.Movie, error)
• type PostgresMovieRepository
  • func NewPostgresMovieRepository(db *sql.DB) *PostgresMovieRepository
  • func (p *PostgresMovieRepository) Save(ctx context.Context, movie movie.Movie) error
  • func (p *PostgresMovieRepository) Search(ctx context.Context, movieId movie.Id) (*movie.Movie, error)
  • func (p *PostgresMovieRepository) SearchByCriteria(ctx context.Context, criteria domain.Criteria) ([]*movie.Movie, error)

Types

type InMemoryMovieRepository

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

@Repository @Adapter

func NewInMemoryMovieRepository

func NewInMemoryMovieRepository() *InMemoryMovieRepository

func (*InMemoryMovieRepository) Save

func (i *InMemoryMovieRepository) Save(_ context.Context, movie movie.Movie) error

func (InMemoryMovieRepository) Search

func (i InMemoryMovieRepository) Search(_ context.Context, movieId movie.Id) (*movie.Movie, error)

func (InMemoryMovieRepository) SearchByCriteria

func (i InMemoryMovieRepository) SearchByCriteria(_ context.Context, criteria domain.Criteria) (
	[]*movie.Movie, error)

type PostgresMovieRepository

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

@Repository @Adapter

func NewPostgresMovieRepository

func NewPostgresMovieRepository(db *sql.DB) *PostgresMovieRepository

func (*PostgresMovieRepository) Save

func (p *PostgresMovieRepository) Save(ctx context.Context, movie movie.Movie) error

func (*PostgresMovieRepository) Search

func (p *PostgresMovieRepository) Search(ctx context.Context, movieId movie.Id) (*movie.Movie, error)

func (*PostgresMovieRepository) SearchByCriteria

func (p *PostgresMovieRepository) SearchByCriteria(ctx context.Context, criteria domain.Criteria) ([]*movie.Movie, error)