rpc_server

package

v0.0.0-...-487d906 Latest Latest Go to latest Published: Nov 12, 2015 License: MPL-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/stackengine/serpc

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Nuke()
func Register(name string, obj interface{}) error
type NewServerCodec
type RPCImpl
- func NewServer() *RPCImpl
type SvcRPC

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrAlreadyRegistered = errors.New("RPC Endpoint already registered")
	ErrMissingObject     = errors.New("Register needs an Object pointer ")
	ErrNoServer          = errors.New("No RPC server present ")
	ErrMissingName       = errors.New("name must have a value ")
)

Functions ¶

func Nuke ¶

func Nuke()

This is only for testing.

func Register ¶

func Register(name string, obj interface{}) error

Types ¶

type NewServerCodec ¶

type NewServerCodec func(conn io.ReadWriteCloser) netrpc.ServerCodec

type RPCImpl ¶

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

func NewServer ¶

func NewServer() *RPCImpl

func (*RPCImpl) Init ¶

func (impl *RPCImpl) Init(tlscfg *ssltls.Cfg, enforce_secure bool, port int, newServerCodec NewServerCodec) error

func (*RPCImpl) MuxRPC ¶

func (impl *RPCImpl) MuxRPC(conn net.Conn, isTLS bool)

func (*RPCImpl) Server ¶

func (impl *RPCImpl) Server() *netrpc.Server

func (*RPCImpl) Shutdown ¶

func (impl *RPCImpl) Shutdown()

func (*RPCImpl) Start ¶

func (impl *RPCImpl) Start() error

type SvcRPC ¶

type SvcRPC interface {
	Init(*ssltls.Cfg, bool, int, NewServerCodec) error
	Start() error
	Shutdown()
	Server() *netrpc.Server
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL