orderedwriter

Documentation

Overview

Package orderedwriter implements an unbounded buffer for ordering concurrent writes for non-seekable writers. It keeps an internal linked list that keeps the chunks in order and flushes buffered chunks when the expected offset is available.

Index

• type OrderedWriterAt
  • func New(w io.Writer) *OrderedWriterAt
  • func (w *OrderedWriterAt) WriteAt(p []byte, offset int64) (int, error)

Types

type OrderedWriterAt

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

func New

func New(w io.Writer) *OrderedWriterAt

func (*OrderedWriterAt) WriteAt

func (w *OrderedWriterAt) WriteAt(p []byte, offset int64) (int, error)