service

package

v1.12.4 Latest Latest Go to latest Published: Oct 29, 2025 License: GPL-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func Register[Options any](registry *Registry, outboundType string, constructor ConstructorFunc[Options])

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

func NewAdapter(serviceType string, serviceTag string) Adapter

func (a *Adapter) Tag() string

func (a *Adapter) Type() string

type ConstructorFunc[T any] func(ctx context.Context, logger log.ContextLogger, tag string, options T) (adapter.Service, error)

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

func NewManager(logger log.ContextLogger, registry adapter.ServiceRegistry) *Manager

func (m *Manager) Close() error

func (m *Manager) Create(ctx context.Context, logger log.ContextLogger, tag string, serviceType string, options any) error

func (m *Manager) Get(tag string) (adapter.Service, bool)

func (m *Manager) Remove(tag string) error

func (m *Manager) Services() []adapter.Service

func (m *Manager) Start(stage adapter.StartStage) error

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

func NewRegistry() *Registry

func (m *Registry) Create(ctx context.Context, logger log.ContextLogger, tag string, outboundType string, options any) (adapter.Service, error)

func (m *Registry) CreateOptions(outboundType string) (any, bool)