snapshot

Documentation

Index

• Constants
• func NewTemp() (*snapshotFile, error)
• func OpenFile(path string) (*snapshotFile, error)
• type Reader
  • func (s Reader) Read(p []byte) (int, error)
  • func (s Reader) WriteTo(w io.Writer) (int64, error)
• type Writer
  • func (g *Writer) ReadFrom(r io.Reader) (int64, error)
  • func (g *Writer) Write(p []byte) (int, error)

Constants

const DefaultSnapshotChunkSize = 1024 * 1024

DefaultSnapshotChunkSize default chunk size of gRPC snapshot stream.

Functions

func NewTemp

func NewTemp() (*snapshotFile, error)

func OpenFile

func OpenFile(path string) (*snapshotFile, error)

Types

type Reader

type Reader struct {
	Stream  regattapb.Snapshot_StreamClient
	Limiter *rate.Limiter
}

func (Reader) Read

func (s Reader) Read(p []byte) (int, error)

func (Reader) WriteTo

func (s Reader) WriteTo(w io.Writer) (int64, error)

type Writer

type Writer struct {
	Sender regattapb.Snapshot_StreamServer
}

func (*Writer) ReadFrom

func (g *Writer) ReadFrom(r io.Reader) (int64, error)

func (*Writer) Write

func (g *Writer) Write(p []byte) (int, error)