testharness

package

v0.1.210 Latest Latest Go to latest Published: Feb 9, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Harness struct {
	Metadata map[string]string
	Outputs  []PortMsg
	// contains filtered or unexported fields
}

Harness wraps a component for testing. Captures all port outputs and manages metadata persistence.

func New(c module.Component) *Harness

New creates a harness for the given component instance.

func (h *Harness) Handle(ctx context.Context, port string, msg any) any

Handle sends a message to the component on the given port.

func (h *Harness) HandleAsLeader(ctx context.Context, port string, msg any) any

HandleAsLeader sends a message with IsLeader=true in context.

func (h *Harness) Handler(ctx context.Context, port string, data any) any

Handler implements module.Handler, capturing outputs and metadata writes.

func (h *Harness) LeaderHandler(ctx context.Context, port string, data any) any

LeaderHandler returns a handler with IsLeader=true in context.

func (h *Harness) NewPod() *Harness

NewPod simulates a pod restart: fresh component instance, same metadata.

func (h *Harness) PortOutputs(port string) []any

PortOutputs returns all data sent to the given port.

func (h *Harness) Ports() []module.Port

Ports returns the component's current port definitions.

func (h *Harness) Reconcile(ctx context.Context) any

Reconcile simulates a reconcile event with current metadata.

func (h *Harness) ReconcileAsLeader(ctx context.Context) any

ReconcileAsLeader simulates a reconcile with IsLeader=true.

func (h *Harness) Reset()

Reset clears captured outputs (but keeps metadata).

type PortMsg struct {
	Port string
	Data any
}

PortMsg captures a single output sent by a component via handler()