scyllasource

Documentation

Index

• type Repository
  • func New(db *scyllarepo.DB) *Repository
  • func (r Repository) Create(source entity.Source) (entity.Source, error)
  • func (r Repository) Delete(source entity.Source) error
  • func (r Repository) Exist(sourceID string) (bool, error)
  • func (r Repository) GetWithID(id string) (entity.Source, error)
  • func (r Repository) HaseMore(ownerID string, lastToken int64, perPage int) (bool, error)
  • func (r Repository) List(ownerID string, lastToken int64, limit int) ([]entity.Source, error)
  • func (r Repository) Update(source entity.Source) (entity.Source, error)

Types

type Repository

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

func New

func New(db *scyllarepo.DB) *Repository

func (Repository) Create

func (r Repository) Create(source entity.Source) (entity.Source, error)

func (Repository) Delete

func (r Repository) Delete(source entity.Source) error

func (Repository) Exist

func (r Repository) Exist(sourceID string) (bool, error)

func (Repository) GetWithID

func (r Repository) GetWithID(id string) (entity.Source, error)

func (Repository) HaseMore

func (r Repository) HaseMore(ownerID string, lastToken int64, perPage int) (bool, error)

func (Repository) List

func (r Repository) List(ownerID string, lastToken int64, limit int) ([]entity.Source, error)

func (Repository) Update

func (r Repository) Update(source entity.Source) (entity.Source, error)