buildkit

Nov 8, 2024

Changes in this version

type Client

+ func (c *Client) GetCredential(ctx context.Context, protocol, host, path string) (*session.CredentialInfo, error)

Oct 25, 2024

Changes in this version

type ExecutionMetadata

+ CacheByCall bool

Oct 9, 2024

Changes in this version

+ const DaggerNoInitEnv

type ExecutionMetadata

+ ExtraSearchDomains []string

+ NoInit bool

Sep 18, 2024

Changes in this version

+ const MetaMountClientIDPath

Aug 30, 2024

Changes in this version

type ExecutionMetadata

+ SSHAuthSocketPath string

type Opts

+ InteractiveCommand []string

Aug 15, 2024

Changes in this version

+ type WalkDirRequest struct

+ Callback func(path string, info *fstypes.Stat) error

+ IncludePattern string

+ Path string

Aug 2, 2024

Changes in this version

type Trie

+ func (t *Trie) Iter() *TrieIter

+ type TrieIter struct

+ func (t *TrieIter) Step(ch byte) *TrieIter

+ func (t *TrieIter) Value() []byte

Jul 25, 2024

Changes in this version

type ExecutionMetadata

+ ClientStableID string

+ ParentIDs map[digest.Digest]*call.ID

Jul 18, 2024

Changes in this version

type ExecutionMetadata

+ CallerClientID string

Jul 12, 2024

Changes in this version

+ const TelemetryComponent

type Client

+ func (c *Client) OpenTerminal(ctx context.Context) (*TerminalClient, error)

+ type ContainerMount struct

+ WorkerRef *bkworker.WorkerRef

type ExecutionMetadata

+ CallID *call.ID

+ ExecID string

+ Internal bool

type Opts

+ Interactive bool

+ type SpanProcessor struct

+ func (sp SpanProcessor) ForceFlush(context.Context) error

+ func (sp SpanProcessor) OnEnd(sdktrace.ReadOnlySpan)

+ func (sp SpanProcessor) OnStart(ctx context.Context, span sdktrace.ReadWriteSpan)

+ func (sp SpanProcessor) Shutdown(context.Context) error

+ type TerminalClient struct

+ Close func(exitCode int) error

+ ErrCh chan error

+ ResizeCh chan bkgw.WinSize

+ Stderr io.WriteCloser

+ Stdin io.ReadCloser

+ Stdout io.WriteCloser

Jun 18, 2024

Changes in this version

+ const DaggerSessionIDEnv

+ const EntitlementsJobKey

+ func AsWorkerController(w worker.Worker) (*worker.Controller, error)

+ func IgnoreErrs(fn func() error, ignored ...error) func() error

+ func Infallible(fn func()) func() error

+ func ToEntitlementStrings(ents entitlements.Set) []string

+ type CleanupFunc struct

+ type Cleanups struct

+ func (c *Cleanups) Add(msg string, f func() error) CleanupFunc

+ func (c *Cleanups) ReAdd(f CleanupFunc) CleanupFunc

+ func (c *Cleanups) Run() error

type ExecutionMetadata

+ CachePerSession bool

+ EncodedFunctionCall json.RawMessage

+ EncodedModuleID string

+ Hostname string

+ SecretToken string

+ SessionID string

type NewWorkerOpts

+ BKSessionManager *bksession.Manager

+ BaseWorker *base.Worker

+ ExecutorRoot string

+ NetworkProviders map[pb.NetMode]network.Provider

+ Runc *runc.Runc

+ SessionHandler sessionHandler

+ WorkerCache bkcache.Manager

+ WorkerRoot string

type Opts

+ BkSession *bksession.Session

+ Containers map[bkgw.Container]struct{}

+ ContainersMu *sync.Mutex

+ Dialer *net.Dialer

+ GetMainClientCaller func() (bksession.Caller, error)

+ Job *bksolver.Job

+ LLBBridge bkfrontend.FrontendLLBBridge

+ Refs map[Reference]struct{}

+ RefsMu *sync.Mutex

+ SpanCtx trace.SpanContext

+ type Reference interface

+ Release func(context.Context) error

Jun 11, 2024

Changes in this version

+ const InstrumentationLibrary

+ const OTelExporterEndpointEnv

+ const OTelExporterProtocolEnv

+ const OTelLogsEndpointEnv

+ const OTelLogsProtocolEnv

+ const OTelMetricsEndpointEnv

+ const OTelMetricsProtocolEnv

+ const OTelTraceParentEnv

+ const OTelTracesEndpointEnv

+ const OTelTracesLiveEnv

+ const OTelTracesProtocolEnv

type Client

+ func (c *Client) BytesToBlob(ctx context.Context, fileName string, perms fs.FileMode, bs []byte, ...) (_ *bksolverpb.Definition, desc specs.Descriptor, _ error)

type ExecutionMetadata

+ OTelEnvs []string

+ SpanContext propagation.MapCarrier

type NewWorkerOpts

+ TelemetryPubSub *telemetry.PubSub

May 28, 2024

Changes in this version

+ const BuildkitSessionIDHeader

+ const DaggerCallDigestEnv

+ const DaggerClientIDEnv

+ const DaggerEngineVersionEnv

+ const DaggerHostnameAliasesEnv

+ const DaggerRedirectStderrEnv

+ const DaggerRedirectStdoutEnv

+ const DaggerServerIDEnv

+ const DaggerSessionPortEnv

+ const DaggerSessionTokenEnv

+ const MetaMountExitCodePath

+ const MetaMountStderrPath

+ const MetaMountStdinPath

+ const MetaMountStdoutPath

+ const OTELExporterEndpointEnv

+ const OTELExporterProtocolEnv

+ const OTELLogsEndpointEnv

+ const OTELLogsProtocolEnv

+ const OTELMetricsEndpointEnv

+ const OTELMetricsProtocolEnv

+ const OTELTraceParentEnv

+ const OTELTracesEndpointEnv

+ const OTELTracesProtocolEnv

+ func NewSecretScrubReader(r io.Reader, env []string, secretEnvs []string, secretFiles []string) (io.Reader, error)

+ func RunInNetNS[T any](ctx context.Context, c *Client, ns Namespaced, fn func() (T, error)) (T, error)

type Client

+ func (c *Client) NewNetworkNamespace(ctx context.Context, hostname string) (Namespaced, error)

+ type Container struct

+ func (ctr *Container) NamespaceID() string

+ type Controller interface

+ HandleConn func(context.Context, net.Conn, *engine.ClientMetadata, map[string][]string) error

type ExecutionMetadata

+ EnabledGPUs []string

+ HostAliases map[string][]string

+ RedirectStderrPath string

+ RedirectStdoutPath string

+ SecretEnvNames []string

+ SecretFilePaths []string

+ ServerID string

+ func ExecutionMetadataFromDescription(desc map[string]string) (*ExecutionMetadata, bool, error)

+ type Namespaced interface

+ NamespaceID func() string

+ Release func(context.Context) error

+ type NewContainerRequest struct

+ Hostname string

+ Mounts []bkgw.Mount

+ Platform *bksolverpb.Platform

+ type Trie struct

+ func (t *Trie) Insert(key []byte, value []byte)

+ func (t *Trie) Step(ch byte) *Trie

+ func (t *Trie) Value() []byte

+ func (t Trie) String() string

May 9, 2024

Changes in this version

type ExecutionMetadata

+ ClientID string

+ OTELEnvs []string

May 8, 2024

Changes in this version

+ const DaggerWorkerJobKey

+ type ExecutionMetadata struct

+ SystemEnvNames []string

+ func (md ExecutionMetadata) AsConstraintsOpt() (llb.ConstraintsOpt, error)

+ type NewWorkerOpts struct

+ ApparmorProfile string

+ BuildkitVersion client.BuildkitVersion

+ DNSConfig *oci.DNSConfig

+ DefaultCgroupParent string

+ Entitlements []string

+ GCPolicy []client.PruneInfo

+ IDMapping *idtools.IdentityMapping

+ Labels map[string]string

+ NetworkProvidersOpts netproviders.Opt

+ ParallelismSem *semaphore.Weighted

+ Platforms []ocispecs.Platform

+ ProcessMode oci.ProcessMode

+ RegistryHosts docker.RegistryHosts

+ Root string

+ SELinux bool

+ SnapshotterFactory workerrunc.SnapshotterFactory

+ TraceSocket string

type Opts

+ BaseWorker *Worker

+ CacheManager bksolver.CacheManager

+ Entitlements []string

+ ServerID string

+ UpstreamCacheImporters map[string]remotecache.ResolveCacheImporterFunc

+ type Worker struct

+ func NewWorker(ctx context.Context, opts *NewWorkerOpts) (*Worker, error)

+ func (w *Worker) AsWorkerController() (*worker.Controller, error)

+ func (w *Worker) Exec(ctx context.Context, id string, process executor.ProcessInfo) (err error)

+ func (w *Worker) Executor() executor.Executor

+ func (w *Worker) ResolveOp(vtx solver.Vertex, s frontend.FrontendLLBBridge, sm *session.Manager) (solver.Op, error)

+ func (w *Worker) Run(ctx context.Context, id string, root executor.Mount, mounts []executor.Mount, ...) (_ resourcestypes.Recorder, rerr error)

+ func (w *Worker) WithServerID(serverID string) *Worker

+ func (w *Worker) WithVertex(vtx solver.Vertex) *Worker

Apr 26, 2024

Changes in this version

type Opts

+ BuildkitLogSink io.Writer

Apr 16, 2024

Changes in this version

type Client

+ func (c *Client) ResolveSourceMetadata(ctx context.Context, op *bksolverpb.SourceOp, opt sourceresolver.Opt) (*sourceresolver.MetaResponse, error)

Mar 5, 2024

Changes in this version

+ var SkipInputs = fmt.Errorf("skip inputs")

Feb 27, 2024

Changes in this version

+ const BuiltinContentOCIStoreName

type Opts

+ Frontends map[string]bkfrontend.Frontend

+ MainClientCallerID string

Feb 9, 2024

Changes in this version

type Client

+ func (c *Client) StatCallerHostPath(ctx context.Context, path string, returnAbsPath bool) (*fsutiltypes.Stat, error)

Feb 1, 2024

Changes in this version

type BK2Progrock

+ ConvertStatus func(*bkclient.SolveStatus) *progrock.StatusUpdate

type Client

+ func (c *Client) DefToBlob(ctx context.Context, pbDef *bksolverpb.Definition) (_ *bksolverpb.Definition, desc specs.Descriptor, _ error)

type ContainerExecUncachedMetadata

+ ProgParent string

Oct 20, 2023

Changes in this version

type Client

+ func (c *Client) ContainerImageToTarball(ctx context.Context, engineHostPlatform specs.Platform, fileName string, ...) (*bksolverpb.Definition, error)

+ func (c *Client) EngineContainerLocalImport(ctx context.Context, recorder *progrock.Recorder, platform specs.Platform, ...) (*bksolverpb.Definition, error)

+ func (c *Client) ListenHostToContainer(ctx context.Context, hostListenAddr, proto, upstream string) (*session.ListenResponse, func() error, error)

type Opts

+ DNSConfig *oci.DNSConfig

Oct 11, 2023

Changes in this version

+ type BlobOp struct

+ func (op *BlobOp) OCIDescriptor() (ocispecs.Descriptor, error)

type Client

+ func (c *Client) IOReaderExport(ctx context.Context, r io.Reader, destPath string, destMode os.FileMode) error

+ func (c *Client) LocalImport(ctx context.Context, recorder *progrock.Recorder, platform specs.Platform, ...) (*bksolverpb.Definition, error)

+ type ContainerExecUncachedMetadata struct

+ FunctionContextDigest digest.Digest

+ ModuleDigest digest.Digest

+ ParentClientIDs []string

+ ProgSockPath string

+ ServerID string

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

+ func (md ContainerExecUncachedMetadata) ToPBFtpProxyVal() (string, error)

+ type DiffOp struct

+ type ExecOp struct

+ func (exec *ExecOp) Input(i pb.InputIndex) *OpDAG

+ func (exec *ExecOp) OutputMount() *pb.Mount

+ func (exec *ExecOp) OutputMountBase() *OpDAG

+ type FileOp struct

+ type GitOp struct

+ type HTTPOp struct

+ type ImageOp struct

+ type LocalOp struct

+ type MergeOp struct

+ type OCIOp struct

+ type OpDAG struct

+ Inputs []*OpDAG

+ Metadata *pb.OpMetadata

+ OpDigest *digest.Digest

+ func DefToDAG(def *pb.Definition) (*OpDAG, error)

+ func (dag *OpDAG) AsBlob() (*BlobOp, bool)

+ func (dag *OpDAG) AsDiff() (*DiffOp, bool)

+ func (dag *OpDAG) AsExec() (*ExecOp, bool)

+ func (dag *OpDAG) AsFile() (*FileOp, bool)

+ func (dag *OpDAG) AsGit() (*GitOp, bool)

+ func (dag *OpDAG) AsHTTP() (*HTTPOp, bool)

+ func (dag *OpDAG) AsImage() (*ImageOp, bool)

+ func (dag *OpDAG) AsLocal() (*LocalOp, bool)

+ func (dag *OpDAG) AsMerge() (*MergeOp, bool)

+ func (dag *OpDAG) AsOCI() (*OCIOp, bool)

+ func (dag *OpDAG) BlobDependencies() (map[digest.Digest]*ocispecs.Descriptor, error)

+ func (dag *OpDAG) Marshal() (*pb.Definition, error)

+ func (dag *OpDAG) String() string

+ func (dag *OpDAG) Walk(f func(*OpDAG) error) error

type Opts

+ ProgSockPath string

Aug 3, 2023

Changes in this version

+ const FocusPrefix

+ const InternalPrefix

+ const MaxExecErrorOutputBytes

+ const MaxFileContentsChunkSize

+ const MaxFileContentsSize

+ const MetaMountDestPath

+ const MetaSourcePath

+ const OCIStoreName

+ const TruncationMessage

+ func BK2Progrock(event *bkclient.SolveStatus) *progrock.StatusUpdate

+ func ConvertToWorkerCacheResult(ctx context.Context, res *solverresult.Result[*ref]) (*solverresult.Result[bkcache.ImmutableRef], error)

+ func DecodeIDHack(scheme string, id string, val any) error

+ func EncodeIDHack(val any) (string, error)

+ func ProgrockForwarder(sockPath string, w progrock.Writer) (progrock.Writer, func() error, error)

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

+ func RecordVertexes(recorder *progrock.Recorder, def *pb.Definition)

+ type Client struct

+ func NewClient(ctx context.Context, opts Opts) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) CombinedResult(ctx context.Context) (*Result, error)

+ func (c *Client) ExportContainerImage(ctx context.Context, inputByPlatform map[string]ContainerExport, ...) (map[string]string, error)

+ func (c *Client) GetSessionCaller(ctx context.Context, clientID string) (bksession.Caller, error)

+ func (c *Client) ID() string

+ func (c *Client) LocalDirExport(ctx context.Context, def *bksolverpb.Definition, destPath string) error

+ func (c *Client) LocalFileExport(ctx context.Context, def *bksolverpb.Definition, destPath string, ...) error

+ func (c *Client) LocalImportLLB(ctx context.Context, srcPath string, opts ...llb.LocalOption) (llb.State, error)

+ func (c *Client) NewContainer(ctx context.Context, req bkgw.NewContainerRequest) (bkgw.Container, error)

+ func (c *Client) PublishContainerImage(ctx context.Context, inputByPlatform map[string]ContainerExport, ...) (map[string]string, error)

+ func (c *Client) ReadCallerHostFile(ctx context.Context, path string) ([]byte, error)

+ func (c *Client) RegisterClient(clientID, clientHostname, secretToken string) error

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

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

+ func (c *Client) UpstreamCacheExport(ctx context.Context, cacheExportFuncs []ResolveCacheExporterFunc) error

+ func (c *Client) VerifyClient(clientID, secretToken string) error

+ func (c *Client) WriteStatusesTo(ctx context.Context, ch chan *bkclient.SolveStatus) error

+ type ContainerExport struct

+ Config specs.ImageConfig

+ Definition *bksolverpb.Definition

+ 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

+ type Opts struct

+ AuthProvider *auth.RegistryAuthProvider

+ GenericSolver *bksolver.Solver

+ LLBSolver *llbsolver.Solver

+ MainClientCaller bksession.Caller

+ PrivilegedExecEnabled bool

+ SecretStore bksecrets.SecretStore

+ SessionManager *bksession.Manager

+ UpstreamCacheImports []bkgw.CacheOptionsEntry

+ Worker bkworker.Worker

+ type ProgrockLogrusWriter struct

+ func (w ProgrockLogrusWriter) Close() error

+ func (w ProgrockLogrusWriter) WriteStatus(ev *progrock.StatusUpdate) error

+ type ResolveCacheExporterFunc func(ctx context.Context, g bksession.Group) (remotecache.Exporter, error)

+ type Result = solverresult.Result[*ref]