client

Documentation

Index

• Constants
• func Tracer() trace.Tracer
• type AnyDirSource
  • 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
  • func (AnyDirTarget) DiffCopy(stream filesync.FileSend_DiffCopyServer) (rerr error)
  • func (t AnyDirTarget) Register(server *grpc.Server)
• type Client
  • func Connect(ctx context.Context, params Params) (_ *Client, _ context.Context, rerr error)
  • func (c *Client) Close() (rerr error)
  • func (c *Client) Dagger() *dagger.Client
  • func (c *Client) DialContext(ctx context.Context, _, _ string) (conn net.Conn, err 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) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type DirectConn
  • 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
• type SocketProvider
  • 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)

Constants

const InstrumentationLibrary = "dagger.io/engine.client"

Functions

func Tracer

func Tracer() trace.Tracer

Types

type AnyDirSource

type AnyDirSource struct{}

Local dir imports

func (AnyDirSource) DiffCopy

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

func (AnyDirSource) Register

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

func (AnyDirSource) TarStream

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

type AnyDirTarget

type AnyDirTarget struct{}

Local dir exports

func (AnyDirTarget) DiffCopy

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

func (AnyDirTarget) Register

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

type Client

type Client struct {
	Params
	// contains filtered or unexported fields
}

func Connect

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

func (*Client) Close

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

func (*Client) Dagger

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

A client to the Dagger API hooked up directly with this engine client.

func (*Client) DialContext

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

func (*Client) Do

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

func (*Client) ID

func (c *Client) ID() string

func (*Client) ServeHTTP

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

type DirectConn

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

func EngineConn

func EngineConn(engineClient *Client) DirectConn

func (DirectConn) Close

func (f DirectConn) Close() error

func (DirectConn) Do

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

func (DirectConn) Host

func (f DirectConn) Host() string

type Params

type Params struct {
	// The id of the server to connect to, or if blank a new one
	// should be started.
	ServerID string

	// Parent client IDs of this Dagger client.
	//
	// Used by Dagger-in-Dagger so that nested sessions can resolve addresses
	// passed from the parent.
	ParentClientIDs []string

	SecretToken string

	RunnerHost string // host of dagger engine runner serving buildkit apis
	UserAgent  string

	DisableHostRW bool

	EngineNameCallback func(string)
	CloudURLCallback   func(string)

	// If this client is for a module function, this digest will be set in the
	// grpc context metadata for any api requests back to the engine. It's used by the API
	// server to determine which schema to serve and other module context metadata.
	ModuleCallerDigest digest.Digest

	EngineTrace sdktrace.SpanExporter
	EngineLogs  sdklog.LogExporter
}

type SocketProvider

type SocketProvider struct {
	EnableHostNetworkAccess bool
}

func (SocketProvider) CheckAgent

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

func (SocketProvider) ForwardAgent

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

func (SocketProvider) Register

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