remilia

Jun 25, 2026

Changes in this version

type Bot

+ func (b *Bot) SyncPlatforms(desired map[string]platform.Adapter) error

type PprofServer

+ func (p *PprofServer) ListenAddr() string

+ func (p *PprofServer) UpdateConfig(cfg PprofConfig)

Jun 22, 2026

Changes in this version

type Bot

+ func (b *Bot) Restart() error

Jun 7, 2026

Changes in this version

type Option

+ func WithGoroutineThreshold(n int) Option

May 15, 2026

Changes in this version

type PprofServer

+ func (p *PprofServer) AddHandler(path string, handler http.HandlerFunc)

May 12, 2026

Changes in this version

type Bot

+ func (b *Bot) UseEngineManager(em *engine.EngineManager) *Bot

+ func (b *Bot) UseRouter(r *router.Router) *Bot

Apr 30, 2026

Changes in this version

+ const DefaultShutdownTimeout

+ const DefaultStartTimeout

+ const Version

+ func CaptureTrace(ctx context.Context, duration time.Duration, filename string) error

+ type AdapterHealthChecker struct

+ func NewAdapterHealthChecker(adapter platform.Adapter) *AdapterHealthChecker

+ func (c *AdapterHealthChecker) Check(_ context.Context) health.CheckResult

+ func (c *AdapterHealthChecker) Name() string

+ type Bot struct

+ func MustNewBot(adapter platform.Adapter, e *engine.Engine, opts ...Option) *Bot

+ func NewBot(adapter platform.Adapter, e *engine.Engine, opts ...Option) (*Bot, error)

+ func (b *Bot) Config() BotMeta

+ func (b *Bot) Context() context.Context

+ func (b *Bot) Engine() *engine.Engine

+ func (b *Bot) Health() health.CheckResponse

+ func (b *Bot) HealthCheck() *health.Check

+ func (b *Bot) IsRunning() bool

+ func (b *Bot) OnAny(rule ...eventctx.Rule) *engine.Matcher

+ func (b *Bot) OnEventKind(kind platform.EventKind, rule ...eventctx.Rule) *engine.Matcher

+ func (b *Bot) PlatformRegistry() *platform.Registry

+ func (b *Bot) Plugins() *plugin.Manager

+ func (b *Bot) Shutdown() error

+ func (b *Bot) ShutdownAsync() <-chan error

+ func (b *Bot) Start() error

+ func (b *Bot) State() lifecycle.State

+ func (b *Bot) Stop(ctx context.Context) error

+ func (b *Bot) Uptime() time.Duration

+ func (b *Bot) UsePlatformRegistry(r *platform.Registry) *Bot

+ func (b *Bot) UsePlugins(pm *plugin.Manager) *Bot

+ func (b *Bot) WaitForShutdown(timeout ...time.Duration)

+ type BotBuilder struct

+ func NewBotBuilder() *BotBuilder

+ func (b *BotBuilder) Build() (*Bot, error)

+ func (b *BotBuilder) MustBuild() *Bot

+ func (b *BotBuilder) WithDebug(debug bool) *BotBuilder

+ func (b *BotBuilder) WithEngine(eng *engine.Engine) *BotBuilder

+ func (b *BotBuilder) WithEngineOptions(opts ...engine.Option) *BotBuilder

+ func (b *BotBuilder) WithName(name string) *BotBuilder

+ func (b *BotBuilder) WithOption(opt Option) *BotBuilder

+ func (b *BotBuilder) WithPlatformAdapter(adapter platform.Adapter) *BotBuilder

+ func (b *BotBuilder) WithPlatformRegistry(r *platform.Registry) *BotBuilder

+ func (b *BotBuilder) WithPluginManager(pm *plugin.Manager) *BotBuilder

+ func (b *BotBuilder) WithPlugins(descriptors ...*plugin.Descriptor) *BotBuilder

+ func (b *BotBuilder) WithVersion(version string) *BotBuilder

+ type BotError struct

+ Err error

+ Name string

+ func (e *BotError) Error() string

+ func (e *BotError) Unwrap() error

+ type BotHealthResult struct

+ Health health.CheckResponse

+ IsRunning bool

+ Name string

+ type BotManager struct

+ func NewBotManager() *BotManager

+ func (m *BotManager) Add(name string, bot *Bot) error

+ func (m *BotManager) Get(name string) (*Bot, bool)

+ func (m *BotManager) HealthAll() map[string]BotHealthResult

+ func (m *BotManager) Len() int

+ func (m *BotManager) MustAdd(name string, bot *Bot) *BotManager

+ func (m *BotManager) MustGet(name string) *Bot

+ func (m *BotManager) Names() []string

+ func (m *BotManager) Remove(name string) bool

+ func (m *BotManager) RunningBots() []string

+ func (m *BotManager) Shutdown() error

+ func (m *BotManager) ShutdownAsync() <-chan error

+ func (m *BotManager) StartAll() error

+ func (m *BotManager) Status() BotManagerStatus

+ func (m *BotManager) StopAll(ctx context.Context) error

+ func (m *BotManager) WaitForShutdown(timeout ...time.Duration)

+ type BotManagerBuilder struct

+ func NewBotManagerBuilder() *BotManagerBuilder

+ func (b *BotManagerBuilder) AddBot(name string, bot *Bot) *BotManagerBuilder

+ func (b *BotManagerBuilder) AddBuilder(name string, builder *BotBuilder) *BotManagerBuilder

+ func (b *BotManagerBuilder) Build() (*BotManager, error)

+ func (b *BotManagerBuilder) MustBuild() *BotManager

+ type BotManagerError struct

+ Errors []BotError

+ Op string

+ func (e *BotManagerError) Error() string

+ func (e *BotManagerError) FailedBots() []string

+ type BotManagerStatus struct

+ Running int

+ Stopped int

+ Total int

+ Uptime map[string]time.Duration

+ type BotMeta struct

+ Debug bool

+ Name string

+ Version string

+ type BotStatusChecker struct

+ func NewBotStatusChecker(bot *Bot) *BotStatusChecker

+ func (c *BotStatusChecker) Check(_ context.Context) health.CheckResult

+ func (c *BotStatusChecker) Name() string

+ type DLQHealthAdapter struct

+ func NewDLQHealthAdapter(q dlqStater) *DLQHealthAdapter

+ func (a *DLQHealthAdapter) Stats() health.DLQStatsSnapshot

+ type Option func(*Bot)

+ func WithAdapter(adapter platform.Adapter) Option

+ func WithConfig(config *BotMeta) Option

+ func WithDebug(debug bool) Option

+ func WithEngine(engine *engine.Engine) Option

+ func WithName(name string) Option

+ func WithPprof(cfg PprofConfig) Option

+ func WithVersion(version string) Option

+ type PprofConfig struct

+ Addr string

+ AutoProfile bool

+ BlockProfileRate int

+ EnableBlock bool

+ EnableMutex bool

+ Enabled bool

+ MutexProfileFraction int

+ OutputDir string

+ ProfileDuration time.Duration

+ ProfileInterval time.Duration

+ func DefaultPprofConfig() PprofConfig

+ type PprofServer struct

+ func NewPprofServer(config PprofConfig) *PprofServer

+ func (p *PprofServer) Start() error

+ func (p *PprofServer) Stop(ctx context.Context) error