source

Documentation

Index

• Variables
• type SourceManager
  • func NewSourceManager(sourceRepo repository.SourceRepository) *SourceManager
  • func (m *SourceManager) BuildSourceFilterAndSortOptions(ctx context.Context, query *url.Values) (*entity.SourceFilter, *entity.SortOptions, error)
  • func (m *SourceManager) CreateSource(ctx context.Context, requestPayload request.CreateSourceRequest) (*entity.Source, error)
  • func (m *SourceManager) DeleteSourceByID(ctx context.Context, id uint) error
  • func (m *SourceManager) GetSourceByID(ctx context.Context, id uint) (*entity.Source, error)
  • func (m *SourceManager) ListSources(ctx context.Context, filter *entity.SourceFilter, ...) (*entity.SourceListResult, error)
  • func (m *SourceManager) UpdateSourceByID(ctx context.Context, id uint, requestPayload request.UpdateSourceRequest) (*entity.Source, error)

Variables

var (
	ErrGettingNonExistingSource  = errors.New("the source does not exist")
	ErrUpdatingNonExistingSource = errors.New("the source to update does not exist")
	ErrInvalidSourceID           = errors.New("the source ID should be a uuid")
)

Types

type SourceManager

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

func NewSourceManager

func NewSourceManager(sourceRepo repository.SourceRepository) *SourceManager

func (*SourceManager) BuildSourceFilterAndSortOptions

func (m *SourceManager) BuildSourceFilterAndSortOptions(ctx context.Context, query *url.Values) (*entity.SourceFilter, *entity.SortOptions, error)

func (*SourceManager) CreateSource

func (m *SourceManager) CreateSource(ctx context.Context, requestPayload request.CreateSourceRequest) (*entity.Source, error)

func (*SourceManager) DeleteSourceByID

func (m *SourceManager) DeleteSourceByID(ctx context.Context, id uint) error

func (*SourceManager) GetSourceByID

func (m *SourceManager) GetSourceByID(ctx context.Context, id uint) (*entity.Source, error)

func (*SourceManager) ListSources

func (m *SourceManager) ListSources(ctx context.Context, filter *entity.SourceFilter, sortOptions *entity.SortOptions) (*entity.SourceListResult, error)

func (*SourceManager) UpdateSourceByID

func (m *SourceManager) UpdateSourceByID(ctx context.Context, id uint, requestPayload request.UpdateSourceRequest) (*entity.Source, error)