registry

Documentation

Overview

Package registry provides a generic, concurrency-safe name→factory registry. Each component kind (datapath, scheduler, generator, payload) keeps its own registry so new backends and protocols register themselves and drop in without a central switch. See DESIGN.md §5.

Index

• type Factory
• type Registry
  • func New[T any, O any]() *Registry[T, O]
  • func (r *Registry[T, O]) Build(name string, opts O) (T, error)
  • func (r *Registry[T, O]) Names() []string
  • func (r *Registry[T, O]) Register(name string, fn Factory[T, O])

Types

type Factory

type Factory[T any, O any] func(O) (T, error)

Factory builds a T from its options O.

type Registry

type Registry[T any, O any] struct {
	// contains filtered or unexported fields
}

Registry maps names to factories for one component kind. T is the produced interface; O is that kind's options struct.

func New

func New[T any, O any]() *Registry[T, O]

New returns an empty Registry.

func (*Registry[T, O]) Build

func (r *Registry[T, O]) Build(name string, opts O) (T, error)

Build constructs the named component from opts, or returns an error naming the registered alternatives.

func (*Registry[T, O]) Names

func (r *Registry[T, O]) Names() []string

Names returns the registered names, sorted.

func (*Registry[T, O]) Register

func (r *Registry[T, O]) Register(name string, fn Factory[T, O])

Register adds a factory under name. It panics on a nil factory or a duplicate name, since registration happens at init time and both are programming errors.