Documentation ¶
Index ¶
- type EventBroadcaster
- func (_m *EventBroadcaster) Close() error
- func (_m *EventBroadcaster) HealthReport() map[string]error
- func (_m *EventBroadcaster) Name() string
- func (_m *EventBroadcaster) Notify(channel string, payload string) error
- func (_m *EventBroadcaster) Ready() error
- func (_m *EventBroadcaster) Start(_a0 context.Context) error
- func (_m *EventBroadcaster) Subscribe(channel string, payloadFilter string) (pg.Subscription, error)
- type Queryer
- func (_m *Queryer) BindNamed(_a0 string, _a1 interface{}) (string, []interface{}, error)
- func (_m *Queryer) DriverName() string
- func (_m *Queryer) Exec(query string, args ...interface{}) (sql.Result, error)
- func (_m *Queryer) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
- func (_m *Queryer) Get(dest interface{}, query string, args ...interface{}) error
- func (_m *Queryer) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
- func (_m *Queryer) NamedExec(query string, arg interface{}) (sql.Result, error)
- func (_m *Queryer) NamedQuery(query string, arg interface{}) (*sqlx.Rows, error)
- func (_m *Queryer) Prepare(query string) (*sql.Stmt, error)
- func (_m *Queryer) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
- func (_m *Queryer) PrepareNamed(query string) (*sqlx.NamedStmt, error)
- func (_m *Queryer) Query(query string, args ...interface{}) (*sql.Rows, error)
- func (_m *Queryer) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
- func (_m *Queryer) QueryRow(query string, args ...interface{}) *sql.Row
- func (_m *Queryer) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
- func (_m *Queryer) QueryRowx(query string, args ...interface{}) *sqlx.Row
- func (_m *Queryer) QueryRowxContext(ctx context.Context, query string, args ...interface{}) *sqlx.Row
- func (_m *Queryer) Queryx(query string, args ...interface{}) (*sqlx.Rows, error)
- func (_m *Queryer) QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)
- func (_m *Queryer) Rebind(_a0 string) string
- func (_m *Queryer) Select(dest interface{}, query string, args ...interface{}) error
- func (_m *Queryer) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
- type Subscription
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventBroadcaster ¶
EventBroadcaster is an autogenerated mock type for the EventBroadcaster type
func NewEventBroadcaster ¶ added in v1.5.0
func NewEventBroadcaster(t mockConstructorTestingTNewEventBroadcaster) *EventBroadcaster
NewEventBroadcaster creates a new instance of EventBroadcaster. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*EventBroadcaster) Close ¶
func (_m *EventBroadcaster) Close() error
Close provides a mock function with given fields:
func (*EventBroadcaster) HealthReport ¶ added in v1.13.0
func (_m *EventBroadcaster) HealthReport() map[string]error
HealthReport provides a mock function with given fields:
func (*EventBroadcaster) Name ¶ added in v1.13.0
func (_m *EventBroadcaster) Name() string
Name provides a mock function with given fields:
func (*EventBroadcaster) Notify ¶
func (_m *EventBroadcaster) Notify(channel string, payload string) error
Notify provides a mock function with given fields: channel, payload
func (*EventBroadcaster) Ready ¶
func (_m *EventBroadcaster) Ready() error
Ready provides a mock function with given fields:
func (*EventBroadcaster) Start ¶
func (_m *EventBroadcaster) Start(_a0 context.Context) error
Start provides a mock function with given fields: _a0
func (*EventBroadcaster) Subscribe ¶
func (_m *EventBroadcaster) Subscribe(channel string, payloadFilter string) (pg.Subscription, error)
Subscribe provides a mock function with given fields: channel, payloadFilter
type Queryer ¶
Queryer is an autogenerated mock type for the Queryer type
func NewQueryer ¶ added in v1.5.0
func NewQueryer(t mockConstructorTestingTNewQueryer) *Queryer
NewQueryer creates a new instance of Queryer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Queryer) DriverName ¶
DriverName provides a mock function with given fields:
func (*Queryer) ExecContext ¶
func (_m *Queryer) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
ExecContext provides a mock function with given fields: ctx, query, args
func (*Queryer) GetContext ¶
func (_m *Queryer) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
GetContext provides a mock function with given fields: ctx, dest, query, args
func (*Queryer) NamedQuery ¶
NamedQuery provides a mock function with given fields: query, arg
func (*Queryer) PrepareContext ¶
PrepareContext provides a mock function with given fields: ctx, query
func (*Queryer) PrepareNamed ¶
PrepareNamed provides a mock function with given fields: query
func (*Queryer) QueryContext ¶
func (_m *Queryer) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
QueryContext provides a mock function with given fields: ctx, query, args
func (*Queryer) QueryRowContext ¶
QueryRowContext provides a mock function with given fields: ctx, query, args
func (*Queryer) QueryRowxContext ¶
func (_m *Queryer) QueryRowxContext(ctx context.Context, query string, args ...interface{}) *sqlx.Row
QueryRowxContext provides a mock function with given fields: ctx, query, args
func (*Queryer) QueryxContext ¶
func (_m *Queryer) QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)
QueryxContext provides a mock function with given fields: ctx, query, args
type Subscription ¶
Subscription is an autogenerated mock type for the Subscription type
func NewSubscription ¶ added in v1.5.0
func NewSubscription(t mockConstructorTestingTNewSubscription) *Subscription
NewSubscription creates a new instance of Subscription. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Subscription) ChannelName ¶
func (_m *Subscription) ChannelName() string
ChannelName provides a mock function with given fields:
func (*Subscription) Close ¶
func (_m *Subscription) Close()
Close provides a mock function with given fields:
func (*Subscription) Events ¶
func (_m *Subscription) Events() <-chan pg.Event
Events provides a mock function with given fields:
func (*Subscription) InterestedIn ¶
func (_m *Subscription) InterestedIn(event pg.Event) bool
InterestedIn provides a mock function with given fields: event
func (*Subscription) Send ¶
func (_m *Subscription) Send(event pg.Event)
Send provides a mock function with given fields: event