core

May 14, 2025

Changes in this version

+ func DoHTTPRequest(ctx context.Context, query *Query, req *http.Request, filename string, ...) (_ bkcache.ImmutableRef, _ digest.Digest, _ *http.Response, rerr error)

+ func MountRef(ctx context.Context, ref bkcache.Ref, g bksession.Group, f func(string) error) error

+ func ResolveDepToSource(ctx context.Context, bk *buildkit.Client, dag *dagql.Server, ...) (inst dagql.Instance[*ModuleSource], err error)

+ type CallerStatFS struct

+ func NewCallerStatFS(bk *buildkit.Client) *CallerStatFS

+ func (fs CallerStatFS) Stat(ctx context.Context, path string) (*fsutiltypes.Stat, error)

+ type ChainedCall struct

+ Args map[string]any

+ Method string

+ type CodeGenerator interface

+ Codegen func(context.Context, *ModDeps, dagql.Instance[*ModuleSource]) (*GeneratedCode, error)

+ type CoreDirStatFS struct

+ func NewCoreDirStatFS(dir *Directory, bk *buildkit.Client) *CoreDirStatFS

+ func (fs CoreDirStatFS) Stat(ctx context.Context, path string) (*fsutiltypes.Stat, error)

type Env

+ func (env *Env) IsPrivileged() bool

+ func (env *Env) Privileged() *Env

type FSDagOp

+ Data any

+ func (op FSDagOp) Digest() (digest.Digest, error)

type LLMTokenUsage

+ CachedTokenReads int64

+ CachedTokenWrites int64

type LLMTool

+ Field *ast.FieldDefinition

+ Strict bool

+ type ModuleSourceStatFS struct

+ func NewModuleSourceStatFS(bk *buildkit.Client, src *ModuleSource) *ModuleSourceStatFS

+ func (fs ModuleSourceStatFS) Stat(ctx context.Context, path string) (*fsutiltypes.Stat, error)

+ type ParsedGitRefString struct

+ ModVersion string

+ RepoRoot *vcs.RepoRoot

+ RepoRootSubdir string

+ SourceCloneRef string

+ func ParseGitRefString(ctx context.Context, refString string) (_ ParsedGitRefString, rerr error)

+ func (p *ParsedGitRefString) GetGitRefAndModVersion(ctx context.Context, dag *dagql.Server, pinCommitRef string) (inst dagql.Instance[*GitRef], _ string, rerr error)

+ type ParsedLocalRefString struct

+ ModPath string

+ type ParsedRefString struct

+ Git *ParsedGitRefString

+ Kind ModuleSourceKind

+ Local *ParsedLocalRefString

+ func ParseRefString(ctx context.Context, statFS StatFS, refString string, refPin string) (_ *ParsedRefString, rerr error)

type RawDagOp

+ func (op RawDagOp) Digest() (digest.Digest, error)

+ type Runtime interface

+ Runtime func(context.Context, *ModDeps, dagql.Instance[*ModuleSource]) (*Container, error)

type SDK

+ AsClientGenerator func() (ClientGenerator, bool)

+ AsCodeGenerator func() (CodeGenerator, bool)

+ AsRuntime func() (Runtime, bool)

type Server

+ BuildkitCache func() bkcache.Manager

+ type StatFS interface

+ Stat func(ctx context.Context, path string) (*fsutiltypes.Stat, error)

+ type StatFSFunc func(ctx context.Context, path string) (*fsutiltypes.Stat, error)

+ func (f StatFSFunc) Stat(ctx context.Context, path string) (*fsutiltypes.Stat, error)

May 6, 2025

Changes in this version

+ func DNSConfig(ctx context.Context, query *Query) (*oci.DNSConfig, error)

type GitRepository

+ func (repo *GitRepository) Branches(ctx context.Context, patterns []string) ([]string, error)

type GitRepositoryBackend

+ Branches func(ctx context.Context, patterns []string) (branches []string, err error)

type LocalGitRepository

+ func (repo *LocalGitRepository) Branches(ctx context.Context, patterns []string) ([]string, error)

type RemoteGitRepository

+ func (repo *RemoteGitRepository) Branches(ctx context.Context, patterns []string) ([]string, error)

type SecretStore

+ func (store *SecretStore) GetSecretPlaintextDirect(ctx context.Context, secret *Secret) ([]byte, error)

type Server

+ SecretSalt func() []byte

Apr 25, 2025

Changes in this version

type FSDagOp

+ func (op FSDagOp) Cache() bkcache.Accessor

+ func (op FSDagOp) Group() bksession.Group

type GitRef

+ func (ref *GitRef) Resolve(ctx context.Context) (string, string, error)

type GitRefBackend

+ Resolve func(ctx context.Context) (commit string, ref string, err error)

type LocalGitRef

+ func (ref *LocalGitRef) Resolve(ctx context.Context) (string, string, error)

type RemoteGitRef

+ FullRef string

+ func (ref *RemoteGitRef) Resolve(ctx context.Context) (commit string, fullref string, _ error)

type Server

+ DNS func() *oci.DNSConfig

+ Locker func() *locker.Locker

Apr 22, 2025

Changes in this version

type AnthropicClient

+ func (c *AnthropicClient) IsRetryable(err error) bool

type Binding

+ ExpectedType string

+ func (b *Binding) Clone() *Binding

type Callable

+ CacheConfigForCall func(context.Context, dagql.Object, map[string]dagql.Input, dagql.CacheConfig) (*dagql.CacheConfig, error)

type CallableField

+ func (f *CallableField) CacheConfigForCall(ctx context.Context, parent dagql.Object, args map[string]dagql.Input, ...) (*dagql.CacheConfig, error)

type Env

+ func (env *Env) DeclareOutput(name string, typ dagql.Type, description string) error

+ func (env *Env) Writable() *Env

type GenaiClient

+ func (c *GenaiClient) IsRetryable(err error) bool

type JSON

+ func (p JSON) String() string

type LLM

+ func (llm *LLM) WithoutDefaultSystemPrompt() *LLM

type LLMClient

+ IsRetryable func(err error) bool

type LLMReplayer

+ func (*LLMReplayer) IsRetryable(err error) bool

+ type LLMToolCall struct

+ Function FuncCall

+ ID string

+ Type string

type MCP

+ func (m *MCP) LastResult() dagql.Typed

+ func (m *MCP) Returned() bool

type ModuleFunction

+ func (fn *ModuleFunction) CacheConfigForCall(ctx context.Context, parent dagql.Object, args map[string]dagql.Input, ...) (*dagql.CacheConfig, error)

type OpenAIClient

+ func (c *OpenAIClient) IsRetryable(err error) bool

Apr 14, 2025

Changes in this version

+ func GetContentHashFromDirectory(ctx context.Context, bk *buildkit.Client, dirInst dagql.Instance[*Directory]) (digest.Digest, error)

+ func ResourceTransferPostCall(ctx context.Context, query *Query, sourceClientID string, ids ...*resource.ID) (func(context.Context) error, error)

type Mod

+ GetSource func() *ModuleSource

type ModDeps

+ func (d *ModDeps) LookupDep(name string) (Mod, bool)

type Module

+ func (mod *Module) CacheConfigForCall(ctx context.Context, _ dagql.Object, _ map[string]dagql.Input, ...) (*dagql.CacheConfig, error)

+ func (mod *Module) GetSource() *ModuleSource

type Secret

+ BuildkitSessionID string

+ URI string

Apr 4, 2025

Changes in this version

type Env

+ func (env *Env) MCP(endpoint *LLMEndpoint) *MCP

+ func (env *Env) Root() dagql.Object

+ func (env *Env) WithRoot(root dagql.Object) *Env

type LLM

+ func (llm *LLM) Interject(ctx context.Context) error

type MCP

+ func (m *MCP) IsDone() bool

Apr 1, 2025

Changes in this version

+ var TypesHiddenFromEnvExtensions = []dagql.Typed

+ type Binding struct

+ Description string

+ Key string

+ Value dagql.Typed

+ func (*Binding) Type() *ast.Type

+ func (b *Binding) AsList() (dagql.Enumerable, bool)

+ func (b *Binding) AsObject() (dagql.Object, bool)

+ func (b *Binding) AsString() (string, bool)

+ func (b *Binding) Digest() digest.Digest

+ func (b *Binding) ID() string

+ func (b *Binding) String() string

+ func (b *Binding) TypeName() string

+ type Env struct

+ func NewEnv() *Env

+ func (*Env) Type() *ast.Type

+ func (env *Env) Clone() *Env

+ func (env *Env) Ingest(obj dagql.Object) string

+ func (env *Env) Input(key string) (*Binding, bool)

+ func (env *Env) Inputs() []*Binding

+ func (env *Env) Output(key string) (*Binding, bool)

+ func (env *Env) Outputs() []*Binding

+ func (env *Env) Types() []string

+ func (env *Env) WithInput(key string, val dagql.Typed, description string) *Env

+ func (env *Env) WithOutput(key string, expectedType dagql.Type, description string) *Env

+ func (env *Env) WithoutInput(key string) *Env

+ type EnvHook struct

+ Server *dagql.Server

+ func (s EnvHook) ExtendEnvType(targetType dagql.ObjectType) error

+ func (s EnvHook) InstallObject(targetType dagql.ObjectType)

+ func (s EnvHook) ModuleWithObject(ctx context.Context, mod *Module, targetTypedef *TypeDef) (*Module, error)

+ type EnvID = dagql.ID[*Env]

type LLM

+ func (llm *LLM) BindResult(ctx context.Context, dag *dagql.Server, name string) (dagql.Nullable[*Binding], error)

+ func (llm *LLM) Env() *Env

+ func (llm *LLM) MCP(ctx context.Context, dag *dagql.Server) error

+ func (llm *LLM) WithEnv(env *Env) *LLM

+ type LLMID = dagql.ID[*LLM]

type LLMRouter

+ OpenAIDisableStreaming bool

+ type MCP struct

+ func NewMCP(endpoint *LLMEndpoint) *MCP

+ func (m *MCP) Builtins(srv *dagql.Server) ([]LLMTool, error)

+ func (m *MCP) Call(ctx context.Context, tools []LLMTool, toolCall ToolCall) (string, bool)

+ func (m *MCP) Clone() *MCP

+ func (m *MCP) Current() dagql.Object

+ func (m *MCP) DefaultSystemPrompt() string

+ func (m *MCP) GetObject(key, expectedType string) (dagql.Object, error)

+ func (m *MCP) Select(obj dagql.Object, functions ...string)

+ func (m *MCP) Tools(srv *dagql.Server) ([]LLMTool, error)

+ func (m *MCP) WithEnvironment(env *Env) *MCP

+ type ModelFinishedError struct

+ Reason string

+ func (err *ModelFinishedError) Error() string

+ type TerminalLegacy struct

+ func (*TerminalLegacy) Evaluate(ctx context.Context) (*buildkit.Result, error)

+ func (*TerminalLegacy) Type() *ast.Type

+ func (*TerminalLegacy) TypeDescription() string

Mar 27, 2025

Changes in this version

+ func ToolFunc[T any](fn func(context.Context, T) (any, error)) func(context.Context, any) (any, error)

type LLM

+ func (llm *LLM) TokenUsage(ctx context.Context, dag *dagql.Server) (*LLMTokenUsage, error)

type LLMEnv

+ func (env *LLMEnv) Call(ctx context.Context, tools []LLMTool, toolCall ToolCall) (string, bool)

+ func (env *LLMEnv) DefaultSystemPrompt() string

+ func (env *LLMEnv) GetObject(key, expectedType string) (dagql.Object, error)

+ func (env *LLMEnv) ReadVariable(name string) (string, bool)

+ func (env *LLMEnv) Select(obj dagql.Object, functions ...string)

+ func (env *LLMEnv) WriteVariable(name, value string)

+ type LLMTokenUsage struct

+ InputTokens int64

+ OutputTokens int64

+ TotalTokens int64

+ func (*LLMTokenUsage) Type() *ast.Type

type LLMTool

+ Returns string

Mar 24, 2025

Changes in this version

type LLM

+ func (llm *LLM) CurrentType(ctx context.Context, dag *dagql.Server) (dagql.Nullable[dagql.String], error)

Mar 20, 2025

Changes in this version

+ var TypesHiddenFromModuleSDKs = []dagql.Typed

+ func SupportsDirSlash(ctx context.Context, query *Query) (bool, error)

+ type AnthropicClient struct

+ func (c *AnthropicClient) SendQuery(ctx context.Context, history []ModelMessage, tools []LLMTool) (res *LLMResponse, rerr error)

type Error

+ Values []*ErrorValue

+ func (e *Error) Error() string

+ func (e *Error) Extensions() map[string]any

+ type ErrorValue struct

+ Name string

+ Value JSON

+ func (e *ErrorValue) Type() *ast.Type

+ type FuncCall struct

+ Arguments map[string]any

+ Name string

+ type GenaiClient struct

+ func (c *GenaiClient) SendQuery(ctx context.Context, history []ModelMessage, tools []LLMTool) (_ *LLMResponse, rerr error)

+ type LLM struct

+ Endpoint *LLMEndpoint

+ Query *Query

+ func NewLLM(ctx context.Context, query *Query, model string, maxAPICalls int) (*LLM, error)

+ func (*LLM) Type() *ast.Type

+ func (llm *LLM) Clone() *LLM

+ func (llm *LLM) Get(ctx context.Context, dag *dagql.Server, key string) (dagql.Typed, error)

+ func (llm *LLM) History(ctx context.Context, dag *dagql.Server) ([]string, error)

+ func (llm *LLM) HistoryJSON(ctx context.Context, dag *dagql.Server) (string, error)

+ func (llm *LLM) LastReply(ctx context.Context, dag *dagql.Server) (string, error)

+ func (llm *LLM) Set(ctx context.Context, dag *dagql.Server, key string, value dagql.Typed) (*LLM, error)

+ func (llm *LLM) State(ctx context.Context, dag *dagql.Server) (dagql.Typed, error)

+ func (llm *LLM) Sync(ctx context.Context, dag *dagql.Server) (*LLM, error)

+ func (llm *LLM) ToolsDoc(ctx context.Context, srv *dagql.Server) (string, error)

+ func (llm *LLM) Variables(ctx context.Context, dag *dagql.Server) ([]*LLMVariable, error)

+ func (llm *LLM) With(ctx context.Context, dag *dagql.Server, value dagql.Typed) (*LLM, error)

+ func (llm *LLM) WithModel(ctx context.Context, model string, srv *dagql.Server) (*LLM, error)

+ func (llm *LLM) WithPrompt(ctx context.Context, prompt string, srv *dagql.Server) (*LLM, error)

+ func (llm *LLM) WithPromptFile(ctx context.Context, file *File, srv *dagql.Server) (*LLM, error)

+ func (llm *LLM) WithPromptVar(name, value string) *LLM

+ func (llm *LLM) WithState(ctx context.Context, objID dagql.IDType, srv *dagql.Server) (*LLM, error)

+ func (llm *LLM) WithSystemPrompt(prompt string) *LLM

+ type LLMClient interface

+ SendQuery func(ctx context.Context, history []ModelMessage, tools []LLMTool) (*LLMResponse, error)

+ type LLMEndpoint struct

+ BaseURL string

+ Client LLMClient

+ Key string

+ Model string

+ Provider LLMProvider

+ type LLMEnv struct

+ func NewLLMEnv() *LLMEnv

+ func (env *LLMEnv) Builtins() []LLMTool

+ func (env *LLMEnv) Clone() *LLMEnv

+ func (env *LLMEnv) Current() dagql.Typed

+ func (env *LLMEnv) Get(key string) (dagql.Typed, error)

+ func (env *LLMEnv) Set(key string, value dagql.Typed) string

+ func (env *LLMEnv) Tools(srv *dagql.Server) []LLMTool

+ func (env *LLMEnv) Unset(key string)

+ func (env *LLMEnv) With(val dagql.Typed)

+ type LLMHook struct

+ Server *dagql.Server

+ func (s LLMHook) ExtendLLMType(targetType dagql.ObjectType) error

+ func (s LLMHook) InstallObject(targetType dagql.ObjectType)

+ func (s LLMHook) ModuleWithObject(ctx context.Context, mod *Module, targetTypedef *TypeDef) (*Module, error)

+ type LLMProvider string

+ const Anthropic

+ const DeepSeek

+ const Google

+ const Meta

+ const Mistral

+ const OpenAI

+ const Other

+ type LLMReplayer struct

+ func (c *LLMReplayer) SendQuery(ctx context.Context, history []ModelMessage, tools []LLMTool) (_ *LLMResponse, rerr error)

+ type LLMResponse struct

+ Content string

+ TokenUsage TokenUsage

+ ToolCalls []ToolCall

+ type LLMRouter struct

+ AnthropicAPIKey string

+ AnthropicBaseURL string

+ AnthropicModel string

+ GeminiAPIKey string

+ GeminiBaseURL string

+ GeminiModel string

+ OpenAIAPIKey string

+ OpenAIAzureVersion string

+ OpenAIBaseURL string

+ OpenAIModel string

+ func NewLLMRouter(ctx context.Context, srv *dagql.Server) (_ *LLMRouter, rerr error)

+ func (r *LLMRouter) DefaultModel() string

+ func (r *LLMRouter) LoadConfig(ctx context.Context, getenv func(context.Context, string) (string, error)) error

+ func (r *LLMRouter) Route(model string) (*LLMEndpoint, error)

+ type LLMTool struct

+ Call func(context.Context, any) (any, error)

+ Description string

+ Name string

+ Schema map[string]any

+ type LLMVariable struct

+ Hash string

+ Name string

+ TypeName string

+ func (v *LLMVariable) Type() *ast.Type

+ type ModelMessage struct

+ Content string

+ Role string

+ TokenUsage TokenUsage

+ ToolCallID string

+ ToolCalls []ToolCall

+ ToolErrored bool

+ type OpenAIClient struct

+ func (c *OpenAIClient) SendQuery(ctx context.Context, history []ModelMessage, tools []LLMTool) (_ *LLMResponse, rerr error)

type SDKConfig

+ Config map[string]interface{}

type Server

+ MainClientCallerMetadata func(context.Context) (*engine.ClientMetadata, error)

+ Server func(context.Context) (*dagql.Server, error)

+ type TokenUsage struct

+ InputTokens int64

+ OutputTokens int64

+ TotalTokens int64

+ type ToolCall struct

+ Function FuncCall

+ ID string

+ Type string

Mar 12, 2025

Changes in this version

+ func DagOpFromContext[T buildkit.CustomOp](ctx context.Context) (t T, ok bool)

+ func DagOpInContext[T buildkit.CustomOp](ctx context.Context) bool

+ func ImportFromEngineHost(bk *buildkit.Client, path string, includePatterns []string, ...) llb.State

+ func NewRawDagOp[T dagql.Typed](ctx context.Context, srv *dagql.Server, id *call.ID, inputs []llb.State) (t T, err error)

+ type ClientGenerator interface

+ GenerateClient func(context.Context, dagql.Instance[*ModuleSource], *ModDeps, string, bool) (dagql.Instance[*Directory], error)

+ RequiredClientGenerationFiles func(ctx context.Context) (dagql.Array[dagql.String], error)

type Directory

+ Result bkcache.ImmutableRef

+ func NewDirectoryDagOp(ctx context.Context, srv *dagql.Server, id *call.ID, inputs []llb.State, ...) (*Directory, error)

+ func (dir *Directory) OnRelease(ctx context.Context) error

+ type FSDagOp struct

+ ID *call.ID

+ Path string

+ func (op FSDagOp) Backend() buildkit.CustomOpBackend

+ func (op FSDagOp) CacheKey(ctx context.Context) (key digest.Digest, err error)

+ func (op FSDagOp) CreateRef(ctx context.Context, parent bkcache.ImmutableRef, opts ...bkcache.RefOption) (bkcache.MutableRef, error)

+ func (op FSDagOp) Exec(ctx context.Context, g bksession.Group, inputs []solver.Result, ...) (outputs []solver.Result, err error)

+ func (op FSDagOp) Mount(ctx context.Context, ref bkcache.Ref, f func(string) error) error

+ func (op FSDagOp) Name() string

type File

+ Result bkcache.ImmutableRef

+ func NewFileDagOp(ctx context.Context, srv *dagql.Server, id *call.ID, inputs []llb.State, ...) (*File, error)

+ func (file *File) OnRelease(ctx context.Context) error

type GitRef

+ Backend GitRefBackend

+ func (ref *GitRef) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (ref *GitRef) UseDagOp() bool

+ type GitRefBackend interface

+ Commit func(ctx context.Context) (string, error)

+ Tree func(ctx context.Context, srv *dagql.Server, discard bool) (*Directory, error)

type GitRepository

+ Backend GitRepositoryBackend

+ func (repo *GitRepository) Head(ctx context.Context) (*GitRef, error)

+ func (repo *GitRepository) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (repo *GitRepository) Ref(ctx context.Context, name string) (*GitRef, error)

+ func (repo *GitRepository) Tags(ctx context.Context, patterns []string) ([]string, error)

+ func (repo *GitRepository) UseDagOp() bool

+ type GitRepositoryBackend interface

+ Head func(ctx context.Context) (GitRefBackend, error)

+ Ref func(ctx context.Context, ref string) (GitRefBackend, error)

+ Tags func(ctx context.Context, patterns []string) ([]string, error)

+ type LocalGitRef struct

+ Query *Query

+ Ref string

+ Repo *LocalGitRepository

+ func (ref *LocalGitRef) Commit(ctx context.Context) (string, error)

+ func (ref *LocalGitRef) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (ref *LocalGitRef) Tree(ctx context.Context, srv *dagql.Server, discardGitDir bool) (_ *Directory, rerr error)

+ type LocalGitRepository struct

+ Directory *Directory

+ Query *Query

+ func (repo *LocalGitRepository) Head(ctx context.Context) (GitRefBackend, error)

+ func (repo *LocalGitRepository) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (repo *LocalGitRepository) Ref(ctx context.Context, ref string) (GitRefBackend, error)

+ func (repo *LocalGitRepository) Tags(ctx context.Context, patterns []string) ([]string, error)

type Module

+ func (mod Module) CloneWithoutDefs() *Module

type ModuleSource

+ ConfigClients []*modules.ModuleConfigClient

+ OriginalSubpath string

+ type RawDagOp struct

+ Filename string

+ ID *call.ID

+ func (op RawDagOp) Backend() buildkit.CustomOpBackend

+ func (op RawDagOp) CacheKey(ctx context.Context) (key digest.Digest, err error)

+ func (op RawDagOp) Exec(ctx context.Context, g bksession.Group, inputs []solver.Result, ...) (outputs []solver.Result, retErr error)

+ func (op RawDagOp) Name() string

+ type RemoteGitRef struct

+ Query *Query

+ Ref string

+ Repo *RemoteGitRepository

+ func (ref *RemoteGitRef) Commit(ctx context.Context) (string, error)

+ func (ref *RemoteGitRef) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (ref *RemoteGitRef) Tree(ctx context.Context, srv *dagql.Server, discardGitDir bool) (*Directory, error)

+ type RemoteGitRepository struct

+ AuthHeader *Secret

+ AuthToken *Secret

+ Platform Platform

+ Query *Query

+ SSHAuthSocket *Socket

+ SSHKnownHosts string

+ Services ServiceBindings

+ URL string

+ func (repo *RemoteGitRepository) Head(ctx context.Context) (GitRefBackend, error)

+ func (repo *RemoteGitRepository) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (repo *RemoteGitRepository) Ref(ctx context.Context, ref string) (GitRefBackend, error)

+ func (repo *RemoteGitRepository) Tags(ctx context.Context, patterns []string) ([]string, error)

Feb 27, 2025

Changes in this version

+ func SecretTransferPostCall(ctx context.Context, query *Query, sourceClientID string, ids ...*resource.ID) (func(context.Context) error, error)

type SecretStore

+ func (store *SecretStore) GetSecretNameOrURI(idDgst digest.Digest) (string, bool)

Feb 19, 2025

Changes in this version

+ var ModuleSourceKindDir = ModuleSourceKindEnum.Register("DIR_SOURCE")

+ func GitRefString(cloneRef, sourceRootSubpath, version string) string

type CallOpts

+ SkipCallDigestCacheKey bool

type GitModuleSource

+ RepoRootPath string

+ UnfilteredContextDir dagql.Instance[*Directory]

type LocalModuleSource

+ ContextDirectoryPath string

type Module

+ func (mod *Module) Evaluate(context.Context) (*buildkit.Result, error)

type ModuleFunction

+ func NewModFunction(ctx context.Context, root *Query, mod *Module, objDef *ObjectTypeDef, ...) (*ModuleFunction, error)

type ModuleSource

+ CodegenConfig *modules.ModuleCodegenConfig

+ ConfigDependencies []*modules.ModuleConfigDependency

+ ConfigExists bool

+ Dependencies []dagql.Instance[*ModuleSource]

+ EngineVersion string

+ Git *GitModuleSource

+ IncludePaths []string

+ Local *LocalModuleSource

+ ModuleConfigUserFields modules.ModuleConfigUserFields

+ RebasedIncludePaths []string

+ SDKImpl SDK

+ func (src *ModuleSource) AsString() string

+ func (src *ModuleSource) CalcDigest() digest.Digest

+ func (src *ModuleSource) Evaluate(context.Context) (*buildkit.Result, error)

type ModuleSourceKind

+ func (proto ModuleSourceKind) HumanString() string

Feb 12, 2025

Changes in this version

+ const XXH3

+ func CachePerClientObject[A any](ctx context.Context, _ dagql.Object, _ A, origDgst digest.Digest) (digest.Digest, error)

+ func CachePerClient[P dagql.Typed, A any](ctx context.Context, inst dagql.Instance[P], args A, origDgst digest.Digest) (digest.Digest, error)

+ func HashFrom(ins ...string) digest.Digest

+ type SDKConfig struct

+ Source string

+ func (*SDKConfig) Type() *ast.Type

+ func (*SDKConfig) TypeDescription() string

+ func (sdk SDKConfig) Clone() *SDKConfig

type SecretStore

+ func (store *SecretStore) GetSecretURI(idDgst digest.Digest) (string, bool)

+ func (store *SecretStore) NewSecret(secret *Secret, buildkitSessionID, uri string) error

Jan 29, 2025

Changes in this version

+ var TypeDefKindFloat = TypeDefKinds.Register("FLOAT_KIND", "A float value.")

+ func GetContentHashFromDef(ctx context.Context, bk *buildkit.Client, def *pb.Definition, subdir string) (digest.Digest, error)

+ func MakeDirectoryContentHashed(ctx context.Context, bk *buildkit.Client, dirInst dagql.Instance[*Directory]) (retInst dagql.Instance[*Directory], err error)

Jan 14, 2025

Changes in this version

+ var ErrNoSvcCommand = errors.New("no service command has been set")

type Container

+ DefaultArgs bool

type ModuleSource

+ WithUpdateAllDependencies bool

+ WithUpdateDependencies []string

+ func (src *ModuleSource) ModuleConfigWithUserFields(ctx context.Context) (*modules.ModuleConfigWithUserFields, bool, error)

Dec 11, 2024

Changes in this version

type Container

+ func (container *Container) AsService(ctx context.Context, args ContainerAsServiceArgs) (*Service, error)

+ func (container *Container) AsServiceLegacy(ctx context.Context) (*Service, error)

+ type ContainerAsServiceArgs struct

+ Args []string

+ Expand bool

+ ExperimentalPrivilegedNesting bool

+ InsecureRootCapabilities bool

+ NoInit bool

+ UseEntrypoint bool

+ type Error struct

+ Message string

+ Query *Query

+ func NewError(message string) *Error

+ func (e *Error) Type() *ast.Type

type FunctionCall

+ func (fnCall *FunctionCall) ReturnError(ctx context.Context, errID dagql.ID[*Error]) error

type ModuleSource

+ WithoutDependencies []string

type Service

+ Creator trace.SpanContext

Oct 31, 2024

Changes in this version

+ var ReturnAny = ReturnTypesEnum.Register("ANY", `Any execution (exit codes 0-127)`)

+ var ReturnFailure = ReturnTypesEnum.Register("FAILURE", `A failed execution (exit codes 1-127)`)

+ var ReturnSuccess = ReturnTypesEnum.Register("SUCCESS", `A successful execution (exit code 0)`)

+ var ReturnTypesEnum = dagql.NewEnum[ReturnTypes]()

type ContainerExecOpts

+ Expect ReturnTypes

type EngineCache

+ MaxUsedSpace int

+ MinFreeSpace int

+ ReservedSpace int

type EnumTypeDef

+ SourceMap *SourceMap

type EnumValueTypeDef

+ SourceMap *SourceMap

type FieldTypeDef

+ SourceMap *SourceMap

type Function

+ SourceMap *SourceMap

+ func (fn *Function) WithSourceMap(sourceMap *SourceMap) *Function

type FunctionArg

+ SourceMap *SourceMap

type InterfaceAnnotatedValue

+ func (iface *InterfaceAnnotatedValue) TypeDefinition(views ...string) *ast.Definition

type InterfaceTypeDef

+ SourceMap *SourceMap

+ func (iface *InterfaceTypeDef) WithSourceMap(sourceMap *SourceMap) *InterfaceTypeDef

type ModuleObject

+ func (obj *ModuleObject) TypeDefinition(views ...string) *ast.Definition

type ObjectTypeDef

+ SourceMap *SourceMap

+ func (obj *ObjectTypeDef) WithSourceMap(sourceMap *SourceMap) *ObjectTypeDef

+ type ReturnTypes string

+ func (expect ReturnTypes) Decoder() dagql.InputDecoder

+ func (expect ReturnTypes) ReturnCodes() []int

+ func (expect ReturnTypes) ToLiteral() call.Literal

+ func (expect ReturnTypes) Type() *ast.Type

+ func (expect ReturnTypes) TypeDescription() string

type Server

+ EngineLocalCachePolicy func() bkclient.PruneInfo

+ type SourceMap struct

+ Column int

+ Filename string

+ Line int

+ Module string

+ func (*SourceMap) Type() *ast.Type

+ func (*SourceMap) TypeDescription() string

+ func (sourceMap *SourceMap) TypeDirective() *ast.Directive

+ func (sourceMap SourceMap) Clone() *SourceMap

+ type SourceMapID = dagql.ID[*SourceMap]

Oct 25, 2024

Changes in this version

type Container

+ func (container *Container) FromCanonicalRef(ctx context.Context, refName reference.Canonical, cfgBytes []byte) (*Container, error)

+ func (container *Container) FromRefString(ctx context.Context, addr string) (*Container, error)

type GitModuleSource

+ func (src *GitModuleSource) Pin() string

type ModuleSource

+ func (src *ModuleSource) Pin() (string, error)

Oct 9, 2024

Changes in this version

type ContainerExecOpts

+ Expand bool

+ NoInit bool

type ContainerMount

+ Size int

type GitRepository

+ DiscardGitDir bool

type Service

+ CustomHostname string

+ func (svc *Service) WithHostname(hostname string) *Service

Sep 18, 2024

Changes in this version

type Container

+ Annotations []ContainerAnnotation

+ func (container *Container) WithAnnotation(ctx context.Context, key, value string) (*Container, error)

+ func (container *Container) WithoutAnnotation(ctx context.Context, name string) (*Container, error)

+ func (container *Container) WithoutPaths(ctx context.Context, destPaths ...string) (*Container, error)

+ type ContainerAnnotation struct

+ Key string

+ Value string

+ type SliceSet []T

+ func (s *SliceSet[T]) Append(element T)

Sep 11, 2024

Changes in this version

type ModuleSource

+ func (src *ModuleSource) Digest(ctx context.Context) (string, error)

Aug 30, 2024

Changes in this version

type CallOpts

+ Server *dagql.Server

type FunctionArg

+ DefaultPath string

+ Ignore []string

type GitModuleSource

+ CloneRef string

+ HTMLRepoURL string

type LocalModuleSource

+ RelHostPath string

type ModuleSource

+ func (src *ModuleSource) LoadContext(ctx context.Context, dag *dagql.Server, path string, ignore []string) (inst dagql.Instance[*Directory], err error)

+ func (src *ModuleSource) ResolveContextPathFromCaller(ctx context.Context) (contextRootAbsPath, sourceRootAbsPath string, _ error)

+ func (src *ModuleSource) ResolveContextPathFromModule(ctx context.Context) (contextRootAbsPath, sourceRootAbsPath string, err error)

+ func (src *ModuleSource) SourceRootRelSubPath() (string, error)

+ type SchemeType int

+ const NoScheme

+ const SchemeHTTP

+ const SchemeHTTPS

+ const SchemeSCPLike

+ const SchemeSSH

+ func (s SchemeType) IsSSH() bool

+ func (s SchemeType) Prefix() string

type Server

+ NonModuleParentClientMetadata func(context.Context) (*engine.ClientMetadata, error)

type SocketStore

+ func (store *SocketStore) MountSocket(ctx context.Context, idDgst digest.Digest) (string, func() error, error)

Aug 15, 2024

Changes in this version

type Container

+ func (container *Container) Stderr(ctx context.Context) (string, error)

+ func (container *Container) Stdout(ctx context.Context) (string, error)

+ type ModuleInitConfig struct

+ Merge bool

type ModuleSource

+ WithInitConfig *ModuleInitConfig

Jul 25, 2024

Changes in this version

type CallOpts

+ ParentFields map[string]any

+ ParentTyped dagql.Typed

Jul 18, 2024

Changes in this version

+ func GetClientResourceAccessor(ctx context.Context, parent *Query, externalName string) (string, error)

+ func GetHostIPSocketAccessor(ctx context.Context, query *Query, upstreamHost string, port PortForward) (string, error)

type InterfaceType

+ func (iface *InterfaceType) CollectCoreIDs(ctx context.Context, value dagql.Typed, ids map[digest.Digest]*call.ID) error

type ListType

+ func (t *ListType) CollectCoreIDs(ctx context.Context, value dagql.Typed, ids map[digest.Digest]*call.ID) error

type ModType

+ CollectCoreIDs func(ctx context.Context, value dagql.Typed, ids map[digest.Digest]*call.ID) error

type ModuleEnumType

+ func (m *ModuleEnumType) CollectCoreIDs(ctx context.Context, value dagql.Typed, ids map[digest.Digest]*call.ID) error

type ModuleObjectType

+ func (t *ModuleObjectType) CollectCoreIDs(ctx context.Context, value dagql.Typed, ids map[digest.Digest]*call.ID) error

type NullableType

+ func (t *NullableType) CollectCoreIDs(ctx context.Context, value dagql.Typed, ids map[digest.Digest]*call.ID) error

type PrimitiveType

+ func (t *PrimitiveType) CollectCoreIDs(context.Context, dagql.Typed, map[digest.Digest]*call.ID) error

type Secret

+ IDDigest digest.Digest

+ func (secret *Secret) LLBID() string

type SecretStore

+ func (store *SecretStore) AddSecretFromOtherStore(secret *Secret, otherStore *SecretStore) error

+ func (store *SecretStore) AsBuildkitSecretStore() secrets.SecretStore

+ func (store *SecretStore) GetSecretName(idDgst digest.Digest) (string, bool)

+ func (store *SecretStore) GetSecretPlaintext(idDgst digest.Digest) ([]byte, bool)

+ func (store *SecretStore) HasSecret(idDgst digest.Digest) bool

type Server

+ AddClientResourcesFromID func(ctx context.Context, id *call.ID, sourceClientID string, skipTopLevel bool) error

+ Sockets func(context.Context) (*SocketStore, error)

type Service

+ HostSockets []*Socket

type Socket

+ IDDigest digest.Digest

+ func (socket *Socket) LLBID() string

+ type SocketStore struct

+ func NewSocketStore(bkSessionManager *bksession.Manager) *SocketStore

+ func (store *SocketStore) AddIPSocket(sock *Socket, buildkitSessionID, upstreamHost string, port PortForward) error

+ func (store *SocketStore) AddSocketFromOtherStore(socket *Socket, otherStore *SocketStore) error

+ func (store *SocketStore) AddUnixSocket(sock *Socket, buildkitSessionID, hostPath string) error

+ func (store *SocketStore) CheckAgent(ctx context.Context, req *sshforward.CheckAgentRequest) (*sshforward.CheckAgentResponse, error)

+ func (store *SocketStore) ConnectSocket(ctx context.Context, idDgst digest.Digest) (sshforward.SSH_ForwardAgentClient, error)

+ func (store *SocketStore) ForwardAgent(stream sshforward.SSH_ForwardAgentServer) error

+ func (store *SocketStore) GetSocketPortForward(idDgst digest.Digest) (PortForward, bool)

+ func (store *SocketStore) GetSocketURLEncoded(idDgst digest.Digest) (string, bool)

+ func (store *SocketStore) HasSocket(idDgst digest.Digest) bool

+ func (store *SocketStore) Register(srv *grpc.Server)

Jul 12, 2024

Changes in this version

+ var ErrNoCommand = errors.New("no command has been set")

+ var TypeDefKindEnum = TypeDefKinds.Register("ENUM_KIND", "A GraphQL enum type and its values", ...)

type ContainerExecOpts

+ UseEntrypoint bool

type Directory

+ func (dir *Directory) Terminal(ctx context.Context, svcID *call.ID, ctr *Container, args *TerminalArgs) error

+ type Engine struct

+ Query *Query

+ func (*Engine) Type() *ast.Type

+ func (*Engine) TypeDescription() string

+ type EngineCache struct

+ KeepBytes int

+ Query *Query

+ func (*EngineCache) Type() *ast.Type

+ func (*EngineCache) TypeDescription() string

+ type EngineCacheEntry struct

+ ActivelyUsed bool

+ CreatedTimeUnixNano int

+ Description string

+ DiskSpaceBytes int

+ MostRecentUseTimeUnixNano int

+ func (*EngineCacheEntry) Type() *ast.Type

+ func (*EngineCacheEntry) TypeDescription() string

+ type EngineCacheEntrySet struct

+ DiskSpaceBytes int

+ EntriesList []*EngineCacheEntry

+ EntryCount int

+ func (*EngineCacheEntrySet) Evaluate(context.Context) (*buildkit.Result, error)

+ func (*EngineCacheEntrySet) Type() *ast.Type

+ func (*EngineCacheEntrySet) TypeDescription() string

+ type EnumTypeDef struct

+ Description string

+ Name string

+ OriginalName string

+ SourceModuleName string

+ Values []*EnumValueTypeDef

+ func NewEnumTypeDef(name, description string) *EnumTypeDef

+ func (*EnumTypeDef) Type() *ast.Type

+ func (*EnumTypeDef) TypeDescription() string

+ func (enum *EnumTypeDef) ListValues() ast.EnumValueList

+ func (enum EnumTypeDef) Clone() *EnumTypeDef

+ type EnumValueTypeDef struct

+ Description string

+ Name string

+ OriginalName string

+ func NewEnumValueTypeDef(name, description string) *EnumValueTypeDef

+ func (*EnumValueTypeDef) Type() *ast.Type

+ func (*EnumValueTypeDef) TypeDescription() string

+ func (enumValue EnumValueTypeDef) Clone() *EnumValueTypeDef

type Mod

+ View func() (string, bool)

type ModDeps

+ func (d *ModDeps) Clone() *ModDeps

type Module

+ EnumDefs []*TypeDef

+ func (mod *Module) View() (string, bool)

+ func (mod *Module) WithEnum(ctx context.Context, def *TypeDef) (*Module, error)

+ type ModuleEnum struct

+ OriginalValue string

+ TypeDef *EnumTypeDef

+ Value string

+ func (e *ModuleEnum) DecodeInput(val any) (dagql.Input, error)

+ func (e *ModuleEnum) Decoder() dagql.InputDecoder

+ func (e *ModuleEnum) Install(dag *dagql.Server) error

+ func (e *ModuleEnum) Lookup(val string) (dagql.Input, error)

+ func (e *ModuleEnum) MarshalJSON() ([]byte, error)

+ func (e *ModuleEnum) PossibleValues() ast.EnumValueList

+ func (e *ModuleEnum) ToLiteral() call.Literal

+ func (e *ModuleEnum) Type() *ast.Type

+ func (e *ModuleEnum) TypeDefinition(views ...string) *ast.Definition

+ func (e *ModuleEnum) TypeDescription() string

+ func (e *ModuleEnum) TypeName() string

+ type ModuleEnumType struct

+ func (m *ModuleEnumType) ConvertFromSDKResult(ctx context.Context, value any) (dagql.Typed, error)

+ func (m *ModuleEnumType) ConvertToSDKInput(ctx context.Context, value dagql.Typed) (any, error)

+ func (m *ModuleEnumType) SourceMod() Mod

+ func (m *ModuleEnumType) TypeDef() *TypeDef

type ModuleSource

+ func (src *ModuleSource) ModuleEngineVersion(ctx context.Context) (string, error)

type Query

+ func (q *Query) RequireMainClient(ctx context.Context) error

type Server

+ Auth func(context.Context) (*auth.RegistryAuthProvider, error)

+ Buildkit func(context.Context) (*buildkit.Client, error)

+ Cache func(context.Context) (dagql.Cache, error)

+ DefaultDeps func(context.Context) (*ModDeps, error)

+ EngineCacheEntrySetMap func(context.Context) (*sync.Map, error)

+ EngineLocalCacheEntries func(context.Context) (*EngineCacheEntrySet, error)

+ EngineLocalCacheKeepBytes func() int64

+ LeaseManager func() *leaseutil.Manager

+ MainClientCallerID func(context.Context) (string, error)

+ OCIStore func() content.Store

+ Platform func() Platform

+ PruneEngineLocalCacheEntries func(context.Context) (*EngineCacheEntrySet, error)

+ Secrets func(context.Context) (*SecretStore, error)

+ Services func(context.Context) (*Services, error)

type Services

+ func (ss *Services) StopSessionServices(ctx context.Context, sessionID string) error

type TypeDef

+ AsEnum dagql.Nullable[*EnumTypeDef]

+ func (typeDef *TypeDef) WithEnum(name, desc string) *TypeDef

+ func (typeDef *TypeDef) WithEnumValue(name, desc string) (*TypeDef, error)

Jun 18, 2024

Changes in this version

type ContainerExecOpts

+ NestedExecMetadata *buildkit.ExecutionMetadata

type GitModuleSource

+ Root string

type JSON

+ func (p *JSON) UnmarshalJSON(bs []byte) error

type QueryOpts

+ Buildkit *buildkit.Client

+ type Server interface

+ CurrentFunctionCall func(context.Context) (*FunctionCall, error)

+ CurrentModule func(context.Context) (*Module, error)

+ CurrentServedDeps func(context.Context) (*ModDeps, error)

+ MuxEndpoint func(context.Context, string, http.Handler) error

+ ServeModule func(context.Context, *Module) error

type ServiceKey

+ SessionID string

Jun 11, 2024

Changes in this version

+ func AroundFunc(ctx context.Context, self dagql.Object, id *call.ID) (context.Context, func(res dagql.Typed, cached bool, rerr error))

type FunctionCall

+ SpanContext trace.SpanContext

type ModDeps

+ func (d *ModDeps) SchemaIntrospectionJSONFile(ctx context.Context) (inst dagql.Instance[*File], _ error)

May 30, 2024

Changes in this version

type File

+ func (file *File) WithName(ctx context.Context, filename string) (*File, error)

May 9, 2024

Changes in this version

type FunctionCall

+ OTELEnvs []string

May 8, 2024

Changes in this version

+ var TypeDefKindScalar = TypeDefKinds.Register("SCALAR_KIND", "A scalar value of any basic kind.")

type Container

+ SystemEnvNames []string

+ func (container *Container) WithoutPath(ctx context.Context, destPath string) (*Container, error)

+ func (container *Container) WithoutSecretVariable(ctx context.Context, name string) (*Container, error)

type ContainerExecOpts

+ NestedExecFunctionCall *FunctionCall

type FunctionCall

+ Cache bool

+ Module *Module

+ SkipSelfSchema bool

type Query

+ func (q *Query) RegisterCaller(ctx context.Context, call *FunctionCall) (string, error)

+ func (q *Query) ServeModule(ctx context.Context, mod *Module) error

type QueryOpts

+ MainClientCallerID string

+ type ScalarTypeDef struct

+ Description string

+ Name string

+ OriginalName string

+ SourceModuleName string

+ func NewScalarTypeDef(name, description string) *ScalarTypeDef

+ func (*ScalarTypeDef) Type() *ast.Type

+ func (typeDef *ScalarTypeDef) TypeDescription() string

+ func (typeDef ScalarTypeDef) Clone() *ScalarTypeDef

type Service

+ HostSessionID string

type Socket

+ SessionID string

type TypeDef

+ AsScalar dagql.Nullable[*ScalarTypeDef]

+ func (typeDef *TypeDef) WithScalar(name string, desc string) *TypeDef

Apr 16, 2024

Changes in this version

type GitRepository

+ AuthHeader *Secret

+ AuthToken *Secret

Apr 4, 2024

Changes in this version

+ const InstrumentationLibrary

+ func Tracer() trace.Tracer

Mar 26, 2024

Changes in this version

type ModuleSource

+ WithViews []*ModuleSourceView

+ func (src *ModuleSource) AutomaticGitignore(ctx context.Context) (*bool, error)

+ func (src *ModuleSource) ViewByName(ctx context.Context, viewName string) (*ModuleSourceView, error)

+ func (src *ModuleSource) Views(ctx context.Context) ([]*ModuleSourceView, error)

+ type ModuleSourceView struct

+ func (v *ModuleSourceView) Type() *ast.Type

+ func (v *ModuleSourceView) TypeDescription() string

Mar 12, 2024

Changes in this version

type ClientCallContext

+ Root *Query

+ type QueryOpts struct

+ Auth *auth.RegistryAuthProvider

+ BuildkitOpts *buildkit.Opts

+ Cache dagql.Cache

+ ClientCallContext map[digest.Digest]*ClientCallContext

+ ClientCallMu *sync.RWMutex

+ DefaultDeps *ModDeps

+ EndpointMu *sync.RWMutex

+ Endpoints map[string]http.Handler

+ LeaseManager *leaseutil.Manager

+ OCIStore content.Store

+ Platform Platform

+ ProgrockSocketPath string

+ Recorder *progrock.Recorder

+ Secrets *SecretStore

+ Services *Services

Mar 5, 2024

Changes in this version

+ type DefaultTerminalCmdOpts struct

+ Args []string

+ ExperimentalPrivilegedNesting bool

+ InsecureRootCapabilities bool

+ type TerminalArgs struct

+ Cmd []string

+ ExperimentalPrivilegedNesting *bool

+ InsecureRootCapabilities *bool

Feb 27, 2024

Changes in this version

+ var ErrNoCurrentModule = fmt.Errorf("no current module")

+ func GetLocalSecretAccessor(ctx context.Context, parent *Query, name string) (string, error)

+ func NewSecretAccessor(name string, scope string) string

type Secret

+ Accessor string

Feb 12, 2024

Changes in this version

type Container

+ func (container *Container) WithFiles(ctx context.Context, destDir string, src []*File, permissions *int, ...) (*Container, error)

type Directory

+ func (dir *Directory) WithFiles(ctx context.Context, destDir string, src []*File, permissions *int, ...) (*Directory, error)

Feb 9, 2024

Changes in this version

type ClientCallContext

+ Module *Module

type Container

+ DefaultTerminalCmd []string

type GitModuleSource

+ ContextDirectory dagql.Instance[*Directory]

+ RootSubpath string

+ func (src *GitModuleSource) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (src *GitModuleSource) RefString() string

type LocalModuleSource

+ ContextDirectory dagql.Instance[*Directory]

+ RootSubpath string

+ func (src *LocalModuleSource) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (src *LocalModuleSource) RefString() string

type Module

+ GeneratedContextDirectory dagql.Instance[*Directory]

+ OriginalSDK string

+ func (mod *Module) IDModule() *idproto.Module

type ModuleSource

+ Query *Query

+ WithDependencies []dagql.Instance[*ModuleDependency]

+ WithName string

+ WithSDK string

+ WithSourceSubpath string

+ func (src *ModuleSource) ContextDirectory() (inst dagql.Instance[*Directory], err error)

+ func (src *ModuleSource) ModuleConfig(ctx context.Context) (*modules.ModuleConfig, bool, error)

+ func (src *ModuleSource) ModuleOriginalName(ctx context.Context) (string, error)

+ func (src *ModuleSource) SDK(ctx context.Context) (string, error)

+ func (src *ModuleSource) SourceRootSubpath() (string, error)

+ func (src *ModuleSource) SourceSubpath(ctx context.Context) (string, error)

+ func (src *ModuleSource) SourceSubpathWithDefault(ctx context.Context) (string, error)

type SDK

+ RequiredPaths func(context.Context) ([]string, error)

Feb 1, 2024

Changes in this version

+ const TerminateGracePeriod

+ var ModuleSourceKindEnum = dagql.NewEnum[ModuleSourceKind]()

+ var ModuleSourceKindGit = ModuleSourceKindEnum.Register("GIT_SOURCE")

+ var ModuleSourceKindLocal = ModuleSourceKindEnum.Register("LOCAL_SOURCE")

+ var TypeDefKindInput = TypeDefKinds.Register("INPUT_KIND", ...)

type ClientCallContext

+ ProgrockParent string

type Container

+ DefaultShell []string

+ func (container *Container) Terminal(svcID *idproto.ID, args []string) (*Terminal, http.Handler, error)

+ type CurrentModule struct

+ Module dagql.Instance[*Module]

+ func (*CurrentModule) Type() *ast.Type

+ func (*CurrentModule) TypeDescription() string

+ func (mod CurrentModule) Clone() *CurrentModule

type Directory

+ func (dir *Directory) AsBlob(ctx context.Context, srv *dagql.Server) (inst dagql.Instance[*Directory], rerr error)

+ type GitModuleSource struct

+ Commit string

+ Subpath string

+ URLParent string

+ Version string

+ func (src *GitModuleSource) CloneURL() string

+ func (src *GitModuleSource) HTMLURL() string

+ func (src *GitModuleSource) String() string

+ func (src *GitModuleSource) Symbolic() string

+ func (src *GitModuleSource) Type() *ast.Type

+ func (src *GitModuleSource) TypeDescription() string

+ func (src GitModuleSource) Clone() *GitModuleSource

+ type GitModuleSourceID = dagql.ID[*GitModuleSource]

+ type InputTypeDef struct

+ Fields []*FieldTypeDef

+ Name string

+ func (*InputTypeDef) Type() *ast.Type

+ func (*InputTypeDef) TypeDescription() string

+ func (typeDef *InputTypeDef) ToInputObjectSpec() dagql.InputObjectSpec

+ func (typeDef InputTypeDef) Clone() *InputTypeDef

+ type LocalModuleSource struct

+ Subpath string

+ func (src *LocalModuleSource) String() (string, error)

+ func (src *LocalModuleSource) Symbolic() (string, error)

+ func (src *LocalModuleSource) Type() *ast.Type

+ func (src *LocalModuleSource) TypeDescription() string

+ func (src LocalModuleSource) Clone() *LocalModuleSource

+ type LocalModuleSourceID = dagql.ID[*LocalModuleSource]

type Module

+ DirectoryExcludeConfig []string

+ DirectoryIncludeConfig []string

+ GeneratedSourceRootDirectory dagql.Instance[*Directory]

+ GeneratedSourceSubpath string

+ OriginalName string

+ Source dagql.Instance[*ModuleSource]

+ func (mod *Module) WithDependencies(ctx context.Context, srv *dagql.Server, dependencies []*ModuleDependency) (*Module, error)

+ func (mod *Module) WithDescription(desc string) *Module

+ func (mod *Module) WithName(ctx context.Context, name string) (*Module, error)

+ func (mod *Module) WithSDK(ctx context.Context, sdk string) (*Module, error)

+ type ModuleDependency struct

+ Name string

+ Source dagql.Instance[*ModuleSource]

+ func (*ModuleDependency) Type() *ast.Type

+ func (*ModuleDependency) TypeDescription() string

+ func (dep ModuleDependency) Clone() *ModuleDependency

+ type ModuleDependencyID = dagql.ID[*ModuleDependency]

+ type ModuleSource struct

+ AsGitSource dagql.Nullable[*GitModuleSource]

+ AsLocalSource dagql.Nullable[*LocalModuleSource]

+ Kind ModuleSourceKind

+ RootDirectory dagql.Instance[*Directory]

+ func (src *ModuleSource) ModuleName(ctx context.Context) (string, error)

+ func (src *ModuleSource) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (src *ModuleSource) RefString() (string, error)

+ func (src *ModuleSource) Subpath() (string, error)

+ func (src *ModuleSource) Symbolic() (string, error)

+ func (src *ModuleSource) Type() *ast.Type

+ func (src *ModuleSource) TypeDescription() string

+ func (src ModuleSource) Clone() *ModuleSource

+ type ModuleSourceID = dagql.ID[*ModuleSource]

+ type ModuleSourceKind string

+ func (proto ModuleSourceKind) Decoder() dagql.InputDecoder

+ func (proto ModuleSourceKind) ToLiteral() *idproto.Literal

+ func (proto ModuleSourceKind) Type() *ast.Type

+ func (proto ModuleSourceKind) TypeDescription() string

type Port

+ ExperimentalSkipHealthcheck bool

+ type Terminal struct

+ Endpoint string

+ func (*Terminal) Type() *ast.Type

+ func (*Terminal) TypeDescription() string

+ func (term *Terminal) WebsocketURL() string

type TypeDef

+ AsInput dagql.Nullable[*InputTypeDef]

Jan 19, 2024

Changes in this version

+ const ModuleName

+ var CacheSharingModes = dagql.NewEnum[CacheSharingMode]()

+ var ImageLayerCompressions = dagql.NewEnum[ImageLayerCompression]()

+ var ImageMediaTypesEnum = dagql.NewEnum[ImageMediaTypes]()

+ var NetworkProtocols = dagql.NewEnum[NetworkProtocol]()

+ var TypeDefKinds = dagql.NewEnum[TypeDefKind]()

+ func LoadBlob(ctx context.Context, srv *dagql.Server, desc specs.Descriptor) (i dagql.Instance[*Directory], err error)

+ func LoadRef(ctx context.Context, srv *dagql.Server, sourceDir dagql.Instance[*Directory], ...) (dagql.Instance[*Module], error)

type BuildArg

+ func (BuildArg) TypeDescription() string

+ func (BuildArg) TypeName() string

type CacheSharingMode

+ func (mode CacheSharingMode) Decoder() dagql.InputDecoder

+ func (mode CacheSharingMode) ToLiteral() *idproto.Literal

+ func (mode CacheSharingMode) Type() *ast.Type

+ func (mode CacheSharingMode) TypeDescription() string

type CacheVolume

+ func (*CacheVolume) Type() *ast.Type

+ func (*CacheVolume) TypeDescription() string

+ type CallOpts struct

+ Cache bool

+ Inputs []CallInput

+ ParentVal map[string]any

+ Pipeline pipeline.Path

+ SkipSelfSchema bool

+ type Callable interface

+ ArgType func(argName string) (ModType, error)

+ Call func(context.Context, *idproto.ID, *CallOpts) (dagql.Typed, error)

+ ReturnType func() (ModType, error)

+ type CallableField struct

+ Field *FieldTypeDef

+ Module *Module

+ Return ModType

+ func (f *CallableField) ArgType(argName string) (ModType, error)

+ func (f *CallableField) Call(ctx context.Context, id *idproto.ID, opts *CallOpts) (dagql.Typed, error)

+ func (f *CallableField) ReturnType() (ModType, error)

+ type ClientCallContext struct

+ Deps *ModDeps

+ FnCall *FunctionCall

+ ModID *idproto.ID

type Container

+ Query *Query

+ func (*Container) Type() *ast.Type

+ func (*Container) TypeDescription() string

type ContainerSocket

+ ContainerPath string

+ Source *Socket

type Directory

+ Query *Query

+ func (*Directory) Type() *ast.Type

+ func (*Directory) TypeDescription() string

+ type DynamicID struct

+ func (d DynamicID) DecodeInput(val any) (dagql.Input, error)

+ func (d DynamicID) Decoder() dagql.InputDecoder

+ func (d DynamicID) ID() *idproto.ID

+ func (d DynamicID) MarshalJSON() ([]byte, error)

+ func (d DynamicID) ToLiteral() *idproto.Literal

+ func (d DynamicID) Type() *ast.Type

+ func (d DynamicID) TypeName() string

type FieldTypeDef

+ func (*FieldTypeDef) Type() *ast.Type

+ func (*FieldTypeDef) TypeDescription() string

type File

+ Query *Query

+ func (*File) Type() *ast.Type

+ func (*File) TypeDescription() string

type Function

+ func (*Function) Type() *ast.Type

+ func (*Function) TypeDescription() string

+ func (fn *Function) FieldSpec() (dagql.FieldSpec, error)

+ func (fn *Function) LookupArg(name string) (*FunctionArg, bool)

type FunctionArg

+ func (*FunctionArg) Type() *ast.Type

+ func (*FunctionArg) TypeDescription() string

type FunctionCall

+ Query *Query

+ func (*FunctionCall) Type() *ast.Type

+ func (*FunctionCall) TypeDescription() string

+ func (fnCall *FunctionCall) ReturnValue(ctx context.Context, val JSON) error

+ type FunctionCallArgValue struct

+ Name string

+ Value JSON

+ func (*FunctionCallArgValue) Type() *ast.Type

+ func (*FunctionCallArgValue) TypeDescription() string

type GeneratedCode

+ func (*GeneratedCode) Type() *ast.Type

+ func (*GeneratedCode) TypeDescription() string

+ func (code *GeneratedCode) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

type GitRef

+ Query *Query

+ func (*GitRef) Type() *ast.Type

+ func (*GitRef) TypeDescription() string

type GitRepository

+ Query *Query

+ func (*GitRepository) Type() *ast.Type

+ func (*GitRepository) TypeDescription() string

type Host

+ Query *Query

+ func (*Host) Type() *ast.Type

+ func (*Host) TypeDescription() string

+ func (host *Host) SetSecretFile(ctx context.Context, srv *dagql.Server, secretName string, path string) (i dagql.Instance[*Secret], err error)

type ImageLayerCompression

+ func (proto ImageLayerCompression) Decoder() dagql.InputDecoder

+ func (proto ImageLayerCompression) ToLiteral() *idproto.Literal

+ func (proto ImageLayerCompression) Type() *ast.Type

+ func (proto ImageLayerCompression) TypeDescription() string

type ImageMediaTypes

+ func (proto ImageMediaTypes) Decoder() dagql.InputDecoder

+ func (proto ImageMediaTypes) ToLiteral() *idproto.Literal

+ func (proto ImageMediaTypes) Type() *ast.Type

+ func (proto ImageMediaTypes) TypeDescription() string

+ type InterfaceAnnotatedValue struct

+ Fields map[string]any

+ IfaceType *InterfaceType

+ TypeDef *InterfaceTypeDef

+ UnderlyingType ModType

+ func (iface *InterfaceAnnotatedValue) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (iface *InterfaceAnnotatedValue) Type() *ast.Type

+ func (iface *InterfaceAnnotatedValue) TypeDescription() string

+ type InterfaceType struct

+ func (iface *InterfaceType) ConvertFromSDKResult(ctx context.Context, value any) (dagql.Typed, error)

+ func (iface *InterfaceType) ConvertToSDKInput(ctx context.Context, value dagql.Typed) (any, error)

+ func (iface *InterfaceType) Install(ctx context.Context, dag *dagql.Server) error

+ func (iface *InterfaceType) SourceMod() Mod

+ func (iface *InterfaceType) TypeDef() *TypeDef

type InterfaceTypeDef

+ func (*InterfaceTypeDef) Type() *ast.Type

+ func (*InterfaceTypeDef) TypeDescription() string

+ type JSON json.RawMessage

+ func (JSON) DecodeInput(val any) (res dagql.Input, err error)

+ func (p JSON) Bytes() []byte

+ func (p JSON) Decoder() dagql.InputDecoder

+ func (p JSON) MarshalJSON() ([]byte, error)

+ func (p JSON) ToLiteral() *idproto.Literal

+ func (p JSON) Type() *ast.Type

+ func (p JSON) TypeDescription() string

+ func (p JSON) TypeName() string

+ type ListType struct

+ Elem *TypeDef

+ Underlying ModType

+ func (t *ListType) ConvertFromSDKResult(ctx context.Context, value any) (dagql.Typed, error)

+ func (t *ListType) ConvertToSDKInput(ctx context.Context, value dagql.Typed) (any, error)

+ func (t *ListType) SourceMod() Mod

+ func (t *ListType) TypeDef() *TypeDef

type ListTypeDef

+ func (*ListTypeDef) Type() *ast.Type

+ func (*ListTypeDef) TypeDescription() string

+ type Mod interface

+ Dependencies func() []Mod

+ Install func(context.Context, *dagql.Server) error

+ ModTypeFor func(ctx context.Context, typeDef *TypeDef, checkDirectDeps bool) (ModType, bool, error)

+ Name func() string

+ TypeDefs func(ctx context.Context) ([]*TypeDef, error)

+ type ModDeps struct

+ Mods []Mod

+ func NewModDeps(root *Query, mods []Mod) *ModDeps

+ func (d *ModDeps) Append(mods ...Mod) *ModDeps

+ func (d *ModDeps) ModTypeFor(ctx context.Context, typeDef *TypeDef) (ModType, bool, error)

+ func (d *ModDeps) Prepend(mods ...Mod) *ModDeps

+ func (d *ModDeps) Schema(ctx context.Context) (*dagql.Server, error)

+ func (d *ModDeps) SchemaIntrospectionJSON(ctx context.Context) (string, error)

+ func (d *ModDeps) TypeDefs(ctx context.Context) ([]*TypeDef, error)

+ type ModType interface

+ ConvertFromSDKResult func(ctx context.Context, value any) (dagql.Typed, error)

+ ConvertToSDKInput func(ctx context.Context, value dagql.Typed) (any, error)

+ SourceMod func() Mod

+ TypeDef func() *TypeDef

type Module

+ DependenciesField []dagql.Instance[*Module]

+ Deps *ModDeps

+ GeneratedCode *GeneratedCode

+ InstanceID *idproto.ID

+ InterfaceDefs []*TypeDef

+ NameField string

+ ObjectDefs []*TypeDef

+ Query *Query

+ SDKConfig string

+ func (*Module) Type() *ast.Type

+ func (*Module) TypeDescription() string

+ func (mod *Module) DependencySchemaIntrospectionJSON(ctx context.Context) (string, error)

+ func (mod *Module) Initialize(ctx context.Context, oldSelf dagql.Instance[*Module], newID *idproto.ID) (*Module, error)

+ func (mod *Module) Install(ctx context.Context, dag *dagql.Server) error

+ func (mod *Module) ModTypeFor(ctx context.Context, typeDef *TypeDef, checkDirectDeps bool) (ModType, bool, error)

+ func (mod *Module) TypeDefs(ctx context.Context) ([]*TypeDef, error)

+ type ModuleFunction struct

+ func (fn *ModuleFunction) ArgType(argName string) (ModType, error)

+ func (fn *ModuleFunction) Call(ctx context.Context, caller *idproto.ID, opts *CallOpts) (t dagql.Typed, rerr error)

+ func (fn *ModuleFunction) ReturnType() (ModType, error)

+ type ModuleObject struct

+ Fields map[string]any

+ Module *Module

+ TypeDef *ObjectTypeDef

+ func (obj *ModuleObject) Install(ctx context.Context, dag *dagql.Server) error

+ func (obj *ModuleObject) PBDefinitions(ctx context.Context) ([]*pb.Definition, error)

+ func (obj *ModuleObject) Type() *ast.Type

+ func (obj *ModuleObject) TypeDescription() string

+ type ModuleObjectType struct

+ func (t *ModuleObjectType) ConvertFromSDKResult(ctx context.Context, value any) (dagql.Typed, error)

+ func (t *ModuleObjectType) ConvertToSDKInput(ctx context.Context, value dagql.Typed) (any, error)

+ func (t *ModuleObjectType) GetCallable(ctx context.Context, name string) (Callable, error)

+ func (t *ModuleObjectType) SourceMod() Mod

+ func (t *ModuleObjectType) TypeDef() *TypeDef

type NetworkProtocol

+ func (proto NetworkProtocol) Decoder() dagql.InputDecoder

+ func (proto NetworkProtocol) ToLiteral() *idproto.Literal

+ func (proto NetworkProtocol) Type() *ast.Type

+ func (proto NetworkProtocol) TypeDescription() string

+ type NullableType struct

+ Inner ModType

+ InnerDef *TypeDef

+ func (t *NullableType) ConvertFromSDKResult(ctx context.Context, value any) (dagql.Typed, error)

+ func (t *NullableType) ConvertToSDKInput(ctx context.Context, value dagql.Typed) (any, error)

+ func (t *NullableType) SourceMod() Mod

+ func (t *NullableType) TypeDef() *TypeDef

type ObjectTypeDef

+ func (*ObjectTypeDef) Type() *ast.Type

+ func (*ObjectTypeDef) TypeDescription() string

+ func (obj *ObjectTypeDef) FieldByOriginalName(name string) (*FieldTypeDef, bool)

+ type Platform specs.Platform

+ func (Platform) DecodeInput(val any) (dagql.Input, error)

+ func (p Platform) Decoder() dagql.InputDecoder

+ func (p Platform) Format() string

+ func (p Platform) MarshalJSON() ([]byte, error)

+ func (p Platform) Spec() specs.Platform

+ func (p Platform) ToLiteral() *idproto.Literal

+ func (p Platform) Type() *ast.Type

+ func (p Platform) TypeDescription() string

+ func (p Platform) TypeName() string

type Port

+ func (Port) Type() *ast.Type

+ func (Port) TypeDescription() string

type PortForward

+ func (pf PortForward) TypeDescription() string

+ func (pf PortForward) TypeName() string

+ type PrimitiveType struct

+ Def *TypeDef

+ func (t *PrimitiveType) ConvertFromSDKResult(ctx context.Context, value any) (dagql.Typed, error)

+ func (t *PrimitiveType) ConvertToSDKInput(ctx context.Context, value dagql.Typed) (any, error)

+ func (t *PrimitiveType) SourceMod() Mod

+ func (t *PrimitiveType) TypeDef() *TypeDef

type Query

+ Auth *auth.RegistryAuthProvider

+ Buildkit *buildkit.Client

+ Cache dagql.Cache

+ DefaultDeps *ModDeps

+ LeaseManager *leaseutil.Manager

+ OCIStore content.Store

+ Platform Platform

+ ProgrockSocketPath string

+ Secrets *SecretStore

+ Services *Services

+ func NewRoot() *Query

+ func (*Query) Type() *ast.Type

+ func (*Query) TypeDescription() string

+ func (q *Query) ClientCallContext(clientDigest digest.Digest) (*ClientCallContext, bool)

+ func (q *Query) CurrentFunctionCall(ctx context.Context) (*FunctionCall, error)

+ func (q *Query) CurrentModule(ctx context.Context) (dagql.ID[*Module], error)

+ func (q *Query) CurrentServedDeps(ctx context.Context) (*ModDeps, error)

+ func (q *Query) IDDeps(ctx context.Context, id *idproto.ID) (*ModDeps, error)

+ func (q *Query) InstallDefaultClientContext(deps *ModDeps)

+ func (q *Query) MuxEndpoint(ctx context.Context, path string, handler http.Handler) error

+ func (q *Query) MuxEndpoints(mux *http.ServeMux)

+ func (q *Query) NewContainer(platform Platform) *Container

+ func (q *Query) NewContainerService(ctr *Container) *Service

+ func (q *Query) NewHost() *Host

+ func (q *Query) NewHostService(upstream string, ports []PortForward) *Service

+ func (q *Query) NewModule() *Module

+ func (q *Query) NewSecret(name string) *Secret

+ func (q *Query) NewTunnelService(upstream dagql.Instance[*Service], ports []PortForward) *Service

+ func (q *Query) RegisterFunctionCall(dgst digest.Digest, deps *ModDeps, modID *idproto.ID, call *FunctionCall) error

+ func (q *Query) ServeModuleToMainClient(ctx context.Context, modMeta dagql.Instance[*Module]) error

+ func (q *Query) WithPipeline(name, desc string, labels []pipeline.Label) *Query

+ func (q Query) Clone() *Query

+ type SDK interface

+ Codegen func(context.Context, *Module, dagql.Instance[*Directory], string) (*GeneratedCode, error)

+ Runtime func(context.Context, *Module, dagql.Instance[*Directory], string) (*Container, error)

type Secret

+ Query *Query

+ func (*Secret) Type() *ast.Type

+ func (*Secret) TypeDescription() string

type Service

+ Query *Query

+ func (*Service) Type() *ast.Type

+ func (*Service) TypeDescription() string

+ func (svc *Service) StartAndTrack(ctx context.Context, id *idproto.ID) error

+ func (svc *Service) Stop(ctx context.Context, id *idproto.ID) error

type ServiceBinding

+ ID *idproto.ID

type ServiceKey

+ ServerID string

type Socket

+ HostAddr string

+ HostProtocol string

+ func NewHostIPSocket(proto string, addr string) *Socket

+ func NewHostUnixSocket(absPath string) *Socket

+ func (*Socket) Type() *ast.Type

+ func (*Socket) TypeDescription() string

+ func (socket *Socket) Addr() string

+ func (socket *Socket) Network() string

+ func (socket *Socket) SSHID() string

type TypeDef

+ func (*TypeDef) Type() *ast.Type

+ func (*TypeDef) TypeDescription() string

+ func (typeDef *TypeDef) ToInput() dagql.Input

+ func (typeDef *TypeDef) ToType() *ast.Type

+ func (typeDef *TypeDef) ToTyped() dagql.Typed

type TypeDefKind

+ func (k TypeDefKind) Decoder() dagql.InputDecoder

+ func (k TypeDefKind) ToLiteral() *idproto.Literal

+ func (k TypeDefKind) Type() *ast.Type

+ func (k TypeDefKind) TypeDescription() string

+ type UserModFunctionArg struct

+ type Void struct

+ func (Void) DecodeInput(val any) (dagql.Input, error)

+ func (p Void) Decoder() dagql.InputDecoder

+ func (p Void) ToLiteral() *idproto.Literal

+ func (p Void) Type() *ast.Type

+ func (p Void) TypeDescription() string

+ func (p Void) TypeName() string

Jan 11, 2024

Changes in this version

type Function

+ func (fn *Function) IsSubtypeOf(otherFn *Function) bool

+ type InterfaceTypeDef struct

+ Description string

+ Functions []*Function

+ Name string

+ OriginalName string

+ SourceModuleName string

+ func NewInterfaceTypeDef(name, description string) *InterfaceTypeDef

+ func (iface *InterfaceTypeDef) IsSubtypeOf(otherIface *InterfaceTypeDef) bool

+ func (iface InterfaceTypeDef) Clone() *InterfaceTypeDef

type Module

+ Interfaces []*TypeDef

+ func (mod *Module) WithInterface(def *TypeDef) (*Module, error)

type ObjectTypeDef

+ SourceModuleName string

+ func (obj *ObjectTypeDef) IsSubtypeOf(iface *InterfaceTypeDef) bool

type TypeDef

+ AsInterface *InterfaceTypeDef

+ func (typeDef *TypeDef) IsSubtypeOf(otherDef *TypeDef) bool

+ func (typeDef *TypeDef) WithFunction(fn *Function) (*TypeDef, error)

+ func (typeDef *TypeDef) WithInterface(name, desc string) *TypeDef

type TypeDefKind

+ const TypeDefKindInterface

Dec 8, 2023

Changes in this version

+ var ErrCacheMapRecursiveCall = fmt.Errorf("recursive call detected")

type CacheMap

+ func (m *CacheMap[K, T]) Get(ctx context.Context, key K) (T, error)

type CallInput

+ func (callInput *CallInput) Digest() (digest.Digest, error)

type ContainerExecOpts

+ ModuleCallerDigest digest.Digest

type FieldTypeDef

+ OriginalName string

type FunctionArg

+ func (arg *FunctionArg) ID() (FunctionArgID, error)

+ type FunctionArgID = resourceid.ID[FunctionArg]

type GitRef

+ Repo *GitRepository

+ func (ref *GitRef) ID() (GitRefID, error)

+ type GitRefID = resourceid.ID[GitRef]

+ type GitRepository struct

+ KeepGitDir bool

+ Pipeline pipeline.Path

+ Platform specs.Platform

+ SSHAuthSocket socket.ID

+ SSHKnownHosts string

+ Services ServiceBindings

+ URL string

+ func (repo *GitRepository) ID() (GitRepositoryID, error)

+ type GitRepositoryID = resourceid.ID[GitRepository]

type Module

+ func ModuleFromConfig(ctx context.Context, bk *buildkit.Client, svcs *Services, sourceDir *Directory, ...) (*Module, error)

+ func ModuleFromRef(ctx context.Context, bk *buildkit.Client, svcs *Services, ...) (*Module, error)

type ObjectTypeDef

+ Constructor *Function

type TypeDef

+ func (typeDef *TypeDef) Underlying() *TypeDef

+ func (typeDef *TypeDef) WithObjectConstructor(fn *Function) (*TypeDef, error)

Oct 31, 2023

Changes in this version

type Container

+ EnabledGPUs []string

+ func (container *Container) WithGPU(ctx context.Context, gpuOpts ContainerGPUOpts) (*Container, error)

type ContainerExecOpts

+ ModuleContextDigest digest.Digest

+ NestedInSameSession bool

+ type ContainerGPUOpts struct

+ Devices []string

type File

+ func NewFileWithContents(ctx context.Context, bk *buildkit.Client, svcs *Services, name string, ...) (*File, error)

type FunctionArg

+ OriginalName string

type Module

+ func (mod *Module) BaseDigest() (digest.Digest, error)

Oct 26, 2023

Changes in this version

type Directory

+ func (dir *Directory) Glob(ctx context.Context, bk *buildkit.Client, svcs *Services, src string, ...) ([]string, error)

type Function

+ OriginalName string

+ ParentOriginalName string

+ type GitRef struct

+ KeepGitDir bool

+ Pipeline pipeline.Path

+ Platform specs.Platform

+ Ref string

+ SSHAuthSocket socket.ID

+ SSHKnownHosts string

+ Services ServiceBindings

+ URL string

+ func (ref *GitRef) Commit(ctx context.Context, bk *buildkit.Client) (string, error)

+ func (ref *GitRef) Tree(ctx context.Context, bk *buildkit.Client) (*Directory, error)

+ func (ref *GitRef) WithRef(name string) *GitRef

type ObjectTypeDef

+ OriginalName string

+ func NewObjectTypeDef(name, description string) *ObjectTypeDef

Oct 20, 2023

Changes in this version

+ var ErrInvalidCacheVolumeID = errors.New("invalid cache ID; create one using cacheVolume")

+ func LoadModuleConfig(ctx *Context, bk *buildkit.Client, svcs *Services, sourceDir *Directory, ...) (string, *modules.Config, error)

+ func LoadModuleConfigFromFile(ctx *Context, bk *buildkit.Client, svcs *Services, configFile *File) (*modules.Config, error)

type CacheSharingMode

+ func (mode *CacheSharingMode) UnmarshalJSON(payload []byte) error

+ func (mode CacheSharingMode) MarshalJSON() ([]byte, error)

+ type CacheVolumeID = resourceid.ID[CacheVolume]

type Container

+ func (container *Container) AsTarball(ctx context.Context, bk *buildkit.Client, engineHostPlatform specs.Platform, ...) (*File, error)

type ContainerMount

+ CacheVolumeID string

type GeneratedCode

+ func NewGeneratedCode(code *Directory) *GeneratedCode

type Module

+ func (mod *Module) FromRef(ctx *Context, bk *buildkit.Client, svcs *Services, progSock string, ...) (*Module, error)

+ type PortForward struct

+ Backend int

+ Frontend int

+ Protocol NetworkProtocol

+ func (pf PortForward) FrontendOrBackendPort() int

type RunningService

+ Service *Service

type Service

+ HostPorts []PortForward

+ HostUpstream string

+ TunnelPorts []PortForward

+ TunnelUpstream *Service

+ func NewHostService(upstream string, ports []PortForward) *Service

+ func NewTunnelService(upstream *Service, ports []PortForward) *Service

Oct 11, 2023

Changes in this version

+ const ModMetaDepsDirPath

+ const ModMetaDirPath

+ const ModMetaInputPath

+ const ModMetaOutputPath

+ const ModSourceDirPath

+ const ShimEnableTTYEnvVar

+ func ResourceFromID(id string) (any, error)

+ func ResourceToID(r any) (string, error)

type CacheVolume

+ func (cache *CacheVolume) Digest() (digest.Digest, error)

+ type CallInput struct

+ Name string

+ Value any

type Container

+ func (container *Container) PBDefinitions() ([]*pb.Definition, error)

+ func (container *Container) ShellEndpoint(bk *buildkit.Client, progSock string, svcs *Services) (string, http.Handler, error)

type ContainerExecOpts

+ CacheExitCode uint32

type ContainerMount

+ Readonly bool

type Directory

+ func (dir *Directory) PBDefinitions() ([]*pb.Definition, error)

+ type FieldTypeDef struct

+ Description string

+ Name string

+ TypeDef *TypeDef

+ func (typeDef FieldTypeDef) Clone() *FieldTypeDef

type File

+ func (file *File) PBDefinitions() ([]*pb.Definition, error)

+ type Function struct

+ Args []*FunctionArg

+ Description string

+ ModuleID ModuleID

+ Name string

+ ParentName string

+ ReturnType *TypeDef

+ func NewFunction(name string, returnType *TypeDef) *Function

+ func (fn *Function) Digest() (digest.Digest, error)

+ func (fn *Function) ID() (FunctionID, error)

+ func (fn *Function) WithArg(name string, typeDef *TypeDef, desc string, defaultValue any) *Function

+ func (fn *Function) WithDescription(desc string) *Function

+ func (fn Function) Clone() *Function

+ type FunctionArg struct

+ DefaultValue any

+ Description string

+ Name string

+ TypeDef *TypeDef

+ func (arg FunctionArg) Clone() *FunctionArg

+ type FunctionCall struct

+ InputArgs []*CallInput

+ Name string

+ Parent any

+ ParentName string

+ func (fnCall *FunctionCall) Digest() (digest.Digest, error)

+ type FunctionID = resourceid.ID[Function]

+ type GeneratedCode struct

+ Code *Directory

+ VCSGeneratedPaths []string

+ VCSIgnoredPaths []string

+ func (code *GeneratedCode) Digest() (digest.Digest, error)

+ func (code *GeneratedCode) ID() (GeneratedCodeID, error)

+ func (code *GeneratedCode) WithCode(dir *Directory) *GeneratedCode

+ func (code *GeneratedCode) WithVCSGeneratedPaths(paths []string) *GeneratedCode

+ func (code *GeneratedCode) WithVCSIgnoredPaths(paths []string) *GeneratedCode

+ func (code GeneratedCode) Clone() *GeneratedCode

+ type GeneratedCodeID = resourceid.ID[GeneratedCode]

+ type HasPBDefinitions interface

+ PBDefinitions func() ([]*pb.Definition, error)

+ type ListTypeDef struct

+ ElementTypeDef *TypeDef

+ func (typeDef ListTypeDef) Clone() *ListTypeDef

+ type Module struct

+ Dependencies []*Module

+ DependencyConfig []string

+ Description string

+ Name string

+ Objects []*TypeDef

+ Pipeline pipeline.Path

+ Platform ocispecs.Platform

+ Runtime *Container

+ SDK string

+ SDKRuntime string

+ SourceDirectory *Directory

+ SourceDirectorySubpath string

+ func NewModule(platform ocispecs.Platform, pipeline pipeline.Path) *Module

+ func (mod *Module) Digest() (digest.Digest, error)

+ func (mod *Module) DigestWithoutObjects() (digest.Digest, error)

+ func (mod *Module) FromConfig(ctx context.Context, bk *buildkit.Client, svcs *Services, progSock string, ...) (*Module, error)

+ func (mod *Module) ID() (ModuleID, error)

+ func (mod *Module) PBDefinitions() ([]*pb.Definition, error)

+ func (mod *Module) WithObject(def *TypeDef) (*Module, error)

+ func (mod Module) Clone() *Module

+ type ModuleID resourceid.ID[Module]

+ func (id ModuleID) Decode() (*Module, error)

+ func (id ModuleID) String() string

+ type ObjectTypeDef struct

+ Description string

+ Fields []*FieldTypeDef

+ Functions []*Function

+ Name string

+ func (typeDef ObjectTypeDef) Clone() *ObjectTypeDef

+ func (typeDef ObjectTypeDef) FieldByName(name string) (*FieldTypeDef, bool)

+ func (typeDef ObjectTypeDef) FunctionByName(name string) (*Function, bool)

type RunningService

+ Wait func(context.Context) error

type Secret

+ func (secret *Secret) Digest() (digest.Digest, error)

+ type TypeDef struct

+ AsList *ListTypeDef

+ AsObject *ObjectTypeDef

+ Kind TypeDefKind

+ Optional bool

+ func (typeDef *TypeDef) Digest() (digest.Digest, error)

+ func (typeDef *TypeDef) ID() (TypeDefID, error)

+ func (typeDef *TypeDef) WithKind(kind TypeDefKind) *TypeDef

+ func (typeDef *TypeDef) WithListOf(elem *TypeDef) *TypeDef

+ func (typeDef *TypeDef) WithObject(name, desc string) *TypeDef

+ func (typeDef *TypeDef) WithObjectField(name string, fieldType *TypeDef, desc string) (*TypeDef, error)

+ func (typeDef *TypeDef) WithObjectFunction(fn *Function) (*TypeDef, error)

+ func (typeDef *TypeDef) WithOptional(optional bool) *TypeDef

+ func (typeDef TypeDef) Clone() *TypeDef

+ type TypeDefID = resourceid.ID[TypeDef]

+ type TypeDefKind string

+ const TypeDefKindBoolean

+ const TypeDefKindInteger

+ const TypeDefKindList

+ const TypeDefKindObject

+ const TypeDefKindString

+ const TypeDefKindVoid

+ func (k TypeDefKind) String() string

Sep 18, 2023

Changes in this version

+ var SeenCacheKeys = new(sync.Map)

Sep 13, 2023

Changes in this version

+ const DetachGracePeriod

type AliasSet

+ func (set AliasSet) Union(other AliasSet) AliasSet

type Container

+ func (container *Container) Service(ctx context.Context, bk *buildkit.Client, progSock string) (*Service, error)

type ContainerExecUncachedMetadata

+ func (md ContainerExecUncachedMetadata) ToEnv() ([]string, error)

type ContainerSecret

+ Mode *int

type NetworkProtocol

+ func (proto NetworkProtocol) EnumName() string

+ type Port struct

+ Description *string

+ Port int

+ Protocol NetworkProtocol

+ type RunningService struct

+ Host string

+ Key ServiceKey

+ Ports []Port

+ Stop func(context.Context) error

type Service

+ func NewContainerService(ctr *Container) *Service

+ func (svc *Service) Clone() *Service

+ func (svc *Service) Digest() (digest.Digest, error)

+ func (svc *Service) Endpoint(ctx context.Context, svcs *Services, port int, scheme string) (string, error)

+ func (svc *Service) Hostname(ctx context.Context, svcs *Services) (string, error)

+ func (svc *Service) ID() (ServiceID, error)

+ func (svc *Service) PipelinePath() pipeline.Path

+ func (svc *Service) Ports(ctx context.Context, svcs *Services) ([]Port, error)

+ func (svc *Service) Start(ctx context.Context, bk *buildkit.Client, svcs *Services) (running *RunningService, err error)

+ type ServiceBinding struct

+ Aliases AliasSet

+ Hostname string

+ Service *Service

+ type ServiceID string

+ func (id ServiceID) Digest() (digest.Digest, error)

+ func (id ServiceID) String() string

+ func (id ServiceID) ToService() (*Service, error)

+ type ServiceKey struct

+ ClientID string

+ Digest digest.Digest

+ type Services struct

+ func NewServices(bk *buildkit.Client) *Services

+ func (ss *Services) Detach(ctx context.Context, svc *RunningService) error

+ func (ss *Services) Get(ctx context.Context, svc Startable) (*RunningService, error)

+ func (ss *Services) Start(ctx context.Context, svc Startable) (*RunningService, error)

+ func (ss *Services) StartBindings(ctx context.Context, bk *buildkit.Client, bindings ServiceBindings) (_ func(), _ []*RunningService, err error)

+ func (ss *Services) Stop(ctx context.Context, bk *buildkit.Client, svc *Service) error

+ func (ss *Services) StopClientServices(ctx context.Context, client *engine.ClientMetadata) error

+ type Startable interface

+ Digest func() (digest.Digest, error)

+ Start func(context.Context, *buildkit.Client, *Services) (*RunningService, error)

Aug 16, 2023

Changes in this version

type Query

+ Pipeline pipeline.Path

Aug 3, 2023

Changes in this version

+ var ErrNotFound = errors.New("secret not found")

+ type CacheMap struct

+ func NewCacheMap() *CacheMap[K, T]

+ func (m *CacheMap[K, T]) GetOrInitialize(key K, fn func() (T, error)) (T, error)

+ type ContainerExecUncachedMetadata struct

+ ParentClientIDs []string

+ ProgSockPath string

+ ServerID string

+ func (md *ContainerExecUncachedMetadata) FromEnv(envKV string) (bool, error)

+ func (md ContainerExecUncachedMetadata) ToLLBRunOpt() (llb.RunOption, error)

type ContainerSocket

+ SocketID socket.ID

+ type Context struct

+ ResolveParams graphql.ResolveParams

+ Vertex *progrock.VertexRecorder

+ type Digestible interface

+ Digest func() (digest.Digest, error)

+ type Resolver func(ctx *Context, parent any, args any) (any, error)

+ type SecretStore struct

+ func NewSecretStore() *SecretStore

+ func (store *SecretStore) AddSecret(_ context.Context, name string, plaintext []byte) (SecretID, error)

+ func (store *SecretStore) GetSecret(ctx context.Context, idOrName string) ([]byte, error)

+ func (store *SecretStore) SetBuildkitClient(bk *buildkit.Client)

Jul 19, 2023

Changes in this version

+ func RecordBuildkitStatus(rec *progrock.Recorder, solveCh <-chan *bkclient.SolveStatus) error

type Container

+ Focused bool

type Directory

+ func (dir *Directory) Evaluate(ctx context.Context, gw bkgw.Client) error

type File

+ func (file *File) Evaluate(ctx context.Context, gw bkgw.Client) error

+ type ImageMediaTypes string

+ const DockerMediaTypes

+ const OCIMediaTypes

Jul 4, 2023

Changes in this version

type Directory

+ func NewScratchDirectory(pipeline pipeline.Path, platform specs.Platform) *Directory

type ProjectConfig

+ Root string

+ type ProjectSDK string

+ const ProjectSDKGo

+ const ProjectSDKPython

Jun 15, 2023

Changes in this version

type Host

+ func (host *Host) File(ctx context.Context, path string, p pipeline.Path, platform specs.Platform) (*File, error)

type ProjectCommand

+ ResultType string

May 25, 2023

Changes in this version

+ const TruncationMessage

+ func AddEnv(env []string, name, value string) []string

+ func LookupEnv(env []string, name string) (string, bool)

+ func WalkEnv(env []string, fn func(string, string, string))

+ type ExecError struct

+ Cmd []string

+ ExitCode int

+ Stderr string

+ Stdout string

+ func (e *ExecError) Error() string

+ func (e *ExecError) Extensions() map[string]interface{}

+ func (e *ExecError) Unwrap() error

May 18, 2023

Changes in this version

+ type ImageLayerCompression string

+ const CompressionEStarGZ

+ const CompressionGzip

+ const CompressionUncompressed

+ const CompressionZstd

+ type Project struct

+ Config ProjectConfig

+ ConfigPath string

+ Directory *Directory

+ Platform specs.Platform

+ Schema string

+ func NewProject(id ProjectID, platform specs.Platform) (*Project, error)

+ func (p *Project) Clone() *Project

+ func (p *Project) Commands(ctx context.Context) ([]ProjectCommand, error)

+ func (p *Project) ID() (ProjectID, error)

+ func (p *Project) Load(ctx context.Context, gw bkgw.Client, r *router.Router, source *Directory, ...) (*Project, error)

+ type ProjectCommand struct

+ Description string

+ Flags []ProjectCommandFlag

+ Name string

+ Subcommands []ProjectCommand

+ func NewProjectCommand(id ProjectCommandID) (*ProjectCommand, error)

+ func (p *ProjectCommand) ID() (ProjectCommandID, error)

+ type ProjectCommandFlag struct

+ Description string

+ Name string

+ type ProjectCommandID string

+ func (id ProjectCommandID) String() string

+ func (id ProjectCommandID) ToProjectCommand() (*ProjectCommand, error)

+ type ProjectConfig struct

+ Name string

+ SDK string

+ type ProjectID string

+ func (id ProjectID) String() string

+ func (id ProjectID) ToProject() (*Project, error)

May 11, 2023

Changes in this version

+ const MaxExecErrorOutputBytes

+ const MaxFileContentsChunkSize

+ const MaxFileContentsSize

type Container

+ func (container *Container) Digest() (digest.Digest, error)

+ func (container *Container) PipelinePath() pipeline.Path

type ContainerID

+ func (id ContainerID) Digest() (digest.Digest, error)

type Directory

+ func NewDirectorySt(ctx context.Context, st llb.State, dir string, pipeline pipeline.Path, ...) (*Directory, error)

+ func (dir *Directory) Digest() (digest.Digest, error)

+ func (dir *Directory) PipelinePath() pipeline.Path

type DirectoryID

+ func (id DirectoryID) Digest() (digest.Digest, error)

+ func (id DirectoryID) String() string

type File

+ func NewFileSt(ctx context.Context, st llb.State, dir string, pipeline pipeline.Path, ...) (*File, error)

+ func (file *File) Digest() (digest.Digest, error)

+ func (file *File) PipelinePath() pipeline.Path

type FileID

+ func (id FileID) Digest() (digest.Digest, error)

+ func (id FileID) String() string

Apr 28, 2023

Changes in this version

type CacheID

+ func (id CacheID) ToCacheVolume() (*CacheVolume, error)

type CacheVolume

+ Keys []string

+ func (cache *CacheVolume) Clone() *CacheVolume

+ func (cache *CacheVolume) Sum() string

type Container

+ Config specs.ImageConfig

+ HostAliases []HostAlias

+ Meta *pb.Definition

+ Ports []ContainerPort

+ Secrets []ContainerSecret

+ Services ServiceBindings

+ Sockets []ContainerSocket

+ func (container *Container) Clone() *Container

+ func (container *Container) FSState() (llb.State, error)

+ func (container *Container) HostnameOrErr() (string, error)

+ func (container *Container) ImageRefOrErr(ctx context.Context, gw bkgw.Client) (string, error)

+ func (container *Container) MetaState() (*llb.State, error)

+ func (container *Container) MountTargets(ctx context.Context) ([]string, error)

+ func (container *Container) WithPipeline(ctx context.Context, name, description string, labels []pipeline.Label) (*Container, error)

type ContainerExecOpts

+ SkipEntrypoint bool

type ContainerID

+ func (id ContainerID) ToContainer() (*Container, error)

type ContainerSecret

+ Owner *Ownership

type ContainerSocket

+ Owner *Ownership

type Directory

+ Dir string

+ LLB *pb.Definition

+ Platform specs.Platform

+ Services ServiceBindings

+ func (dir *Directory) Clone() *Directory

+ func (dir *Directory) Root() (*Directory, error)

+ func (dir *Directory) SetState(ctx context.Context, st llb.State) error

+ func (dir *Directory) State() (llb.State, error)

+ func (dir *Directory) StateWithSourcePath() (llb.State, error)

+ func (dir *Directory) WithPipeline(ctx context.Context, name, description string, labels []pipeline.Label) (*Directory, error)

type DirectoryID

+ func (id DirectoryID) ToDirectory() (*Directory, error)

type File

+ File string

+ LLB *pb.Definition

+ Pipeline pipeline.Path

+ Platform specs.Platform

+ Services ServiceBindings

+ func (file *File) Clone() *File

+ func (file *File) State() (llb.State, error)

type FileID

+ func (id FileID) ToFile() (*File, error)

+ type Ownership struct

+ GID int

+ UID int

+ func (owner Ownership) Opt() llb.ChownOption

type Secret

+ FromFile FileID

+ FromHostEnv string

+ Name string

+ func NewDynamicSecret(name string) *Secret

+ func (secret *Secret) Clone() *Secret

+ func (secret *Secret) IsOldFormat() bool

+ func (secret *Secret) LegacyPlaintext(ctx context.Context, gw bkgw.Client) ([]byte, error)

type SecretID

+ func (id SecretID) ToSecret() (*Secret, error)

type Socket

+ HostPath string

type SocketID

+ func (id SocketID) ToSocket() (*Socket, error)

Apr 6, 2023

Changes in this version

+ const OCIStoreName

type Container

+ func (container *Container) Import(ctx context.Context, host *Host, source io.Reader, tag string, ...) (*Container, error)

+ func (container *Container) WithServiceBinding(svc *Container, alias string) (*Container, error)

type File

+ func (file *File) Open(ctx context.Context, host *Host, gw bkgw.Client) (io.ReadCloser, error)

Mar 16, 2023

Changes in this version

+ type PipelineMetaResolver struct

+ Pipeline pipeline.Path

+ Resolver llb.ImageMetaResolver

+ func (r PipelineMetaResolver) ResolveImageConfig(ctx context.Context, ref string, opt llb.ResolveImageConfigOpt) (digest.Digest, []byte, error)

type SecretID

+ func NewSecretID(name, plaintext string) (SecretID, error)

+ func (id SecretID) IsOldFormat() (bool, error)

Mar 8, 2023

Changes in this version

+ var ErrContainerNoExec = errors.New("no command has been executed")

type ContainerExecOpts

+ InsecureRootCapabilities bool

type Query

+ func (query *Query) PipelinePath() pipeline.Path

Feb 24, 2023

Changes in this version

+ func WithServices(ctx context.Context, gw bkgw.Client, svcs ServiceBindings, ...) (T, error)

+ type AliasSet []string

+ func (set AliasSet) String() string

+ func (set AliasSet) With(alias string) AliasSet

type Container

+ func (container *Container) Endpoint(port int, scheme string) (string, error)

+ func (container *Container) Evaluate(ctx context.Context, gw bkgw.Client) error

+ func (container *Container) ExposedPorts() ([]ContainerPort, error)

+ func (container *Container) Hostname() (string, error)

+ func (container *Container) ImageRef(ctx context.Context, gw bkgw.Client) (string, error)

+ func (container *Container) Start(ctx context.Context, gw bkgw.Client) (*Service, error)

+ func (container *Container) WithExec(ctx context.Context, gw bkgw.Client, defaultPlatform specs.Platform, ...) (*Container, error)

+ func (container *Container) WithExposedPort(port ContainerPort) (*Container, error)

+ func (container *Container) WithServiceDependency(svc *Container, alias string) (*Container, error)

+ func (container *Container) WithoutExposedPort(port int, protocol NetworkProtocol) (*Container, error)

type ContainerID

+ func (id ContainerID) String() string

+ type ContainerPort struct

+ Description *string

+ Port int

+ Protocol NetworkProtocol

type GatewayClient

+ func NewGatewayClient(baseClient bkgw.Client) *GatewayClient

+ func (g *GatewayClient) CombinedResult() *bkgw.Result

+ type HostAlias struct

+ Alias string

+ Target string

+ type NetworkProtocol string

+ const NetworkProtocolTCP

+ const NetworkProtocolUDP

+ func (p NetworkProtocol) Network() string

+ type SecretToScrubInfo struct

+ Envs []string

+ Files []string

+ type Service struct

+ Container *Container

+ Detach func()

+ type ServiceBindings map[ContainerID]AliasSet

+ func (bndp *ServiceBindings) Merge(other ServiceBindings)

Feb 8, 2023

Changes in this version

+ type CacheSharingMode string

+ const CacheSharingModeLocked

+ const CacheSharingModePrivate

+ const CacheSharingModeShared

type PipelinePath

+ func (g PipelinePath) String() string

Jan 25, 2023

Changes in this version

type Container

+ func (container *Container) Pipeline(ctx context.Context, name, description string) (*Container, error)

+ type CustomName struct

+ Internal bool

+ Name string

+ Pipeline PipelinePath

+ func (c CustomName) LLBOpt() llb.ConstraintsOpt

+ func (c CustomName) String() string

type Directory

+ func (dir *Directory) Pipeline(ctx context.Context, name, description string) (*Directory, error)

+ type Pipeline struct

+ Description string

+ Name string

+ type PipelinePath []Pipeline

+ func (g PipelinePath) Add(pipeline Pipeline) PipelinePath

+ func (g PipelinePath) Copy() PipelinePath

+ func (g PipelinePath) ID() string

+ func (g PipelinePath) LLBOpt() llb.ConstraintsOpt

+ func (g PipelinePath) Name() string

+ func (g PipelinePath) ProgressGroup() *pb.ProgressGroup

+ type Query struct

+ Context QueryContext

+ type QueryContext struct

+ Pipeline PipelinePath

Jan 9, 2023

Changes in this version

+ const DebugFailedExecEnv

+ type BuildArg struct

+ Name string

+ Value string

type Directory

+ func (dir *Directory) WithTimestamps(ctx context.Context, unix int) (*Directory, error)

type File

+ func (file *File) WithTimestamps(ctx context.Context, unix int) (*File, error)

+ type GatewayClient struct

+ func (g *GatewayClient) Solve(ctx context.Context, req bkgw.SolveRequest) (_ *bkgw.Result, rerr error)

type Socket

+ func (socket *Socket) IsHost() (bool, error)

Dec 1, 2022

Changes in this version

type Container

+ func (container *Container) WithDirectory(ctx context.Context, gw bkgw.Client, subdir string, src *Directory, ...) (*Container, error)

+ func (container *Container) WithFile(ctx context.Context, gw bkgw.Client, subdir string, src *File) (*Container, error)

+ func (container *Container) WithNewFile(ctx context.Context, gw bkgw.Client, dest string, content []byte) (*Container, error)

+ func (container *Container) WithUnixSocket(ctx context.Context, target string, source *Socket) (*Container, error)

+ func (container *Container) WithoutUnixSocket(ctx context.Context, target string) (*Container, error)

+ type ContainerSocket struct

+ Socket SocketID

+ UnixPath string

type Host

+ func (host *Host) Socket(ctx context.Context, sockPath string) (*Socket, error)

type SecretID

+ func (id SecretID) String() string

+ type Socket struct

+ ID SocketID

+ func NewHostSocket(absPath string) (*Socket, error)

+ func NewSocket(id SocketID) *Socket

+ func (socket *Socket) Server() (sshforward.SSHServer, error)

+ type SocketID string

+ func (id SocketID) LLBID() string

+ func (id SocketID) String() string

Nov 22, 2022

Changes in this version

+ const RunnerProxySockName

+ const RunnerProxySockPath

type Container

+ func (container *Container) MetaFileContents(ctx context.Context, gw bkgw.Client, filePath string) (*string, error)

+ func (container *Container) RootFS(ctx context.Context) (*Directory, error)

+ func (container *Container) WithRootFS(ctx context.Context, dir *Directory) (*Container, error)

+ type RunnerProxy struct

+ func NewRunnerProxy(buildkitdHost string) *RunnerProxy

+ func (p *RunnerProxy) CheckAgent(ctx context.Context, req *sshforward.CheckAgentRequest) (*sshforward.CheckAgentResponse, error)

+ func (p *RunnerProxy) ForwardAgent(stream sshforward.SSH_ForwardAgentServer) error

+ func (p *RunnerProxy) Register(server *grpc.Server)

Nov 10, 2022

Changes in this version

+ const DaggerSockName

+ const DaggerSockPath

type ContainerExecOpts

+ ExperimentalPrivilegedNesting bool

Nov 2, 2022

Changes in this version

+ var ErrHostRWDisabled = errors.New("host read/write is disabled")

type Container

+ func NewContainer(id ContainerID, platform specs.Platform) (*Container, error)

+ func (container *Container) Export(ctx context.Context, host *Host, dest string, platformVariants []ContainerID, ...) error

+ func (container *Container) Platform() (specs.Platform, error)

+ type ContainerMounts []ContainerMount

+ func (mnts ContainerMounts) With(newMnt ContainerMount) ContainerMounts

+ type CopyFilter struct

+ Exclude []string

+ Include []string

type Directory

+ func (dir *Directory) Export(ctx context.Context, host *Host, dest string, bkClient *bkclient.Client, ...) error

+ func (dir *Directory) WithFile(ctx context.Context, subdir string, src *File) (*Directory, error)

+ func (dir *Directory) WithNewDirectory(ctx context.Context, gw bkgw.Client, dest string) (*Directory, error)

type File

+ func (file *File) Export(ctx context.Context, host *Host, dest string, bkClient *bkclient.Client, ...) error

+ type Host struct

+ DisableRW bool

+ Workdir string

+ func NewHost(workdir string, disableRW bool) *Host

+ func (host *Host) Directory(ctx context.Context, dirPath string, platform specs.Platform, ...) (*Directory, error)

+ func (host *Host) Export(ctx context.Context, export bkclient.ExportEntry, dest string, ...) error

+ func (host *Host) NormalizeDest(dest string) (string, error)

Oct 25, 2022

Changes in this version

+ var ErrInvalidCacheID = errors.New("invalid cache ID; create one using cacheVolume")

+ type CacheID string

+ type CacheVolume struct

+ ID CacheID

+ func NewCache(keys ...string) (*CacheVolume, error)

+ func NewCacheFromID(id CacheID) (*CacheVolume, error)

+ func (cache *CacheVolume) WithKey(key string) (*CacheVolume, error)

+ type Container struct

+ ID ContainerID

+ func (container *Container) Build(ctx context.Context, gw bkgw.Client, context *Directory, dockerfile string, ...) (*Container, error)

+ func (container *Container) Directory(ctx context.Context, gw bkgw.Client, dirPath string) (*Directory, error)

+ func (container *Container) Exec(ctx context.Context, gw bkgw.Client, opts ContainerExecOpts) (*Container, error)

+ func (container *Container) ExitCode(ctx context.Context, gw bkgw.Client) (*int, error)

+ func (container *Container) FS(ctx context.Context) (*Directory, error)

+ func (container *Container) File(ctx context.Context, gw bkgw.Client, filePath string) (*File, error)

+ func (container *Container) From(ctx context.Context, gw bkgw.Client, addr string, platform specs.Platform) (*Container, error)

+ func (container *Container) ImageConfig(ctx context.Context) (specs.ImageConfig, error)

+ func (container *Container) MetaFile(ctx context.Context, gw bkgw.Client, filePath string) (*File, error)

+ func (container *Container) Mounts(ctx context.Context) ([]string, error)

+ func (container *Container) Publish(ctx context.Context, ref string, bkClient *bkclient.Client, ...) (string, error)

+ func (container *Container) UpdateImageConfig(ctx context.Context, updateFn func(specs.ImageConfig) specs.ImageConfig) (*Container, error)

+ func (container *Container) WithFS(ctx context.Context, dir *Directory, platform specs.Platform) (*Container, error)

+ func (container *Container) WithMountedCache(ctx context.Context, target string, cache CacheID, source *Directory) (*Container, error)

+ func (container *Container) WithMountedDirectory(ctx context.Context, target string, source *Directory) (*Container, error)

+ func (container *Container) WithMountedFile(ctx context.Context, target string, source *File) (*Container, error)

+ func (container *Container) WithMountedSecret(ctx context.Context, target string, source *Secret) (*Container, error)

+ func (container *Container) WithMountedTemp(ctx context.Context, target string) (*Container, error)

+ func (container *Container) WithSecretVariable(ctx context.Context, name string, secret *Secret) (*Container, error)

+ func (container *Container) WithoutMount(ctx context.Context, target string) (*Container, error)

+ type ContainerExecOpts struct

+ Args []string

+ RedirectStderr string

+ RedirectStdout string

+ Stdin string

+ type ContainerID string

+ type ContainerMount struct

+ CacheID string

+ CacheSharingMode string

+ Source *pb.Definition

+ SourcePath string

+ Target string

+ Tmpfs bool

+ func (mnt ContainerMount) SourceState() (llb.State, error)

+ type ContainerSecret struct

+ EnvName string

+ MountPath string

+ Secret SecretID

+ type Directory struct

+ ID DirectoryID

+ func MergeDirectories(ctx context.Context, dirs []*Directory, platform specs.Platform) (*Directory, error)

+ func NewDirectory(ctx context.Context, st llb.State, cwd string, platform specs.Platform) (*Directory, error)

+ func (dir *Directory) Diff(ctx context.Context, other *Directory) (*Directory, error)

+ func (dir *Directory) Directory(ctx context.Context, subdir string) (*Directory, error)

+ func (dir *Directory) Entries(ctx context.Context, gw bkgw.Client, src string) ([]string, error)

+ func (dir *Directory) File(ctx context.Context, file string) (*File, error)

+ func (dir *Directory) Stat(ctx context.Context, gw bkgw.Client, src string) (*fstypes.Stat, error)

+ func (dir *Directory) WithCopiedFile(ctx context.Context, subdir string, src *File) (*Directory, error)

+ func (dir *Directory) WithDirectory(ctx context.Context, subdir string, src *Directory) (*Directory, error)

+ func (dir *Directory) WithNewFile(ctx context.Context, gw bkgw.Client, dest string, content []byte) (*Directory, error)

+ func (dir *Directory) Without(ctx context.Context, path string) (*Directory, error)

+ type DirectoryID string

+ func (id DirectoryID) Decode() (*directoryIDPayload, error)

+ type File struct

+ ID FileID

+ func NewFile(ctx context.Context, st llb.State, file string, platform specs.Platform) (*File, error)

+ func (file *File) Contents(ctx context.Context, gw bkgw.Client) ([]byte, error)

+ func (file *File) Secret(ctx context.Context) (*Secret, error)

+ func (file *File) Stat(ctx context.Context, gw bkgw.Client) (*fstypes.Stat, error)

+ type FileID string

+ type HostDirectory struct

+ ID HostDirectoryID

+ func (dir *HostDirectory) Read(ctx context.Context, platform specs.Platform) (*Directory, error)

+ func (dir *HostDirectory) Write(ctx context.Context, localDir, dest string, source *Directory, ...) (bool, error)

+ type HostDirectoryID string

+ type HostVariable struct

+ Name string

+ type Secret struct

+ ID SecretID

+ func NewSecret(id SecretID) *Secret

+ func NewSecretFromFile(fileID FileID) (*Secret, error)

+ func NewSecretFromHostEnv(name string) (*Secret, error)

+ func (secret *Secret) Plaintext(ctx context.Context, gw bkgw.Client) ([]byte, error)

+ type SecretID string