client

Oct 25, 2024

Changes in this version

type Params

+ EngineMetrics []sdkmetric.Exporter

Sep 18, 2024

Changes in this version

+ func ExpandHomeDir(homeDir string, path string) (string, error)

Sep 11, 2024

Changes in this version

type Params

+ Version string

Aug 30, 2024

Changes in this version

+ func LexicalRelativePath(cwdPath, modPath string) (string, error)

type Params

+ InteractiveCommand []string

Jul 25, 2024

Changes in this version

+ const StableIDFileName

+ func GetHostStableID(lg *slog.Logger) string

Jul 18, 2024

Changes in this version

type SocketProvider

+ IPDialer func(network, addr string) (net.Conn, error)

+ UnixPathMapper func(path string) (string, error)

Jul 12, 2024

Changes in this version

type Params

+ Interactive bool

+ WithTerminal session.WithTerminalFunc

Jun 18, 2024

Changes in this version

+ type BuildkitSessionServer struct

+ Conn net.Conn

+ MethodURLs []string

+ func ConnectBuildkitSession(ctx context.Context, conn net.Conn, headers http.Header, ...) (*BuildkitSessionServer, error)

+ func NewBuildkitSessionServer(ctx context.Context, conn net.Conn, attachables ...bksession.Attachable) *BuildkitSessionServer

+ func (srv *BuildkitSessionServer) Run(ctx context.Context)

type Client

+ func (c *Client) AppendHTTPRequestHeaders(headers http.Header) http.Header

type Params

+ SessionID string

Jun 11, 2024

Changes in this version

type Params

+ LogLevel slog.Level

May 28, 2024

Changes in this version

+ type FilesyncSource Filesyncer

+ func (s FilesyncSource) DiffCopy(stream filesync.FileSync_DiffCopyServer) error

+ func (s FilesyncSource) Register(server *grpc.Server)

+ func (s FilesyncSource) TarStream(stream filesync.FileSync_TarStreamServer) error

+ type FilesyncTarget Filesyncer

+ func (t FilesyncTarget) DiffCopy(stream filesync.FileSend_DiffCopyServer) (rerr error)

+ func (t FilesyncTarget) Register(server *grpc.Server)

+ type Filesyncer struct

+ func NewFilesyncer(rootDir, cwdPath string, uid, gid *uint32) (Filesyncer, error)

+ func (f Filesyncer) AsSource() FilesyncSource

+ func (f Filesyncer) AsTarget() FilesyncTarget

type Params

+ CloudCallback func(string)

+ EngineCallback func(string, string)

type SocketProvider

+ Dialer func(network, addr string) (net.Conn, error)

May 8, 2024

Changes in this version

type Params

+ ID string

Apr 4, 2024

Changes in this version

+ const InstrumentationLibrary

+ func Tracer() trace.Tracer

type Params

+ EngineLogs sdklog.LogExporter

+ EngineTrace sdktrace.SpanExporter

Feb 27, 2024

Changes in this version

+ const ProgrockParentHeader

Feb 1, 2024

Changes in this version

type Params

+ ProgrockParent string

Dec 8, 2023

Changes in this version

type Params

+ ModuleCallerDigest digest.Digest

Oct 31, 2023

Changes in this version

+ const GPUSupportEnvName

type Params

+ ModuleContextDigest digest.Digest

Oct 11, 2023

Changes in this version

type Client

+ func (c *Client) Dagger() *dagger.Client

+ type DirectConn func(*http.Request) (*http.Response, error)

+ func EngineConn(engineClient *Client) DirectConn

+ func (f DirectConn) Close() error

+ func (f DirectConn) Do(r *http.Request) (*http.Response, error)

+ func (f DirectConn) Host() string

type Params

+ FunctionContextDigest digest.Digest

+ ModuleDigest digest.Digest

Sep 13, 2023

Changes in this version

+ const DaggerCloudToken

Aug 3, 2023

Changes in this version

+ const DaggerCloudCacheToken

+ const DefaultStateDir

+ const DockerImageProvider

+ const OCIStoreName

+ const ServicesDNSEnvName

+ type AnyDirSource struct

+ func (s AnyDirSource) DiffCopy(stream filesync.FileSync_DiffCopyServer) error

+ func (s AnyDirSource) Register(server *grpc.Server)

+ func (s AnyDirSource) TarStream(stream filesync.FileSync_TarStreamServer) error

+ type AnyDirTarget struct

+ func (AnyDirTarget) DiffCopy(stream filesync.FileSend_DiffCopyServer) (rerr error)

+ func (t AnyDirTarget) Register(server *grpc.Server)

+ type Client struct

+ Recorder *progrock.Recorder

+ func Connect(ctx context.Context, params Params) (_ *Client, _ context.Context, rerr error)

+ func (c *Client) Close() (rerr error)

+ func (c *Client) DialContext(ctx context.Context, _, _ string) (net.Conn, error)

+ func (c *Client) Do(ctx context.Context, query string, opName string, variables map[string]any, ...) (rerr error)

+ func (c *Client) ID() string

+ func (c *Client) NestedDialContext(ctx context.Context, _, _ string) (net.Conn, error)

+ func (c *Client) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Params struct

+ CloudURLCallback func(string)

+ DisableHostRW bool

+ EngineNameCallback func(string)

+ JournalFile string

+ ParentClientIDs []string

+ ProgrockWriter progrock.Writer

+ RunnerHost string

+ SecretToken string

+ ServerID string

+ UserAgent string

+ type SocketProvider struct

+ EnableHostNetworkAccess bool

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

+ func (p SocketProvider) ForwardAgent(stream sshforward.SSH_ForwardAgentServer) error

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