test

Documentation

Index

• Constants
• type MockDB
  • func NewMockDB(_ *testing.T, logr testhelp.TestLogFuncWrap, dsn v1.PostgreSQLDSN) *MockDB
  • func (m *MockDB) CallCount(name string) (int, bool)
  • func (m *MockDB) CallCountMap() map[string]int
  • func (m *MockDB) CallCountReset()
  • func (m *MockDB) Close(ctx context.Context) error
  • func (m *MockDB) Config() *pgx.ConnConfig
  • func (m *MockDB) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)
  • func (m *MockDB) IsClosed() bool
  • func (m *MockDB) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
  • func (m *MockDB) SetLogger(logr testhelp.TestLogFuncWrap)
• type MockRows
  • func NewMockRows(_ *MockDB, logr testhelp.TestLogFuncWrap, o []string) *MockRows
  • func (r *MockRows) CallCount(name string) (int, bool)
  • func (r *MockRows) CallCountMap() map[string]int
  • func (r *MockRows) CallCountReset()
  • func (r *MockRows) Close()
  • func (r *MockRows) CommandTag() pgconn.CommandTag
  • func (r *MockRows) Conn() *pgx.Conn
  • func (r *MockRows) Err() error
  • func (r *MockRows) FieldDescriptions() []pgconn.FieldDescription
  • func (r *MockRows) Next() bool
  • func (r *MockRows) RawValues() [][]byte
  • func (r *MockRows) Scan(dest ...any) error
  • func (r *MockRows) Values() ([]any, error)
• type MockServer
  • func NewMockServer(dsn string) *MockServer
  • func (m *MockServer) CallCount(name string) (int, bool)
  • func (m *MockServer) CallCountMap() map[string]int
  • func (m *MockServer) CallCountReset()
  • func (m *MockServer) CheckInvalidName(name string) (string, error)
  • func (m *MockServer) Close(ctx context.Context) error
  • func (m *MockServer) Connect(ctx context.Context) error
  • func (m *MockServer) CopyInitConfigToSecret(dbAccount *dbov1.DatabaseAccount, secret *corev1.Secret)
  • func (m *MockServer) CreateDatabase(ctx context.Context, dbName, roleName string) (string, error)
  • func (m *MockServer) CreateRole(ctx context.Context, roleName string) (string, string, error)
  • func (m *MockServer) CreateSchema(ctx context.Context, schemaName, roleName string) error
  • func (m *MockServer) Delete(ctx context.Context, name string) error
  • func (m *MockServer) GetDatabaseHost(dbAccount *dbov1.DatabaseAccount) string
  • func (m *MockServer) GetDatabaseHostConfig() string
  • func (m *MockServer) IsDatabase(ctx context.Context, dbName string) (string, bool, error)
  • func (m *MockServer) IsRole(ctx context.Context, roleName string) (bool, error)
  • func (m *MockServer) ListUsers(ctx context.Context) []string
  • func (m *MockServer) UpdateRolePassword(ctx context.Context, roleName string) (string, string, error)

Constants

const (
	Hostname = "testhost"
	Port     = 1337
)

const (
	TestDSN = "postgres://adminuser:adminpass@databasehost:5432/k8s_01h97g9exfs6bw874x0k567jr7"
)

Types

type MockDB

type MockDB struct {
	OnConfig   func() *pgx.ConnConfig
	OnClose    func(context.Context) error
	OnExec     func(context.Context, string, ...any) (pgconn.CommandTag, error)
	OnQuery    func(context.Context, string, ...any) (pgx.Rows, error)
	OnIsClosed func() bool
	// contains filtered or unexported fields
}

func NewMockDB

func NewMockDB(_ *testing.T, logr testhelp.TestLogFuncWrap, dsn v1.PostgreSQLDSN) *MockDB

func (*MockDB) CallCount

func (m *MockDB) CallCount(name string) (int, bool)

func (*MockDB) CallCountMap

func (m *MockDB) CallCountMap() map[string]int

func (*MockDB) CallCountReset

func (m *MockDB) CallCountReset()

func (*MockDB) Close

func (m *MockDB) Close(ctx context.Context) error

func (*MockDB) Config

func (m *MockDB) Config() *pgx.ConnConfig

func (*MockDB) Exec

func (m *MockDB) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)

func (*MockDB) IsClosed

func (m *MockDB) IsClosed() bool

func (*MockDB) Query

func (m *MockDB) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

func (*MockDB) SetLogger

func (m *MockDB) SetLogger(logr testhelp.TestLogFuncWrap)

type MockRows

type MockRows struct {
	OnErr              func() error
	OnCommandTag       func() pgconn.CommandTag
	OnFieldDescription func() []pgconn.FieldDescription
	OnNext             func() bool
	OnScan             func(dest ...any) error
	OnValues           func() ([]any, error)
	OnRawValues        func() [][]byte
	OnConn             func() *pgx.Conn
	OnClose            func()
	// contains filtered or unexported fields
}

func NewMockRows

func NewMockRows(_ *MockDB, logr testhelp.TestLogFuncWrap, o []string) *MockRows

func (*MockRows) CallCount

func (r *MockRows) CallCount(name string) (int, bool)

func (*MockRows) CallCountMap

func (r *MockRows) CallCountMap() map[string]int

func (*MockRows) CallCountReset

func (r *MockRows) CallCountReset()

func (*MockRows) Close

func (r *MockRows) Close()

func (*MockRows) CommandTag

func (r *MockRows) CommandTag() pgconn.CommandTag

func (*MockRows) Conn

func (r *MockRows) Conn() *pgx.Conn

func (*MockRows) Err

func (r *MockRows) Err() error

func (*MockRows) FieldDescriptions

func (r *MockRows) FieldDescriptions() []pgconn.FieldDescription

func (*MockRows) Next

func (r *MockRows) Next() bool

func (*MockRows) RawValues

func (r *MockRows) RawValues() [][]byte

func (*MockRows) Scan

func (r *MockRows) Scan(dest ...any) error

func (*MockRows) Values

func (r *MockRows) Values() ([]any, error)

type MockServer

type MockServer struct {
	OnCheckInvalidName       func(name string) (string, error)
	OnConnect                func(ctx context.Context) error
	OnClose                  func(ctx context.Context) error
	OnListUsers              func(ctx context.Context) []string
	OnIsRole                 func(ctx context.Context, roleName string) (bool, error)
	OnIsDatabase             func(ctx context.Context, dbName string) (string, bool, error)
	OnCreateRole             func(ctx context.Context, roleName string) (string, string, error)
	OnUpdateRolePassword     func(ctx context.Context, roleName string) (string, string, error)
	OnCreateDatabase         func(ctx context.Context, dbName, roleName string) (string, error)
	OnCreateSchema           func(ctx context.Context, schemaName, roleName string) error
	OnGetDatabaseHostConfig  func() string
	OnGetDatabaseHost        func(dbAccount *dbov1.DatabaseAccount) string
	OnCopyInitConfigToSecret func(dbAccount *dbov1.DatabaseAccount, secret *corev1.Secret)
	OnDelete                 func(ctx context.Context, name string) error
	// contains filtered or unexported fields
}

func NewMockServer

func NewMockServer(dsn string) *MockServer

func (*MockServer) CallCount

func (m *MockServer) CallCount(name string) (int, bool)

func (*MockServer) CallCountMap

func (m *MockServer) CallCountMap() map[string]int

func (*MockServer) CallCountReset

func (m *MockServer) CallCountReset()

func (*MockServer) CheckInvalidName

func (m *MockServer) CheckInvalidName(name string) (string, error)

func (*MockServer) Close

func (m *MockServer) Close(ctx context.Context) error

func (*MockServer) Connect

func (m *MockServer) Connect(ctx context.Context) error

func (*MockServer) CopyInitConfigToSecret

func (m *MockServer) CopyInitConfigToSecret(dbAccount *dbov1.DatabaseAccount, secret *corev1.Secret)

func (*MockServer) CreateDatabase

func (m *MockServer) CreateDatabase(ctx context.Context, dbName, roleName string) (string, error)

func (*MockServer) CreateRole

func (m *MockServer) CreateRole(ctx context.Context, roleName string) (string, string, error)

func (*MockServer) CreateSchema

func (m *MockServer) CreateSchema(ctx context.Context, schemaName, roleName string) error

func (*MockServer) Delete

func (m *MockServer) Delete(ctx context.Context, name string) error

func (*MockServer) GetDatabaseHost

func (m *MockServer) GetDatabaseHost(dbAccount *dbov1.DatabaseAccount) string

func (*MockServer) GetDatabaseHostConfig

func (m *MockServer) GetDatabaseHostConfig() string

func (*MockServer) IsDatabase

func (m *MockServer) IsDatabase(ctx context.Context, dbName string) (string, bool, error)

func (*MockServer) IsRole

func (m *MockServer) IsRole(ctx context.Context, roleName string) (bool, error)

func (*MockServer) ListUsers

func (m *MockServer) ListUsers(ctx context.Context) []string

func (*MockServer) UpdateRolePassword

func (m *MockServer) UpdateRolePassword(ctx context.Context, roleName string) (string, string, error)