tests

package

v0.0.0-...-45adee8 Latest Latest Go to latest Published: Dec 1, 2024 License: MIT Imports: 25 Imported by: 0

Details

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

Repository

github.com/0xhea/azure-sdk-for-go

Links

Open Source Insights

Documentation ¶

Overview ¶

Index ¶

Constants
func BalanceTester(ctx context.Context) error
func BatchStressTester(ctx context.Context) error
func MultiBalanceTester(ctx context.Context) error
func ProcessorStressTester(ctx context.Context) error

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 ¶

func BalanceTester(ctx context.Context) error

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

func BatchStressTester ¶

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 ¶

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 ¶

func ProcessorStressTester(ctx context.Context) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

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