Documentation
¶
Index ¶
Constants ¶
View Source
const (
BUFSIZE = 32 * 1024
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChecksumReaderWriter ¶
type ChecksumReaderWriter struct {
// contains filtered or unexported fields
}
func NewChecksumReaderWriter ¶
func NewChecksumReaderWriter(mac hash.Hash, logger *logger.Logger) *ChecksumReaderWriter
func (*ChecksumReaderWriter) StartReader ¶
func (cr *ChecksumReaderWriter) StartReader(reader io.Reader) io.Reader
func (*ChecksumReaderWriter) StartWriter ¶
func (cr *ChecksumReaderWriter) StartWriter(writer io.Writer) io.Writer
type EncryptReader ¶
type EncryptReader struct {
// contains filtered or unexported fields
}
func NewEncryptReader ¶
func (*EncryptReader) StartReader ¶
func (er *EncryptReader) StartReader(reader io.Reader) io.Reader
type ProgressReaderWriter ¶
type ProgressReaderWriter struct {
// contains filtered or unexported fields
}
func NewProgressReaderWriter ¶
func NewProgressReaderWriter(filesize int64, interval time.Duration, callback callbackFunc) *ProgressReaderWriter
func (*ProgressReaderWriter) StartReader ¶
func (pr *ProgressReaderWriter) StartReader(reader io.Reader) io.Reader
func (*ProgressReaderWriter) StartWriter ¶
func (pr *ProgressReaderWriter) StartWriter(writer io.Writer) io.Writer
type RWQueueEntry ¶
type RWQueueEntry interface {
ReadQueueEntry
WriteQueueEntry
}
type ReadStreamQueue ¶
type ReadStreamQueue struct {
// contains filtered or unexported fields
}
func NewReadStreamQueue ¶
func NewReadStreamQueue(entries ...ReadQueueEntry) (*ReadStreamQueue, error)
func (*ReadStreamQueue) Append ¶
func (rsq *ReadStreamQueue) Append(entry ...ReadQueueEntry)
func (*ReadStreamQueue) StartReader ¶
func (rsq *ReadStreamQueue) StartReader(reader io.Reader) io.Reader
Source Files
Click to show internal directories.
Click to hide internal directories.