proxy

Documentation

Index

• func NewProxyCallPlugin(fn func(*Label) CallForwarder) drpc.Plugin
• func NewProxyPlugin(fn func(*Label) Forwarder) drpc.Plugin
• func NewProxyPushPlugin(fn func(*Label) PushForwarder) drpc.Plugin
• type CallForwarder
• type Forwarder
• type Label
• type PushForwarder

Functions

func NewProxyCallPlugin

func NewProxyCallPlugin(fn func(*Label) CallForwarder) drpc.Plugin

NewProxyCallPlugin 创建call方法的代理插件

func NewProxyPlugin

func NewProxyPlugin(fn func(*Label) Forwarder) drpc.Plugin

NewProxyPlugin 创建代理插件，支持call方法和push方法

func NewProxyPushPlugin

func NewProxyPushPlugin(fn func(*Label) PushForwarder) drpc.Plugin

NewProxyPushPlugin 创建push方法的代理插件

Types

type CallForwarder

type CallForwarder interface {
	Call(uri string, arg interface{}, result interface{}, setting ...message.MsgSetting) drpc.CallCmd
}

type Forwarder

type Forwarder interface {
	CallForwarder
	PushForwarder
}

type Label

type Label struct {
	SessionID     string
	RealIP        string
	ServiceMethod string
}

type PushForwarder

type PushForwarder interface {
	Push(uri string, arg interface{}, setting ...message.MsgSetting) *drpc.Status
}