Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

nan0

package module

Go to main page

Versions in this module

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

Incompatible versions in this module

v2.1.2+incompatible

Nov 2, 2019

v2.1.1+incompatible

Oct 24, 2019

v2.1.0+incompatible

Oct 24, 2019

v2.0.0+incompatible

Sep 7, 2019

Other modules containing this package

github.com/yomiji/nan0/v2