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) Tag(key string) (value string, exist bool)
  • 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) Tag

func (p *GRPCProxy) Tag(key string) (value string, exist bool)

func (*GRPCProxy) Target

func (p *GRPCProxy) Target() string

func (*GRPCProxy) Weight

func (p *GRPCProxy) Weight() uint32

type Options

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