Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions tests/zz_enterprise_gate_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -564,6 +564,7 @@ func TestAdminDeregister(t *testing.T) {
// TestClearKeyExpiry verifies that a key expiry can be cleared, re-enabling
// heartbeats that would otherwise be blocked.
func TestClearKeyExpiry(t *testing.T) {
requireRealNetwork(t)
t.Parallel()

clk := newTestClock()
Expand Down Expand Up @@ -4476,6 +4477,7 @@ func TestJoinMaxMembersEnforced(t *testing.T) {
// TestRegistryWebhookDispatch verifies that the registry dispatches audit events
// to a configured webhook URL.
func TestRegistryWebhookDispatch(t *testing.T) {
requireRealNetwork(t)
t.Parallel()

// Collect webhook events
Expand Down Expand Up @@ -4612,6 +4614,7 @@ func TestRegistryWebhookRequiresAdmin(t *testing.T) {
// - ExternalID persistence across restart
// - Backwards compatibility (old nodes without identity still work)
func TestExternalIdentityIntegration(t *testing.T) {
requireRealNetwork(t)
t.Parallel()

tmpDir, err := os.MkdirTemp("/tmp", "w4-identity-")
Expand Down
2 changes: 2 additions & 0 deletions tests/zz_eventstream_broker_parity_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -206,6 +206,7 @@ func TestBrokerParityNormal(t *testing.T) {
// We assert: delivered < 400 (rate-limit fired) AND delivered ≥ 150
// (burst was honored — not catastrophically dropping everything).
func TestBrokerParityRateLimit(t *testing.T) {
requireRealNetwork(t)
t.Parallel()
env := NewTestEnv(t)

Expand Down Expand Up @@ -744,6 +745,7 @@ func TestBrokerParityLockContention(t *testing.T) {
// publishes 5 events. The webhook collector must observe 5
// pubsub.published events for our topic.
func TestBrokerParityWebhooks(t *testing.T) {
requireRealNetwork(t)
t.Parallel()
collector := newWebhookCollector()
defer collector.Close()
Expand Down
3 changes: 3 additions & 0 deletions tests/zz_handshake_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@ import (
)

func TestHandshakeMutualAutoApprove(t *testing.T) {
requireRealNetwork(t)
t.Parallel()
// Two nodes send handshake requests to each other → auto-approved (mutual)

Expand Down Expand Up @@ -257,6 +258,7 @@ func TestHandshakePendingApproveReject(t *testing.T) {
}

func TestHandshakeNetworkTrust(t *testing.T) {
requireRealNetwork(t)
t.Parallel()
// Two nodes on the same non-backbone network should auto-approve handshakes

Expand Down Expand Up @@ -358,6 +360,7 @@ func TestHandshakeNetworkTrust(t *testing.T) {

// TestHandshakeRevokeTrust verifies trust can be revoked after being established.
func TestHandshakeRevokeTrust(t *testing.T) {
requireRealNetwork(t)
t.Parallel()
env := NewTestEnv(t)

Expand Down
Loading