cmd

Documentation

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

Functions

func Decode

func Decode(ncpu int, input, output string)

func Dump

func Dump(ncpu int, from, output string)

func PipeReaderWriter

func PipeReaderWriter(wg *sync.WaitGroup, r io.Reader, w io.Writer, nread, nwrite *AtomicInt64, total int64)

func Restore

func Restore(ncpu int, input, target string)

func Sync

func Sync(ncpu int, from, target string)

Types

type AtomicInt64

type AtomicInt64 int64

func (*AtomicInt64) Add

func (a *AtomicInt64) Add(v int64) int64

func (*AtomicInt64) Get

func (a *AtomicInt64) Get() int64

func (*AtomicInt64) Reset

func (a *AtomicInt64) Reset() int64

func (*AtomicInt64) Set

func (a *AtomicInt64) Set(v int64)

func (*AtomicInt64) Sub

func (a *AtomicInt64) Sub(v int64) int64

type BufWriter

type BufWriter struct {
	// contains filtered or unexported fields
}

func NewBufWriter

func NewBufWriter(wg *sync.WaitGroup, size int, writer *bufio.Writer, nwrite *AtomicInt64) *BufWriter

func (*BufWriter) Append

func (w *BufWriter) Append(s string)

func (*BufWriter) Close

func (w *BufWriter) Close()

type ClockTicker

type ClockTicker struct {
	// contains filtered or unexported fields
}

func NewClockTicker

func NewClockTicker(wg *sync.WaitGroup, onTick func(), onClose func()) *ClockTicker

func (*ClockTicker) Close

func (t *ClockTicker) Close()

type RdbLoader

type RdbLoader struct {
	// contains filtered or unexported fields
}

func NewRdbLoader

func NewRdbLoader(wg *sync.WaitGroup, size int, reader *bufio.Reader, nread *AtomicInt64) *RdbLoader

func (*RdbLoader) Pipe

func (l *RdbLoader) Pipe() chan *rdb.Entry