recorder

type Chunk struct {
	// Data is a captured terminal data
	Data []byte `json:"data"`
	// Delay is delay before the previous chunk appeared
	Delay time.Duration `json:"delay"`
	// ServerID is a server ID of the recorded session
	ServerID string `json:"server_id"`
}

type ChunkReadCloser interface {
	ChunkReader
	io.Closer
}

type ChunkReadWriteCloser interface {
	ChunkReader
	ChunkWriter
	io.Closer
}

type ChunkReader interface {
	// ReadChunks returns a list of chunks from start to end indexes
	ReadChunks(start int, end int) ([]Chunk, error)
	GetChunksCount() (uint64, error)
}

type ChunkWriteCloser interface {
	ChunkWriter
	io.Closer
}

type ChunkWriter interface {
	// WriteChunks stores recorded chunks in the registry
	WriteChunks([]Chunk) error
}

type Recorder interface {
	// GetChunkWriter returns a new writer that can record
	// chunks with active session data to the recording server
	GetChunkWriter(id string) (ChunkWriteCloser, error)
	// GetChunkReader returns a reader of recorded chunks
	GetChunkReader(id string) (ChunkReadCloser, error)
}