schema

package
v0.8.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 11, 2023 License: Apache-2.0 Imports: 53 Imported by: 1

README

Core API proposal

This directory contains a proposal for a complete GraphQL API for Dagger. It is written with the following goals in mind:

  1. Feature parity with Dagger 0.2
  2. Close to feature parity with Buildkit, with an incremental path to reaching full parity in the future
  3. Follow established graphql best practices
  4. Sove as many outstanding DX problems as possible

Reference

DX problems solved

Some problems in the DX that are not yet resolved, and this proposal would help solve, include:

  • Uncertainty as to how to express uploads in a graphql-friendly way (deployment, image push, git push, etc)
  • Chaining of FS operations greatly reduces verbosity, but cannot be applied all the time
  • Transitioning a script to an extension requires non-trivial refactoring, to tease apart the script-specific code from the underlying "API".
  • The API sandbox is amazing for prototyping small queries, but of limited use when multiple queries must reference each other. This is because the native code doing the stitching cannot be run by the playground, so filesystem IDs must be manually copy-pasted between queries.

Design highlights

withX and withoutX

To avoid the use of rpc-style verbs (a graphql best practice) and maximize chaining (a strength of our DX), we use the terminology withX and withoutX.

A field of the form withX returns the same object with content X added or changed.

Example:

"An empty directory with a README copied to it"
query readmeDir($readme: FileID!) {
  directory {
    withFile(source: $readme, path: "README.md") {
      id
    }
}

"An empty container with an app directory mounted into it"
query appContainer($app: DirectoryID!) {
  container {
    withMountedDirectory(source: $app, path: "/app") {
      id
    }
  }
}

A field of the form withoutX returns the same object with content X removed.

"Remove node_modules from a JS project"
query removeNodeModules($dir: DirectoryID!) {
  directory(id: $dir) {
    withoutDirectory(path: "node_modules") {
      id
    }
  }
}
Secrets

Secret handling has been simplified and made more consistent with Directory handling.

  • Secrets have an ID, and can be loaded by ID in the standard graphql manner
  • Secrets can be created in one of two ways:
    1. From an environment variable: type Environment { secret }
    2. From a file: type Directory { secret }
Embrace the llb / Dockerfile model

The Container type proposes an expansive definition of the container, similar to the Buildkit/Dockerfile model. A Container is:

  1. A filesystem state
  2. An OCI artifact which can be pulled from, and pushed to a repository at any time
  3. A persistent configuration to be applied to all commands executed inside it

This is similar to how buildkit models llb state, and how the Dockerfile language models stage state. Note that Dagger extends this model to include even mount configuration (which are scoped to exec in buildkit, but scoped to container in dagger).

Examples:

"""
Download a file over HTTP in a very convoluted way:

1. Download a base linux container
2. Install curl
3. Download the file into the container
4. Load and return the file
"""
query convolutedDownload($url: String!) {
  container {
    from(address: "index.docker.io/alpine:latest") {
      exec(args: ["apk", "add", "curl"]) {
        exec(args: ["curl", "-o", "/tmp/download", $url) {
          file(path: "/tmp/download") {
            id
         }
      }
    }
  }
}

"""
Specialize two containers from a common base
"""
query twoContainers {
  container {
    from(address: "alpine") {
      debug: withVariable(name: "DEBUG", value: "1") {
        id
        exec(args: ["env"]) {
          stdout
        }
      }
      noDebug: withVariable(name: "DEBUG", value: "0") {
        id
        exec(args: ["env"]) {
          stdout
        }
      }
    }
  }
}

Documentation

Index

Constants

View Source
const (
	ContentTypeJSON           = "application/json"
	ContentTypeGraphQL        = "application/graphql"
	ContentTypeFormURLEncoded = "application/x-www-form-urlencoded"
)

Variables

View Source
var (
	ErrMergeTypeConflict   = errors.New("object type re-defined")
	ErrMergeFieldConflict  = errors.New("field re-defined")
	ErrMergeScalarConflict = errors.New("scalar re-defined")
)
View Source
var Cache string
View Source
var Container string
View Source
var Directory string
View Source
var File string
View Source
var Function string
View Source
var HTTP string
View Source
var Host string
View Source
var InternalSDK string
View Source
var Module string
View Source
var Platform string
View Source
var Query string
View Source
var Secret string
View Source
var Socket string

Functions

func ErrResolver added in v0.8.0

func ErrResolver(err error) graphql.FieldResolveFn

func PassthroughResolver added in v0.8.0

func PassthroughResolver(p graphql.ResolveParams) (any, error)

func ToResolver added in v0.8.0

func ToResolver[P any, A any, R any](f func(*core.Context, P, A) (R, error)) graphql.FieldResolveFn

ToResolver transforms any function f with a *Context, a parent P and some args A that returns a Response R and an error into a graphql resolver graphql.FieldResolveFn.

func ToVoidResolver added in v0.8.8

func ToVoidResolver[P any, A any](f func(*core.Context, P, A) error) graphql.FieldResolveFn

Types

type EnvVariable

type EnvVariable struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type ExecutableSchema added in v0.8.0

type ExecutableSchema interface {
	Name() string
	Schema() string
	Resolvers() Resolvers
	Dependencies() []ExecutableSchema
}

func StaticSchema added in v0.8.0

func StaticSchema(p StaticSchemaParams) ExecutableSchema

type ExposedPort added in v0.3.13

type ExposedPort struct {
	Port        int     `json:"port"`
	Protocol    string  `json:"protocol"`
	Description *string `json:"description,omitempty"`
}

NB(vito): we have to use a different type with a regular string Protocol field so that the enum mapping works.

type FieldResolvers added in v0.8.0

type FieldResolvers interface {
	Resolver
	Fields() map[string]graphql.FieldResolveFn
	SetField(string, graphql.FieldResolveFn)
}

type FunctionContext added in v0.8.8

type FunctionContext struct {
	Module      *core.Module
	CurrentCall *core.FunctionCall
}

FunctionContext holds the metadata of a function call. Used to support the currentModule and currentFunctionCall APIs.

func (*FunctionContext) Digest added in v0.8.8

func (fnCtx *FunctionContext) Digest() (digest.Digest, error)

type FunctionContextCache added in v0.8.8

type FunctionContextCache core.CacheMap[digest.Digest, *FunctionContext]

FunctionContextCache stores the mapping of FunctionContext's digest -> FunctionContext. This enables us to pass just the digest along the client metadata rather than massive serialized objects.

func NewFunctionContextCache added in v0.8.8

func NewFunctionContextCache() *FunctionContextCache

func (*FunctionContextCache) FunctionContextFrom added in v0.8.8

func (cache *FunctionContextCache) FunctionContextFrom(ctx context.Context) (*FunctionContext, error)

func (*FunctionContextCache) WithFunctionContext added in v0.8.8

func (cache *FunctionContextCache) WithFunctionContext(ctx *core.Context, fnCtx *FunctionContext) (*core.Context, error)

type Handler added in v0.8.8

type Handler struct {
	Schema *graphql.Schema
	// contains filtered or unexported fields
}

func NewHandler added in v0.8.8

func NewHandler(p *HandlerConfig) *Handler

func (*Handler) ContextHandler added in v0.8.8

func (h *Handler) ContextHandler(ctx context.Context, w http.ResponseWriter, r *http.Request)

ContextHandler provides an entrypoint into executing graphQL queries with a user-provided context.

func (*Handler) ServeHTTP added in v0.8.8

func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP provides an entrypoint into executing graphQL queries.

type HandlerConfig added in v0.8.8

type HandlerConfig struct {
	Schema           *graphql.Schema
	Pretty           bool
	RootObjectFn     RootObjectFn
	ResultCallbackFn ResultCallbackFn
	FormatErrorFn    func(err error) gqlerrors.FormattedError
}

func NewConfig added in v0.8.8

func NewConfig() *HandlerConfig

type IDableObjectResolver added in v0.8.0

type IDableObjectResolver interface {
	FromID(id string) (any, error)
	ToID(any) (string, error)
	Resolver
}

func ToIDableObjectResolver added in v0.8.0

func ToIDableObjectResolver[T any, I ~string](idToObject func(I) (*T, error), r ObjectResolver) IDableObjectResolver

type InitializeArgs

type InitializeArgs struct {
	BuildkitClient *buildkit.Client
	Platform       specs.Platform
	ProgSockPath   string
	OCIStore       content.Store
	LeaseManager   *leaseutil.Manager
	Auth           *auth.RegistryAuthProvider
	Secrets        *core.SecretStore
}

type InvalidInputError added in v0.8.0

type InvalidInputError struct {
	Err error
}

func (InvalidInputError) Error added in v0.8.0

func (e InvalidInputError) Error() string

func (InvalidInputError) Unwrap added in v0.8.0

func (e InvalidInputError) Unwrap() error

type Label added in v0.3.10

type Label struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type MergedSchemas added in v0.8.0

type MergedSchemas struct {
	// contains filtered or unexported fields
}

func New

func New(params InitializeArgs) (*MergedSchemas, error)

func (*MergedSchemas) HTTPHandler added in v0.8.8

func (s *MergedSchemas) HTTPHandler(moduleDigest digest.Digest) (http.Handler, error)

func (*MergedSchemas) MuxEndpoint added in v0.8.8

func (s *MergedSchemas) MuxEndpoint(path string, handler http.Handler, moduleDigest digest.Digest) error

func (*MergedSchemas) Schema added in v0.8.0

func (s *MergedSchemas) Schema(moduleDigest digest.Digest) (*graphql.Schema, error)

func (*MergedSchemas) ShutdownClient added in v0.8.5

func (s *MergedSchemas) ShutdownClient(ctx context.Context, client *engine.ClientMetadata) error

type ObjectResolver added in v0.8.0

type ObjectResolver map[string]graphql.FieldResolveFn

func (ObjectResolver) Fields added in v0.8.0

func (ObjectResolver) SetField added in v0.8.0

func (r ObjectResolver) SetField(name string, fn graphql.FieldResolveFn)

type RequestOptions added in v0.8.8

type RequestOptions struct {
	Query         string                 `json:"query" url:"query" schema:"query"`
	Variables     map[string]interface{} `json:"variables" url:"variables" schema:"variables"`
	OperationName string                 `json:"operationName" url:"operationName" schema:"operationName"`
}

func NewRequestOptions added in v0.8.8

func NewRequestOptions(r *http.Request) *RequestOptions

RequestOptions Parses a http.Request into GraphQL request options struct

type Resolver added in v0.8.0

type Resolver interface {
	// contains filtered or unexported methods
}

type Resolvers added in v0.8.0

type Resolvers map[string]Resolver

type ResultCallbackFn added in v0.8.8

type ResultCallbackFn func(ctx context.Context, params *graphql.Params, result *graphql.Result, responseBody []byte)

type RootObjectFn added in v0.8.8

type RootObjectFn func(ctx context.Context, r *http.Request) map[string]interface{}

RootObjectFn allows a user to generate a RootObject per request

type ScalarResolver added in v0.8.0

type ScalarResolver struct {
	Serialize    graphql.SerializeFn
	ParseValue   graphql.ParseValueFn
	ParseLiteral graphql.ParseLiteralFn
}

type SecretPlaintext added in v0.6.0

type SecretPlaintext string

func (SecretPlaintext) MarshalText added in v0.6.0

func (s SecretPlaintext) MarshalText() ([]byte, error)

This method ensures that the progrock vertex info does not display the plaintext.

type StaticSchemaParams added in v0.8.0

type StaticSchemaParams struct {
	Name         string
	Schema       string
	Resolvers    Resolvers
	Dependencies []ExecutableSchema
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL