generator

package

v0.0.0-...-81c94d3 Latest Latest Go to latest Published: Jun 5, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation ¶

Index ¶

func RandStringBytesMaskImprSrc(n int) string
func SetLog(entty *logrus.Entry)
func SetLogger(nLogger *logrus.Logger)
type GMeterValue
type Generator
- func NewGenerator(mg MeterGenerator) (*Generator, error)
type MeterGenerator
type MeterValue
type RandomGenerator
- func NewRandomMeterGenerator() RandomGenerator
type TimedViolationGenerator
- func NewTimedViolationGenerator(args []string) TimedViolationGenerator
type ViolationfreeGenerator
- func NewViolationfreeGenerator() ViolationfreeGenerator

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func RandStringBytesMaskImprSrc ¶

func RandStringBytesMaskImprSrc(n int) string

func SetLog ¶

func SetLog(entty *logrus.Entry)

func SetLogger ¶

func SetLogger(nLogger *logrus.Logger)

Types ¶

type GMeterValue ¶

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

func (*GMeterValue) AsDuration ¶

func (g *GMeterValue) AsDuration() time.Duration

func (*GMeterValue) AsFloat ¶

func (g *GMeterValue) AsFloat() float64

func (*GMeterValue) AsInt ¶

func (g *GMeterValue) AsInt() int32

func (*GMeterValue) AsInterface ¶

func (g *GMeterValue) AsInterface() interface{}

type Generator ¶

type Generator struct {
	Blueprint spec.BlueprintType
	ESC       *elastic.Client
	// contains filtered or unexported fields
}

func NewGenerator ¶

func NewGenerator(mg MeterGenerator) (*Generator, error)

func (*Generator) Generate ¶

func (gen *Generator) Generate(methods map[string]blueprint.ExtendedMethods, agentQueue chan agent.ElasticData, trafficQueue chan []throughputagent.TrafficMessage, requestQueue chan monitor.MeterMessage, exchangeQueue chan monitor.ExchangeMessage, mg MeterGenerator)

func (*Generator) GenerateAgentData ¶

func (gen *Generator) GenerateAgentData(v blueprint.ExtendedMethods, agentQueue chan agent.ElasticData, now time.Time, operationID string, meterGenerator MeterGenerator)

func (*Generator) GenerateRequestData ¶

func (gen *Generator) GenerateRequestData(requestQueue chan monitor.MeterMessage, exchangeQueue chan monitor.ExchangeMessage, operationID string, method blueprint.ExtendedMethods)

func (*Generator) GenerateTrafficData ¶

func (gen *Generator) GenerateTrafficData(trafficQueue chan []throughputagent.TrafficMessage) time.Time

func (*Generator) Start ¶

func (gen *Generator) Start()

type MeterGenerator ¶

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

type MeterValue ¶

type MeterValue interface {
	AsFloat() float64
	AsInt() int32
	AsDuration() time.Duration
	AsInterface() interface{}
}

type RandomGenerator ¶

type RandomGenerator struct{}

func NewRandomMeterGenerator ¶

func NewRandomMeterGenerator() RandomGenerator

type TimedViolationGenerator ¶

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

func NewTimedViolationGenerator ¶

func NewTimedViolationGenerator(args []string) TimedViolationGenerator

type ViolationfreeGenerator ¶

type ViolationfreeGenerator struct{}

func NewViolationfreeGenerator ¶

func NewViolationfreeGenerator() ViolationfreeGenerator

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL