grpcpool

package

v1.9.9 Latest Latest Go to latest Published: Jan 28, 2023 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var (
	// ClosedErr pool has closed
	ClosedErr = stderr.New("grpc pool has closed")
)

This section is empty.

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

Builder builer for create grpc client connection

type ClientConn interface {
	grpc.ClientConnInterface
	// contains filtered or unexported methods
}

ClientConn wrapper for *grpc.ClientConn

type Option func(*option)

Option optional configs

func WithEnablePrometheus() Option

WithEnablePrometheus enable to record prometheus metrics

type Pool interface {
	Close()
	Get() (Stub, error)
	Restore(Stub)
}

Pool grpc pool

func NewPool(builder Builder, options ...Option) (Pool, error)

NewPool create a grpc pool

type Stub interface {
	Conn() ClientConn
	// contains filtered or unexported methods
}

Stub the real handler in pool