Documentation
¶
Overview ¶
* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Dubbo3GrpcService ¶
type Dubbo3GrpcService interface {
// SetProxyImpl sets proxy.
SetProxyImpl(impl protocol.Invoker)
// GetProxyImpl gets proxy.
GetProxyImpl() protocol.Invoker
// ServiceDesc gets an RPC service's specification.
ServiceDesc() *grpc.ServiceDesc
}
Dubbo3GrpcService is gRPC service
type Dubbo3HessianService ¶
type Dubbo3HessianService struct {
// contains filtered or unexported fields
}
func (*Dubbo3HessianService) InvokeWithArgs ¶
func (d *Dubbo3HessianService) InvokeWithArgs(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error)
type DubboExporter ¶
type DubboExporter struct {
protocol.BaseExporter
// contains filtered or unexported fields
}
DubboExporter is dubbo3 service exporter.
func NewDubboExporter ¶
func NewDubboExporter(key string, invoker protocol.Invoker, exporterMap *sync.Map, serviceMap *sync.Map) *DubboExporter
NewDubboExporter get a Dubbo3Exporter.
func (*DubboExporter) Unexport ¶
func (de *DubboExporter) Unexport()
Unexport unexport dubbo3 service exporter.
type DubboInvoker ¶
type DubboInvoker struct {
protocol.BaseInvoker
// contains filtered or unexported fields
}
DubboInvoker is implement of protocol.Invoker, a dubboInvoker refer to one service and ip.
func NewDubboInvoker ¶
func NewDubboInvoker(url *common.URL) (*DubboInvoker, error)
NewDubboInvoker constructor
func (*DubboInvoker) Destroy ¶
func (di *DubboInvoker) Destroy()
Destroy destroy dubbo3 client invoker.
func (*DubboInvoker) Invoke ¶
func (di *DubboInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result
Invoke call remoting.
func (*DubboInvoker) IsAvailable ¶
func (di *DubboInvoker) IsAvailable() bool
IsAvailable check if invoker is available, now it is useless
type DubboProtocol ¶
type DubboProtocol struct {
protocol.BaseProtocol
// contains filtered or unexported fields
}
It support dubbo protocol. It implements Protocol interface for dubbo protocol.
func NewDubboProtocol ¶
func NewDubboProtocol() *DubboProtocol
NewDubboProtocol create a dubbo protocol.
Source Files
Directories