Documentation ¶
Index ¶
- type ObservationRepoImpl
- func (dr *ObservationRepoImpl) CheckIfExistsByPrimaryKey(ctx context.Context, entityID uint64, timestamp time.Time) (bool, error)
- func (s *ObservationRepoImpl) CountByFilter(ctx context.Context, f *domain.ObservationFilter) (uint64, error)
- func (r *ObservationRepoImpl) DeleteByPrimaryKey(ctx context.Context, entityID uint64, timestamp time.Time) error
- func (dr *ObservationRepoImpl) GetByPrimaryKey(ctx context.Context, entityID uint64, timestamp time.Time) (*domain.Observation, error)
- func (r *ObservationRepoImpl) Insert(ctx context.Context, m *domain.Observation) error
- func (s *ObservationRepoImpl) ListByFilter(ctx context.Context, f *domain.ObservationFilter) ([]*domain.Observation, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ObservationRepoImpl ¶
type ObservationRepoImpl struct {
// contains filtered or unexported fields
}
func NewObservationRepoImpl ¶
func NewObservationRepoImpl(db *sql.DB, logger *zerolog.Logger) *ObservationRepoImpl
func (*ObservationRepoImpl) CheckIfExistsByPrimaryKey ¶
func (*ObservationRepoImpl) CountByFilter ¶
func (s *ObservationRepoImpl) CountByFilter(ctx context.Context, f *domain.ObservationFilter) (uint64, error)
func (*ObservationRepoImpl) DeleteByPrimaryKey ¶
func (*ObservationRepoImpl) GetByPrimaryKey ¶
func (dr *ObservationRepoImpl) GetByPrimaryKey(ctx context.Context, entityID uint64, timestamp time.Time) (*domain.Observation, error)
func (*ObservationRepoImpl) Insert ¶
func (r *ObservationRepoImpl) Insert(ctx context.Context, m *domain.Observation) error
func (*ObservationRepoImpl) ListByFilter ¶
func (s *ObservationRepoImpl) ListByFilter(ctx context.Context, f *domain.ObservationFilter) ([]*domain.Observation, error)
Click to show internal directories.
Click to hide internal directories.