server

Documentation

Index

• type LisServer
• type RPCServer
• type Server
  • func NewServer(m *mesh.Mesh, authCrt string) (*Server, error)
  • func (s *Server) CleanUp()
  • func (s *Server) Publish(ctx context.Context, data *rpc.PublishData) (*rpc.Response, error)
  • func (s *Server) RegisterToPublish(ctx context.Context, info *rpc.PeerTopicInfo) (*rpc.Response, error)
  • func (s *Server) Shutdown()
  • func (s *Server) Start()
  • func (s *Server) Subscribe(info *rpc.PeerTopicInfo, stream rpc.Mesh_SubscribeServer) error
  • func (s *Server) UnregisterToPublish(ctx context.Context, info *rpc.PeerTopicInfo) (*rpc.Response, error)
  • func (s *Server) Unsubscribe(ctx context.Context, info *rpc.PeerTopicInfo) (*rpc.Response, error)
• type WrapperHTTP
  • func (wh *WrapperHTTP) Serve(l net.Listener) error
  • func (wh *WrapperHTTP) Stop()

Types

type LisServer

type LisServer struct {
	Listener net.Listener
	Server   RPCServer
}

LisServer is a container for RPC Listener and Server

type RPCServer

type RPCServer interface {
	Serve(net.Listener) error
	Stop()
}

RPCServer brings compatibility for raw (http/2) and web (http/1.1) RPC

type Server

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

Server is the RPC server and contains variables needed for RPC to work.

func NewServer

func NewServer(m *mesh.Mesh, authCrt string) (*Server, error)

NewServer creates a new RPC server.

func (*Server) CleanUp

func (s *Server) CleanUp()

CleanUp the RPC server.

func (*Server) Publish

func (s *Server) Publish(ctx context.Context, data *rpc.PublishData) (*rpc.Response, error)

Publish serves a publish request over RPC

func (*Server) RegisterToPublish

func (s *Server) RegisterToPublish(ctx context.Context, info *rpc.PeerTopicInfo) (*rpc.Response, error)

RegisterToPublish register a peer and topic with the remote access server.

func (*Server) Shutdown

func (s *Server) Shutdown()

Shutdown all RPC server currently running.

func (*Server) Start

func (s *Server) Start()

func (*Server) Subscribe

func (s *Server) Subscribe(info *rpc.PeerTopicInfo, stream rpc.Mesh_SubscribeServer) error

Subscribe serves a subscribe request over RPC

func (*Server) UnregisterToPublish

func (s *Server) UnregisterToPublish(ctx context.Context, info *rpc.PeerTopicInfo) (*rpc.Response, error)

UnregisterToPublish unregister a peer and topic with the remote access server.

func (*Server) Unsubscribe

func (s *Server) Unsubscribe(ctx context.Context, info *rpc.PeerTopicInfo) (*rpc.Response, error)

Unsubscribe serves an unsubscribe request over RPC

type WrapperHTTP

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

func (*WrapperHTTP) Serve

func (wh *WrapperHTTP) Serve(l net.Listener) error

func (*WrapperHTTP) Stop

func (wh *WrapperHTTP) Stop()