Documentation
¶
Index ¶
- Constants
- type AIMessage
- type AIRequest
- type AIResponse
- type ConsensusPolicy
- type CrashSnapshot
- type CronJob
- type EnginePair
- type FunctionDiscovery
- type Gojinn
- func (*Gojinn) CaddyModule() caddy.ModuleInfo
- func (r *Gojinn) Cleanup() error
- func (r *Gojinn) CreateGlobalSnapshot() (string, error)
- func (g *Gojinn) EnsureTenantResources(tenantID string) (nats.KeyValue, error)
- func (r *Gojinn) EnsureTenantWorkers(tenantID string) error
- func (r *Gojinn) HandleMCPMessage(w http.ResponseWriter, req *http.Request)
- func (r *Gojinn) Provision(ctx caddy.Context) error
- func (g *Gojinn) ReloadWorkers() error
- func (r *Gojinn) RestoreGlobalSnapshot(archivePath string) error
- func (r *Gojinn) SemanticMatch(query string) bool
- func (r *Gojinn) ServeHTTP(rw http.ResponseWriter, req *http.Request, next caddyhttp.Handler) error
- func (r *Gojinn) ServeMCP(w http.ResponseWriter, req *http.Request)
- type HttpContext
- type MQTTSub
- type Permissions
- type ToolDefinition
Constants ¶
View Source
const ( MaxRetries = 5 MaxOutputBytes = 5 * 1024 * 1024 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AIResponse ¶ added in v0.10.0
type AIResponse struct {
Choices []struct {
Message AIMessage `json:"message"`
} `json:"choices"`
}
type ConsensusPolicy ¶ added in v0.26.0
type CrashSnapshot ¶ added in v0.16.0
type EnginePair ¶ added in v0.4.0
type EnginePair struct {
Runtime wazero.Runtime
Code wazero.CompiledModule
}
type FunctionDiscovery ¶ added in v0.24.0
type Gojinn ¶
type Gojinn struct {
Path string `json:"path,omitempty"`
Args []string `json:"args,omitempty"`
Env map[string]string `json:"env,omitempty"`
Timeout caddy.Duration `json:"timeout,omitempty"`
MemoryLimit string `json:"memory_limit,omitempty"`
PoolSize int `json:"pool_size,omitempty"`
DebugSecret string `json:"debug_secret,omitempty"`
RecordCrashes bool `json:"record_crashes,omitempty"`
CrashPath string `json:"crash_path,omitempty"`
DataDir string `json:"data_dir,omitempty"`
TrustedKeys []string `json:"trusted_keys,omitempty"`
SecurityPolicy string `json:"security_policy,omitempty"`
NatsPort int `json:"nats_port,omitempty"`
NatsRoutes []string `json:"nats_routes,omitempty"`
NatsUserSeed string `json:"nats_user_seed,omitempty"`
TrustedNatsUsers []string `json:"trusted_nats_users,omitempty"`
Perms Permissions `json:"permissions,omitempty"`
ExposeAsTool bool `json:"expose_as_tool,omitempty"`
ToolMeta FunctionDiscovery `json:"tool_meta,omitempty"`
FuelLimit uint64 `json:"fuel_limit,omitempty"`
Mounts map[string]string `json:"mounts,omitempty"`
DBDriver string `json:"db_driver,omitempty"`
DBDSN string `json:"db_dsn,omitempty"`
DBSyncURL string `json:"db_sync_url,omitempty"`
DBSyncToken string `json:"db_sync_token,omitempty"`
S3Endpoint string `json:"s3_endpoint,omitempty"`
S3Region string `json:"s3_region,omitempty"`
S3Bucket string `json:"s3_bucket,omitempty"`
S3AccessKey string `json:"s3_access_key,omitempty"`
S3SecretKey string `json:"s3_secret_key,omitempty"`
CronJobs []CronJob `json:"cron_jobs,omitempty"`
MQTTBroker string `json:"mqtt_broker,omitempty"`
MQTTClientID string `json:"mqtt_client_id,omitempty"`
MQTTUsername string `json:"mqtt_username,omitempty"`
MQTTPassword string `json:"mqtt_password,omitempty"`
MQTTSubs []MQTTSub `json:"mqtt_subs,omitempty"`
AIProvider string `json:"ai_provider,omitempty"`
AIModel string `json:"ai_model,omitempty"`
AIEndpoint string `json:"ai_endpoint,omitempty"`
AIToken string `json:"ai_token,omitempty"`
APIKeys []string `json:"api_keys,omitempty"`
AllowedHosts []string `json:"allowed_hosts,omitempty"`
CorsOrigins []string `json:"cors_origins,omitempty"`
RateLimit float64 `json:"rate_limit,omitempty"`
RateBurst int `json:"rate_burst,omitempty"`
ClusterName string `json:"cluster_name,omitempty"`
ClusterPort int `json:"cluster_port,omitempty"`
ClusterPeers []string `json:"cluster_peers,omitempty"`
ClusterReplicas int `json:"cluster_replicas,omitempty"`
Consensus []ConsensusPolicy `json:"consensus,omitempty"`
StoreCipherKey string `json:"store_cipher_key,omitempty"`
ServerName string `json:"server_name,omitempty"`
LeafRemotes []string `json:"leaf_remotes,omitempty"`
LeafPort int `json:"leaf_port,omitempty"`
// contains filtered or unexported fields
}
func (*Gojinn) CaddyModule ¶
func (*Gojinn) CaddyModule() caddy.ModuleInfo
func (*Gojinn) CreateGlobalSnapshot ¶ added in v0.27.0
func (*Gojinn) EnsureTenantResources ¶ added in v0.28.0
func (*Gojinn) EnsureTenantWorkers ¶ added in v0.28.0
func (*Gojinn) HandleMCPMessage ¶ added in v0.24.0
func (r *Gojinn) HandleMCPMessage(w http.ResponseWriter, req *http.Request)
func (*Gojinn) ReloadWorkers ¶ added in v0.18.0
func (*Gojinn) RestoreGlobalSnapshot ¶ added in v0.27.0
func (*Gojinn) SemanticMatch ¶ added in v0.24.0
type HttpContext ¶ added in v0.15.0
type Permissions ¶ added in v0.23.0
type ToolDefinition ¶ added in v0.24.0
Source Files
¶
Click to show internal directories.
Click to hide internal directories.