streamrestore

Documentation

Index

• Variables
• type BlockBackup
• type StreamRestore
  • func (sr *StreamRestore) Run() error

Variables

var ConnectStream = stream.ConnectStream

var NewBlockWriter = blockwriter.NewBlockWriter

Types

type BlockBackup

type BlockBackup struct {
	Sequence      uint64
	MessageBackup *messagebackup.MessageBackup
	Block         *types.AbstractBlock
}

type StreamRestore

type StreamRestore struct {
	Mode            string
	Chunks          chunks.ChunksInterface
	Stream          *stream.Opts
	Writer          *blockwriter.Opts
	StartSeq        uint64
	EndSeq          uint64
	ToleranceWindow uint
	ReconnectWaitMs uint

	ParseBlock blockparse.ParseBlockFn
	// contains filtered or unexported fields
}

func (*StreamRestore) Run

func (sr *StreamRestore) Run() error