testutil

package

Go to main page

Versions in this module

v0

v0.2.0

Oct 13, 2026

Changes in this version

+ const TestServerVersion

+ func NewEmbeddedMQ(t testing.TB, maxBytes int64, tenants ...tenant.ID) *mq.EmbeddedNATS

+ func NewSchemaConn(tables []*discovery.TableSchema) driver.Conn

type MockCache

+ InvTenants []tenant.ID

+ func (m *MockCache) GetTenants() []tenant.ID

+ func (m *MockCache) InvalidateTenant(_ context.Context, id tenant.ID) error

+ type MockDeadLetterStats struct

+ Counts mq.DeadLetterCounts

+ Err error

+ Table string

+ Tenant tenant.ID

+ func (m *MockDeadLetterStats) DeadLetterCounts(_ context.Context, id tenant.ID, table string) (mq.DeadLetterCounts, error)

type MockDeduplicator

+ CommitErr error

+ Commits int

+ ErrAfter int

+ ReleaseErr error

+ Released []dedupe.Claim

+ Reserves int

+ func (m *MockDeduplicator) Commit(_ context.Context, claims []dedupe.Claim, retention time.Duration) error

+ func (m *MockDeduplicator) Committed(k dedupe.Key) bool

+ func (m *MockDeduplicator) Hold(k dedupe.Key)

+ func (m *MockDeduplicator) Pending(k dedupe.Key) bool

+ func (m *MockDeduplicator) Release(_ context.Context, claims []dedupe.Claim) error

+ func (m *MockDeduplicator) Reserve(_ context.Context, keys []dedupe.Key, _ time.Duration) ([]dedupe.Claim, error)

+ func (m *MockDeduplicator) Retention(k dedupe.Key) time.Duration

+ type MockMessage struct

+ AckErr error

+ Acked atomic.Bool

+ DoubleAckErr error

+ DoubleAcked atomic.Bool

+ MsgData []byte

+ MsgTopic mq.Topic

+ NakDelay atomic.Int64

+ NakErr error

+ Naked atomic.Bool

+ func (m *MockMessage) Message() *mq.Message

type MockPublisher

+ ErrAfter int

+ func (m *MockPublisher) DeadLetter(_ context.Context, msg *mq.Message, opts ...mq.PublishOpt) error

+ func (m *MockPublisher) Published() []PublishedMessage

+ type MockPurger struct

+ Calls []PurgeCall

+ Err error

+ Purged bool

+ func (m *MockPurger) PurgeAcked(_ context.Context, consumer string, olderThan map[tenant.ID]time.Time) (bool, error)

type PublishedMessage

+ DeadLetter bool

+ Headers mq.Headers

+ Topic mq.Topic

+ type PurgeCall struct

+ Consumer string

+ OlderThan map[tenant.ID]time.Time

v0.1.0

Aug 19, 2026

Changes in this version

+ const TestJWTSecret

+ func AssertBodyContains(t *testing.T, rec *httptest.ResponseRecorder, expectedStatus int, ...)

+ func AssertBodyEquals(t *testing.T, rec *httptest.ResponseRecorder, expectedStatus int, ...)

+ func AssertJSONContains(t *testing.T, rec *httptest.ResponseRecorder, expectedStatus int, ...)

+ func AssertJSONErrorResponse(t *testing.T, w *httptest.ResponseRecorder)

+ func AssertJSONResponse(t *testing.T, rec *httptest.ResponseRecorder, expectedStatus int, expected any)

+ func MakeExpiredJWT(t *testing.T, claims map[string]any) string

+ func MakeJWT(t *testing.T, claims map[string]any) string

+ func NewJetStream(t *testing.T) jetstream.JetStream

+ func NewTestSchemaRegistry(t testing.TB, tables []*discovery.TableSchema) *discovery.SchemaRegistry

+ func NopLogger() *slog.Logger

+ func RunRoleMatrix(t *testing.T, cases []RoleCase, ...)

+ type CapturedRequest struct

+ Body []byte

+ Header http.Header

+ Method string

+ URL string

+ type FakeOTLP struct

+ func NewFakeOTLP(t *testing.T) *FakeOTLP

+ func NewFakeOTLPTLS(t *testing.T) *FakeOTLP

+ func (r *FakeOTLP) Addr() string

+ func (r *FakeOTLP) CertFile(t *testing.T) string

+ func (r *FakeOTLP) LastLogHeaders() metadata.MD

+ func (r *FakeOTLP) LastMetricHeaders() metadata.MD

+ func (r *FakeOTLP) LastTraceHeaders() metadata.MD

+ func (r *FakeOTLP) LogCount() int

+ func (r *FakeOTLP) LogCountAtLevel(minSeverity int32) int

+ func (r *FakeOTLP) MetricCount() int

+ func (r *FakeOTLP) Reset()

+ func (r *FakeOTLP) SpanCount() int

+ type MockCache struct

+ InvErr error

+ InvNamespaces []cache.Namespace

+ func (m *MockCache) GetNamespaces() []cache.Namespace

+ func (m *MockCache) Invalidate(_ context.Context, namespaces []cache.Namespace) (uint64, error)

+ type MockConsumer struct

+ InfoErr error

+ InfoVal *jetstream.ConsumerInfo

+ func (m *MockConsumer) Info(_ context.Context) (*jetstream.ConsumerInfo, error)

+ type MockDeduplicator struct

+ Err error

+ func NewMockDeduplicator() *MockDeduplicator

+ func (m *MockDeduplicator) CheckAndMark(_ context.Context, eventID string) (bool, error)

+ func (m *MockDeduplicator) Close() error

+ func (m *MockDeduplicator) Stats() map[string]int64

+ type MockJetStream struct

+ ConsumerFn func(ctx context.Context, stream, consumer string) (jetstream.Consumer, error)

+ PubErr error

+ PublishMsgFn func(ctx context.Context, msg *nats.Msg, opts ...jetstream.PublishOpt) (*jetstream.PubAck, error)

+ StreamFn func(ctx context.Context, name string) (jetstream.Stream, error)

+ func (m *MockJetStream) Consumer(ctx context.Context, stream, consumer string) (jetstream.Consumer, error)

+ func (m *MockJetStream) PublishMsg(ctx context.Context, msg *nats.Msg, opts ...jetstream.PublishOpt) (*jetstream.PubAck, error)

+ func (m *MockJetStream) Published() []*nats.Msg

+ func (m *MockJetStream) Stream(ctx context.Context, name string) (jetstream.Stream, error)

+ type MockJetStreamMsg struct

+ AckErr error

+ Acked atomic.Bool

+ DoubleAckErr error

+ DoubleAcked atomic.Bool

+ MsgData []byte

+ MsgHeaders nats.Header

+ MsgSubject string

+ NakErr error

+ Naked atomic.Bool

+ func (m *MockJetStreamMsg) Ack() error

+ func (m *MockJetStreamMsg) Data() []byte

+ func (m *MockJetStreamMsg) DoubleAck(_ context.Context) error

+ func (m *MockJetStreamMsg) Headers() nats.Header

+ func (m *MockJetStreamMsg) InProgress() error

+ func (m *MockJetStreamMsg) Metadata() (*jetstream.MsgMetadata, error)

+ func (m *MockJetStreamMsg) Nak() error

+ func (m *MockJetStreamMsg) NakWithDelay(_ time.Duration) error

+ func (m *MockJetStreamMsg) Reply() string

+ func (m *MockJetStreamMsg) Subject() string

+ func (m *MockJetStreamMsg) Term() error

+ func (m *MockJetStreamMsg) TermWithReason(string) error

+ type MockPublisher struct

+ Err error

+ Messages []PublishedMessage

+ func (m *MockPublisher) Close() error

+ func (m *MockPublisher) LastMessage() *PublishedMessage

+ func (m *MockPublisher) Publish(_ context.Context, subject string, data []byte, opts ...mq.PublishOpt) error

+ type MockRoundTripper struct

+ Fn func(req *http.Request) (*http.Response, error)

+ func (m *MockRoundTripper) Captured() []CapturedRequest

+ func (m *MockRoundTripper) Hits() int32

+ func (m *MockRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

+ type MockStream struct

+ GetMsgFn func(ctx context.Context, seq uint64, opts ...jetstream.GetMsgOpt) (*jetstream.RawStreamMsg, error)

+ InfoErr error

+ InfoVal *jetstream.StreamInfo

+ Msgs map[uint64]*jetstream.RawStreamMsg

+ PurgeErr error

+ Purged []jetstream.StreamPurgeOpt

+ func (m *MockStream) GetMsg(ctx context.Context, seq uint64, opts ...jetstream.GetMsgOpt) (*jetstream.RawStreamMsg, error)

+ func (m *MockStream) Info(_ context.Context, _ ...jetstream.StreamInfoOpt) (*jetstream.StreamInfo, error)

+ func (m *MockStream) Purge(_ context.Context, opts ...jetstream.StreamPurgeOpt) error

+ type MockSubscriber struct

+ Err error

+ Handler func(msg *mq.Message) error

+ func (m *MockSubscriber) Close() error

+ func (m *MockSubscriber) Subscribe(_ context.Context, _, _ string, handler func(msg *mq.Message) error) error

+ type PublishedMessage struct

+ Data []byte

+ Subject string

+ type RoleCase struct

+ AllowedRoles []string

+ Name string

+ Role string

+ SetRole bool

+ WantForbidden bool

+ func StandardRoleMatrix() []RoleCase

+ type UTCRow struct

+ func (UTCRow) Scan(dest ...any) error

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