server

Documentation

Overview

Package server ...

Index

• type Server
  • func NewServer() *Server
  • func (p *Server) AddService(name string, service *rpc.Service, data rpc.Map) *Server
  • func (p *Server) BuildReplyCache() *Server
  • func (p *Server) Close() bool
  • func (p *Server) IsRunning() bool
  • func (p *Server) Listen(network string, addr string, tlsConfig *tls.Config) *Server
  • func (p *Server) ListenWithDebug(network string, addr string, tlsConfig *tls.Config) *Server
  • func (p *Server) OnReceiveStream(stream *rpc.Stream)
  • func (p *Server) Open() bool
  • func (p *Server) SetActionCache(actionCache rpc.ActionCache) *Server
  • func (p *Server) SetLogHub(logHub rpc.IStreamHub) *Server
  • func (p *Server) SetNumOfThreads(numOfThreads int) *Server
  • func (p *Server) SetThreadBufferSize(threadBufferSize uint32) *Server

Types

type Server

type Server struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Server ...

func NewServer

func NewServer() *Server

NewServer ...

func (*Server) AddService

func (p *Server) AddService(
	name string,
	service *rpc.Service,
	data rpc.Map,
) *Server

AddService ...

func (*Server) BuildReplyCache

func (p *Server) BuildReplyCache() *Server

BuildReplyCache ...

func (*Server) Close

func (p *Server) Close() bool

Close ...

func (*Server) IsRunning

func (p *Server) IsRunning() bool

IsRunning ...

func (*Server) Listen

func (p *Server) Listen(
	network string,
	addr string,
	tlsConfig *tls.Config,
) *Server

Listen ...

func (*Server) ListenWithDebug

func (p *Server) ListenWithDebug(
	network string,
	addr string,
	tlsConfig *tls.Config,
) *Server

ListenWithDebug ...

func (*Server) OnReceiveStream

func (p *Server) OnReceiveStream(stream *rpc.Stream)

OnReceiveStream ...

func (*Server) Open

func (p *Server) Open() bool

Open ...

func (*Server) SetActionCache

func (p *Server) SetActionCache(actionCache rpc.ActionCache) *Server

SetActionCache ...

func (*Server) SetLogHub

func (p *Server) SetLogHub(logHub rpc.IStreamHub) *Server

SetLogHub ...

func (*Server) SetNumOfThreads

func (p *Server) SetNumOfThreads(numOfThreads int) *Server

SetNumOfThreads ...

func (*Server) SetThreadBufferSize

func (p *Server) SetThreadBufferSize(threadBufferSize uint32) *Server

SetThreadBufferSize ...