util

Mar 16, 2018

Changes in this version

+ func DecodeChannels(data []byte) ([]string, error)

+ func SendChannelsList(channels []string, sendInbox, replyInbox string, nc *nats.Conn, ...) error

Oct 25, 2017

Changes in this version

+ func IsChannelNameLiteral(channel string) bool

+ func IsChannelNameValid(channel string, wildcardsAllowed bool) bool

Jun 27, 2017

Changes in this version

+ var ErrInvalidSubject = errors.New("sublist: invalid subject")

+ var ErrNotFound = errors.New("sublist: no match found")

+ func IsSubjectLiteral(subject string) bool

+ type Sublist struct

+ func NewSublist() *Sublist

+ func (s *Sublist) CacheCount() int

+ func (s *Sublist) Count() uint32

+ func (s *Sublist) Insert(subject string, element interface{}) error

+ func (s *Sublist) Match(subject string) []interface{}

+ func (s *Sublist) NumLevels() int

+ func (s *Sublist) Remove(subject string, element interface{}) error

+ func (s *Sublist) Subjects() []string

Apr 10, 2017

Changes in this version

+ var ErrUnableToLockNow = errors.New("unable to acquire the lock at the moment")

+ func CloseFile(err error, f io.Closer) error

+ func FriendlyBytes(bytes int64) string

+ func IsSubjectValid(subject string) bool

+ type BackoffTimeCheck struct

+ func NewBackoffTimeCheck(minFrequency time.Duration, factor int, maxFrequency time.Duration) (*BackoffTimeCheck, error)

+ func (bp *BackoffTimeCheck) Ok() bool

+ func (bp *BackoffTimeCheck) Reset()

+ type LockFile interface

+ IsClosed func() bool

+ func CreateLockFile(file string) (LockFile, error)

Jan 19, 2017

Changes in this version

+ const RaceEnabled

Jun 24, 2016

Changes in this version

+ var ByteOrder binary.ByteOrder

+ func EnsureBufBigEnough(buf []byte, needed int) []byte

+ func ReadInt(r io.Reader) (int, error)

+ func WriteInt(w io.Writer, v int) error