testdriver

package

v3.21.1 Latest Latest Go to latest Published: Feb 4, 2026 License: Apache-2.0 Imports: 2 Imported by: 0

Details

View Source

const (
	Name    = "testdriver"
	ErrName = "testdriver-error"
)

View Source

var FakeConn = &Connection{
	openConnections: make(map[string]FakeConnection),
}

View Source

var FakeErrConn = &ErrConnection{
	openErrConnections: make(map[string]FakeErrConnection),
}

This section is empty.

type Connection struct {
	// contains filtered or unexported fields
}

Connection represents driver to use testdriver.

func (r *Connection) CloseConnection(connectionName string) error

func (r *Connection) CreateConnection(_ context.Context, connectionName string, config interface{}) error

func (r *Connection) Publish(_ context.Context, _ string, _ interface{}, _ string) error

func (r *Connection) UpdateConnection(_ context.Context, connectionName string, config interface{}) error

type ErrConnection struct {
	// contains filtered or unexported fields
}

ErrConnection represents driver to use testdriver.

func (r *ErrConnection) CloseConnection(connectionName string) error

func (r *ErrConnection) CreateConnection(_ context.Context, connectionName string, config interface{}) error

func (r *ErrConnection) Publish(_ context.Context, _ string, _ interface{}, _ string) error

func (r *ErrConnection) UpdateConnection(_ context.Context, connectionName string, config interface{}) error

type FakeConnection struct {
	// contains filtered or unexported fields
}

type FakeErrConnection struct {
	// contains filtered or unexported fields
}