client

Documentation

Index

• Variables
• type Client
  • func New(opts ...Option) (Client, error)
• type Option
  • func WithDialOptions(opts ...grpc.DialOption) Option
  • func WithName(name string) Option
  • func WithRegistry(registry registry.Registry) Option
  • func WithSecure(s bool) Option
  • func WithTLSConfig(conf *tls.Config) Option
  • func WithVersion(version string) Option
• type Options

Variables

var (
	// DefaultPoolSize sets the connection pool size
	DefaultPoolSize = 100
	// DefaultPoolTTL sets the connection pool ttl
	DefaultPoolTTL = time.Minute
	// DefaultPoolMaxStreams maximum streams on a connectioin
	// (20)
	DefaultPoolMaxStreams = 20

	// DefaultPoolMaxIdle maximum idle conns of a pool
	// (50)
	DefaultPoolMaxIdle = 50

	// DefaultMaxRecvMsgSize maximum message that client can receive
	// (4 MB).
	DefaultMaxRecvMsgSize = 1024 * 1024 * 4

	// DefaultMaxSendMsgSize maximum message that client can send
	// (4 MB).
	DefaultMaxSendMsgSize = 1024 * 1024 * 4
)

Types

type Client

type Client interface {
	grpc.ClientConnInterface
}

func New

func New(opts ...Option) (Client, error)

type Option

type Option func(*options)

func WithDialOptions

func WithDialOptions(opts ...grpc.DialOption) Option

func WithName

func WithName(name string) Option

func WithRegistry

func WithRegistry(registry registry.Registry) Option

func WithSecure

func WithSecure(s bool) Option

func WithTLSConfig

func WithTLSConfig(conf *tls.Config) Option

func WithVersion

func WithVersion(version string) Option

type Options

type Options interface {
	Name() string
	Version() string
	Registry() registry.Registry
	TLSConfig() *tls.Config
	DialOptions() []grpc.DialOption
}