squirrel

Documentation

Overview

Package squirrel collects static data from ESI and dumps it into the db

Index

• type LimiterTransport
  • func (t LimiterTransport) RoundTrip(req *http.Request) (*http.Response, error)
• type Squirrel
  • func NewSquirrel(redis *redis.Pool, db *sqlx.DB) *Squirrel
  • func (s *Squirrel) ChangeBasePath(path string)
  • func (s *Squirrel) Close()
  • func (s *Squirrel) QueueWork(work []redisqueue.Work, priority int) error
  • func (s *Squirrel) Run()

Types

type LimiterTransport

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

LimiterTransport provides concurrency limiting to outbound http calls

func (LimiterTransport) RoundTrip

func (t LimiterTransport) RoundTrip(req *http.Request) (*http.Response, error)

RoundTrip wraps http.DefaultTransport.RoundTrip to limit concurrency.

type Squirrel

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

Squirrel Collects and dumps all static data from ESI

func NewSquirrel

func NewSquirrel(redis *redis.Pool, db *sqlx.DB) *Squirrel

NewSquirrel Service.

func (*Squirrel) ChangeBasePath

func (s *Squirrel) ChangeBasePath(path string)

ChangeBasePath for ESI (sisi/mock/tranquility)

func (*Squirrel) Close

func (s *Squirrel) Close()

Close the service

func (*Squirrel) QueueWork

func (s *Squirrel) QueueWork(work []redisqueue.Work, priority int) error

QueueWork directly

func (*Squirrel) Run

func (s *Squirrel) Run()

Run the service