scenario

Documentation

Index

• type DurationSleep
• type RangeSleep
• type ScenarioService
  • func NewScenarioService() *ScenarioService
  • func (s *ScenarioService) Do(proxy *url.URL, startTime time.Time) (response *types.Response, err *types.RequestError)
  • func (s *ScenarioService) Done()
  • func (s *ScenarioService) Init(ctx context.Context, scenario types.Scenario, proxies []*url.URL) (err error)
• type Sleeper

Types

type DurationSleep

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

DurationSleep is the implementation of the exact duration sleep feature

type RangeSleep

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

RangeSleep is the implementation of the range sleep feature

type ScenarioService

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

ScenarioService encapsulates proxy/scenario/requester information and runs the scenario.

func NewScenarioService

func NewScenarioService() *ScenarioService

NewScenarioService is the constructor of the ScenarioService.

func (*ScenarioService) Do

func (s *ScenarioService) Do(proxy *url.URL, startTime time.Time) (response *types.Response, err *types.RequestError)

Do executes the scenario for the given proxy. Returns "types.Response" filled by the requester of the given Proxy, injects the given startTime to the response Returns error only if types.Response.Err.Type is types.ErrorProxy or types.ErrorIntented

func (*ScenarioService) Done

func (s *ScenarioService) Done()

func (*ScenarioService) Init

func (s *ScenarioService) Init(ctx context.Context, scenario types.Scenario, proxies []*url.URL) (err error)

Init initializes the ScenarioService.clients with the given types.Scenario and proxies. Passes the given ctx to the underlying requestor so we are able to control the life of each request.

type Sleeper

type Sleeper interface {
	// contains filtered or unexported methods
}

Sleeper is the interface for implementing different sleep strategies.