loadgenerator

Documentation

Index

• func Run(configFile *string, threads int, signals chan os.Signal)
• type Postgres
  • func NewPG(ctx context.Context, server string, wg *sync.WaitGroup, threads int) *Postgres
  • func (p *Postgres) Start()
  • func (p *Postgres) StringGenerator(n int) interface{}

Functions

func Run

func Run(configFile *string, threads int, signals chan os.Signal)

Run start entry for generator

Types

type Postgres

type Postgres struct {
	DSN     string
	CTX     context.Context
	DBPool  *pgxpool.Pool
	Threads int
	Mutex   *sync.Mutex
	Ticker  *time.Ticker
	Master  string
	// contains filtered or unexported fields
}

Postgres is the main structure for each server

func NewPG

func NewPG(ctx context.Context, server string, wg *sync.WaitGroup, threads int) *Postgres

NewPG create new Postgres server instance

func (*Postgres) Start

func (p *Postgres) Start()

Start create Postgres.Threads amount of threads

func (*Postgres) StringGenerator

func (p *Postgres) StringGenerator(n int) interface{}

StringGenerator generate new random string for inserts