sized

type Writer ¶

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

Writer wraps an io.WriteCloser and adds a size limit. when the size limit is reached, the io.WriteCloser is closed and a new one is created using the open function.

func NewWriter(
	ctx context.Context,
	n int,
	saveCommandChan chan int,
	limit uint64,
	open func(context.Context, int, *atomic.Uint64) (io.WriteCloser, error),
) (*Writer, error)

func (f *Writer) Close() error

func (f *Writer) Write(p []byte) (n int, err error)