dubbo

package

v1.6.0 Latest Latest Go to latest Published: Jul 1, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/taoCoder/dubbo-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetProtocol() protocol.Protocol
type DubboCodec
type DubboExporter
- func NewDubboExporter(key string, invoker protocol.Invoker, exporterMap *sync.Map) *DubboExporter
- func (de *DubboExporter) Unexport()
type DubboInvoker
- func NewDubboInvoker(url *common.URL, client *remoting.ExchangeClient) *DubboInvoker
type DubboProtocol
- func NewDubboProtocol() *DubboProtocol
type SerialID

Constants ¶

View Source

const (
	// DUBBO is dubbo protocol name
	DUBBO = "dubbo"
)

Variables ¶

This section is empty.

Functions ¶

func GetProtocol ¶

func GetProtocol() protocol.Protocol

GetProtocol get a single dubbo protocol.

Types ¶

type DubboCodec ¶

type DubboCodec struct {
}

DubboCodec. It is implements remoting.Codec

func (*DubboCodec) Decode ¶

func (c *DubboCodec) Decode(data []byte) (*remoting.DecodeResult, int, error)

Decode data, including request and response.

func (*DubboCodec) EncodeRequest ¶

func (c *DubboCodec) EncodeRequest(request *remoting.Request) (*bytes.Buffer, error)

encode request for transport

func (*DubboCodec) EncodeResponse ¶

func (c *DubboCodec) EncodeResponse(response *remoting.Response) (*bytes.Buffer, error)

encode response

type DubboExporter ¶

type DubboExporter struct {
	protocol.BaseExporter
}

DubboExporter is dubbo service exporter.

func NewDubboExporter ¶

func NewDubboExporter(key string, invoker protocol.Invoker, exporterMap *sync.Map) *DubboExporter

NewDubboExporter get a DubboExporter.

func (*DubboExporter) Unexport ¶

func (de *DubboExporter) Unexport()

Unexport unexport dubbo service exporter.

type DubboInvoker ¶

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

DubboInvoker is implement of protocol.Invoker. A dubboInvoker refers to one service and ip.

func NewDubboInvoker ¶

func NewDubboInvoker(url *common.URL, client *remoting.ExchangeClient) *DubboInvoker

NewDubboInvoker constructor

func (*DubboInvoker) Destroy ¶

func (di *DubboInvoker) Destroy()

Destroy destroy dubbo 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

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.

func (*DubboProtocol) Destroy ¶

func (dp *DubboProtocol) Destroy()

Destroy destroy dubbo service.

func (*DubboProtocol) Export ¶

func (dp *DubboProtocol) Export(invoker protocol.Invoker) protocol.Exporter

Export export dubbo service.

func (*DubboProtocol) Refer ¶

func (dp *DubboProtocol) Refer(url *common.URL) protocol.Invoker

Refer create dubbo service reference.

type SerialID ¶

type SerialID byte

SerialID serial ID

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
hessian2 * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements.	* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements.
impl * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements.	* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements.

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