Documentation ¶
Index ¶
- type RabbitMQ
- type RabbitMQFactory
- func (f *RabbitMQFactory) ActivateObject(ctx context.Context, object *pool.PooledObject) error
- func (f *RabbitMQFactory) DestroyObject(ctx context.Context, object *pool.PooledObject) error
- func (f *RabbitMQFactory) MakeObject(ctx context.Context) (*pool.PooledObject, error)
- func (f *RabbitMQFactory) PassivateObject(ctx context.Context, object *pool.PooledObject) error
- func (f *RabbitMQFactory) ValidateObject(ctx context.Context, object *pool.PooledObject) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMQ ¶
type RabbitMQ struct {
ObjectPool *pool.ObjectPool
}
func NewRabbitMQPools ¶
func NewRabbitMQPools() *RabbitMQ
type RabbitMQFactory ¶
type RabbitMQFactory struct { }
pools factory
func (*RabbitMQFactory) ActivateObject ¶
func (f *RabbitMQFactory) ActivateObject(ctx context.Context, object *pool.PooledObject) error
do activate
func (*RabbitMQFactory) DestroyObject ¶
func (f *RabbitMQFactory) DestroyObject(ctx context.Context, object *pool.PooledObject) error
do destroy
func (*RabbitMQFactory) MakeObject ¶
func (f *RabbitMQFactory) MakeObject(ctx context.Context) (*pool.PooledObject, error)
make rabbitMQ object
func (*RabbitMQFactory) PassivateObject ¶
func (f *RabbitMQFactory) PassivateObject(ctx context.Context, object *pool.PooledObject) error
do passivate
func (*RabbitMQFactory) ValidateObject ¶
func (f *RabbitMQFactory) ValidateObject(ctx context.Context, object *pool.PooledObject) bool
do validate
Click to show internal directories.
Click to hide internal directories.