http_client

Documentation

Index

• Variables
• func Init()
• func SendGetRequest(url string) (int, []byte, error)
• type Fetcher
  • func NewFetcher(providerService interfaces.IProviderService, ...) *Fetcher
  • func (s *Fetcher) FetchTasks(ctx context.Context, provider *entity.Provider) error
  • func (s *Fetcher) FetchTasksFromMongo(ctx context.Context) error

Variables

var MaxConnPerHost = &env.Env.MaxConnsPerHost

var MaxConnWaitTimeout = &env.Env.MaxConnWaitTimeout

var MaxIdempotentCallAttempts = &env.Env.MaxIdempotentCallAttempts

var NetClient fasthttp.Client

var ReadTimeout = &env.Env.ReadTimeout

Functions

func Init

func Init()

func SendGetRequest

func SendGetRequest(url string) (int, []byte, error)

Types

type Fetcher

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

func NewFetcher

func NewFetcher(providerService interfaces.IProviderService, taskService interfaces.ITaskService) *Fetcher

func (*Fetcher) FetchTasks

func (s *Fetcher) FetchTasks(ctx context.Context, provider *entity.Provider) error

func (*Fetcher) FetchTasksFromMongo

func (s *Fetcher) FetchTasksFromMongo(ctx context.Context) error