gomsgpool

Documentation

Index

• func InjectGonatsMsgPool(s *GonatsMsgPool)
• func LoadGonatsMsgPool() baseiface.ISingleton
• type GonatsMsgPool
  • func FindBeanGonatsMsgPool() *GonatsMsgPool
  • func NewGonatsMsgPool() *GonatsMsgPool
  • func (gomp *GonatsMsgPool) BorrowObject(ctx context.Context) (*gomsg.GonatsMsg, error)
  • func (gomp *GonatsMsgPool) Link() (*gomsg.GonatsMsg, error)
  • func (gomp *GonatsMsgPool) ReturnObject(ctx context.Context, msg *gomsg.GonatsMsg) error

Functions

func InjectGonatsMsgPool

func InjectGonatsMsgPool(s *GonatsMsgPool)

func LoadGonatsMsgPool

func LoadGonatsMsgPool() baseiface.ISingleton

Types

type GonatsMsgPool

type GonatsMsgPool struct {
	basedto.BaseEntitySingle
	CommonPool *pool.ObjectPool
}

func FindBeanGonatsMsgPool

func FindBeanGonatsMsgPool() *GonatsMsgPool

FindBeanGonatsMsgPool

func NewGonatsMsgPool

func NewGonatsMsgPool() *GonatsMsgPool

NewGonatsMsgPool 使用传入的上下文初始化连接池

func (*GonatsMsgPool) BorrowObject

func (gomp *GonatsMsgPool) BorrowObject(ctx context.Context) (*gomsg.GonatsMsg, error)

BorrowObject 从连接池借用对象，增加了错误处理和重试逻辑

func (*GonatsMsgPool) Link

func (gomp *GonatsMsgPool) Link() (*gomsg.GonatsMsg, error)

Link 初始化连接

func (*GonatsMsgPool) ReturnObject

func (gomp *GonatsMsgPool) ReturnObject(ctx context.Context, msg *gomsg.GonatsMsg) error

ReturnObject 交还对象到连接池