streamconformance

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package streamconformance defines the shared behavioral contract exercised by every first-class Streams worker.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Run 

func Run(t *testing.T, backendName string, factory Factory)

Run exercises the stable worker behavior shared by native stream backends.

Types

type Factory 

type Factory func(
	t *testing.T,
	run func(context.Context, core.TaskMessage) error,
	requestTimeout time.Duration,
) core.Worker

Factory constructs an isolated worker with the supplied handler and request timeout. Implementations must register their own resource cleanup with t.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.