Function New

pkg/component/component.go:154–244

New returns a new component.

(logger log.Stack, config *Config, opts ...Option)

// New returns a new component.
func New(logger log.Stack, config *Config, opts ...Option) (c *Component, err error) {
	ctx, cancel := context.WithCancel(context.Background())
	defer func() {
		if err != nil {
			cancel()
		}
	}()

	ctx = log.NewContext(ctx, logger)

	c = &Component{
		ctx:                ctx,
		cancelCtx:          cancel,
		terminationSignals: make(chan os.Signal),

		config: config,
		logger: logger,

		tcpListeners: make(map[string]*listener),

		taskStarter: task.StartTaskFunc(task.DefaultStartTask),
	}

	c.healthHandler, err = healthcheck.NewDefaultHealthChecker()
	if err != nil {
		return nil, err
	}

	c.componentKEKLabeler, err = config.KeyVault.ComponentKEKLabeler()
	if err != nil {
		return nil, err
	}
	c.keyService, err = config.KeyVault.KeyService(ctx, c)
	if err != nil {
		return nil, err
	}

	c.limiter, err = ratelimit.New(ctx, config.RateLimiting, config.Blob, c)
	if err != nil {
		return nil, err
	}

	for _, opt := range opts {
		opt(c)
	}

	fpsFetcher, err := config.FrequencyPlansFetcher(ctx, c)
	if err != nil {
		return nil, err
	}
	c.frequencyPlans = frequencyplans.NewStore(fpsFetcher)

	caStoreFetcher, err := config.MTLSAuthCAStoreFetcher(ctx, c)
	if err != nil {
		return nil, err
	}
	c.caStore, err = mtls.NewCAStore(ctx, caStoreFetcher)
	if err != nil {