reflection

Documentation

Index

• func HandleReflectionStatus(w http.ResponseWriter, r *http.Request)
• func HandleReflectionTrigger(w http.ResponseWriter, r *http.Request)
• func RegisterRoutes(mux *http.ServeMux)
• type ReflectionScheduler
  • func GetGlobalReflection() *ReflectionScheduler
  • func GetReflectionScheduler(cfg *config.ReflectionConfig) *ReflectionScheduler
  • func (r *ReflectionScheduler) GetStatus() ReflectionStatus
  • func (r *ReflectionScheduler) IsRunning() bool
  • func (r *ReflectionScheduler) SetDatabase(db *sql.DB)
  • func (r *ReflectionScheduler) Start() error
  • func (r *ReflectionScheduler) Stop()
  • func (r *ReflectionScheduler) TriggerReflection() error
  • func (r *ReflectionScheduler) UpdateConfig(cfg *config.ReflectionConfig) error
• type ReflectionStatus

Functions

func HandleReflectionStatus

func HandleReflectionStatus(w http.ResponseWriter, r *http.Request)

HandleReflectionStatus returns the current reflection scheduler status

func HandleReflectionTrigger

func HandleReflectionTrigger(w http.ResponseWriter, r *http.Request)

HandleReflectionTrigger manually triggers a reflection session

func RegisterRoutes

func RegisterRoutes(mux *http.ServeMux)

RegisterRoutes registers reflection HTTP handlers on the given mux

Types

type ReflectionScheduler

type ReflectionScheduler struct {
	// contains filtered or unexported fields
}

func GetGlobalReflection

func GetGlobalReflection() *ReflectionScheduler

GetGlobalReflection returns the global reflection scheduler (nil if not initialized)

func GetReflectionScheduler

func GetReflectionScheduler(cfg *config.ReflectionConfig) *ReflectionScheduler

GetReflectionScheduler returns the global reflection scheduler instance

func (*ReflectionScheduler) GetStatus

func (r *ReflectionScheduler) GetStatus() ReflectionStatus

GetStatus returns current reflection scheduler status

func (*ReflectionScheduler) IsRunning

func (r *ReflectionScheduler) IsRunning() bool

IsRunning returns whether the reflection scheduler is running

func (*ReflectionScheduler) SetDatabase

func (r *ReflectionScheduler) SetDatabase(db *sql.DB)

SetDatabase sets the database connection

func (*ReflectionScheduler) Start

func (r *ReflectionScheduler) Start() error

Start begins the reflection scheduler

func (*ReflectionScheduler) Stop

func (r *ReflectionScheduler) Stop()

Stop gracefully stops the reflection scheduler

func (*ReflectionScheduler) TriggerReflection

func (r *ReflectionScheduler) TriggerReflection() error

TriggerReflection manually triggers a reflection (for API endpoint)

func (*ReflectionScheduler) UpdateConfig

func (r *ReflectionScheduler) UpdateConfig(cfg *config.ReflectionConfig) error

UpdateConfig updates the reflection configuration (must be called when stopped)

type ReflectionStatus

type ReflectionStatus struct {
	Enabled           bool                     `json:"enabled"`
	Running           bool                     `json:"running"`
	LastReflection    *time.Time               `json:"last_reflection,omitempty"`
	ConversationCount int                      `json:"conversation_count"`
	Config            *config.ReflectionConfig `json:"config"`
}