Versions in this module Expand all Collapse all v1 v1.6.1 Jul 23, 2019 Changes in this version + var Debug *log.Logger = nil + var Error = log.New(os.Stderr, "Nan0 [ERROR]: ", log.Ldate | log.Ltime) + var Info = log.New(os.Stdout, "Nan0 [INFO]: ", log.Ldate | log.Ltime) + var MaxNanoCache = 50 + var ProtoPreamble = []byte + var SizeArrayWidth = defaultArrayWidth + var SizeReader = func(bytes []byte) int + var SizeWriter = func(size int) (bytes []byte) + var TCPTimeout = 10 * time.Second + var Warn = log.New(os.Stderr, "Nan0 [WARN]: ", log.Ldate | log.Ltime) + func NoLogging() + func SetLogWriter(w io.Writer) + func ToggleLineNumberPrinting(info, warn, fail, debug bool) + type Nan0 struct + ServiceName string + func (n *Nan0) Close() + func (n Nan0) Equals(other NanoServiceWrapper) bool + func (n Nan0) GetReceiver() <-chan interface{} + func (n Nan0) GetSender() chan<- interface{} + func (n Nan0) GetServiceName() string + func (n Nan0) IsClosed() bool + type NanoBuilder struct + func (sec *NanoBuilder) AddMessageIdentities(messageIdents ...proto.Message) *NanoBuilder + func (sec *NanoBuilder) AddMessageIdentity(messageIdent proto.Message) *NanoBuilder + func (sec *NanoBuilder) BuildServer(handler func(net.Listener, *NanoBuilder)) (*NanoServer, error) + func (sec *NanoBuilder) ReceiveBuffer(receiveBuffer int) *NanoBuilder + func (sec *NanoBuilder) SendBuffer(sendBuffer int) *NanoBuilder + func (sec *NanoBuilder) ToggleWriteDeadline(writeDeadline bool) *NanoBuilder + func (sec *NanoBuilder) Websocket() *NanoBuilder + func (sec NanoBuilder) Build() (nan0 NanoServiceWrapper, err error) + func (sec NanoBuilder) WrapConnection(connection interface{}) (nan0 NanoServiceWrapper, err error) + type NanoServer struct + func (server *NanoServer) AddConnection(conn NanoServiceWrapper) + func (server *NanoServer) GetAllConnections() []NanoServiceWrapper + func (server *NanoServer) GetConnections() <-chan NanoServiceWrapper + func (server *NanoServer) IsShutdown() bool + func (server *NanoServer) Shutdown() + func (server NanoServer) GetHost() string + func (server NanoServer) GetPort() int32 + func (server NanoServer) GetServiceName() string + func (server NanoServer) GetServiceType() string + func (server NanoServer) GetStartTime() int64 + func (server NanoServer) IsAlive() bool + func (server NanoServer) IsExpired() bool + type NanoServiceWrapper interface + Close func() + Equals func(NanoServiceWrapper) bool + GetReceiver func() <-chan interface{} + GetSender func() chan<- interface{} + GetServiceName func() string + IsClosed func() bool + type Server interface + AddConnection func(NanoServiceWrapper) + GetConnections func() <-chan NanoServiceWrapper + GetServiceName func() string + IsAlive func() bool + IsExpired func() bool + IsShutdown func() bool + Shutdown func() + type Service struct + Expired bool + HostName string + Port int32 + ServiceName string + ServiceType string + StartTime int64 + Uri string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Service) Descriptor() ([]byte, []int) + func (*Service) ProtoMessage() + func (dst *Service) XXX_Merge(src proto.Message) + func (m *Service) GetExpired() bool + func (m *Service) GetHostName() string + func (m *Service) GetPort() int32 + func (m *Service) GetServiceName() string + func (m *Service) GetServiceType() string + func (m *Service) GetStartTime() int64 + func (m *Service) GetUri() string + func (m *Service) Reset() + func (m *Service) String() string + func (m *Service) XXX_DiscardUnknown() + func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Service) XXX_Size() int + func (m *Service) XXX_Unmarshal(b []byte) error + func (ns *Service) NewNanoBuilder() *NanoBuilder + func (ns *Service) Refresh() + func (ns *Service) Start() (net.Listener, error) + func (ns Service) Equals(other Service) bool + func (ns Service) IsAlive() bool + func (ns Service) IsExpired() bool + type WsNan0 struct + ServiceName string + func (n WsNan0) Close() + func (n WsNan0) Equals(other NanoServiceWrapper) bool + func (n WsNan0) GetReceiver() <-chan interface{} + func (n WsNan0) GetSender() chan<- interface{} + func (n WsNan0) GetServiceName() string + func (n WsNan0) IsClosed() bool
Go to main page