manager

type BaseManager struct {
	Manager // Embedded interface for type safety
	options.RequiredFields

	AssistantName string
	AssistantID   id.ID

	Ctx           context.Context
	FragmentStore *stores.FragmentStore

	ActorStore   *stores.ActorStore
	SessionStore *stores.SessionStore

	InteractionFragmentStore *stores.FragmentStore

	Cache *cache.Cache

	LLM *llm.LLMClient

	Logger *logger.Logger
	// contains filtered or unexported fields
}

type EventCallbackFunc func(eventData EventData) error

type EventData struct {
	EventType EventType   // Type of the event being triggered
	Data      interface{} // Associated data payload for the event
}

type EventType string

type Manager interface {
	// GetID returns the unique identifier for this manager
	GetID() ManagerID

	// GetDependencies returns a list of other manager IDs that this manager depends on
	GetDependencies() []ManagerID

	// Process performs analysis on the current state
	// This is called explicitly by the agent during message processing
	Process(state *state.State) error

	// PostProcess performs actions based on the current state
	// This is called explicitly by the agent after response generation
	PostProcess(state *state.State) error

	// ProvideContext collects and returns manager-specific data for the current state
	Context(state *state.State) ([]state.StateData, error)

	// StoreFragment persists a message fragment to storage
	Store(fragment *db.Fragment) error

	// StartBackgroundProcesses initializes any background tasks
	StartBackgroundProcesses()

	// StopBackgroundProcesses cleanly shuts down any background tasks
	StopBackgroundProcesses()

	// RegisterEventHandler sets up a callback for handling manager events
	RegisterEventHandler(callback EventCallbackFunc)
	// contains filtered or unexported methods
}

type ManagerID string