remote

Documentation

Index

• type Option
  • func Addr(s string) Option
  • func BasePath(s string) Option
  • func RegistryAddr(s string) Option
  • func RegistryType(s string) Option
• type Options
• type RegisterPlugin
• type Remote
  • func NewRemote(opts ...Option) *Remote
  • func (r *Remote) GetRemoteAddrs() string
  • func (r *Remote) OnDestroy()
  • func (r *Remote) OnInit(s component.ServerImpl)
  • func (r *Remote) OnRun(closeSig chan bool)
  • func (r *Remote) RegisterHandler(rcvr interface{}, metadata string) error
  • func (r *Remote) RegisterName(nodeId string, rcvr interface{}, metadata string) error

Types

type Option

type Option func(*Options)

func Addr

func Addr(s string) Option

Address of rpc service

func BasePath

func BasePath(s string) Option

Base path of rpc service

func RegistryAddr

func RegistryAddr(s string) Option

Address of register service

func RegistryType

func RegistryType(s string) Option

Register service type. option is consul, etcd, etcdv3, zookeeper.

type Options

type Options struct {
	Addr         string
	RegistryType string
	RegistryAddr string
	BasePath     string
}

type RegisterPlugin

type RegisterPlugin interface {
	Start() error
}

type Remote

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

func NewRemote

func NewRemote(opts ...Option) *Remote

func (*Remote) GetRemoteAddrs

func (r *Remote) GetRemoteAddrs() string

func (*Remote) OnDestroy

func (r *Remote) OnDestroy()

func (*Remote) OnInit

func (r *Remote) OnInit(s component.ServerImpl)

func (*Remote) OnRun

func (r *Remote) OnRun(closeSig chan bool)

func (*Remote) RegisterHandler

func (r *Remote) RegisterHandler(rcvr interface{}, metadata string) error

func (*Remote) RegisterName

func (r *Remote) RegisterName(nodeId string, rcvr interface{}, metadata string) error