cmd

Index ¶

• func Decode(ncpu int, input, output string)
• func Dump(ncpu int, from, output string)
• func PipeReaderWriter(wg *sync.WaitGroup, r io.Reader, w io.Writer, nread, nwrite *AtomicInt64, ...)
• func Restore(ncpu int, input, target string)
• func Sync(ncpu int, from, target string)
• type AtomicInt64
• • func (a *AtomicInt64) Add(v int64) int64
  • func (a *AtomicInt64) Get() int64
  • func (a *AtomicInt64) Reset() int64
  • func (a *AtomicInt64) Set(v int64)
  • func (a *AtomicInt64) Sub(v int64) int64
• type BufWriter
• • func NewBufWriter(wg *sync.WaitGroup, size int, writer *bufio.Writer, nwrite *AtomicInt64) *BufWriter
• • func (w *BufWriter) Append(s string)
  • func (w *BufWriter) Close()
• type ClockTicker
• • func NewClockTicker(wg *sync.WaitGroup, onTick func(), onClose func()) *ClockTicker
• • func (t *ClockTicker) Close()
• type RdbLoader
• • func NewRdbLoader(wg *sync.WaitGroup, size int, reader *bufio.Reader, nread *AtomicInt64) *RdbLoader
• • func (l *RdbLoader) Pipe() chan *rdb.Entry