Versions in this module Expand all Collapse all v5 v5.28.3 May 28, 2025 v5.28.2 May 28, 2025 v5.28.1 May 28, 2025 Changes in this version + func AssertAfter(t *testing.T, t1, t2 time.Time) + func AssertAll[T any](t *testing.T, slice []T, predicate func(T) bool) + func AssertAny[T any](t *testing.T, slice []T, predicate func(T) bool) + func AssertBoolEqual(t *testing.T, ai, ei bool) + func AssertDeepEquals(t *testing.T, values ...any) + func AssertEmptyString(t *testing.T, s string) + func AssertEqualsInAnyOrder(t *testing.T, actual []string, expected []string) + func AssertError(t *testing.T, err error) + func AssertErrorMessageContains(t *testing.T, err error, msg string, args ...any) + func AssertFalse(t *testing.T, b bool) + func AssertIntEqual(t *testing.T, ai, ei int) + func AssertLen(t *testing.T, x any, el int) + func AssertMajorVersionInHandshake(t *testing.T, handshake []byte, major byte) + func AssertMapDoesNotHaveKey[K comparable](t *testing.T, m map[K]any, key K) + func AssertMapHasKey[K comparable](t *testing.T, m map[K]any, key K) + func AssertNeo4jError(t *testing.T, err error) + func AssertNextOnlyError(t *testing.T, rec *db.Record, sum *db.Summary, err error) + func AssertNextOnlyRecord(t *testing.T, rec *db.Record, sum *db.Summary, err error) + func AssertNextOnlySummary(t *testing.T, rec *db.Record, sum *db.Summary, err error) + func AssertNil(t *testing.T, x any) + func AssertNoError(t *testing.T, err error) + func AssertNotDeepEquals(t *testing.T, value1, value2 any) + func AssertNotNil(t *testing.T, x any) + func AssertPanics(t *testing.T, f func()) + func AssertSameType(t *testing.T, x, y any) + func AssertSliceEqual[T comparable](t *testing.T, x, y []T) + func AssertStringContain(t *testing.T, s, sub string) + func AssertStringEqual(t *testing.T, as, es string) + func AssertStringNotContain(t *testing.T, s, sub string) + func AssertStringNotEmpty(t *testing.T, s string) + func AssertTrue(t *testing.T, b bool) + func AssertVersionInHandshake(t *testing.T, handshake []byte, major, minor byte) + func AssertWriteSucceeds(t *testing.T, w io.Writer, b []byte) + type ConnFake struct + Alive bool + Birth time.Time + Bookm string + BufferErr error + BufferHook func() + Closed bool + ConnectionVersion db.ProtocolVersion + ConsumeErr error + ConsumeHook func() + ConsumeSum *db.Summary + DatabaseName string + Err error + ForceResetHook func() + Id int + Idle time.Time + Name string + Nexts []Next + PinHomeDatabaseCallback func(context.Context, string) + ReAuthHook func(context.Context, *idb.ReAuthToken) error + RecordedTxs []RecordedTx + RunErr error + RunStream idb.StreamHandle + RunTxErr error + RunTxStream idb.StreamHandle + ServerVersionValue string + SsrEnabled bool + Table *idb.RoutingTable + TxBeginErr error + TxBeginHandle idb.TxHandle + TxCommitErr error + TxCommitHook func() + TxRollbackErr error + func (c *ConnFake) Birthdate() time.Time + func (c *ConnFake) Bookmark() string + func (c *ConnFake) Buffer(context.Context, idb.StreamHandle) error + func (c *ConnFake) Close(ctx context.Context) + func (c *ConnFake) ConnId() string + func (c *ConnFake) Connect(context.Context, int, *idb.ReAuthToken, string, map[string]string, ...) error + func (c *ConnFake) Consume(context.Context, idb.StreamHandle) (*db.Summary, error) + func (c *ConnFake) Database() string + func (c *ConnFake) ForceReset(context.Context) + func (c *ConnFake) GetCurrentAuth() (auth.TokenManager, iauth.Token) + func (c *ConnFake) GetRoutingTable(_ context.Context, _ map[string]string, _ []string, database, _ string) (*idb.RoutingTable, error) + func (c *ConnFake) HasFailed() bool + func (c *ConnFake) IdleDate() time.Time + func (c *ConnFake) IsAlive() bool + func (c *ConnFake) IsSsrEnabled() bool + func (c *ConnFake) Keys(idb.StreamHandle) ([]string, error) + func (c *ConnFake) Next(context.Context, idb.StreamHandle) (*db.Record, *db.Summary, error) + func (c *ConnFake) ReAuth(ctx context.Context, token *idb.ReAuthToken) error + func (c *ConnFake) Reset(context.Context) + func (c *ConnFake) ResetAuth() + func (c *ConnFake) Run(_ context.Context, _ idb.Command, txConfig idb.TxConfig) (idb.StreamHandle, error) + func (c *ConnFake) RunTx(context.Context, idb.TxHandle, idb.Command) (idb.StreamHandle, error) + func (c *ConnFake) SelectDatabase(database string) + func (c *ConnFake) ServerName() string + func (c *ConnFake) ServerVersion() string + func (c *ConnFake) SetBoltLogger(log.BoltLogger) + func (c *ConnFake) SetPinHomeDatabaseCallback(callback func(ctx context.Context, database string)) + func (c *ConnFake) Telemetry(telemetry.API, func()) + func (c *ConnFake) TxBegin(_ context.Context, txConfig idb.TxConfig, syncMessages bool) (idb.TxHandle, error) + func (c *ConnFake) TxCommit(context.Context, idb.TxHandle) error + func (c *ConnFake) TxRollback(context.Context, idb.TxHandle) error + func (c *ConnFake) Version() db.ProtocolVersion + type Next struct + Err error + Record *db.Record + Summary *db.Summary + type PoolFake struct + BorrowConn db.Connection + BorrowErr error + BorrowHook func() (db.Connection, error) + CleanUpHook func() + ReturnHook func() + func (p *PoolFake) Borrow(context.Context, func() []string, bool, log.BoltLogger, time.Duration, ...) (db.Connection, error) + func (p *PoolFake) CleanUp(context.Context) + func (p *PoolFake) Now() time.Time + func (p *PoolFake) Return(context.Context, db.Connection) + type RecordedTx struct + Bookmarks []string + Meta map[string]any + Mode idb.AccessMode + Origin string + Timeout time.Duration + type RouterFake struct + CleanUpHook func() + Err error + GetNameOfDefaultDbHook func(user string) (string, error) + GetOrUpdateReadersHook func(bookmarks func(context.Context) ([]string, error), database string) ([]string, error) + GetOrUpdateReadersRet []string + GetOrUpdateWritersHook func(bookmarks func(context.Context) ([]string, error), database string) ([]string, error) + GetOrUpdateWritersRet []string + GetTableHook func(database string) *db.RoutingTable + InvalidateMode string + Invalidated bool + InvalidatedDb string + InvalidatedServer string + func (r *RouterFake) CleanUp() + func (r *RouterFake) GetNameOfDefaultDatabase(_ context.Context, _ []string, user string, _ *db.ReAuthToken, ...) (string, error) + func (r *RouterFake) GetOrUpdateReaders(_ context.Context, bookmarksFn func(context.Context) ([]string, error), ...) ([]string, error) + func (r *RouterFake) GetOrUpdateWriters(_ context.Context, bookmarksFn func(context.Context) ([]string, error), ...) ([]string, error) + func (r *RouterFake) Invalidate(database string) + func (r *RouterFake) InvalidateReader(database string, server string) + func (r *RouterFake) InvalidateServer(server string) + func (r *RouterFake) InvalidateWriter(database string, server string) + func (r *RouterFake) Readers(string) []string + func (r *RouterFake) Writers(string) []string
Go to main page