protocol_impl

Documentation

Index

• Constants
• func ParseArgs(argsType []reflect.Type, data []byte) (finalArgument []interface{}, err error)
• type IOCProtocol
  • func GetIOCProtocol(p *Param) (*IOCProtocol, error)
  • func (i *IOCProtocol) Export(invoker dubboProtocol.Invoker) dubboProtocol.Exporter
  • func (i *IOCProtocol) Invoke(invocation dubboProtocol.Invocation) dubboProtocol.Result
• type IOCProtocolIOCInterface
  • func GetIOCProtocolIOCInterface(p *Param) (IOCProtocolIOCInterface, error)
• type Param
  • func (p *Param) Init(iocProtocol *IOCProtocol) (*IOCProtocol, error)

Constants

const DefaultSchema = "http"

const IOCProtocolName = "ioc"

Functions

func ParseArgs

func ParseArgs(argsType []reflect.Type, data []byte) (finalArgument []interface{}, err error)

ParseArgs @data should be []interface{}'s marshal result, @argsType should be each object's reflect type

Types

type IOCProtocol

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

IOCProtocol is ioc protocol impl

func GetIOCProtocol

func GetIOCProtocol(p *Param) (*IOCProtocol, error)

func (*IOCProtocol) Export

func (i *IOCProtocol) Export(invoker dubboProtocol.Invoker) dubboProtocol.Exporter

func (*IOCProtocol) Invoke

func (i *IOCProtocol) Invoke(invocation dubboProtocol.Invocation) dubboProtocol.Result

type IOCProtocolIOCInterface

type IOCProtocolIOCInterface interface {
	Invoke(invocation protocol.Invocation) protocol.Result
	Export(invoker protocol.Invoker) protocol.Exporter
}

func GetIOCProtocolIOCInterface

func GetIOCProtocolIOCInterface(p *Param) (IOCProtocolIOCInterface, error)

type Param

type Param struct {
	Address    string
	Timeout    string
	ExportPort string
}

func (*Param) Init

func (p *Param) Init(iocProtocol *IOCProtocol) (*IOCProtocol, error)