TestKit

​

TestKit

    kit := testkit.New(ctx, t, testkit.WithLogging(log.DebugLevel), testkit.WithExtensions(ext))
    defer kit.Shutdown(ctx)

• ActorSystem: Access the underlying actor system.
• Spawn: Spawn an actor. Fails the test on error.
• SpawnChild: Spawn a child of an existing actor.
• Subscribe: Create an event-stream subscriber. Auto-unsubscribes on test cleanup.
• Kill: Stop an actor by name.
• NewProbe: Create a test probe.
• NewGrainProbe: Create a grain test probe.
• GrainOf[T]: Create a grain identity of kind T (package-level function).
• Shutdown: Stop the actor system.

​

Options

• WithLogging: Enable logging at the given level.
• WithExtensions: Register extensions with the test system.

​

Probe

    probe := kit.NewProbe(ctx)
    defer probe.Stop()
    kit.Spawn(ctx, "worker", NewWorkerActor())
    probe.Send("worker", msg)
    probe.ExpectMessage(expected)

​

Probe interface

• ExpectMessage: Assert the next message exactly matches msg. Fails on timeout or mismatch.
• ExpectMessageWithin: Same with custom timeout.
• ExpectMessageOfType: Assert the next message has the same type as msg.
• ExpectMessageOfTypeWithin: Same with custom timeout.
• ExpectNoMessage: Assert no message arrives within the default timeout.
• ExpectAnyMessage: Wait for and return the next message.
• ExpectAnyMessageWithin: Same with custom timeout.
• ExpectTerminated: Assert a Terminated message for the given actor.
• ExpectTerminatedWithin: Same with custom timeout.
• ExpectMessageMatching: Assert the next message satisfies the predicate function.
• ExpectChildSpawned: Assert a child actor was spawned by the given parent.
• ExpectChildSpawnedWithin: Same with custom timeout.
• ClearMessages: Drain all pending messages from the probe’s queue.
• Send: Tell the named actor (fire-and-forget).
• SendSync: Ask the named actor; record the response in the probe.
• Sender: PID of the sender of the last received message.
• PID: PID of the probe itself (use as sender in tests).
• Watch: Subscribe to termination of pid.
• WatchNamed: Subscribe to termination of the named actor.
• Stop: Shutdown the probe. Call in cleanup.

​

Asserting child actor creation

func TestSpawnsChild(t *testing.T) {
    ctx := context.Background()
    kit := testkit.New(ctx, t)
    defer kit.Shutdown(ctx)

    probe := kit.NewProbe(ctx)
    defer probe.Stop()

    kit.Spawn(ctx, "parent", NewParentActor())
    probe.ExpectChildSpawned("parent", "worker")
}

​

GrainProbe

• ExpectResponse: Assert the next response matches.
• ExpectResponseWithin: Same with custom timeout.
• ExpectResponseOfType: Assert type match.
• ExpectNoResponse: Assert no response within timeout.
• ExpectAnyResponse: Wait for and return the next response.
• ExpectTerminated: Assert grain termination.
• Send: Tell the grain.
• SendSync: Ask the grain; record response.
• Stop: Shutdown the probe.

​

MultiNodes

​

Usage pattern

func TestWorker(t *testing.T) {
    ctx := context.Background()
    kit := testkit.New(ctx, t)
    defer kit.Shutdown(ctx)

    probe := kit.NewProbe(ctx)
    defer probe.Stop()

    kit.Spawn(ctx, "worker", NewWorkerActor())
    probe.Send("worker", &DoWork{ID: "1"})
    probe.ExpectMessage(&WorkDone{ID: "1"})
}