grpcclient

Documentation

Index

• Constants
• func Now() time.Duration
• type Client
  • func New(ctx context.Context, opts ...Option) (*Client, error)
  • func (c *Client) Close()
• type Option
  • func WithAddr(addr string) Option
  • func WithBalancingPolicy(policy string) Option
  • func WithBlock() Option
  • func WithDefault() Option
  • func WithDialOpts(opts ...grpc.DialOption) Option
  • func WithInsecure() Option
  • func WithRateLimiter(limit float64, burst int) Option
• type Resolver
  • func NewResolver(cc resolver.ClientConn, serviceName string, discovery discover.Discovery) *Resolver
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(opt resolver.ResolveNowOptions)
  • func (r *Resolver) Start()

Constants

const (
	BalancerName = "p2c_ewma"
)

Functions

func Now

func Now() time.Duration

Types

type Client

type Client struct {
	*grpc.ClientConn
	Addr     string
	DialOpts []grpc.DialOption
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, opts ...Option) (*Client, error)

func (*Client) Close

func (c *Client) Close()

type Option

type Option func(c *Client)

func WithAddr

func WithAddr(addr string) Option

func WithBalancingPolicy

func WithBalancingPolicy(policy string) Option

func WithBlock

func WithBlock() Option

func WithDefault

func WithDefault() Option

func WithDialOpts

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

func WithInsecure

func WithInsecure() Option

func WithRateLimiter

func WithRateLimiter(limit float64, burst int) Option

type Resolver

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

func NewResolver

func NewResolver(cc resolver.ClientConn, serviceName string, discovery discover.Discovery) *Resolver

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(opt resolver.ResolveNowOptions)

func (*Resolver) Start

func (r *Resolver) Start()