proxy

package

v3.1.1 Latest Latest Go to latest Published: Feb 20, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/apache/dubbo-go

Links

Open Source Insights

Documentation ¶

Index ¶

func DefaultProxyImplementFunc(p *Proxy, v common.RPCService)
type ImplementFunc
type Option
type Proxy
- func NewProxy(invoke protocol.Invoker, callback interface{}, attachments map[string]string) *Proxy
- func NewProxyWithOptions(invoke protocol.Invoker, callback interface{}, attachments map[string]string, ...) *Proxy
type ProxyFactory
type ProxyOption
- func WithProxyImplementFunc(f ImplementFunc) ProxyOption

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DefaultProxyImplementFunc ¶

func DefaultProxyImplementFunc(p *Proxy, v common.RPCService)

DefaultProxyImplementFunc the default function for proxy impl

Types ¶

type ImplementFunc ¶

type ImplementFunc func(p *Proxy, v common.RPCService)

ImplementFunc function for proxy impl of RPCService functions

type Option ¶

type Option func(ProxyFactory)

Option will define a function of handling ProxyFactory

type Proxy ¶

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

nolint

func NewProxy ¶

func NewProxy(invoke protocol.Invoker, callback interface{}, attachments map[string]string) *Proxy

NewProxy create service proxy.

func NewProxyWithOptions ¶

func NewProxyWithOptions(invoke protocol.Invoker, callback interface{}, attachments map[string]string, opts ...ProxyOption) *Proxy

NewProxyWithOptions create service proxy with options.

func (*Proxy) Get ¶

func (p *Proxy) Get() common.RPCService

Get gets rpc service instance.

func (*Proxy) GetCallback ¶

func (p *Proxy) GetCallback() interface{}

GetCallback gets callback.

func (*Proxy) GetInvoker ¶

func (p *Proxy) GetInvoker() protocol.Invoker

GetInvoker gets Invoker.

func (*Proxy) Implement ¶

func (p *Proxy) Implement(v common.RPCService)

Implement proxy implement In consumer, RPCService like:

		type XxxProvider struct {
 		Yyy func(ctx context.Context, args []interface{}, rsp *Zzz) error
		}

type ProxyFactory ¶

type ProxyFactory interface {
	GetProxy(invoker protocol.Invoker, url *common.URL) *Proxy
	GetAsyncProxy(invoker protocol.Invoker, callBack interface{}, url *common.URL) *Proxy
	GetInvoker(url *common.URL) protocol.Invoker
}

type ProxyOption ¶

type ProxyOption func(p *Proxy)

ProxyOption a function to init Proxy with options

func WithProxyImplementFunc ¶

func WithProxyImplementFunc(f ImplementFunc) ProxyOption

WithProxyImplementFunc an option function to setup proxy.ImplementFunc

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
proxy_factory

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