grpc

Documentation

Index

• type GRPCProxy
  • func New(options Options) (*GRPCProxy, error)
  • func (p *GRPCProxy) AddFailedCount(count uint) error
  • func (p *GRPCProxy) Close() error
  • func (p *GRPCProxy) ID() string
  • func (p *GRPCProxy) IsAvailable() bool
  • func (p *GRPCProxy) ServeHTTP(ctx context.Context, c *app.RequestContext)
  • func (p *GRPCProxy) Target() string
  • func (p *GRPCProxy) Weight() uint32
• type Options

Types

type GRPCProxy

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

func New

func New(options Options) (*GRPCProxy, error)

func (*GRPCProxy) AddFailedCount

func (p *GRPCProxy) AddFailedCount(count uint) error

func (*GRPCProxy) Close

func (p *GRPCProxy) Close() error

func (*GRPCProxy) ID

func (p *GRPCProxy) ID() string

ID return proxy's ID

func (*GRPCProxy) IsAvailable

func (p *GRPCProxy) IsAvailable() bool

func (*GRPCProxy) ServeHTTP

func (p *GRPCProxy) ServeHTTP(ctx context.Context, c *app.RequestContext)

ServeHTTP implements the http.Handler interface

func (*GRPCProxy) Target

func (p *GRPCProxy) Target() string

func (*GRPCProxy) Weight

func (p *GRPCProxy) Weight() uint32

type Options

type Options struct {
	Target      string
	TLSVerify   bool
	Weight      uint
	MaxFails    uint
	Timeout     time.Duration
	FailTimeout time.Duration
	DailOptions []grpc.DialOption
}