websocket

Sep 15, 2026

Changes in this version

+ type Module struct

+ func New(bus event.Bus, opts ...Option) *Module

+ func (m *Module) Adapter() *store.Adapter

+ func (m *Module) Configure(config config.Config) error

+ func (m *Module) Dependencies() []string

+ func (m *Module) GetMigrationSources(projectRoot string) []migration_runner.Source

+ func (m *Module) Initialize(ctx context.Context, db *gorm.DB, ginRouter *gin.Engine) error

+ func (m *Module) Manager() *connections.Manager

+ func (m *Module) MigrationsDir() string

+ func (m *Module) Name() string

+ func (m *Module) Namespace() module.ModuleNamespace

+ func (m *Module) NewConfig() config.Config

+ func (m *Module) ProvidesMigrations() bool

+ func (m *Module) Shutdown(ctx context.Context) error

+ func (m *Module) Subscriptions() *store.Subscriptions

+ func (m *Module) Validators() *store.ValidatorRegistry

+ func (m *Module) Version() string

+ type Option func(*Module)

+ func WithClaimsResolver(resolve wsauth.ClaimsResolverFunc) Option

+ func WithValidator(pattern string, fn store.TopicValidatorFunc) Option