testutil

package
v5.28.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 28, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package testutil contains shared test functionality

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AssertAfter 

func AssertAfter(t *testing.T, t1, t2 time.Time)

func AssertAll 

func AssertAll[T any](t *testing.T, slice []T, predicate func(T) bool)

func AssertAny 

func AssertAny[T any](t *testing.T, slice []T, predicate func(T) bool)

func AssertBoolEqual 

func AssertBoolEqual(t *testing.T, ai, ei bool)

func AssertDeepEquals 

func AssertDeepEquals(t *testing.T, values ...any)

func AssertEmptyString 

func AssertEmptyString(t *testing.T, s string)

func AssertEqualsInAnyOrder 

func AssertEqualsInAnyOrder(t *testing.T, actual []string, expected []string)

func AssertError 

func AssertError(t *testing.T, err error)

func AssertErrorMessageContains 

func AssertErrorMessageContains(t *testing.T, err error, msg string, args ...any)

func AssertFalse 

func AssertFalse(t *testing.T, b bool)

func AssertIntEqual 

func AssertIntEqual(t *testing.T, ai, ei int)

func AssertLen 

func AssertLen(t *testing.T, x any, el int)

func AssertMajorVersionInHandshake 

func AssertMajorVersionInHandshake(t *testing.T, handshake []byte, major byte)

func AssertMapDoesNotHaveKey 

func AssertMapDoesNotHaveKey[K comparable](t *testing.T, m map[K]any, key K)

func AssertMapHasKey 

func AssertMapHasKey[K comparable](t *testing.T, m map[K]any, key K)

func AssertNeo4jError 

func AssertNeo4jError(t *testing.T, err error)

func AssertNextOnlyError 

func AssertNextOnlyError(t *testing.T, rec *db.Record, sum *db.Summary, err error)

func AssertNextOnlyRecord 

func AssertNextOnlyRecord(t *testing.T, rec *db.Record, sum *db.Summary, err error)

func AssertNextOnlySummary 

func AssertNextOnlySummary(t *testing.T, rec *db.Record, sum *db.Summary, err error)

func AssertNil 

func AssertNil(t *testing.T, x any)

func AssertNoError 

func AssertNoError(t *testing.T, err error)

func AssertNotDeepEquals 

func AssertNotDeepEquals(t *testing.T, value1, value2 any)

func AssertNotNil 

func AssertNotNil(t *testing.T, x any)

func AssertPanics 

func AssertPanics(t *testing.T, f func())

func AssertSameType 

func AssertSameType(t *testing.T, x, y any)

func AssertSliceEqual 

func AssertSliceEqual[T comparable](t *testing.T, x, y []T)

func AssertStringContain 

func AssertStringContain(t *testing.T, s, sub string)

func AssertStringEqual 

func AssertStringEqual(t *testing.T, as, es string)

func AssertStringNotContain 

func AssertStringNotContain(t *testing.T, s, sub string)

func AssertStringNotEmpty 

func AssertStringNotEmpty(t *testing.T, s string)

func AssertTrue 

func AssertTrue(t *testing.T, b bool)

func AssertVersionInHandshake 

func AssertVersionInHandshake(t *testing.T, handshake []byte, major, minor byte)

func AssertWriteSucceeds 

func AssertWriteSucceeds(t *testing.T, w io.Writer, b []byte)

Types

type ConnFake 

type ConnFake struct {
	Name                    string
	ConnectionVersion       db.ProtocolVersion
	Alive                   bool
	Birth                   time.Time
	Table                   *idb.RoutingTable
	Err                     error
	Id                      int
	TxBeginErr              error
	TxBeginHandle           idb.TxHandle
	RunErr                  error
	RunStream               idb.StreamHandle
	RunTxErr                error
	RunTxStream             idb.StreamHandle
	Nexts                   []Next
	Bookm                   string
	TxCommitErr             error
	TxCommitHook            func()
	TxRollbackErr           error
	ConsumeSum              *db.Summary
	ConsumeErr              error
	ConsumeHook             func()
	RecordedTxs             []RecordedTx // Appended to by Run/TxBegin
	BufferErr               error
	BufferHook              func()
	DatabaseName            string
	Idle                    time.Time
	ServerVersionValue      string
	ForceResetHook          func()
	ReAuthHook              func(context.Context, *idb.ReAuthToken) error
	SsrEnabled              bool
	PinHomeDatabaseCallback func(context.Context, string)
	Closed                  bool
}

func (*ConnFake) Birthdate 

func (c *ConnFake) Birthdate() time.Time

func (*ConnFake) Bookmark 

func (c *ConnFake) Bookmark() string

func (*ConnFake) Buffer 

func (c *ConnFake) Buffer(context.Context, idb.StreamHandle) error

func (*ConnFake) Close 

func (c *ConnFake) Close(ctx context.Context)

func (*ConnFake) ConnId 

func (c *ConnFake) ConnId() string

func (*ConnFake) Connect 

func (c *ConnFake) Connect(
	context.Context,
	int,
	*idb.ReAuthToken,
	string,
	map[string]string,
	idb.NotificationConfig,
) error

func (*ConnFake) Consume 

func (c *ConnFake) Consume(context.Context, idb.StreamHandle) (*db.Summary, error)

func (*ConnFake) Database 

func (c *ConnFake) Database() string

func (*ConnFake) ForceReset 

func (c *ConnFake) ForceReset(context.Context)

func (*ConnFake) GetCurrentAuth 

func (c *ConnFake) GetCurrentAuth() (auth.TokenManager, iauth.Token)

func (*ConnFake) GetRoutingTable 

func (c *ConnFake) GetRoutingTable(_ context.Context, _ map[string]string, _ []string, database, _ string) (*idb.RoutingTable, error)

func (*ConnFake) HasFailed 

func (c *ConnFake) HasFailed() bool

func (*ConnFake) IdleDate 

func (c *ConnFake) IdleDate() time.Time

func (*ConnFake) IsAlive 

func (c *ConnFake) IsAlive() bool

func (*ConnFake) IsSsrEnabled 

func (c *ConnFake) IsSsrEnabled() bool

func (*ConnFake) Keys 

func (c *ConnFake) Keys(idb.StreamHandle) ([]string, error)

func (*ConnFake) Next 

func (c *ConnFake) Next(context.Context, idb.StreamHandle) (*db.Record, *db.Summary, error)

func (*ConnFake) ReAuth 

func (c *ConnFake) ReAuth(ctx context.Context, token *idb.ReAuthToken) error

func (*ConnFake) Reset 

func (c *ConnFake) Reset(context.Context)

func (*ConnFake) ResetAuth 

func (c *ConnFake) ResetAuth()

func (*ConnFake) Run 

func (c *ConnFake) Run(_ context.Context, _ idb.Command, txConfig idb.TxConfig) (idb.StreamHandle, error)

func (*ConnFake) RunTx 

func (c *ConnFake) RunTx(context.Context, idb.TxHandle, idb.Command) (idb.StreamHandle, error)

func (*ConnFake) SelectDatabase 

func (c *ConnFake) SelectDatabase(database string)

func (*ConnFake) ServerName 

func (c *ConnFake) ServerName() string

func (*ConnFake) ServerVersion 

func (c *ConnFake) ServerVersion() string

func (*ConnFake) SetBoltLogger 

func (c *ConnFake) SetBoltLogger(log.BoltLogger)

func (*ConnFake) SetPinHomeDatabaseCallback 

func (c *ConnFake) SetPinHomeDatabaseCallback(callback func(ctx context.Context, database string))

func (*ConnFake) Telemetry 

func (c *ConnFake) Telemetry(telemetry.API, func())

func (*ConnFake) TxBegin 

func (c *ConnFake) TxBegin(_ context.Context, txConfig idb.TxConfig, syncMessages bool) (idb.TxHandle, error)

func (*ConnFake) TxCommit 

func (c *ConnFake) TxCommit(context.Context, idb.TxHandle) error

func (*ConnFake) TxRollback 

func (c *ConnFake) TxRollback(context.Context, idb.TxHandle) error

func (*ConnFake) Version 

func (c *ConnFake) Version() db.ProtocolVersion

type Next 

type Next struct {
	Record  *db.Record
	Summary *db.Summary
	Err     error
}

type PoolFake 

type PoolFake struct {
	BorrowConn  db.Connection
	BorrowErr   error
	ReturnHook  func()
	CleanUpHook func()
	BorrowHook  func() (db.Connection, error)
}

func (*PoolFake) Borrow 

func (p *PoolFake) Borrow(context.Context, func() []string, bool, log.BoltLogger, time.Duration, *db.ReAuthToken) (db.Connection, error)

func (*PoolFake) CleanUp 

func (p *PoolFake) CleanUp(context.Context)

func (*PoolFake) Now 

func (p *PoolFake) Now() time.Time

func (*PoolFake) Return 

func (p *PoolFake) Return(context.Context, db.Connection)

type RecordedTx 

type RecordedTx struct {
	Origin    string
	Mode      idb.AccessMode
	Bookmarks []string
	Timeout   time.Duration
	Meta      map[string]any
}

type RouterFake 

type RouterFake struct {
	Invalidated            bool
	InvalidatedDb          string
	InvalidateMode         string
	InvalidatedServer      string
	GetOrUpdateReadersRet  []string
	GetOrUpdateReadersHook func(bookmarks func(context.Context) ([]string, error), database string) ([]string, error)
	GetOrUpdateWritersRet  []string
	GetOrUpdateWritersHook func(bookmarks func(context.Context) ([]string, error), database string) ([]string, error)
	Err                    error
	CleanUpHook            func()
	GetNameOfDefaultDbHook func(user string) (string, error)
	GetTableHook           func(database string) *db.RoutingTable
}

func (*RouterFake) CleanUp 

func (r *RouterFake) CleanUp()

func (*RouterFake) GetNameOfDefaultDatabase 

func (r *RouterFake) GetNameOfDefaultDatabase(_ context.Context, _ []string, user string, _ *db.ReAuthToken, _ log.BoltLogger) (string, error)

func (*RouterFake) GetOrUpdateReaders 

func (r *RouterFake) GetOrUpdateReaders(
	_ context.Context,
	bookmarksFn func(context.Context) ([]string, error),
	dbSelection db.DatabaseSelection,
	_ *db.ReAuthToken,
	_ log.BoltLogger,
	_ func(string),
) ([]string, error)

func (*RouterFake) GetOrUpdateWriters 

func (r *RouterFake) GetOrUpdateWriters(
	_ context.Context,
	bookmarksFn func(context.Context) ([]string, error),
	dbSelection db.DatabaseSelection,
	_ *db.ReAuthToken,
	_ log.BoltLogger,
	_ func(string),
) ([]string, error)

func (*RouterFake) Invalidate 

func (r *RouterFake) Invalidate(database string)

func (*RouterFake) InvalidateReader 

func (r *RouterFake) InvalidateReader(database string, server string)

func (*RouterFake) InvalidateServer 

func (r *RouterFake) InvalidateServer(server string)

func (*RouterFake) InvalidateWriter 

func (r *RouterFake) InvalidateWriter(database string, server string)

func (*RouterFake) Readers 

func (r *RouterFake) Readers(string) []string

func (*RouterFake) Writers 

func (r *RouterFake) Writers(string) []string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.