Documentation
¶
Overview ¶
Package inmem provides an in-process Transport driver. It is intended for unit tests, examples, and single-binary deployments. It is not safe for cross-process communication.
Index ¶
- type Driver
- func (*Driver) Capabilities() transport.Capabilities
- func (d *Driver) Close() error
- func (*Driver) Connect(context.Context) error
- func (d *Driver) OpenInbox(ctx context.Context) (transport.Inbox, error)
- func (d *Driver) Publish(ctx context.Context, msg *transport.RawMessage) error
- func (d *Driver) Request(ctx context.Context, msg *transport.RawMessage) (*transport.RawMessage, error)
- func (d *Driver) Subscribe(_ context.Context, subject, queue string, h transport.Handler) (transport.Subscription, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Driver ¶
type Driver struct {
// contains filtered or unexported fields
}
Driver is an in-memory pub/sub broker.
func (*Driver) Capabilities ¶
func (*Driver) Capabilities() transport.Capabilities
func (*Driver) Request ¶
func (d *Driver) Request(ctx context.Context, msg *transport.RawMessage) (*transport.RawMessage, error)
Source Files
Click to show internal directories.
Click to hide internal directories.