grpc

package
v1.4.0-rc8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 9, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

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

Variables

View Source
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 ...

Directories

Path Synopsis
just for test, never use internal for production.
just for test, never use internal for production.
plugin/dubbo
Package dubbo plugin for protobuf.
Package dubbo plugin for protobuf.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL