blockwriter

Documentation

Overview

Package blockwriter is not currently used, but it's useful code we may need

It maintains a buffered queue for writing blocks

TODO: Delete when confirmed not to be needed

Index

• Constants
• type BlockWriter
  • func NewBlockWriter(underlying io.Writer, maxSize uint64, handleError ErrorHandler) *BlockWriter
  • func (bq *BlockWriter) Close() error
  • func (bq *BlockWriter) Write(p []byte) (n int, err error)
• type ErrorHandler

Constants

const ErrClosed errorType = "writer closed"

Types

type BlockWriter

type BlockWriter struct {
	// contains filtered or unexported fields
}

func NewBlockWriter

func NewBlockWriter(underlying io.Writer, maxSize uint64, handleError ErrorHandler) *BlockWriter

func (*BlockWriter) Close

func (bq *BlockWriter) Close() error

func (*BlockWriter) Write

func (bq *BlockWriter) Write(p []byte) (n int, err error)

type ErrorHandler

type ErrorHandler func(error) bool