rpc_service

Documentation

Index

• Constants
• func GetImpl(key string) (interface{}, error)
• func GetImplWithProxy(key string) (interface{}, error)
• func RegisterStructDescriptor(s *autowire.StructDescriptor)
• func SetParam(param *Param)
• type Autowire
  • func (a *Autowire) CanBeEntrance() bool
  • func (a *Autowire) GetAllStructDescriptors() map[string]*autowire.StructDescriptor
  • func (a *Autowire) TagKey() string
• type Param
• type ProxyInvoker
  • func (pi *ProxyInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result

Constants

const Name = "rpc-service"

Functions

func GetImpl

func GetImpl(key string) (interface{}, error)

func GetImplWithProxy

func GetImplWithProxy(key string) (interface{}, error)

func RegisterStructDescriptor

func RegisterStructDescriptor(s *autowire.StructDescriptor)

func SetParam

func SetParam(param *Param)

Types

type Autowire

type Autowire struct {
	autowire.Autowire
}

func (*Autowire) CanBeEntrance

func (a *Autowire) CanBeEntrance() bool

func (*Autowire) GetAllStructDescriptors

func (a *Autowire) GetAllStructDescriptors() map[string]*autowire.StructDescriptor

GetAllStructDescriptors re-write SingletonAutowire

func (*Autowire) TagKey

func (a *Autowire) TagKey() string

type Param

type Param struct {
	ExportPort string
}

type ProxyInvoker

type ProxyInvoker struct {
	protocol.BaseInvoker
}

ProxyInvoker is a invoker struct

func (*ProxyInvoker) Invoke

func (pi *ProxyInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result

Invoke is used to call service method by invocation