testutil

package
v5.8.1-12 Latest Latest
Warning

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

 Go to latest Published: May 16, 2023 License: Apache-2.0 Imports: 13 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 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 *testing.T, x, y any)

func AssertStringContain 

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

func AssertStringEqual 

func AssertStringEqual(t *testing.T, as, es 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
}

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) 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) 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) 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) TxBegin 

func (c *ConnFake) TxBegin(_ context.Context, txConfig idb.TxConfig) (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(context.Context) ([]string, error), bool, log.BoltLogger, time.Duration, *db.ReAuthToken) (db.Connection, error)

func (*PoolFake) CleanUp 

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

func (*PoolFake) Now 

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

func (*PoolFake) Return 

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

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
	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)
	InvalidatedServer      string
}

func (*RouterFake) CleanUp 

func (r *RouterFake) CleanUp(ctx context.Context) error

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), database string, _ *db.ReAuthToken, _ log.BoltLogger) ([]string, error)

func (*RouterFake) GetOrUpdateWriters 

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

func (*RouterFake) Invalidate 

func (r *RouterFake) Invalidate(ctx context.Context, database string) error

func (*RouterFake) InvalidateReader 

func (r *RouterFake) InvalidateReader(ctx context.Context, database string, server string) error

func (*RouterFake) InvalidateWriter 

func (r *RouterFake) InvalidateWriter(context.Context, string, string) error

func (*RouterFake) Readers 

func (r *RouterFake) Readers(context.Context, string) ([]string, error)

func (*RouterFake) Writers 

func (r *RouterFake) Writers(context.Context, string) ([]string, error)

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.