producer

Documentation

Index

• type Factory
• type Producer
• type Registrar
  • func NewRegistrar(logger *zap.Logger) *Registrar
  • func (pr *Registrar) GetProducerFactory(name string) (Factory, bool)
  • func (pr *Registrar) Register(name, vendor string, pf Factory)

Types

type Factory

type Factory func(context.Context, config.Producer, *zap.Logger, telemetry.ExtDSChan) Producer

Factory is a function that returns a new instance of producer

type Producer

type Producer interface {
	Start()
}

Producer represents a producer

type Registrar

type Registrar struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Registrar represents producer factory registration.

func NewRegistrar

func NewRegistrar(logger *zap.Logger) *Registrar

NewRegistrar creates new registrar.

func (*Registrar) GetProducerFactory

func (pr *Registrar) GetProducerFactory(name string) (Factory, bool)

GetProducerFactory returns requested producer factory.

func (*Registrar) Register

func (pr *Registrar) Register(name, vendor string, pf Factory)

Register adds new producer factory