Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

wftest

package

Go to main page

Versions in this module

v0

v0.3.65

Mar 24, 2026

v0.3.64

Mar 24, 2026

v0.3.63

Mar 24, 2026

Changes in this version

type Harness

+ func (h *Harness) HEAD(path string, opts ...RequestOption) *Result

+ func (h *Harness) PATCH(path, body string, opts ...RequestOption) *Result

v0.3.62

Mar 23, 2026

v0.3.61

Mar 23, 2026

v0.3.60

Mar 23, 2026

v0.3.59

Mar 23, 2026

v0.3.58

Mar 23, 2026

v0.3.57

Mar 23, 2026

Changes in this version

type Assertion

+ State map[string]map[string]any

+ type FixtureDef struct

+ File string

+ Target string

type Harness

+ func (h *Harness) State() *StateStore

type Option

+ func WithState() Option

+ type SequenceStep struct

+ Assertions []Assertion

+ Name string

+ Pipeline string

+ Trigger TriggerDef

+ type StateConfig struct

+ Fixtures []FixtureDef

+ Seed map[string]map[string]any

+ type StateStore struct

+ func NewStateStore() *StateStore

+ func (s *StateStore) Assert(store string, expected map[string]any) error

+ func (s *StateStore) Get(store, key string) (any, bool)

+ func (s *StateStore) GetAll(store string) map[string]any

+ func (s *StateStore) LoadFixture(path string, store string) error

+ func (s *StateStore) Seed(store string, data map[string]any)

+ func (s *StateStore) Set(store, key string, value any)

type TestCase

+ Sequence []SequenceStep

+ State *StateConfig

v0.3.56

Mar 23, 2026

Changes in this version

+ func RegisterTriggerAdapter(adapter TriggerAdapter)

+ func RunAllYAMLTests(t *testing.T, dir string)

+ func RunYAMLTests(t *testing.T, testFilePath string)

+ func UnregisterTriggerAdapter(name string)

+ type Assertion struct

+ Executed *bool

+ Output map[string]any

+ Response *ResponseAssert

+ Step string

+ type Call struct

+ type ExecOption func(*execConfig)

+ func StopAfter(stepName string) ExecOption

+ type Harness struct

+ func New(t *testing.T, opts ...Option) *Harness

+ func (h *Harness) BaseURL() string

+ func (h *Harness) DELETE(path string, opts ...RequestOption) *Result

+ func (h *Harness) ExecutePipeline(name string, data map[string]any) *Result

+ func (h *Harness) ExecutePipelineOpts(name string, data map[string]any, opts ...ExecOption) *Result

+ func (h *Harness) FireEvent(topic string, data map[string]any) *Result

+ func (h *Harness) FireSchedule(pipelineName string, params map[string]any) *Result

+ func (h *Harness) GET(path string, opts ...RequestOption) *Result

+ func (h *Harness) InjectTrigger(name, event string, data map[string]any) *Result

+ func (h *Harness) POST(path, body string, opts ...RequestOption) *Result

+ func (h *Harness) PUT(path, body string, opts ...RequestOption) *Result

+ func (h *Harness) RecordStep(stepType string) *Recorder

+ func (h *Harness) WSDialer(path string) (*websocket.Conn, *http.Response, error)

+ type MockConfig struct

+ Steps map[string]map[string]any

+ type MockModule struct

+ func NewMockModule(name string, service any) *MockModule

+ func (m *MockModule) Init(app modular.Application) error

+ func (m *MockModule) Name() string

+ func (m *MockModule) ProvidesServices() []modular.ServiceProvider

+ func (m *MockModule) RequiresServices() []modular.ServiceDependency

+ type Option interface

+ func MockStep(stepType string, handler StepHandler) Option

+ func WithConfig(path string) Option

+ func WithMockModule(mod *MockModule) Option

+ func WithPlugin(p plugin.EnginePlugin) Option

+ func WithServer() Option

+ func WithYAML(yaml string) Option

+ type Recorder struct

+ func NewRecorder() *Recorder

+ func RecordStep(stepType string) *Recorder

+ func (r *Recorder) CallCount() int

+ func (r *Recorder) Calls() []Call

+ func (r *Recorder) Handle(ctx context.Context, config, input map[string]any) (map[string]any, error)

+ func (r *Recorder) Reset()

+ func (r *Recorder) WithOutput(output map[string]any) *Recorder

+ type RequestOption func(*http.Request)

+ func Header(key, value string) RequestOption

+ type ResponseAssert struct

+ Body string

+ Status int

+ type Result struct

+ Duration time.Duration

+ Error error

+ Headers map[string]string

+ Output map[string]any

+ RawBody []byte

+ StatusCode int

+ StepResults map[string]map[string]any

+ func (r *Result) Header(key string) string

+ func (r *Result) JSON() map[string]any

+ func (r *Result) StepCount() int

+ func (r *Result) StepExecuted(name string) bool

+ func (r *Result) StepOutput(name string) map[string]any

+ func (r *Result) StepOutputs() map[string]map[string]any

+ type StepContext struct

+ Config map[string]any

+ Ctx context.Context

+ Input map[string]any

+ type StepHandler interface

+ Handle func(ctx context.Context, config, input map[string]any) (map[string]any, error)

+ func Returns(output map[string]any) StepHandler

+ type StepHandlerFunc func(ctx context.Context, config, input map[string]any) (map[string]any, error)

+ func (f StepHandlerFunc) Handle(ctx context.Context, config, input map[string]any) (map[string]any, error)

+ type TestCase struct

+ Assertions []Assertion

+ Description string

+ Mocks *MockConfig

+ StopAfter string

+ Trigger TriggerDef

+ type TestFile struct

+ Config string

+ Mocks MockConfig

+ Tests map[string]TestCase

+ YAML string

+ type TriggerAdapter interface

+ Inject func(ctx context.Context, h *Harness, event string, data map[string]any) (*Result, error)

+ Name func() string

+ type TriggerAdapterFunc struct

+ AdapterName string

+ Fn func(ctx context.Context, h *Harness, event string, data map[string]any) (*Result, error)

+ func (f *TriggerAdapterFunc) Inject(ctx context.Context, h *Harness, event string, data map[string]any) (*Result, error)

+ func (f *TriggerAdapterFunc) Name() string

+ type TriggerDef struct

+ Data map[string]any

+ Headers map[string]string

+ Method string

+ Name string

+ Path string

+ Type string