itemgenerator

Documentation

Index

• type Generator
  • func NewGenerator[T any](name string, min, max int, delay time.Duration, ...) (*Generator[T], error)
  • func (g *Generator[T]) Close()
  • func (g *Generator[T]) GetItem(ctx context.Context) (*T, error)
  • func (g *Generator[T]) Run(ctx context.Context)

Types

type Generator

type Generator[T any] struct {
	// contains filtered or unexported fields
}

func NewGenerator

func NewGenerator[T any](name string, min, max int, delay time.Duration, generateFunc func() (*T, error)) (*Generator[T], error)

func (*Generator[T]) Close

func (g *Generator[T]) Close()

func (*Generator[T]) GetItem

func (g *Generator[T]) GetItem(ctx context.Context) (*T, error)

func (*Generator[T]) Run

func (g *Generator[T]) Run(ctx context.Context)