server

Documentation

Index

• func StartPackageRegistryWatcher(parentCtx context.Context, agentfieldHome string, ...) (context.CancelFunc, error)
• func SyncPackagesFromRegistry(agentfieldHome string, storageProvider packageStorage) error
• type AgentFieldServer
  • func NewAgentFieldServer(cfg *config.Config) (*AgentFieldServer, error)
  • func (s *AgentFieldServer) ListReasoners(ctx context.Context, _ *adminpb.ListReasonersRequest) (*adminpb.ListReasonersResponse, error)
  • func (s *AgentFieldServer) Start() error
  • func (s *AgentFieldServer) Stop() error
• type InstallationRegistry
• type InstalledPackage

Functions

func StartPackageRegistryWatcher

func StartPackageRegistryWatcher(parentCtx context.Context, agentfieldHome string, storageProvider packageStorage) (context.CancelFunc, error)

StartPackageRegistryWatcher watches the installed.yaml registry and keeps storage in sync.

func SyncPackagesFromRegistry

func SyncPackagesFromRegistry(agentfieldHome string, storageProvider packageStorage) error

SyncPackagesFromRegistry ensures all packages in installed.yaml are present in the database.

Types

type AgentFieldServer

type AgentFieldServer struct {
	adminpb.UnimplementedAdminReasonerServiceServer

	Router *gin.Engine
	// contains filtered or unexported fields
}

AgentFieldServer represents the core AgentField orchestration service.

func NewAgentFieldServer

func NewAgentFieldServer(cfg *config.Config) (*AgentFieldServer, error)

NewAgentFieldServer creates a new instance of the AgentFieldServer.

func (*AgentFieldServer) ListReasoners

func (s *AgentFieldServer) ListReasoners(ctx context.Context, _ *adminpb.ListReasonersRequest) (*adminpb.ListReasonersResponse, error)

ListReasoners implements the admin gRPC surface for listing registered reasoners.

func (*AgentFieldServer) Start

func (s *AgentFieldServer) Start() error

Start initializes and starts the AgentFieldServer.

func (*AgentFieldServer) Stop

func (s *AgentFieldServer) Stop() error

Stop gracefully shuts down the AgentFieldServer.

type InstallationRegistry

type InstallationRegistry struct {
	Installed map[string]InstalledPackage `yaml:"installed"`
}

InstallationRegistry mirrors the structure of installed.yaml

type InstalledPackage

type InstalledPackage struct {
	Name        string `yaml:"name"`
	Version     string `yaml:"version"`
	Description string `yaml:"description"`
	Path        string `yaml:"path"`
	Source      string `yaml:"source"`
	SourcePath  string `yaml:"source_path"`
	InstalledAt string `yaml:"installed_at"`
	Status      string `yaml:"status"`
	Runtime     struct {
		Port      int    `yaml:"port"`
		PID       int    `yaml:"pid"`
		StartedAt string `yaml:"started_at"`
		LogFile   string `yaml:"log_file"`
	} `yaml:"runtime"`
}