tests

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 2, 2024 License: MIT Imports: 23 Imported by: 0

Documentation

Overview

Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT License.

Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT License.

Index

Constants

View Source
const (
	// standard to all tests
	MetricSent          = "Sent"
	MetricReceived      = "Received"
	MetricOwnershipLost = "OwnershipLost"

	// go specific
	MetricDeadlineExceeded = "DeadlineExceeded"
)

metric names

View Source
const (
	EventBalanceTest log.Event = "balance.test"
)

Variables

This section is empty.

Functions

func BalanceTester added in v1.0.3

func BalanceTester(ctx context.Context) error

BalanceTester checks that we can properly distribute partitions and maintain it over time.

func BatchStressTester added in v0.2.0

func BatchStressTester(ctx context.Context) error

BatchStressTester sends a limited number of events and then consumes that set of events over and over to see what we get with different wait times.

func MultiBalanceTester added in v1.0.3

func MultiBalanceTester(ctx context.Context) error

MultiBalanceTester runs the BalanceTest multiple times against different combinations of partition acquisition strategy and number of processors.

NOTE: this test assumes that the Event Hub you're using has 32 partitions.

func ProcessorStressTester added in v0.2.0

func ProcessorStressTester(ctx context.Context) error

Types

This section is empty.

Jump to

Keyboard shortcuts

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