daemon

package

Go to main page

Versions in this module

v0

v0.5.1

Apr 28, 2026

Changes in this version

type RegisterRequest

+ HostGatewayIP string

type RunContext

+ HostGatewayIP string

v0.5.0

Apr 7, 2026

Changes in this version

type AWSConfig

+ Profile string

type HealthResponse

+ Capabilities []string

+ type PolicyRuleSetSpec struct

+ Deny []string

+ Mode string

+ Scope string

type RegisterRequest

+ AllowedHostPorts []int

+ HostGateway string

+ PolicyRuleSets []PolicyRuleSetSpec

+ PolicyYAML map[string][]byte

type RegisterResponse

+ Error string

type Registry

+ func (r *Registry) UnregisterAndGet(token string) (*RunContext, bool)

+ func (r *Registry) UnregisterAndGetWithCount(token string) (rc *RunContext, found bool, remaining int)

type RunContext

+ AllowedHostPorts []int

+ HostGateway string

+ KeepEngines map[string]*keeplib.Engine

+ func (rc *RunContext) Close()

+ func (rc *RunContext) GetCredentials(host string) []CredentialEntry

+ func (rc *RunContext) SetContainerID(id string)

v0.4.0

Mar 19, 2026

Changes in this version

type CommandContainerChecker

+ func (c *CommandContainerChecker) ForgetContainer(id string)

type RegisterRequest

+ NetworkRules []netrules.HostRules

type RunContext

+ NetworkRules []netrules.HostRules

v0.3.3

Mar 7, 2026

Changes in this version

+ const DefaultProxyPort

v0.3.2

Mar 6, 2026

Changes in this version

+ func RestoreRuns(ctx context.Context, registry *Registry, runs []PersistedRun) int

type LivenessChecker

+ func (lc *LivenessChecker) SetPersister(p *RunPersister)

+ type PersistedRun struct

+ AWSConfig *AWSConfig

+ AuthToken string

+ ContainerID string

+ Grants []string

+ MCPServers []config.MCPServerConfig

+ NetworkAllow []string

+ NetworkPolicy string

+ RunID string

+ TransformerSpecs []TransformerSpec

type RunContext

+ Grants []string

+ type RunPersister struct

+ func NewRunPersister(path string, registry *Registry) *RunPersister

+ func (p *RunPersister) Flush() error

+ func (p *RunPersister) Load() ([]PersistedRun, error)

+ func (p *RunPersister) Save() error

+ func (p *RunPersister) SaveDebounced()

type Server

+ func (s *Server) SetPersister(p *RunPersister)

v0.3.1

Mar 4, 2026

v0.3.0

Mar 4, 2026

Changes in this version

+ var BuildCommit string

+ var ErrRunNotFound = errors.New("run not found")

+ func RemoveLockFile(dir string)

+ func StartTokenRefresh(ctx context.Context, rc *RunContext, grants []string)

+ func WriteLockFile(dir string, info LockInfo) error

+ type AWSConfig struct

+ ExternalID string

+ Region string

+ RoleARN string

+ SessionDuration time.Duration

+ type Client struct

+ func EnsureRunning(dir string, proxyPort int) (*Client, error)

+ func NewClient(sockPath string) *Client

+ func (c *Client) Health(ctx context.Context) (*HealthResponse, error)

+ func (c *Client) ListRuns(ctx context.Context) ([]RunInfo, error)

+ func (c *Client) RegisterRoutes(ctx context.Context, agent string, services map[string]string) error

+ func (c *Client) RegisterRun(ctx context.Context, regReq RegisterRequest) (*RegisterResponse, error)

+ func (c *Client) Shutdown(ctx context.Context) error

+ func (c *Client) UnregisterRoutes(ctx context.Context, agent string) error

+ func (c *Client) UnregisterRun(ctx context.Context, token string) error

+ func (c *Client) UpdateRun(ctx context.Context, token, containerID string) error

+ type CommandContainerChecker struct

+ func NewCommandContainerChecker() *CommandContainerChecker

+ func (c *CommandContainerChecker) IsContainerRunning(ctx context.Context, id string) (bool, error)

+ type ContainerChecker interface

+ IsContainerRunning func(ctx context.Context, id string) (alive bool, err error)

+ type CredentialEntry struct

+ Grant string

+ Name string

+ Value string

+ type CredentialSpec struct

+ Grant string

+ Header string

+ Host string

+ Value string

+ type ExtraHeaderEntry struct

+ Name string

+ Value string

+ type ExtraHeaderSpec struct

+ HeaderName string

+ Host string

+ Value string

+ type HealthResponse struct

+ Commit string

+ PID int

+ ProxyPort int

+ RunCount int

+ StartedAt string

+ type IdleTimer struct

+ func NewIdleTimer(duration time.Duration, callback func()) *IdleTimer

+ func (t *IdleTimer) Cancel()

+ func (t *IdleTimer) Reset()

+ type LivenessChecker struct

+ func NewLivenessChecker(registry *Registry, checker ContainerChecker) *LivenessChecker

+ func (lc *LivenessChecker) CheckOnce(ctx context.Context)

+ func (lc *LivenessChecker) Run(ctx context.Context)

+ func (lc *LivenessChecker) SetOnCleanup(fn func(token, runID string))

+ func (lc *LivenessChecker) SetOnEmpty(fn func())

+ type LockInfo struct

+ Commit string

+ PID int

+ ProxyPort int

+ SockPath string

+ StartedAt time.Time

+ func ReadLockFile(dir string) (*LockInfo, error)

+ func (l *LockInfo) IsAlive() bool

+ type RegisterRequest struct

+ AWSConfig *AWSConfig

+ AuthToken string

+ Credentials []CredentialSpec

+ ExtraHeaders []ExtraHeaderSpec

+ Grants []string

+ MCPServers []config.MCPServerConfig

+ NetworkAllow []string

+ NetworkPolicy string

+ RemoveHeaders []RemoveHeaderSpec

+ ResponseTransformers []TransformerSpec

+ RunID string

+ TokenSubstitutions []TokenSubstitutionSpec

+ func (req *RegisterRequest) ToRunContext() *RunContext

+ type RegisterResponse struct

+ AuthToken string

+ ProxyPort int

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Count() int

+ func (r *Registry) List() []*RunContext

+ func (r *Registry) Lookup(token string) (*RunContext, bool)

+ func (r *Registry) Register(rc *RunContext) string

+ func (r *Registry) RegisterWithToken(rc *RunContext, token string)

+ func (r *Registry) Unregister(token string)

+ func (r *Registry) UpdateContainerID(token, containerID string) bool

+ type RemoveHeaderSpec struct

+ HeaderName string

+ Host string

+ type RouteRegistration struct

+ Services map[string]string

+ type RunContext struct

+ AWSConfig *AWSConfig

+ AuthToken string

+ ContainerID string

+ Credentials map[string]CredentialEntry

+ ExtraHeaders map[string][]ExtraHeaderEntry

+ MCPServers []config.MCPServerConfig

+ NetworkAllow []string

+ NetworkPolicy string

+ RegisteredAt time.Time

+ RemoveHeaders map[string][]string

+ ResponseTransformers map[string][]credential.ResponseTransformer

+ RunID string

+ TokenSubstitutions map[string]TokenSubstitutionEntry

+ TransformerSpecs []TransformerSpec

+ func NewRunContext(runID string) *RunContext

+ func (rc *RunContext) AddExtraHeader(host, headerName, headerValue string)

+ func (rc *RunContext) AddResponseTransformer(host string, transformer credential.ResponseTransformer)

+ func (rc *RunContext) CancelRefresh()

+ func (rc *RunContext) GetContainerID() string

+ func (rc *RunContext) GetCredential(host string) (CredentialEntry, bool)

+ func (rc *RunContext) GetExtraHeaders(host string) []ExtraHeaderEntry

+ func (rc *RunContext) GetRemoveHeaders(host string) []string

+ func (rc *RunContext) GetResponseTransformers(host string) []credential.ResponseTransformer

+ func (rc *RunContext) GetTokenSubstitution(host string) (TokenSubstitutionEntry, bool)

+ func (rc *RunContext) RemoveRequestHeader(host, headerName string)

+ func (rc *RunContext) SetAWSHandler(h http.Handler)

+ func (rc *RunContext) SetCredential(host, value string)

+ func (rc *RunContext) SetCredentialHeader(host, headerName, headerValue string)

+ func (rc *RunContext) SetCredentialWithGrant(host, headerName, headerValue, grant string)

+ func (rc *RunContext) SetRefreshCancel(cancel context.CancelFunc)

+ func (rc *RunContext) SetTokenSubstitution(host, placeholder, realToken string)

+ func (rc *RunContext) ToProxyContextData() *proxy.RunContextData

+ type RunInfo struct

+ ContainerID string

+ RegisteredAt string

+ RunID string

+ type Server struct

+ func NewServer(sockPath string, proxyPort int) *Server

+ func (s *Server) Registry() *Registry

+ func (s *Server) SetOnEmpty(fn func())

+ func (s *Server) SetOnRegister(fn func())

+ func (s *Server) SetOnShutdown(fn func())

+ func (s *Server) SetOnUnregister(fn func(runID string))

+ func (s *Server) SetProxyPort(port int)

+ func (s *Server) SetRoutes(rt *routing.RouteTable)

+ func (s *Server) Start() error

+ func (s *Server) Stop(ctx context.Context) error

+ type TokenSubstitutionEntry struct

+ Placeholder string

+ RealToken string

+ type TokenSubstitutionSpec struct

+ Host string

+ Placeholder string

+ RealToken string

+ type TransformerSpec struct

+ Host string

+ Kind string

+ type UpdateRunRequest struct

+ ContainerID string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL