svrpool

Documentation

Index

• func AcquireService(key string, interval time.Duration, retryTimes int) (pool.ResourceID, string, error)
• func RegistryServicePool(group, key string)
• func ReleaseService(key string, value pool.ResourceID)
• type PoolManager
  • func (pm *PoolManager) AcquireService(key string, interval time.Duration, retryTimes int) (pool.ResourceID, string, error)
  • func (pm *PoolManager) RegistryServicePool(group, key string)
  • func (pm *PoolManager) ReleaseService(key string, id pool.ResourceID)
• type ServicePool
  • func NewServicePool(ctx context.Context, group, key string) *ServicePool

Functions

func AcquireService

func AcquireService(key string, interval time.Duration, retryTimes int) (pool.ResourceID, string, error)

AcquireService 获取服务

func RegistryServicePool

func RegistryServicePool(group, key string)

RegistryServicePool 注册服务

func ReleaseService

func ReleaseService(key string, value pool.ResourceID)

ReleaseService 释放服务

Types

type PoolManager

type PoolManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

PoolManager 服务池管理器

func (*PoolManager) AcquireService

func (pm *PoolManager) AcquireService(key string, interval time.Duration, retryTimes int) (pool.ResourceID, string, error)

AcquireService 获取服务

func (*PoolManager) RegistryServicePool

func (pm *PoolManager) RegistryServicePool(group, key string)

RegistryServicePool 注册服务

func (*PoolManager) ReleaseService

func (pm *PoolManager) ReleaseService(key string, id pool.ResourceID)

ReleaseService 释放服务

type ServicePool

type ServicePool struct {
	// contains filtered or unexported fields
}

ServicePool 服务池

func NewServicePool

func NewServicePool(ctx context.Context, group, key string) *ServicePool

NewServicePool 创建服务池