repository

Documentation

Index

• type ObservationCountRepoImpl
  • func NewObservationCountRepoImpl(db *sql.DB, logger *zerolog.Logger) *ObservationCountRepoImpl
  • func (dr *ObservationCountRepoImpl) CheckIfExistsByPrimaryKey(ctx context.Context, entityID uint64, frequency int8, start time.Time, ...) (bool, error)
  • func (s *ObservationCountRepoImpl) CountByFilter(ctx context.Context, f *domain.ObservationCountFilter) (uint64, error)
  • func (dr *ObservationCountRepoImpl) GetByPrimaryKey(ctx context.Context, entityID uint64, frequency int8, start time.Time, ...) (*domain.ObservationCount, error)
  • func (r *ObservationCountRepoImpl) Insert(ctx context.Context, m *domain.ObservationCount) error
  • func (r *ObservationCountRepoImpl) InsertOrGetByPrimaryKey(ctx context.Context, oc *domain.ObservationCount) (*domain.ObservationCount, error)
  • func (s *ObservationCountRepoImpl) ListByFilter(ctx context.Context, f *domain.ObservationCountFilter) ([]*domain.ObservationCount, error)
  • func (r *ObservationCountRepoImpl) UpdateByPrimaryKey(ctx context.Context, oc *domain.ObservationCount) error

Types

type ObservationCountRepoImpl

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

func NewObservationCountRepoImpl

func NewObservationCountRepoImpl(db *sql.DB, logger *zerolog.Logger) *ObservationCountRepoImpl

func (*ObservationCountRepoImpl) CheckIfExistsByPrimaryKey

func (dr *ObservationCountRepoImpl) CheckIfExistsByPrimaryKey(ctx context.Context, entityID uint64, frequency int8, start time.Time, finish time.Time) (bool, error)

func (*ObservationCountRepoImpl) CountByFilter

func (s *ObservationCountRepoImpl) CountByFilter(ctx context.Context, f *domain.ObservationCountFilter) (uint64, error)

func (*ObservationCountRepoImpl) GetByPrimaryKey

func (dr *ObservationCountRepoImpl) GetByPrimaryKey(ctx context.Context, entityID uint64, frequency int8, start time.Time, finish time.Time) (*domain.ObservationCount, error)

func (*ObservationCountRepoImpl) Insert

func (r *ObservationCountRepoImpl) Insert(ctx context.Context, m *domain.ObservationCount) error

func (*ObservationCountRepoImpl) InsertOrGetByPrimaryKey

func (r *ObservationCountRepoImpl) InsertOrGetByPrimaryKey(ctx context.Context, oc *domain.ObservationCount) (*domain.ObservationCount, error)

func (*ObservationCountRepoImpl) ListByFilter

func (s *ObservationCountRepoImpl) ListByFilter(ctx context.Context, f *domain.ObservationCountFilter) ([]*domain.ObservationCount, error)

func (*ObservationCountRepoImpl) UpdateByPrimaryKey

func (r *ObservationCountRepoImpl) UpdateByPrimaryKey(ctx context.Context, oc *domain.ObservationCount) error