pool

Documentation

Index

• type Pool
  • func New[T any](new func(key string) Runner[T]) *Pool[T]
  • func (p *Pool[T]) Close() error
  • func (p *Pool[T]) Get(key string) Runner[T]
  • func (p *Pool[T]) Keys() []string
  • func (p *Pool[T]) Remove(key string)
• type Runner

Types

type Pool

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

func New

func New[T any](new func(key string) Runner[T]) *Pool[T]

func (*Pool[T]) Close

func (p *Pool[T]) Close() error

func (*Pool[T]) Get

func (p *Pool[T]) Get(key string) Runner[T]

func (*Pool[T]) Keys

func (p *Pool[T]) Keys() []string

func (*Pool[T]) Remove

func (p *Pool[T]) Remove(key string)

type Runner

type Runner[T any] interface {
	Run()
	Push(t T)
	LastWrite() time.Time
	Close() error
}