@@ -60,7 +60,7 @@ func main() {
6060
6161func run (settings config.Config , logger * zap.Logger ) error {
6262 tlsVerify := ! settings .IgnoreVerifyCerts
63- componentClient , err := component .Connect (component.Options {CoreURL : settings .CoreHost , TLSVerify : tlsVerify , Timeout : settings .HTTPRequestTimeout , Name : settings .Name , BootstrapToken : settings .BootstrapToken , AccessKeyFile : settings .AccessKeyFilePath })
63+ componentClient , err := component .Connect (component.Options {CoreURL : settings .CoreHost , TLSVerify : tlsVerify , Timeout : settings .HTTPRequestTimeout , Name : settings .Name , BootstrapToken : settings .BootstrapToken , AccessKeyFile : settings .AccessKeyFilePath , Logger : logger })
6464 if err != nil {
6565 return err
6666 }
@@ -69,15 +69,8 @@ func run(settings config.Config, logger *zap.Logger) error {
6969 return err
7070 }
7171 defer engine .Close ()
72- var runtimeStore ports.Store
73- switch settings .RuntimeStore {
74- case "core" :
75- runtimeStore , err = store .NewCore (componentClient , settings .RuntimeDataFolderPath )
76- case "jsonl" :
77- runtimeStore , err = store .NewJSONL (settings .RuntimeDataFolderPath )
78- default :
79- return fmt .Errorf ("unsupported runtime store %q" , settings .RuntimeStore )
80- }
72+ retention := store.RetentionOptions {KeepDays : settings .TerminalAIKeepDays , MaxBytes : settings .TerminalAIMaxBytes , MinFreeBytes : settings .TerminalAIMinFreeBytes }
73+ runtimeStore , err := store .NewCore (componentClient , settings .RuntimeDataFolderPath , retention )
8174 if err != nil {
8275 return err
8376 }
@@ -91,7 +84,7 @@ func run(settings config.Config, logger *zap.Logger) error {
9184 return err
9285 }
9386 }
94- runtimeService , err := service .New (service.Options {Store : runtimeStore , Engine : engine , Bus : bus , Logger : logger , InstanceID : settings .Name , Workers : 4 , ToolResultTimeout : settings .ToolResultTimeout , ArtifactDir : settings .ArtifactFolderPath , Capability : capability , StorageKind : settings . RuntimeStore , StorageDurable : true })
87+ runtimeService , err := service .New (service.Options {Store : runtimeStore , Engine : engine , Bus : bus , Logger : logger , InstanceID : settings .Name , Workers : 4 , ToolResultTimeout : settings .ToolResultTimeout , ArtifactDir : settings .ArtifactFolderPath , Capability : capability , StorageKind : "core" , StorageDurable : true })
9588 if err != nil {
9689 return err
9790 }
@@ -114,7 +107,7 @@ func run(settings config.Config, logger *zap.Logger) error {
114107 heartbeatContext , cancelHeartbeat := context .WithCancel (context .Background ())
115108 defer cancelHeartbeat ()
116109 go componentClient .RunHeartbeat (heartbeatContext , logger )
117- logger .Info ("kael started" , zap .String ("address" , httpServer .Addr ), zap .String ("version" , Version ), zap .String ("component" , settings .Name ), zap .String ("model" , engine .Info ().Model ), zap .String ("storage" , settings . RuntimeStore ))
110+ logger .Info ("kael started" , zap .String ("address" , httpServer .Addr ), zap .String ("version" , Version ), zap .String ("component" , settings .Name ), zap .String ("model" , engine .Info ().Model ), zap .String ("storage" , "core" ), zap . String ( "terminal_storage" , "jsonl" ))
118111 signals , stop := signal .NotifyContext (context .Background (), syscall .SIGINT , syscall .SIGTERM )
119112 defer stop ()
120113 var serveErr error
0 commit comments