protocolwrapper

package

v1.5.0 Latest Latest Go to latest Published: Jul 23, 2020 License: Apache-2.0 Imports: 8 Imported by: 2

Details

View Source

const (
	// FILTER is protocol key.
	FILTER = "filter"
)

This section is empty.

func GetProtocol() protocol.Protocol

GetProtocol ...

func NewMockProtocolFilter() protocol.Protocol

NewMockProtocolFilter creates a new mock protocol

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

FilterInvoker ...

func (fi *FilterInvoker) Destroy()

Destroy ...

func (fi *FilterInvoker) GetUrl() common.URL

GetUrl ...

func (fi *FilterInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result

Invoke ...

func (fi *FilterInvoker) IsAvailable() bool

IsAvailable ...

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

ProtocolFilterWrapper protocol in url decide who ProtocolFilterWrapper.protocol is

func (pfw *ProtocolFilterWrapper) Destroy()

Destroy will destroy all invoker and exporter.

func (pfw *ProtocolFilterWrapper) Export(invoker protocol.Invoker) protocol.Exporter

Export service for remote invocation

func (pfw *ProtocolFilterWrapper) Refer(url common.URL) protocol.Invoker

Refer a remote service