Documentation ¶
Index ¶
- Variables
- type Channel
- type Channels
- type Configuration
- type Connection
- func (c *Connection) Close() error
- func (c *Connection) Config() *Configuration
- func (c *Connection) DefaultTube() (string, error)
- func (c *Connection) Delete(id uint64) (err error)
- func (c *Connection) Dialer() Dialer
- func (c *Connection) Init() (err error)
- func (c *Connection) Put(body []byte, pri uint32, delay, ttr time.Duration) (id uint64, err error)
- func (c *Connection) Reserve(timeout time.Duration) (id uint64, body []byte, err error)
- type Dialer
- type Handler
Constants ¶
This section is empty.
Variables ¶
View Source
var WireSet = wire.NewSet(NewConnection, NewConfiguration, wire.Bind(new(Handler), new(*Connection)), wire.Bind(new(consumer.ConnectionHandler), new(*Connection)))
Functions ¶
This section is empty.
Types ¶
type Configuration ¶
func NewConfiguration ¶
func NewConfiguration() *Configuration
type Connection ¶
type Connection struct { consumer.ConnectionHandler *Configuration // contains filtered or unexported fields }
func NewConnection ¶
func NewConnection(config *Configuration, dialer Dialer) *Connection
func (*Connection) Close ¶
func (c *Connection) Close() error
func (*Connection) Config ¶
func (c *Connection) Config() *Configuration
func (*Connection) DefaultTube ¶
func (c *Connection) DefaultTube() (string, error)
func (*Connection) Delete ¶
func (c *Connection) Delete(id uint64) (err error)
func (*Connection) Dialer ¶
func (c *Connection) Dialer() Dialer
func (*Connection) Init ¶
func (c *Connection) Init() (err error)
Click to show internal directories.
Click to hide internal directories.