wftest

package

Go to main page

Versions in this module

v0

v0.3.68

Mar 26, 2026

v0.3.67

Mar 25, 2026

v0.3.66

Mar 25, 2026

Changes in this version

+ func IsJSONEmpty(val any) bool

+ func JSONPath(body []byte, path string) (any, error)

type ResponseAssert

+ Headers map[string]string

+ JSON map[string]any

+ JSONNotEmpty []string

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

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