pagerepository

Documentation

Index

• type Mongo
  • func NewMongo(config spiderconfiginterface.Configurator, logger logger.Logger, ...) *Mongo
  • func (r *Mongo) FindOneLatestByURL(ctx context.Context, url string) (page *entity.Page, found bool, err error)
  • func (r *Mongo) Save(ctx context.Context, page *entity.Page) error
  • func (r *Mongo) Update(ctx context.Context, page *entity.Page) error

Types

type Mongo

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

func NewMongo

func NewMongo(
	config spiderconfiginterface.Configurator,
	logger logger.Logger,
	mongodb *mongo.Database,
) *Mongo

func (*Mongo) FindOneLatestByURL

func (r *Mongo) FindOneLatestByURL(ctx context.Context, url string) (page *entity.Page, found bool, err error)

func (*Mongo) Save

func (r *Mongo) Save(ctx context.Context, page *entity.Page) error

func (*Mongo) Update

func (r *Mongo) Update(ctx context.Context, page *entity.Page) error