services

type Bytes []byte

type FetchHelper struct {
}

type Fetcher struct {
	Client *http.Client
}

type FetcherIntf interface {
	Fetch(url string) (Bytes, error)
}

type Publisher interface {
	Publish(queue string, payload []byte) error
}

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

type RedisSubscriber struct {
	PubSub *redis.PubSub
	// contains filtered or unexported fields
}

type Scraper struct {
}

type Subscriber interface {
	Subscribe(queue string, payload []byte) error
}