connpool

Documentation

Index

• func NewConnPoolFactory(options func(ring.InstanceDesc) []grpc.DialOption) ring_client.PoolFactory
• type ConnFactory
  • func (f *ConnFactory) FromInstance(inst ring.InstanceDesc) (ring_client.PoolClient, error)
• type ConnPool
• type RingConnPool
  • func (p *RingConnPool) GetConnFor(addr string) (grpc.ClientConnInterface, error)

Functions

func NewConnPoolFactory

func NewConnPoolFactory(options func(ring.InstanceDesc) []grpc.DialOption) ring_client.PoolFactory

Types

type ConnFactory

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

func (*ConnFactory) FromInstance

func (f *ConnFactory) FromInstance(inst ring.InstanceDesc) (ring_client.PoolClient, error)

type ConnPool

type ConnPool interface {
	GetConnFor(addr string) (grpc.ClientConnInterface, error)
	services.Service
}

type RingConnPool

type RingConnPool struct{ *ring_client.Pool }

func (*RingConnPool) GetConnFor

func (p *RingConnPool) GetConnFor(addr string) (grpc.ClientConnInterface, error)