gateway

package

v1.0.0 Latest Latest Go to latest Published: Jun 22, 2018 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func NewInvoker(opt *option.GatewayOption) types.Plugin

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

func NewGateway(o ...func(*option.GatewayOption)) *HproseGateway

func NewGatewayWith(opt *option.GatewayOption) *HproseGateway

func (g *HproseGateway) Invoke(name string, args []reflect.Value, context rpc.Context) ([]reflect.Value, error)

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

func NewTable(key string) *HproseTable

func (t *HproseTable) Close() error

func (t *HproseTable) Pipe(w io.Writer)

func (t *HproseTable) Pop() ([]types.Update, error)

func (t *HproseTable) Push(updates []types.Update) error

type Invoker option.GatewayOption

func (i *Invoker) Close() error

func (i *Invoker) Handler(_ types.InvokeHandler, ctx context.Context, method string, args []reflect.Value) ([]reflect.Value, error)

func (i *Invoker) Level() int

func (i *Invoker) Name() string