concurrent

Documentation

Index

• func NewBuffer(writer io.Writer) io.Writer
• type Buffer
  • func (s *Buffer) Write(p []byte) (n int, err error)
• type ErrGroup
  • func NewErrGroup(ctx context.Context, concurrency int) *ErrGroup
  • func (g *ErrGroup) Go(f func(ctx context.Context) error)
  • func (g *ErrGroup) Wait() error

Functions

func NewBuffer

func NewBuffer(writer io.Writer) io.Writer

NewBuffer is used to create a new buffer

Types

type Buffer

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

Buffer is goroutine safety buffer

func (*Buffer) Write

func (s *Buffer) Write(p []byte) (n int, err error)

Write implements the io.Writer

type ErrGroup

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

ErrGroup is another ErrGroup implement

func NewErrGroup

func NewErrGroup(ctx context.Context, concurrency int) *ErrGroup

NewErrGroup is used to create a new ErrGroup

func (*ErrGroup) Go

func (g *ErrGroup) Go(f func(ctx context.Context) error)

Go is used to start a new goroutine

func (*ErrGroup) Wait

func (g *ErrGroup) Wait() error

Wait is used to wait ErrGroup finish