protocol

Documentation

Index

• type BaseExporter
  • func NewBaseExporter(key string, invoker Invoker, exporterMap *sync.Map) *BaseExporter
  • func (de *BaseExporter) GetInvoker() Invoker
  • func (de *BaseExporter) Unexport()
• type BaseInvoker
  • func NewBaseInvoker(url common.URL) *BaseInvoker
  • func (bi *BaseInvoker) Destroy()
  • func (bi *BaseInvoker) GetUrl() common.URL
  • func (bi *BaseInvoker) Invoke(invocation Invocation) Result
  • func (bi *BaseInvoker) IsAvailable() bool
  • func (bi *BaseInvoker) IsDestroyed() bool
• type BaseProtocol
  • func NewBaseProtocol() BaseProtocol
  • func (bp *BaseProtocol) Destroy()
  • func (bp *BaseProtocol) Export(invoker Invoker) Exporter
  • func (bp *BaseProtocol) ExporterMap() *sync.Map
  • func (bp *BaseProtocol) Invokers() []Invoker
  • func (bp *BaseProtocol) Refer(url common.URL) Invoker
  • func (bp *BaseProtocol) SetExporterMap(key string, exporter Exporter)
  • func (bp *BaseProtocol) SetInvokers(invoker Invoker)
• type Exporter
• type Invocation
• type Invoker
• type Protocol
• type RPCResult
  • func (r *RPCResult) Error() error
  • func (r *RPCResult) Result() interface{}
• type Result

Types

type BaseExporter

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

func NewBaseExporter

func NewBaseExporter(key string, invoker Invoker, exporterMap *sync.Map) *BaseExporter

func (*BaseExporter) GetInvoker

func (de *BaseExporter) GetInvoker() Invoker

func (*BaseExporter) Unexport

func (de *BaseExporter) Unexport()

type BaseInvoker

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

func NewBaseInvoker

func NewBaseInvoker(url common.URL) *BaseInvoker

func (*BaseInvoker) Destroy

func (bi *BaseInvoker) Destroy()

func (*BaseInvoker) GetUrl

func (bi *BaseInvoker) GetUrl() common.URL

func (*BaseInvoker) Invoke

func (bi *BaseInvoker) Invoke(invocation Invocation) Result

func (*BaseInvoker) IsAvailable

func (bi *BaseInvoker) IsAvailable() bool

func (*BaseInvoker) IsDestroyed

func (bi *BaseInvoker) IsDestroyed() bool

type BaseProtocol

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

func NewBaseProtocol

func NewBaseProtocol() BaseProtocol

func (*BaseProtocol) Destroy

func (bp *BaseProtocol) Destroy()

Destroy will destroy all invoker and exporter, so it only is called once.

func (*BaseProtocol) Export

func (bp *BaseProtocol) Export(invoker Invoker) Exporter

func (*BaseProtocol) ExporterMap

func (bp *BaseProtocol) ExporterMap() *sync.Map

func (*BaseProtocol) Invokers

func (bp *BaseProtocol) Invokers() []Invoker

func (*BaseProtocol) Refer

func (bp *BaseProtocol) Refer(url common.URL) Invoker

func (*BaseProtocol) SetExporterMap

func (bp *BaseProtocol) SetExporterMap(key string, exporter Exporter)

func (*BaseProtocol) SetInvokers

func (bp *BaseProtocol) SetInvokers(invoker Invoker)

type Exporter

type Exporter interface {
	GetInvoker() Invoker
	Unexport()
}

wrapping invoker

type Invocation

type Invocation interface {
	MethodName() string
	ParameterTypes() []reflect.Type
	Arguments() []interface{}
	Reply() interface{}
	Attachments() map[string]string
	AttachmentsByKey(string, string) string
	Invoker() Invoker
}

type Invoker

type Invoker interface {
	common.Node
	Invoke(Invocation) Result
}

Extension - Invoker

type Protocol

type Protocol interface {
	Export(invoker Invoker) Exporter
	Refer(url common.URL) Invoker
	Destroy()
}

Extension - protocol

type RPCResult

type RPCResult struct {
	Err  error
	Rest interface{}
}

func (*RPCResult) Error

func (r *RPCResult) Error() error

func (*RPCResult) Result

func (r *RPCResult) Result() interface{}

type Result

type Result interface {
	Error() error
	Result() interface{}
}