test

Documentation

Index

• func DecodeParam[P any](payload *testsv1.Payload) (P, error)
• func DecodeTemporalParam[P any](payload *common.Payload) (P, error)
• func ExecuteTest(ctx workflow.Context, wf func(ctx workflow.Context)) error
• func GetPendingError(pending *Pending) error
• func GetPendingFuture(pending *Pending) workflow.Future
• func ResultChanFromContext(ctx context.Context) chan<- any
• type CaseExecutor
• type CaseResponse
  • func ExecuteCase(ctx context.Context, a func(ctx context.Context)) (*CaseResponse[any], error)
• type Pending
  • func NewPending(id test.CaseExecutionID, name string, base workflow.Future) *Pending
  • func NewPendingError(id test.CaseExecutionID, name string, err error) *Pending
  • func (p *Pending) IsReady() bool
• type TestExecutor

Functions

func DecodeParam

func DecodeParam[P any](payload *testsv1.Payload) (P, error)

func DecodeTemporalParam

func DecodeTemporalParam[P any](payload *common.Payload) (P, error)

func ExecuteTest

func ExecuteTest(ctx workflow.Context, wf func(ctx workflow.Context)) error

func GetPendingError

func GetPendingError(pending *Pending) error

func GetPendingFuture

func GetPendingFuture(pending *Pending) workflow.Future

func ResultChanFromContext

func ResultChanFromContext(ctx context.Context) chan<- any

Types

type CaseExecutor

type CaseExecutor func(ctx context.Context, payload *common.Payload) (any, error)

type CaseResponse

type CaseResponse[T any] struct {
	Result   T
	Finished time.Time
	Duration time.Duration
}

func ExecuteCase

func ExecuteCase(ctx context.Context, a func(ctx context.Context)) (*CaseResponse[any], error)

type Pending

type Pending struct {
	// contains filtered or unexported fields
}

func NewPending

func NewPending(id test.CaseExecutionID, name string, base workflow.Future) *Pending

func NewPendingError

func NewPendingError(id test.CaseExecutionID, name string, err error) *Pending

func (*Pending) IsReady

func (p *Pending) IsReady() bool

type TestExecutor

type TestExecutor func(ctx workflow.Context, payload *testsv1.Payload) error