grpc

Documentation

Index

• Constants
• Variables
• func GetProtocol() protocol.Protocol
• type Client
  • func NewClient(url common.URL) *Client
• type DubboGrpcService
• type GrpcExporter
  • func NewGrpcExporter(key string, invoker protocol.Invoker, exporterMap *sync.Map) *GrpcExporter
  • func (gg *GrpcExporter) Unexport()
• type GrpcInvoker
  • func NewGrpcInvoker(url common.URL, client *Client) *GrpcInvoker
  • func (gi *GrpcInvoker) Destroy()
  • func (gi *GrpcInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result
  • func (gi *GrpcInvoker) IsAvailable() bool
  • func (gi *GrpcInvoker) IsDestroyed() bool
• type GrpcProtocol
  • func NewGRPCProtocol() *GrpcProtocol
  • func (gp *GrpcProtocol) Destroy()
  • func (gp *GrpcProtocol) Export(invoker protocol.Invoker) protocol.Exporter
  • func (gp *GrpcProtocol) Refer(url common.URL) protocol.Invoker
• type Server
  • func NewServer() *Server
  • func (s *Server) Start(url common.URL)
  • func (s *Server) Stop()

Constants

const (
	// GRPC module name
	GRPC = "grpc"
)

Variables

var ErrNoReply = errors.New("request need @response")

ErrNoReply ...

Functions

func GetProtocol

func GetProtocol() protocol.Protocol

GetProtocol ...

Types

type Client

type Client struct {
	*grpc.ClientConn
	// contains filtered or unexported fields
}

Client ...

func NewClient

func NewClient(url common.URL) *Client

NewClient ...

type DubboGrpcService

type DubboGrpcService interface {
	SetProxyImpl(impl protocol.Invoker)
	GetProxyImpl() protocol.Invoker
	ServiceDesc() *grpc.ServiceDesc
}

DubboGrpcService ...

type GrpcExporter

type GrpcExporter struct {
	*protocol.BaseExporter
}

GrpcExporter ...

func NewGrpcExporter

func NewGrpcExporter(key string, invoker protocol.Invoker, exporterMap *sync.Map) *GrpcExporter

NewGrpcExporter ...

func (*GrpcExporter) Unexport

func (gg *GrpcExporter) Unexport()

Unexport ...

type GrpcInvoker

type GrpcInvoker struct {
	protocol.BaseInvoker
	// contains filtered or unexported fields
}

GrpcInvoker ...

func NewGrpcInvoker

func NewGrpcInvoker(url common.URL, client *Client) *GrpcInvoker

NewGrpcInvoker ...

func (*GrpcInvoker) Destroy

func (gi *GrpcInvoker) Destroy()

Destroy ...

func (*GrpcInvoker) Invoke

func (gi *GrpcInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result

Invoke ...

func (*GrpcInvoker) IsAvailable

func (gi *GrpcInvoker) IsAvailable() bool

IsAvailable ...

func (*GrpcInvoker) IsDestroyed

func (gi *GrpcInvoker) IsDestroyed() bool

IsDestroyed ...

type GrpcProtocol

type GrpcProtocol struct {
	protocol.BaseProtocol
	// contains filtered or unexported fields
}

GrpcProtocol ...

func NewGRPCProtocol

func NewGRPCProtocol() *GrpcProtocol

NewGRPCProtocol ...

func (*GrpcProtocol) Destroy

func (gp *GrpcProtocol) Destroy()

Destroy ...

func (*GrpcProtocol) Export

func (gp *GrpcProtocol) Export(invoker protocol.Invoker) protocol.Exporter

Export ...

func (*GrpcProtocol) Refer

func (gp *GrpcProtocol) Refer(url common.URL) protocol.Invoker

Refer ...

type Server

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

Server ...

func NewServer

func NewServer() *Server

NewServer ...

func (*Server) Start

func (s *Server) Start(url common.URL)

Start ...

func (*Server) Stop

func (s *Server) Stop()

Stop ...