dubbo2_context

Documentation

Index

• func NewContext(req *invocation.RPCInvocation, port int) dubbo2_context.IDubbo2Context
• func NewDubboParamBody(typesList []string, valuesList []hessian.Object) *dubbo2_context.Dubbo2ParamBody
• type DubboContext
  • func (d *DubboContext) AcceptTime() time.Time
  • func (d *DubboContext) Assert(i interface{}) error
  • func (d *DubboContext) Clone() (eocontext.EoContext, error)
  • func (d *DubboContext) Context() context.Context
  • func (d *DubboContext) GetBalance() eocontext.BalanceHandler
  • func (d *DubboContext) GetComplete() eocontext.CompleteHandler
  • func (d *DubboContext) GetFinish() eocontext.FinishHandler
  • func (d *DubboContext) GetLabel(name string) string
  • func (d *DubboContext) GetUpstreamHostHandler() eocontext.UpstreamHostHandler
  • func (d *DubboContext) HeaderReader() dubbo2_context.IRequestReader
  • func (d *DubboContext) Invoke(node eoscContext.INode, timeout time.Duration) error
  • func (d *DubboContext) IsCloneable() bool
  • func (d *DubboContext) Labels() map[string]string
  • func (d *DubboContext) LocalAddr() net.Addr
  • func (d *DubboContext) LocalIP() net.IP
  • func (d *DubboContext) LocalPort() int
  • func (d *DubboContext) Proxy() dubbo2_context.IProxy
  • func (d *DubboContext) RealIP() string
  • func (d *DubboContext) RequestId() string
  • func (d *DubboContext) Response() dubbo2_context.IResponse
  • func (d *DubboContext) Scheme() string
  • func (d *DubboContext) SetBalance(handler eocontext.BalanceHandler)
  • func (d *DubboContext) SetCompleteHandler(handler eocontext.CompleteHandler)
  • func (d *DubboContext) SetFinish(handler eocontext.FinishHandler)
  • func (d *DubboContext) SetLabel(name, value string)
  • func (d *DubboContext) SetUpstreamHostHandler(handler eocontext.UpstreamHostHandler)
  • func (d *DubboContext) Value(key interface{}) interface{}
  • func (d *DubboContext) WithValue(key, val interface{})
• type Proxy
  • func NewProxy(serviceWriter dubbo2_context.IServiceWriter, ...) *Proxy
  • func (p *Proxy) Attachments() map[string]interface{}
  • func (p *Proxy) GetParam() *dubbo2_context.Dubbo2ParamBody
  • func (p *Proxy) Service() dubbo2_context.IServiceWriter
  • func (p *Proxy) SetAttachment(k string, v interface{})
  • func (p *Proxy) SetParam(param *dubbo2_context.Dubbo2ParamBody)
• type RequestReader
  • func NewRequestReader(serviceReader dubbo2_context.IServiceReader, host string, remoteIp string, ...) *RequestReader
  • func (r *RequestReader) Attachment(s string) (interface{}, bool)
  • func (r *RequestReader) Attachments() map[string]interface{}
  • func (r *RequestReader) Body() interface{}
  • func (r *RequestReader) Host() string
  • func (r *RequestReader) RemoteIP() string
  • func (r *RequestReader) Service() dubbo2_context.IServiceReader
• type RequestServiceReader
  • func NewRequestServiceReader(path string, serviceName string, group string, version string, method string) *RequestServiceReader
  • func (r *RequestServiceReader) Group() string
  • func (r *RequestServiceReader) Interface() string
  • func (r *RequestServiceReader) Method() string
  • func (r *RequestServiceReader) Path() string
  • func (r *RequestServiceReader) Version() string
• type RequestServiceWrite
  • func NewRequestServiceWrite(path string, serviceName string, group string, version string, method string) *RequestServiceWrite
  • func (r *RequestServiceWrite) Group() string
  • func (r *RequestServiceWrite) Interface() string
  • func (r *RequestServiceWrite) Method() string
  • func (r *RequestServiceWrite) Path() string
  • func (r *RequestServiceWrite) SetGroup(group string)
  • func (r *RequestServiceWrite) SetInterface(s string)
  • func (r *RequestServiceWrite) SetMethod(s string)
  • func (r *RequestServiceWrite) SetPath(path string)
  • func (r *RequestServiceWrite) SetVersion(s string)
  • func (r *RequestServiceWrite) Version() string
• type Response
  • func (r *Response) GetBody() interface{}
  • func (r *Response) ResponseError() error
  • func (r *Response) ResponseTime() time.Duration
  • func (r *Response) SetBody(body interface{})
  • func (r *Response) SetResponseTime(duration time.Duration)

Functions

func NewContext

func NewContext(req *invocation.RPCInvocation, port int) dubbo2_context.IDubbo2Context

func NewDubboParamBody

func NewDubboParamBody(typesList []string, valuesList []hessian.Object) *dubbo2_context.Dubbo2ParamBody

Types

type DubboContext

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

func (*DubboContext) AcceptTime

func (d *DubboContext) AcceptTime() time.Time

func (*DubboContext) Assert

func (d *DubboContext) Assert(i interface{}) error

func (*DubboContext) Clone

func (d *DubboContext) Clone() (eocontext.EoContext, error)

func (*DubboContext) Context

func (d *DubboContext) Context() context.Context

func (*DubboContext) GetBalance

func (d *DubboContext) GetBalance() eocontext.BalanceHandler

func (*DubboContext) GetComplete

func (d *DubboContext) GetComplete() eocontext.CompleteHandler

func (*DubboContext) GetFinish

func (d *DubboContext) GetFinish() eocontext.FinishHandler

func (*DubboContext) GetLabel

func (d *DubboContext) GetLabel(name string) string

func (*DubboContext) GetUpstreamHostHandler

func (d *DubboContext) GetUpstreamHostHandler() eocontext.UpstreamHostHandler

func (*DubboContext) HeaderReader

func (d *DubboContext) HeaderReader() dubbo2_context.IRequestReader

func (*DubboContext) Invoke

func (d *DubboContext) Invoke(node eoscContext.INode, timeout time.Duration) error

func (*DubboContext) IsCloneable

func (d *DubboContext) IsCloneable() bool

func (*DubboContext) Labels

func (d *DubboContext) Labels() map[string]string

func (*DubboContext) LocalAddr

func (d *DubboContext) LocalAddr() net.Addr

func (*DubboContext) LocalIP

func (d *DubboContext) LocalIP() net.IP

func (*DubboContext) LocalPort

func (d *DubboContext) LocalPort() int

func (*DubboContext) Proxy

func (d *DubboContext) Proxy() dubbo2_context.IProxy

func (*DubboContext) RealIP

func (d *DubboContext) RealIP() string

func (*DubboContext) RequestId

func (d *DubboContext) RequestId() string

func (*DubboContext) Response

func (d *DubboContext) Response() dubbo2_context.IResponse

func (*DubboContext) Scheme

func (d *DubboContext) Scheme() string

func (*DubboContext) SetBalance

func (d *DubboContext) SetBalance(handler eocontext.BalanceHandler)

func (*DubboContext) SetCompleteHandler

func (d *DubboContext) SetCompleteHandler(handler eocontext.CompleteHandler)

func (*DubboContext) SetFinish

func (d *DubboContext) SetFinish(handler eocontext.FinishHandler)

func (*DubboContext) SetLabel

func (d *DubboContext) SetLabel(name, value string)

func (*DubboContext) SetUpstreamHostHandler

func (d *DubboContext) SetUpstreamHostHandler(handler eocontext.UpstreamHostHandler)

func (*DubboContext) Value

func (d *DubboContext) Value(key interface{}) interface{}

func (*DubboContext) WithValue

func (d *DubboContext) WithValue(key, val interface{})

type Proxy

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

func NewProxy

func NewProxy(serviceWriter dubbo2_context.IServiceWriter, param *dubbo2_context.Dubbo2ParamBody, attachments map[string]interface{}) *Proxy

func (*Proxy) Attachments

func (p *Proxy) Attachments() map[string]interface{}

func (*Proxy) GetParam

func (p *Proxy) GetParam() *dubbo2_context.Dubbo2ParamBody

func (*Proxy) Service

func (p *Proxy) Service() dubbo2_context.IServiceWriter

func (*Proxy) SetAttachment

func (p *Proxy) SetAttachment(k string, v interface{})

func (*Proxy) SetParam

func (p *Proxy) SetParam(param *dubbo2_context.Dubbo2ParamBody)

type RequestReader

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

func NewRequestReader

func NewRequestReader(serviceReader dubbo2_context.IServiceReader, host string, remoteIp string, attachments map[string]interface{}) *RequestReader

func (*RequestReader) Attachment

func (r *RequestReader) Attachment(s string) (interface{}, bool)

func (*RequestReader) Attachments

func (r *RequestReader) Attachments() map[string]interface{}

func (*RequestReader) Body

func (r *RequestReader) Body() interface{}

func (*RequestReader) Host

func (r *RequestReader) Host() string

func (*RequestReader) RemoteIP

func (r *RequestReader) RemoteIP() string

func (*RequestReader) Service

func (r *RequestReader) Service() dubbo2_context.IServiceReader

type RequestServiceReader

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

func NewRequestServiceReader

func NewRequestServiceReader(path string, serviceName string, group string, version string, method string) *RequestServiceReader

func (*RequestServiceReader) Group

func (r *RequestServiceReader) Group() string

func (*RequestServiceReader) Interface

func (r *RequestServiceReader) Interface() string

func (*RequestServiceReader) Method

func (r *RequestServiceReader) Method() string

func (*RequestServiceReader) Path

func (r *RequestServiceReader) Path() string

func (*RequestServiceReader) Version

func (r *RequestServiceReader) Version() string

type RequestServiceWrite

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

func NewRequestServiceWrite

func NewRequestServiceWrite(path string, serviceName string, group string, version string, method string) *RequestServiceWrite

func (*RequestServiceWrite) Group

func (r *RequestServiceWrite) Group() string

func (*RequestServiceWrite) Interface

func (r *RequestServiceWrite) Interface() string

func (*RequestServiceWrite) Method

func (r *RequestServiceWrite) Method() string

func (*RequestServiceWrite) Path

func (r *RequestServiceWrite) Path() string

func (*RequestServiceWrite) SetGroup

func (r *RequestServiceWrite) SetGroup(group string)

func (*RequestServiceWrite) SetInterface

func (r *RequestServiceWrite) SetInterface(s string)

func (*RequestServiceWrite) SetMethod

func (r *RequestServiceWrite) SetMethod(s string)

func (*RequestServiceWrite) SetPath

func (r *RequestServiceWrite) SetPath(path string)

func (*RequestServiceWrite) SetVersion

func (r *RequestServiceWrite) SetVersion(s string)

func (*RequestServiceWrite) Version

func (r *RequestServiceWrite) Version() string

type Response

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

func (*Response) GetBody

func (r *Response) GetBody() interface{}

func (*Response) ResponseError

func (r *Response) ResponseError() error

func (*Response) ResponseTime

func (r *Response) ResponseTime() time.Duration

func (*Response) SetBody

func (r *Response) SetBody(body interface{})

func (*Response) SetResponseTime

func (r *Response) SetResponseTime(duration time.Duration)