rpc

func (*Config) Dialer ¶

func (c *Config) Dialer() (net.Conn, error)

Dialer creates rpc socket Dialer.

func (*Config) InitDefaults ¶

func (c *Config) InitDefaults()

InitDefaults allows to init blank config with pre-defined set of default values.

func (*Config) Listener ¶

func (c *Config) Listener() (net.Listener, error)

Listener creates new rpc socket Listener.

func (*Config) Valid ¶

func (c *Config) Valid() error

Valid returns nil if config is valid.

func (*Plugin) Collects ¶

func (s *Plugin) Collects() []any

Collects all plugins which implement Name + RPCer interfaces

func (*Plugin) Init ¶

func (s *Plugin) Init(cfg config.Configurer, log *zap.Logger) error

Init rpc service. Must return true if service is enabled.

func (*Plugin) Name ¶

func (s *Plugin) Name() string

Name contains service name.

func (*Plugin) Register ¶

func (s *Plugin) Register(name string, svc any) error

Register publishes in the server the set of methods of the receiver value that satisfy the following conditions:

• exported method of exported type
• two arguments, both of exported type
• the second argument is a pointer
• one return value, of type error

It returns an error if the receiver is not an exported type or has no suitable methods. It also logs the error using package log.

func (*Plugin) RegisterPlugin ¶

func (s *Plugin) RegisterPlugin(name endure.Named, p api.RPCer)

RegisterPlugin registers RPC service plugin.

func (*Plugin) Serve ¶

func (s *Plugin) Serve() chan error

Serve serves the service.

func (*Plugin) Stop ¶

func (s *Plugin) Stop() error

Stop stops the service.