server

Documentation

Index

• func MainProc(category string, typex string, registry *Registry, ...)
• type Registry
  • func NewRegistry() *Registry
  • func (reg *Registry) AddService(name string, service interface{})
  • func (reg *Registry) GetServiceNames() []string
  • func (registry *Registry) NewServer(category string, typex string, appHandler map[string]http.Handler) (*Server, error)
• type Server
  • func (server *Server) Unpublish() error

Functions

func MainProc

func MainProc(category string, typex string, registry *Registry, appHandler map[string]http.Handler)

MainProc is a main routine for rpc server processes

Types

type Registry

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

Registry represents a function registry

func NewRegistry

func NewRegistry() *Registry

NewRegistry creates a new registry object

func (*Registry) AddService

func (reg *Registry) AddService(name string, service interface{})

AddService adds an service interface to the registry

func (*Registry) GetServiceNames

func (reg *Registry) GetServiceNames() []string

GetServiceNames returns all service names

func (*Registry) NewServer

func (registry *Registry) NewServer(category string, typex string, appHandler map[string]http.Handler) (*Server, error)

NewServer creates a new rpc server for a specific registry

type Server

type Server struct {
	Address      *net.TCPAddr
	StoppedEvent <-chan error
	// contains filtered or unexported fields
}

Server represents an rpc server

func (*Server) Unpublish

func (server *Server) Unpublish() error

Unpublish stops the rpc server