core

Documentation

Index

• Constants
• type Config
• type Core
  • func NewCore() *Core
  • func (core *Core) CheckReady() bool
  • func (core *Core) FormResultAttack() *rest_contracts.BomberResult
  • func (core *Core) GetConfig() *nats_listener.NatsConnectionConfiguration
  • func (core *Core) GetConnection() *nats.Conn
  • func (core *Core) InitializeService()
  • func (core *Core) PreparingData(task rest_contracts.Task)
  • func (core *Core) Start(task rest_contracts.Task, wg *sync.WaitGroup)
• type RequestPayload
• type SliceResult

Constants

const (
	MaxIdleConnections int = 20
	RequestTimeout     int = 5
)

Types

type Config

type Config struct {
	AmountRequestPerWorker int64
	AmountTimeInSeconds    int64
}

type Core

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

func NewCore

func NewCore() *Core

func (*Core) CheckReady

func (core *Core) CheckReady() bool

func (*Core) FormResultAttack

func (core *Core) FormResultAttack() *rest_contracts.BomberResult

func (*Core) GetConfig

func (core *Core) GetConfig() *nats_listener.NatsConnectionConfiguration

func (*Core) GetConnection

func (core *Core) GetConnection() *nats.Conn

func (*Core) InitializeService

func (core *Core) InitializeService()

func (*Core) PreparingData

func (core *Core) PreparingData(task rest_contracts.Task)

func (*Core) Start

func (core *Core) Start(task rest_contracts.Task, wg *sync.WaitGroup)

type RequestPayload

type RequestPayload struct {
	Request  *fasthttp.Request
	Response *fasthttp.Response
	Id       int
}

type SliceResult

type SliceResult struct {
	Status      int
	TimeElapsed int64
	Timeout     bool
}