model

Jun 21, 2026

Changes in this version

+ type MessageBus interface

+ AttachWebSocket func(messenger Messenger, ws *websocket.Conn)

+ NewMessenger func(name string) (Messenger, error)

+ Register func(module common.Named)

+ type Messenger interface

+ Ch func() <-chan entity.PubsubMessage

+ Close func()

+ Send func(ctx context.Context, kind string, payload any) error

Jun 20, 2026

Changes in this version

+ type Database interface

+ Cleanup func(schema bool) error

+ DB func() *sql.DB

+ FromContext func(ctx context.Context) *gorm.DB

+ FromContextTimeout func(ctx context.Context, timeout time.Duration) (*gorm.DB, context.CancelFunc)

+ ORM func() *gorm.DB

+ Reload func() error

+ Transaction func(ctx context.Context, fn func(tctx context.Context) error, ...) error

+ type Supervisor interface

+ InitService func(ctx context.Context, name string) error

+ Register func(services ...common.Service)

+ Restart func(ctx context.Context) error

+ RestartService func(ctx context.Context, name string) error

+ Services func() []common.Service

+ StartService func(name string) error

+ Stats func() ([]*entity.SupervisorStats, error)

+ StopService func(name string, wait bool) error

+ TopoSort func() error

Jun 5, 2026

Changes in this version

+ type Application interface

+ InitService func(ctx context.Context, name string) error

+ Register func(services ...common.Service)

+ RestartService func(ctx context.Context, name string) error

+ Services func() []common.Service

+ StartService func(name string) error

+ Stats func() ([]*entity.ApplicationStats, error)

+ StopService func(name string, wait bool) error

+ TopoSort func() error

+ type DB interface

+ Cleanup func(schema bool) error

+ DB func() *sql.DB

+ FromContext func(ctx context.Context) *gorm.DB

+ FromContextTimeout func(ctx context.Context, timeout time.Duration) (*gorm.DB, context.CancelFunc)

+ ORM func() *gorm.DB

+ Reload func() error

+ Transaction func(ctx context.Context, fn func(ctx context.Context) error, ...) error

+ type Planner interface

+ Add func(todo *entity.PlannerTODO) error

+ Cancel func(id string) error

+ Delete func(id string, force bool) error

+ GetResult func(id string) (any, error)

+ Stats func(opts entity.PlannerStatsOptions) ([]*entity.PlannerStats, error)

+ type Pubsub interface

+ Publish func(from common.Named, topic string, kind string, payload any)

+ Subscribe func(svc common.Named, topic string)

+ Unsubscribe func(svc common.Named, topic string)

+ type PubsubDriver interface

+ GetSubscribers func(topic string) []string

+ Publish func(from string, topic string, kind string, payload any) error

+ Subscribe func(name string, topic string) (<-chan entity.PubsubMessage, error)

+ Unsubscribe func(name string, topic string) error