test

package

v0.0.1 Latest Latest Go to latest Published: Jan 31, 2024 License: GPL-3.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ethpandaops/assertoor

Links

Open Source Insights

Documentation ¶

Index ¶

func CreateTest(coordinator types.Coordinator, config *Config, variables types.Variables) (types.Test, error)
type Config
type ExternalConfig
type Metrics
- func NewMetrics(namespace, testName string) Metrics
type TaskScheduler
- func NewTaskScheduler(log logrus.FieldLogger, coordinator types.Coordinator, ...) *TaskScheduler
type Test

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateTest ¶

func CreateTest(coordinator types.Coordinator, config *Config, variables types.Variables) (types.Test, error)

Types ¶

type Config ¶

type Config struct {
	Name         string                 `yaml:"name" json:"name"`
	Disable      bool                   `yaml:"disable" json:"disable"`
	Timeout      human.Duration         `yaml:"timeout" json:"timeout"`
	Config       map[string]interface{} `yaml:"config" json:"config"`
	ConfigVars   map[string]string      `yaml:"configVars" json:"configVars"`
	Tasks        []helper.RawMessage    `yaml:"tasks" json:"tasks"`
	CleanupTasks []helper.RawMessage    `yaml:"cleanupTasks" json:"cleanupTasks"`
}

type ExternalConfig ¶

type ExternalConfig struct {
	File       string                 `yaml:"file" json:"file"`
	Name       string                 `yaml:"name" json:"name"`
	Timeout    *human.Duration        `yaml:"timeout" json:"timeout"`
	Config     map[string]interface{} `yaml:"config" json:"config"`
	ConfigVars map[string]string      `yaml:"configVars" json:"configVars"`
}

type Metrics ¶

type Metrics struct {
	TaskInfo     *prometheus.GaugeVec
	TestDuration *prometheus.GaugeVec
	TestResult   *prometheus.GaugeVec

	CurrentTask  *prometheus.GaugeVec
	TotalTasks   *prometheus.GaugeVec
	TaskDuration *prometheus.GaugeVec
	TestInfo     *prometheus.GaugeVec
	// contains filtered or unexported fields
}

func NewMetrics ¶

func NewMetrics(namespace, testName string) Metrics

NewMetrics returns a new Metrics instance.

func (*Metrics) Register ¶

func (m *Metrics) Register()

func (*Metrics) SetTestDuration ¶

func (m *Metrics) SetTestDuration(duration float64)

func (*Metrics) SetTestInfo ¶

func (m *Metrics) SetTestInfo(description string)

func (*Metrics) SetTotalTasks ¶

func (m *Metrics) SetTotalTasks(total float64)

type TaskScheduler ¶

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

func NewTaskScheduler ¶

func NewTaskScheduler(log logrus.FieldLogger, coordinator types.Coordinator, variables types.Variables) *TaskScheduler

func (*TaskScheduler) AddCleanupTask ¶

func (ts *TaskScheduler) AddCleanupTask(options *types.TaskOptions) (types.Task, error)

func (*TaskScheduler) AddRootTask ¶

func (ts *TaskScheduler) AddRootTask(options *types.TaskOptions) (types.Task, error)

func (*TaskScheduler) ExecuteTask ¶

func (ts *TaskScheduler) ExecuteTask(ctx context.Context, task types.Task, taskWatchFn func(ctx context.Context, cancelFn context.CancelFunc, task types.Task)) error

ExecuteTask executes a task this function blocks until the task is executed or the context cancelled

func (*TaskScheduler) GetAllCleanupTasks ¶

func (ts *TaskScheduler) GetAllCleanupTasks() []types.Task

func (*TaskScheduler) GetAllTasks ¶

func (ts *TaskScheduler) GetAllTasks() []types.Task

func (*TaskScheduler) GetCoordinator ¶

func (ts *TaskScheduler) GetCoordinator() types.Coordinator

func (*TaskScheduler) GetRootCleanupTasks ¶

func (ts *TaskScheduler) GetRootCleanupTasks() []types.Task

func (*TaskScheduler) GetRootTasks ¶

func (ts *TaskScheduler) GetRootTasks() []types.Task

func (*TaskScheduler) GetTaskCount ¶

func (ts *TaskScheduler) GetTaskCount() int

func (*TaskScheduler) GetTaskResultUpdateChan ¶

func (ts *TaskScheduler) GetTaskResultUpdateChan(task types.Task, oldResult types.TaskResult) <-chan bool

func (*TaskScheduler) GetTaskStatus ¶

func (ts *TaskScheduler) GetTaskStatus(task types.Task) *types.TaskStatus

func (*TaskScheduler) ParseTaskOptions ¶

func (ts *TaskScheduler) ParseTaskOptions(rawtask *helper.RawMessage) (*types.TaskOptions, error)

func (*TaskScheduler) RunTasks ¶

func (ts *TaskScheduler) RunTasks(ctx context.Context, timeout time.Duration) error

func (*TaskScheduler) WatchTaskPass ¶

func (ts *TaskScheduler) WatchTaskPass(ctx context.Context, cancelFn context.CancelFunc, task types.Task)

type Test ¶

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

func (*Test) GetTaskScheduler ¶

func (t *Test) GetTaskScheduler() types.TaskScheduler

func (*Test) Logger ¶

func (t *Test) Logger() logrus.FieldLogger

func (*Test) Name ¶

func (t *Test) Name() string

func (*Test) Percent ¶

func (t *Test) Percent() float64

func (*Test) Run ¶

func (t *Test) Run(ctx context.Context) error

func (*Test) StartTime ¶

func (t *Test) StartTime() time.Time

func (*Test) Status ¶

func (t *Test) Status() types.TestStatus

func (*Test) StopTime ¶

func (t *Test) StopTime() time.Time

func (*Test) Timeout ¶

func (t *Test) Timeout() time.Duration

func (*Test) Validate ¶

func (t *Test) Validate() error

Source Files ¶

View all Source files

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