conformance

package

v0.2.1 Latest Latest Go to latest Published: Apr 2, 2026 License: Apache-2.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/driftlessaf/go-driftlessaf

Links

Open Source Insights

Documentation ¶

Overview ¶

Package conformance provides a suite of conformance tests for workqueue implementations.

Use TestSemantics and TestConcurrency to verify that a workqueue.Interface implementation satisfies the expected behavioral contracts.

Index ¶

func TestConcurrency(t *testing.T, ctor func(int) workqueue.Interface)
func TestDurability(t *testing.T, ctor func(int) workqueue.Interface)
func TestMaxRetry(t *testing.T, ctor func(int) workqueue.Interface)
func TestSemantics(t *testing.T, ctor func(int) workqueue.Interface)
type ExpectedState

Examples ¶

ExpectedState

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func TestConcurrency ¶

func TestConcurrency(t *testing.T, ctor func(int) workqueue.Interface)

func TestDurability ¶

func TestDurability(t *testing.T, ctor func(int) workqueue.Interface)

Unlike the other tests, this one is only expected for implementations that have some degree of durability. For instance, the in-memory implementation will not pass this test.

func TestMaxRetry ¶

func TestMaxRetry(t *testing.T, ctor func(int) workqueue.Interface)

TestMaxRetry tests the max retry functionality with Fail method

func TestSemantics ¶

func TestSemantics(t *testing.T, ctor func(int) workqueue.Interface)

Types ¶

type ExpectedState ¶

type ExpectedState struct {
	WorkInProgress []string
	Queued         []string
}

Example ¶

ExampleExpectedState demonstrates constructing an ExpectedState value used by the conformance suite to assert queue contents.

package main

import (
	"fmt"

	"chainguard.dev/driftlessaf/workqueue/conformance"
)

func main() {
	es := conformance.ExpectedState{
		WorkInProgress: []string{"key-a"},
		Queued:         []string{"key-b", "key-c"},
	}
	fmt.Printf("wip=%d queued=%d\n", len(es.WorkInProgress), len(es.Queued))
}

Output:
wip=1 queued=2

Source Files ¶

View all Source files

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