indexer

Documentation

Index

• type Clock
• type WordCountRepository
  • func New(redisURL string, clock Clock) *WordCountRepository
  • func (repo *WordCountRepository) Cleanup(word string, before time.Time) error
  • func (repo *WordCountRepository) Close() error
  • func (repo *WordCountRepository) Count(word string, since time.Time) (uint, error)
  • func (repo *WordCountRepository) IndexWord(s string) error

Types

type Clock

type Clock interface {
	Now() time.Time
}

type WordCountRepository

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

func New

func New(redisURL string, clock Clock) *WordCountRepository

func (*WordCountRepository) Cleanup

func (repo *WordCountRepository) Cleanup(word string, before time.Time) error

func (*WordCountRepository) Close

func (repo *WordCountRepository) Close() error

func (*WordCountRepository) Count

func (repo *WordCountRepository) Count(word string, since time.Time) (uint, error)

func (*WordCountRepository) IndexWord

func (repo *WordCountRepository) IndexWord(s string) error