asyncwriter

Documentation

Overview

Package asyncwriter contains an asynchronous writer.

Index

• type Writer
  • func New(queueSize int, parent logger.Writer) *Writer
  • func (w *Writer) Error() chan error
  • func (w *Writer) Push(cb func() error)
  • func (w *Writer) Start()
  • func (w *Writer) Stop()

Types

type Writer

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

Writer is an asynchronous writer.

func New

func New(
	queueSize int,
	parent logger.Writer,
) *Writer

New allocates a Writer.

func (*Writer) Error

func (w *Writer) Error() chan error

Error returns whenever there's an error.

func (*Writer) Push

func (w *Writer) Push(cb func() error)

Push appends an element to the queue.

func (*Writer) Start

func (w *Writer) Start()

Start starts the writer routine.

func (*Writer) Stop

func (w *Writer) Stop()

Stop stops the writer routine.