Documentation
¶
Index ¶
- Constants
- func FormatPlatforms(p []ocispecs.Platform) []string
- type ClientInitOpts
- type NewServerOpts
- type Server
- func (srv *Server) Auth(ctx context.Context) (*auth.RegistryAuthProvider, error)
- func (srv *Server) Buildkit(ctx context.Context) (*buildkit.Client, error)
- func (srv *Server) Cache(ctx context.Context) (dagql.Cache, error)
- func (srv *Server) Close() error
- func (srv *Server) CurrentFunctionCall(ctx context.Context) (*core.FunctionCall, error)
- func (srv *Server) CurrentModule(ctx context.Context) (*core.Module, error)
- func (srv *Server) CurrentServedDeps(ctx context.Context) (*core.ModDeps, error)
- func (srv *Server) DefaultDeps(ctx context.Context) (*core.ModDeps, error)
- func (srv *Server) EngineCacheEntrySetMap(ctx context.Context) (*sync.Map, error)
- func (srv *Server) EngineLocalCacheEntries(ctx context.Context) (*core.EngineCacheEntrySet, error)
- func (srv *Server) EngineLocalCacheKeepBytes() int64
- func (srv *Server) Info(context.Context, *controlapi.InfoRequest) (*controlapi.InfoResponse, error)
- func (srv *Server) LeaseManager() *leaseutil.Manager
- func (srv *Server) ListWorkers(context.Context, *controlapi.ListWorkersRequest) (*controlapi.ListWorkersResponse, error)
- func (srv *Server) LogMetrics(l *logrus.Entry) *logrus.Entry
- func (srv *Server) MainClientCallerID(ctx context.Context) (string, error)
- func (srv *Server) MuxEndpoint(ctx context.Context, path string, handler http.Handler) error
- func (srv *Server) OCIStore() content.Store
- func (srv *Server) Platform() core.Platform
- func (srv *Server) PruneEngineLocalCacheEntries(ctx context.Context) (*core.EngineCacheEntrySet, error)
- func (srv *Server) Register(server *grpc.Server)
- func (srv *Server) Secrets(ctx context.Context) (*core.SecretStore, error)
- func (srv *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (srv *Server) ServeHTTPToNestedClient(w http.ResponseWriter, r *http.Request, execMD *buildkit.ExecutionMetadata)
- func (srv *Server) ServeModule(ctx context.Context, mod *core.Module) error
- func (srv *Server) Services(ctx context.Context) (*core.Services, error)
Constants ¶
const DefaultDiskSpacePercentage int64 = 75
Variables ¶
This section is empty.
Functions ¶
func FormatPlatforms ¶ added in v0.11.8
Types ¶
type ClientInitOpts ¶ added in v0.11.8
type ClientInitOpts struct {
*engine.ClientMetadata
// If the client is running from a function in a module, this is the encoded dagQL ID
// of that module.
EncodedModuleID string
// If the client is running from a function in a module, this is the encoded function call
// metadata (of type core.FunctionCall)
EncodedFunctionCall json.RawMessage
}
type NewServerOpts ¶ added in v0.11.8
type Server ¶ added in v0.11.8
type Server struct {
controlapi.UnimplementedControlServer
SolverCache daggercache.Manager
// contains filtered or unexported fields
}
func NewServer ¶ added in v0.11.8
func NewServer(ctx context.Context, opts *NewServerOpts) (*Server, error)
func (*Server) CurrentFunctionCall ¶ added in v0.11.8
If the current client is coming from a function, return the function call metadata
func (*Server) CurrentModule ¶ added in v0.11.8
If the current client is coming from a function, return the module that function is from
func (*Server) CurrentServedDeps ¶ added in v0.11.8
Return the list of deps being served to the current client
func (*Server) DefaultDeps ¶ added in v0.12.0
The default deps of every user module (currently just core)
func (*Server) EngineCacheEntrySetMap ¶ added in v0.12.0
A map of unique IDs for the result of a given cache entry set query, allowing further queries on the result to operate on a stable result rather than the live state.
func (*Server) EngineLocalCacheEntries ¶ added in v0.12.0
Return all the cache entries in the local cache. No support for filtering yet.
func (*Server) EngineLocalCacheKeepBytes ¶ added in v0.12.0
The KeepBytes setting to use for automatic local cache GC.
func (*Server) Info ¶ added in v0.11.8
func (srv *Server) Info(context.Context, *controlapi.InfoRequest) (*controlapi.InfoResponse, error)
func (*Server) LeaseManager ¶ added in v0.12.0
The lease manager for the engine as a whole
func (*Server) ListWorkers ¶ added in v0.11.8
func (srv *Server) ListWorkers(context.Context, *controlapi.ListWorkersRequest) (*controlapi.ListWorkersResponse, error)
func (*Server) LogMetrics ¶ added in v0.11.8
func (*Server) MainClientCallerID ¶ added in v0.12.0
The ClientID of the main client caller (i.e. the one who created the session, typically the CLI invoked by the user)
func (*Server) MuxEndpoint ¶ added in v0.11.8
Mix in this http endpoint+handler to the current client's session
func (*Server) PruneEngineLocalCacheEntries ¶ added in v0.12.0
func (srv *Server) PruneEngineLocalCacheEntries(ctx context.Context) (*core.EngineCacheEntrySet, error)
Prune everything that is releasable in the local cache. No support for filtering yet.
func (*Server) ServeHTTP ¶ added in v0.11.8
func (srv *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
ServeHTTP serves clients directly hitting the engine API (i.e. main client callers, not nested execs like module functions)
func (*Server) ServeHTTPToNestedClient ¶ added in v0.11.8
func (srv *Server) ServeHTTPToNestedClient(w http.ResponseWriter, r *http.Request, execMD *buildkit.ExecutionMetadata)
ServeHTTPToNestedClient serves nested clients, including module function calls. The only difference is that additional execution metadata is passed alongside the request from the executor. We don't want to put all this execution metadata in http headers since it includes arbitrary values from users in the function call metadata, which can exceed max header size.
func (*Server) ServeModule ¶ added in v0.11.8
Stitch in the given module to the list being served to the current client
Source Files