crawler

package
v0.0.0-...-91eafdd Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 14, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Start

func Start(crawler *Crawler, cfg *Config, logger log.Logger)

Types

type Config

type Config struct {
	Interval    string `json:"interval"`
	MaxRoutines int    `json:"routines"`
	CacheLimit  int    `json:"cache"`
	Start       uint64 `json:"start"`
}

type Crawler

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

func NewCrawler

func NewCrawler(cfg *Config, state *state.State, rpc *common.RPCClient, writer *kafka.Writer, logger log.Logger) *Crawler

func (*Crawler) RunLoop

func (c *Crawler) RunLoop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL