Function InitializeEvents

cmd/internal/shared/events.go:47–78

InitializeEvents initializes the event system.

(ctx context.Context, component Component, conf config.ServiceBase)

// InitializeEvents initializes the event system.
func InitializeEvents(ctx context.Context, component Component, conf config.ServiceBase) error {
	var ps events.PubSub
	switch conf.Events.Backend {
	case "internal":
		ps = basic.NewPubSub()
	case "redis":
		ps = redis.NewPubSub(ctx, component, conf.Events.Redis, conf.Events.Batch)
	case "cloud":
		cloudPS, err := cloud.NewPubSub(ctx, component, conf.Events.Cloud.PublishURL, conf.Events.Cloud.SubscribeURL)
		if err != nil {
			return err
		}
		ps = cloudPS
	default:
		return fmt.Errorf("unknown events backend: %s", conf.Events.Backend)
	}

	var extraStreams []mux.Option
	if conf.TTGC.Enabled {
		matcher, err := mux.MatchPatterns(managedclient.EventNamePattern)
		if err != nil {
			return err
		}
		extraStreams = append(extraStreams, mux.WithStream(managedclient.NewEvents(component), matcher))
	}

	if len(extraStreams) > 0 {
		ps = mux.New(component, ps, extraStreams...)
	}
	events.SetDefaultPubSub(ps)
	return nil
}