elastic

Documentation

Index

• type Repository
  • func NewRepository(client *driver.Client, uuid share.UUIDProviderInterface) (*Repository, error)
  • func (repository *Repository) FindAll(limit int64, offset int64) ([]*entity.Visit, error)
  • func (repository *Repository) FindAllByClientID(clientID string, limit int64, offset int64) (result []*entity.Visit, err error)
  • func (repository *Repository) FindAllBySessionID(sessionID types.UUID, limit int64, offset int64) (result []*entity.Visit, err error)
  • func (repository *Repository) FindByID(visitID types.UUID) (*entity.Visit, error)
  • func (repository *Repository) Insert(visit *entity.Visit) (err error)
  • func (repository *Repository) Verify(sessionID types.UUID, clientID string) (ok bool, err error)

Types

type Repository

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

func NewRepository

func NewRepository(client *driver.Client, uuid share.UUIDProviderInterface) (*Repository, error)

func (*Repository) FindAll

func (repository *Repository) FindAll(limit int64, offset int64) ([]*entity.Visit, error)

func (*Repository) FindAllByClientID

func (repository *Repository) FindAllByClientID(
	clientID string,
	limit int64,
	offset int64,
) (result []*entity.Visit, err error)

func (*Repository) FindAllBySessionID

func (repository *Repository) FindAllBySessionID(
	sessionID types.UUID,
	limit int64,
	offset int64,
) (result []*entity.Visit, err error)

func (*Repository) FindByID

func (repository *Repository) FindByID(visitID types.UUID) (*entity.Visit, error)

func (*Repository) Insert

func (repository *Repository) Insert(visit *entity.Visit) (err error)

Save visit

func (*Repository) Verify

func (repository *Repository) Verify(sessionID types.UUID, clientID string) (ok bool, err error)

Verify method MUST check that sessionID is not registered by another not empty clientID