driver

Documentation

Index

• type Driver
  • func NewDriver(driverConfig *config.Configuration) *Driver
  • func (d *Driver) CreateMetricsScrapper(interval time.Duration, signalReady *sync.WaitGroup, finishCh chan int, ...) func()
  • func (d *Driver) GenerateSpecification()
  • func (d *Driver) ReadOrWriteFileSpecification(writeIATsToFile bool, readIATsFromFile bool)
  • func (d *Driver) RunExperiment()
• type InvocationMetadata

Types

type Driver

type Driver struct {
	Configuration          *config.Configuration
	SpecificationGenerator *generator.SpecificationGenerator
	Invoker                clients.Invoker

	AsyncRecords *common.LockFreeQueue[*mc.ExecutionRecord]
	// contains filtered or unexported fields
}

func NewDriver

func NewDriver(driverConfig *config.Configuration) *Driver

func (*Driver) CreateMetricsScrapper

func (d *Driver) CreateMetricsScrapper(interval time.Duration,
	signalReady *sync.WaitGroup, finishCh chan int, allRecordsWritten *sync.WaitGroup) func()

func (*Driver) GenerateSpecification

func (d *Driver) GenerateSpecification()

func (*Driver) ReadOrWriteFileSpecification

func (d *Driver) ReadOrWriteFileSpecification(writeIATsToFile bool, readIATsFromFile bool)

func (*Driver) RunExperiment

func (d *Driver) RunExperiment()

type InvocationMetadata

type InvocationMetadata struct {
	RootFunction *list.List
	Phase        common.ExperimentPhase

	InvocationID string
	IatIndex     int

	SuccessCount        *int64
	FailedCount         *int64
	FunctionsInvoked    *int64
	RecordOutputChannel chan *mc.ExecutionRecord
	AnnounceDoneWG      *sync.WaitGroup
	AnnounceDoneExe     *sync.WaitGroup
}