utils

package

v0.12.1 Latest Latest Go to latest Published: May 26, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

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

Repository

github.com/dapr/durabletask-go

Links

Open Source Insights

Documentation ¶

Index ¶

func AssertActivity(name string, id api.InstanceID, taskID int64, ...) spanValidator
func AssertExternalEvent(eventName string, payloadSize int) spanEventValidator
func AssertPatch(patchName string, optionalAsserts ...spanAttributeValidator) spanValidator
func AssertResumedEvent() spanEventValidator
func AssertSpan(name string, optionalAsserts ...spanAttributeValidator) spanValidator
func AssertSpanEvents(eventAsserts ...spanEventValidator) spanAttributeValidator
func AssertSpanSequence(t assert.TestingT, spans []trace.ReadOnlySpan, spanAsserts ...spanValidator)
func AssertSpanStringAttribute(key string, value string) spanAttributeValidator
func AssertSpanStringSliceAttribute(key string, value []string) spanAttributeValidator
func AssertSuspendedEvent() spanEventValidator
func AssertTaskID(expectedTaskID int64) spanAttributeValidator
func AssertTimer(id api.InstanceID, optionalAsserts ...spanAttributeValidator) spanValidator
func AssertWorkflowCreated(name string, id api.InstanceID, optionalAsserts ...spanAttributeValidator) spanValidator
func AssertWorkflowExecuted(name string, id api.InstanceID, status string, ...) spanValidator
func InitTracing() *tracetest.InMemoryExporter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AssertActivity ¶

func AssertActivity(name string, id api.InstanceID, taskID int64, optionalAsserts ...spanAttributeValidator) spanValidator

func AssertExternalEvent ¶

func AssertExternalEvent(eventName string, payloadSize int) spanEventValidator

func AssertPatch ¶ added in v0.11.0

func AssertPatch(patchName string, optionalAsserts ...spanAttributeValidator) spanValidator

func AssertResumedEvent ¶

func AssertResumedEvent() spanEventValidator

func AssertSpan ¶

func AssertSpan(name string, optionalAsserts ...spanAttributeValidator) spanValidator

func AssertSpanEvents ¶

func AssertSpanEvents(eventAsserts ...spanEventValidator) spanAttributeValidator

func AssertSpanSequence ¶

func AssertSpanSequence(t assert.TestingT, spans []trace.ReadOnlySpan, spanAsserts ...spanValidator)

func AssertSpanStringAttribute ¶ added in v0.11.0

func AssertSpanStringAttribute(key string, value string) spanAttributeValidator

func AssertSpanStringSliceAttribute ¶ added in v0.11.0

func AssertSpanStringSliceAttribute(key string, value []string) spanAttributeValidator

func AssertSuspendedEvent ¶

func AssertSuspendedEvent() spanEventValidator

func AssertTaskID ¶

func AssertTaskID(expectedTaskID int64) spanAttributeValidator

func AssertTimer ¶

func AssertTimer(id api.InstanceID, optionalAsserts ...spanAttributeValidator) spanValidator

func AssertWorkflowCreated ¶ added in v0.12.0

func AssertWorkflowCreated(name string, id api.InstanceID, optionalAsserts ...spanAttributeValidator) spanValidator

AssertWorkflowCreated validates a create_orchestration span

func AssertWorkflowExecuted ¶ added in v0.12.0

func AssertWorkflowExecuted(name string, id api.InstanceID, status string, optionalAsserts ...spanAttributeValidator) spanValidator

AssertWorkflowExecuted validates an orchestration span

func InitTracing ¶

func InitTracing() *tracetest.InMemoryExporter

initTracing configures in-memory OTel tracing and returns an exporter which can be used to examine the exported traces. We only want to look at exported traces because we do tricks to mark certain spans as non-exported (i.e. workflow replays), and want to ensure that those spans are never actually exported.

Types ¶

This section is empty.

Source Files ¶

View all Source files

tracing.go

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