Versions in this module Expand all Collapse all v0 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
Go to main page