latency

Documentation

Index

• type DataType
• type LatencyReader
  • func NewReader(processor func(ol *OffsetAndLatency) error) (LatencyReader, error)
• type LatencyWriter
  • func NewFileWriter(filename string, compressed bool) (LatencyWriter, error)
  • func NewWriter(downstream io.Writer, compressed bool) (LatencyWriter, error)
• type OffsetAndLatency

Types

type DataType

type DataType int

const (
	Tar DataType = iota
	TarGz
	Gzip
	Snappy
	Raw
	Unsupported
)

type LatencyReader

type LatencyReader interface {
	ConvertFileExtensionToDataType(filename string) DataType
	ReadByType(r io.Reader, dataType DataType) error
}

func NewReader

func NewReader(processor func(ol *OffsetAndLatency) error) (LatencyReader, error)

type LatencyWriter

type LatencyWriter interface {
	Close() error
	Write(p []byte) (n int, err error)
	WriteSimple(offset, latency uint32) (n int, err error)
	WriteOffsetAndLatency(ol OffsetAndLatency) (n int, err error)
}

func NewFileWriter

func NewFileWriter(filename string, compressed bool) (LatencyWriter, error)

func NewWriter

func NewWriter(downstream io.Writer, compressed bool) (LatencyWriter, error)

type OffsetAndLatency

type OffsetAndLatency struct {
	Offset  uint32
	Latency uint32
}