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

lib

package

Go to main page

Versions in this module

v1

v1.999.224

May 1, 2023

v1.999.223

Apr 2, 2023

v1.999.222

Mar 1, 2023

v1.999.221

Feb 1, 2023

v1.999.220

Oct 18, 2022

v1.999.211

Jun 15, 2022

v1.999.210

Apr 19, 2022

v1.999.202

Jan 4, 2022

v1.999.201

Nov 22, 2021

v1.999.200

Oct 14, 2021

v1.199.221

Feb 1, 2023

Changes in this version

+ var CRC32Q = crc32.MakeTable(0xD5828281)

+ var DefaultBufferLength = 16384

+ var ErrAliasOwner = fmt.Errorf("not an owner")

+ var ErrAliasUnknown = fmt.Errorf("unknown alias")

+ var ErrAppAlreadyLoaded = fmt.Errorf("application is already loaded")

+ var ErrAppAlreadyStarted = fmt.Errorf("application is already started")

+ var ErrAppIsNotRunning = fmt.Errorf("application is not running")

+ var ErrAppUnknown = fmt.Errorf("unknown application name")

+ var ErrBehaviorGroupUnknown = fmt.Errorf("unknown behavior group")

+ var ErrBehaviorUnknown = fmt.Errorf("unknown behavior")

+ var ErrEventMismatch = fmt.Errorf("message type mismatch")

+ var ErrEventOwner = fmt.Errorf("not an owner")

+ var ErrEventSelf = fmt.Errorf("monitor events from itself")

+ var ErrEventUnknown = fmt.Errorf("unknown event type")

+ var ErrFragmented = fmt.Errorf("fragmented data")

+ var ErrMonitorUnknown = fmt.Errorf("unknown monitor reference")

+ var ErrNameOwner = fmt.Errorf("not an owner")

+ var ErrNameUnknown = fmt.Errorf("unknown name")

+ var ErrNoRoute = fmt.Errorf("no route to node")

+ var ErrPeerUnsupported = fmt.Errorf("peer does not support this feature")

+ var ErrProcessBusy = fmt.Errorf("process is busy")

+ var ErrProcessContext = fmt.Errorf("not a Process context")

+ var ErrProcessIncarnation = fmt.Errorf("process ID belongs to the previous incarnation")

+ var ErrProcessMailboxFull = fmt.Errorf("process mailbox is full")

+ var ErrProcessTerminated = fmt.Errorf("process terminated")

+ var ErrProcessUnknown = fmt.Errorf("unknown process")

+ var ErrProxyConnect = fmt.Errorf("can't establish proxy connection")

+ var ErrProxyHopExceeded = fmt.Errorf("proxy hop is exceeded")

+ var ErrProxyLoopDetected = fmt.Errorf("proxy loop detected")

+ var ErrProxyNoRoute = fmt.Errorf("no proxy route to node")

+ var ErrProxyPathTooLong = fmt.Errorf("proxy path too long")

+ var ErrProxySessionDuplicate = fmt.Errorf("session is already exist")

+ var ErrProxySessionUnknown = fmt.Errorf("unknown session id")

+ var ErrProxyTransitDisabled = fmt.Errorf("proxy feature disabled")

+ var ErrProxyTransitRestricted = fmt.Errorf("proxy connect restricted")

+ var ErrProxyUnknownRequest = fmt.Errorf("unknown proxy request")

+ var ErrReferenceUnknown = fmt.Errorf("unknown reference")

+ var ErrRouteName = fmt.Errorf("incorrect route name")

+ var ErrSenderUnknown = fmt.Errorf("unknown sender")

+ var ErrServerTerminated = fmt.Errorf("server terminated")

+ var ErrTaken = fmt.Errorf("resource is taken")

+ var ErrTimeout = fmt.Errorf("timed out")

+ var ErrTooLarge = fmt.Errorf("Too large")

+ var ErrUnknown = fmt.Errorf("unknown")

+ var ErrUnsupported = fmt.Errorf("not supported")

+ var ErrUnsupportedRequest = fmt.Errorf("unsupported request")

+ func CatchPanic() bool

+ func GenerateSelfSignedCert(org string, hosts ...string) (tls.Certificate, error)

+ func Log(f string, a ...interface{})

+ func RandomString(length int) string

+ func ReleaseBuffer(b *Buffer)

+ func ReleaseTimer(t *time.Timer)

+ func TakeTimer() *time.Timer

+ func Warning(f string, a ...interface{})

+ type Buffer struct

+ B []byte

+ func TakeBuffer() *Buffer

+ func (b *Buffer) Allocate(n int)

+ func (b *Buffer) Append(v []byte)

+ func (b *Buffer) AppendByte(v byte)

+ func (b *Buffer) Extend(n int) []byte

+ func (b *Buffer) Len() int

+ func (b *Buffer) Read(v []byte) (n int, err error)

+ func (b *Buffer) ReadDataFrom(r io.Reader, limit int) (int, error)

+ func (b *Buffer) Reset()

+ func (b *Buffer) Set(v []byte)

+ func (b *Buffer) String() string

+ func (b *Buffer) Write(v []byte) (n int, err error)

+ func (b *Buffer) WriteDataTo(w io.Writer) error

+ type CertUpdater struct

+ func CreateCertUpdater(cert tls.Certificate) *CertUpdater

+ func (cu *CertUpdater) GetCertificateFunc() func(*tls.ClientHelloInfo) (*tls.Certificate, error)

+ func (cu *CertUpdater) Update(cert tls.Certificate)

+ type ItemMPSC interface

+ Clear func()

+ Next func() ItemMPSC

+ Value func() interface{}

+ type NetReadWriter interface

+ type NetReader interface

+ SetReadDeadline func(t time.Time) error

+ type NetWriter interface

+ SetWriteDeadline func(t time.Time) error

+ type QueueMPSC interface

+ Item func() ItemMPSC

+ Len func() int64

+ Pop func() (interface{}, bool)

+ Push func(value interface{}) bool

+ func NewQueueLimitMPSC(limit int64) QueueMPSC

+ func NewQueueMPSC() QueueMPSC