pool

Documentation

Index

• Variables
• type CallOption
  • func WithNoRetry() CallOption
  • func WithRetryResolver(f RetryResolver) CallOption
• type CallerFunc
• type Factory
• type GRPCPool
  • func New(ctx context.Context, factory Factory, capacity int, ...) GRPCPool
  • func NewSingleConnPool(_ context.Context, factory Factory) (GRPCPool, error)
• type Pool
  • func (p *Pool) Call(ctx context.Context, timeout time.Duration, caller CallerFunc, ...) error
  • func (p *Pool) Close()
  • func (p *Pool) IsClosed() bool
• type RetryResolver
• type SingleConnectionPool
  • func (p *SingleConnectionPool) Call(ctx context.Context, timeout time.Duration, caller CallerFunc, ...) error
  • func (p *SingleConnectionPool) Close()

Variables

var ErrPoolClosed = errors.New("pool is closed")

Types

type CallOption

type CallOption func(*callOptions)

func WithNoRetry

func WithNoRetry() CallOption

func WithRetryResolver

func WithRetryResolver(f RetryResolver) CallOption

type CallerFunc

type CallerFunc func(ctx context.Context, conn *grpc.ClientConn) error

type Factory

type Factory func() (*grpc.ClientConn, error)

Factory is a function type creating a grpc client.

type GRPCPool

type GRPCPool interface {
	Close()
	Call(ctx context.Context, timeout time.Duration, caller CallerFunc, opts ...CallOption) error
}

func New

func New(ctx context.Context, factory Factory, capacity int, idleTimeout, maxLifeDuration time.Duration) GRPCPool

func NewSingleConnPool

func NewSingleConnPool(_ context.Context, factory Factory) (GRPCPool, error)

type Pool

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

Pool is the grpc client pool.

func (*Pool) Call

func (p *Pool) Call(ctx context.Context, timeout time.Duration, caller CallerFunc, opts ...CallOption) error

func (*Pool) Close

func (p *Pool) Close()

func (*Pool) IsClosed

func (p *Pool) IsClosed() bool

IsClosed returns true if the client pool is closed.

type RetryResolver

type RetryResolver func(reqErr error) (isRetrievable bool)

type SingleConnectionPool

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

func (*SingleConnectionPool) Call

func (p *SingleConnectionPool) Call(ctx context.Context, timeout time.Duration, caller CallerFunc, opts ...CallOption) error

func (*SingleConnectionPool) Close

func (p *SingleConnectionPool) Close()