proxy

Documentation

Index

• func NewCallPlugin(fn func(*Label) CallForwarder) drpc.Plugin
• func NewPlugin(fn func(*Label) Forwarder) drpc.Plugin
• func NewPushPlugin(fn func(*Label) PushForwarder) drpc.Plugin
• type CallForwarder
• type Forwarder
• type Label
• type PushForwarder

Functions

func NewCallPlugin

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

NewCallPlugin 创建call方法的代理插件

func NewPlugin

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

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

func NewPushPlugin

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

NewPushPlugin 创建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
}