dagql

Feb 27, 2025

Changes in this version

+ func UnwrapAs[T any](val any) (T, bool)

type Cache

+ GetOrInitializeWithPostCall func(context.Context, digest.Digest, ...) (Typed, bool, func(context.Context) error, error)

type Class

+ func (class Class[T]) FieldSpec(name string, views ...string) (FieldSpec, bool)

type Field

+ func (field Field[T]) Sensitive() Field[T]

type FieldSpec

+ Sensitive bool

type Instance

+ func (r Instance[T]) GetPostCall() (func(context.Context) error, Typed)

+ func (r Instance[T]) WithPostCall(fn func(context.Context) error) Instance[T]

type ObjectType

+ FieldSpec func(name string, views ...string) (FieldSpec, bool)

type PostCallTyped

+ func NewPostCallTyped(t Typed, fn func(context.Context) error) PostCallTyped

+ func (p PostCallTyped) GetPostCall() (func(context.Context) error, Typed)

+ type PostCallable interface

+ GetPostCall func() (func(context.Context) error, Typed)

Feb 19, 2025

Changes in this version

type Cache

+ GetOrInitializeValue func(context.Context, digest.Digest, Typed) (Typed, bool, error)

+ type PostCallTyped struct

+ PostCall func(context.Context) error

+ func (p PostCallTyped) Unwrap() Typed

Feb 12, 2025

Changes in this version

+ func NewDefaultHandler(es graphql.ExecutableSchema) *handler.Server

+ type FieldCacheKeyFunc func(context.Context, Object, map[string]Input, digest.Digest) (digest.Digest, error)

Jan 29, 2025

Changes in this version

type Field

+ CacheKeyFunc func(context.Context, Instance[T], map[string]Input, digest.Digest) (digest.Digest, error)

+ func FuncWithCacheKey[T Typed, A any, R any](name string, fn func(ctx context.Context, self T, args A) (R, error), ...) Field[T]

+ func NodeFuncWithCacheKey[T Typed, A any, R any](name string, fn func(ctx context.Context, self Instance[T], args A) (R, error), ...) Field[T]

type Instance

+ func NewInstanceForID[P, T Typed](srv *Server, parent Instance[P], self T, id *call.ID) (Instance[T], error)

+ func (r Instance[T]) Call(ctx context.Context, s *Server, newID *call.ID) (Typed, *call.ID, error)

+ func (r Instance[T]) WithMetadata(customDigest digest.Digest, isPure bool) Instance[T]

type Object

+ Call func(context.Context, *Server, *call.ID) (Typed, *call.ID, error)

Dec 11, 2024

Changes in this version

type Selector

+ Pure bool

Oct 31, 2024

Changes in this version

type FieldSpec

+ Directives []*ast.Directive

type InputSpec

+ Directives []*ast.Directive

Oct 25, 2024

Changes in this version

+ type EnumValueName struct

+ Enum string

+ Value string

+ func (e *EnumValueName) DecodeInput(val any) (Input, error)

+ func (e *EnumValueName) Decoder() InputDecoder

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

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

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

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

+ func (e *EnumValueName) TypeName() string

type Instance

+ func NewInstanceForCurrentID[P, T Typed](ctx context.Context, srv *Server, parent Instance[P], self T) (Instance[T], error)

Sep 11, 2024

Changes in this version

type Field

+ func (field Field[T]) ArgRemove(name string) Field[T]

Jul 18, 2024

Changes in this version

type ID

+ func WalkedIDs[T Typed](idWalker *IDWalker) []ID[T]

+ type IDWalker struct

+ func WalkID(id *call.ID, skipTopLevel bool) (*IDWalker, error)

Jul 12, 2024

Changes in this version

+ type AllView struct

+ func (v AllView) Contains(s string) bool

+ type ExactView string

+ func (v ExactView) Contains(s string) bool

type Field

+ ViewFilter View

+ func (field Field[T]) Extend() Field[T]

+ func (field Field[T]) View(view View) Field[T]

type Selector

+ View string

type Server

+ View string

+ type View interface

+ Contains func(string) bool

+ var GlobalView View = nil

May 8, 2024

Changes in this version

+ type Scalar struct

+ Name string

+ Value T

+ func NewScalar[T ScalarValue](name string, val T) Scalar[T]

+ func (s *Scalar[T]) UnmarshalJSON(p []byte) error

+ func (s Scalar[T]) DecodeInput(val any) (Input, error)

+ func (s Scalar[T]) Decoder() InputDecoder

+ func (s Scalar[T]) MarshalJSON() ([]byte, error)

+ func (s Scalar[T]) ToLiteral() call.Literal

+ func (s Scalar[T]) Type() *ast.Type

+ func (s Scalar[T]) TypeDefinition() *ast.Definition

+ func (s Scalar[T]) TypeName() string

+ type ScalarValue interface

Apr 4, 2024

Changes in this version

+ const InstrumentationLibrary

+ func NoopDone(res Typed, cached bool, rerr error)

+ func Tracer() trace.Tracer

Feb 27, 2024

Changes in this version

+ func IsInternal(ctx context.Context) bool

+ type PanicError struct

+ Cause any

+ Selection Selection

+ Self Object

+ Stack []byte

+ func (err PanicError) Error() string

Feb 9, 2024

Changes in this version

+ type CacheMap interface

+ Get func(context.Context, K) (T, error)

+ GetOrInitialize func(context.Context, K, func(context.Context) (T, error)) (T, error)

+ Keys func() []K

+ func NewCacheMap[K comparable, T any]() CacheMap[K, T]

type DynamicArrayOutput

+ func (d DynamicArrayOutput) SetField(val reflect.Value) error

Feb 1, 2024

Changes in this version

+ func IDTypeNameFor(t Typed) string

Jan 19, 2024

Changes in this version

+ var DirectiveLocationArgumentDefinition = DirectiveLocations.Register("ARGUMENT_DEFINITION")

+ var DirectiveLocationEnum = DirectiveLocations.Register("ENUM")

+ var DirectiveLocationEnumValue = DirectiveLocations.Register("ENUM_VALUE")

+ var DirectiveLocationField = DirectiveLocations.Register("FIELD")

+ var DirectiveLocationFieldDefinition = DirectiveLocations.Register("FIELD_DEFINITION")

+ var DirectiveLocationFragmentDefinition = DirectiveLocations.Register("FRAGMENT_DEFINITION")

+ var DirectiveLocationFragmentSpread = DirectiveLocations.Register("FRAGMENT_SPREAD")

+ var DirectiveLocationInlineFragment = DirectiveLocations.Register("INLINE_FRAGMENT")

+ var DirectiveLocationInputFieldDefinition = DirectiveLocations.Register("INPUT_FIELD_DEFINITION")

+ var DirectiveLocationInputObject = DirectiveLocations.Register("INPUT_OBJECT")

+ var DirectiveLocationInterface = DirectiveLocations.Register("INTERFACE")

+ var DirectiveLocationMutation = DirectiveLocations.Register("MUTATION")

+ var DirectiveLocationObject = DirectiveLocations.Register("OBJECT")

+ var DirectiveLocationQuery = DirectiveLocations.Register("QUERY")

+ var DirectiveLocationScalar = DirectiveLocations.Register("SCALAR")

+ var DirectiveLocationSchema = DirectiveLocations.Register("SCHEMA")

+ var DirectiveLocationSubscription = DirectiveLocations.Register("SUBSCRIPTION")

+ var DirectiveLocationUnion = DirectiveLocations.Register("UNION")

+ var DirectiveLocationVariableDefinition = DirectiveLocations.Register("VARIABLE_DEFINITION")

+ var DirectiveLocations = NewEnum[DirectiveLocation]()

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

+ func CurrentID(ctx context.Context) *idproto.ID

+ func FormatDescription(paras ...string) string

+ func LoadIDs[T Typed](ctx context.Context, srv *Server, ids []ID[T]) ([]T, error)

+ type AroundFunc func(context.Context, Object, *idproto.ID, func(context.Context) (Typed, error)) func(context.Context) (Typed, error)

+ type Array []T

+ func MapArrayInput[T Input, R Typed](opt ArrayInput[T], fn func(T) (R, error)) (Array[R], error)

+ func NewBoolArray(elems ...bool) Array[Boolean]

+ func NewFloatArray(elems ...float64) Array[Float]

+ func NewIntArray(elems ...int) Array[Int]

+ func NewStringArray(elems ...string) Array[String]

+ func ToArray[A any, T Typed](fn func(A) T, elems ...A) Array[T]

+ func (arr Array[T]) Len() int

+ func (arr Array[T]) Nth(i int) (Typed, error)

+ func (i Array[T]) Type() *ast.Type

+ type ArrayInput []I

+ func (a ArrayInput[I]) DecodeInput(val any) (Input, error)

+ func (a ArrayInput[S]) Decoder() InputDecoder

+ func (a ArrayInput[S]) ToArray() Array[S]

+ func (a ArrayInput[S]) Type() *ast.Type

+ func (d ArrayInput[I]) SetField(val reflect.Value) error

+ func (i ArrayInput[S]) ToLiteral() *idproto.Literal

+ type Boolean bool

+ func NewBoolean(val bool) Boolean

+ func (Boolean) DecodeInput(val any) (Input, error)

+ func (Boolean) Decoder() InputDecoder

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

+ func (Boolean) TypeName() string

+ func (b *Boolean) UnmarshalJSON(p []byte) error

+ func (b Boolean) Bool() bool

+ func (b Boolean) MarshalJSON() ([]byte, error)

+ func (b Boolean) SetField(v reflect.Value) error

+ func (b Boolean) ToLiteral() *idproto.Literal

+ func (b Boolean) TypeDefinition() *ast.Definition

+ type Cache interface

+ GetOrInitialize func(context.Context, digest.Digest, func(context.Context) (Typed, error)) (Typed, error)

+ func NewCache() Cache

+ type Class struct

+ func NewClass[T Typed](opts_ ...ClassOpts[T]) Class[T]

+ func (class Class[T]) Field(name string) (Field[T], bool)

+ func (class Class[T]) IDType() (IDType, bool)

+ func (class Class[T]) Install(fields ...Field[T])

+ func (class Class[T]) Typed() Typed

+ func (cls Class[T]) Call(ctx context.Context, node Instance[T], fieldName string, args map[string]Input) (Typed, error)

+ func (cls Class[T]) Extend(spec FieldSpec, fun FieldFunc)

+ func (cls Class[T]) New(id *idproto.ID, val Typed) (Object, error)

+ func (cls Class[T]) ParseField(ctx context.Context, astField *ast.Field, vars map[string]any) (Selector, *ast.Type, error)

+ func (cls Class[T]) TypeDefinition() *ast.Definition

+ func (cls Class[T]) TypeName() string

+ type ClassOpts struct

+ NoIDs bool

+ Typed T

+ type DecoderFunc func(any) (Input, error)

+ func (f DecoderFunc) DecodeInput(val any) (Input, error)

+ type Definitive interface

+ TypeDefinition func() *ast.Definition

+ type Derefable interface

+ Deref func() (Typed, bool)

+ type Descriptive interface

+ TypeDescription func() string

+ type DirectiveLocation string

+ func (DirectiveLocation) Decoder() InputDecoder

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

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

+ type DirectiveSpec struct

+ Args InputSpecs

+ Description string

+ IsRepeatable bool

+ Locations []DirectiveLocation

+ Name string

+ func (d DirectiveSpec) DirectiveDefinition() *ast.DirectiveDefinition

+ type DynamicArrayInput struct

+ Elem Input

+ Values []Input

+ func (d DynamicArrayInput) DecodeInput(val any) (Input, error)

+ func (d DynamicArrayInput) Decoder() InputDecoder

+ func (d DynamicArrayInput) Len() int

+ func (d DynamicArrayInput) Nth(i int) (Typed, error)

+ func (d DynamicArrayInput) SetField(val reflect.Value) error

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

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

+ type DynamicArrayOutput struct

+ Elem Typed

+ Values []Typed

+ func (d DynamicArrayOutput) Len() int

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

+ func (d DynamicArrayOutput) Nth(i int) (Typed, error)

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

+ type DynamicNullable struct

+ Elem Typed

+ Valid bool

+ Value Typed

+ func (n *DynamicNullable) UnmarshalJSON(p []byte) error

+ func (n DynamicNullable) Deref() (Typed, bool)

+ func (n DynamicNullable) MarshalJSON() ([]byte, error)

+ func (n DynamicNullable) Type() *ast.Type

+ type DynamicOptional struct

+ Elem Input

+ Valid bool

+ Value Input

+ func (o DynamicOptional) DecodeInput(val any) (Input, error)

+ func (o DynamicOptional) Decoder() InputDecoder

+ func (o DynamicOptional) Deref() (Typed, bool)

+ func (o DynamicOptional) MarshalJSON() ([]byte, error)

+ func (o DynamicOptional) SetField(val reflect.Value) error

+ func (o DynamicOptional) ToLiteral() *idproto.Literal

+ func (o DynamicOptional) Type() *ast.Type

+ type EnumValue interface

+ type EnumValues struct

+ func NewEnum[T EnumValue](vals ...T) *EnumValues[T]

+ func (e *EnumValues[T]) DecodeInput(val any) (Input, error)

+ func (e *EnumValues[T]) Install(srv *Server)

+ func (e *EnumValues[T]) Literal(val T) *idproto.Literal

+ func (e *EnumValues[T]) Lookup(val string) (T, error)

+ func (e *EnumValues[T]) PossibleValues() ast.EnumValueList

+ func (e *EnumValues[T]) Register(val T, desc ...string) T

+ func (e *EnumValues[T]) Type() *ast.Type

+ func (e *EnumValues[T]) TypeDefinition() *ast.Definition

+ func (e *EnumValues[T]) TypeName() string

+ type Enumerable interface

+ Len func() int

+ Nth func(int) (Typed, error)

+ type ExtendedError interface

+ Extensions func() map[string]any

+ type Field struct

+ Func func(context.Context, Instance[T], map[string]Input) (Typed, error)

+ Spec FieldSpec

+ func Func[T Typed, A any, R any](name string, fn func(ctx context.Context, self T, args A) (R, error)) Field[T]

+ func NodeFunc[T Typed, A any, R any](name string, fn func(ctx context.Context, self Instance[T], args A) (R, error)) Field[T]

+ func (field Field[T]) ArgDeprecated(name string, paras ...string) Field[T]

+ func (field Field[T]) ArgDoc(name string, paras ...string) Field[T]

+ func (field Field[T]) ArgSensitive(name string) Field[T]

+ func (field Field[T]) Deprecated(paras ...string) Field[T]

+ func (field Field[T]) Doc(paras ...string) Field[T]

+ func (field Field[T]) DynamicReturnType(ret Typed) Field[T]

+ func (field Field[T]) FieldDefinition() *ast.FieldDefinition

+ func (field Field[T]) Impure(reason string, paras ...string) Field[T]

+ func (field Field[T]) Meta() Field[T]

+ type FieldFunc func(context.Context, Object, map[string]Input) (Typed, error)

+ type FieldSpec struct

+ Args InputSpecs

+ DeprecatedReason string

+ Description string

+ ImpurityReason string

+ Meta bool

+ Module *idproto.ID

+ Name string

+ Type Typed

+ func (spec FieldSpec) FieldDefinition() *ast.FieldDefinition

+ type Fields []Field[T]

+ func (fields Fields[T]) Install(server *Server)

+ type Float float64

+ func NewFloat(val float64) Float

+ func (Float) DecodeInput(val any) (Input, error)

+ func (Float) Decoder() InputDecoder

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

+ func (Float) TypeName() string

+ func (f *Float) UnmarshalJSON(p []byte) error

+ func (f Float) Float64() float64

+ func (f Float) MarshalJSON() ([]byte, error)

+ func (f Float) SetField(v reflect.Value) error

+ func (f Float) ToLiteral() *idproto.Literal

+ func (f Float) TypeDefinition() *ast.Definition

+ type ID struct

+ func NewDynamicID[T Typed](id *idproto.ID, typed T) ID[T]

+ func NewID[T Typed](id *idproto.ID) ID[T]

+ func (i *ID[T]) Decode(str string) error

+ func (i *ID[T]) UnmarshalJSON(p []byte) error

+ func (i ID[T]) DecodeInput(val any) (Input, error)

+ func (i ID[T]) Decoder() InputDecoder

+ func (i ID[T]) Display() string

+ func (i ID[T]) Encode() (string, error)

+ func (i ID[T]) ID() *idproto.ID

+ func (i ID[T]) Load(ctx context.Context, server *Server) (Instance[T], error)

+ func (i ID[T]) MarshalJSON() ([]byte, error)

+ func (i ID[T]) SetField(v reflect.Value) error

+ func (i ID[T]) String() string

+ func (i ID[T]) ToLiteral() *idproto.Literal

+ func (i ID[T]) Type() *ast.Type

+ func (i ID[T]) TypeDefinition() *ast.Definition

+ func (i ID[T]) TypeName() string

+ type IDType interface

+ type IDable interface

+ ID func() *idproto.ID

+ type Input interface

+ Decoder func() InputDecoder

+ type InputDecoder interface

+ DecodeInput func(any) (Input, error)

+ type InputObject struct

+ Value T

+ func (InputObject[T]) Decoder() InputDecoder

+ func (InputObject[T]) Type() *ast.Type

+ func (input InputObject[T]) ToLiteral() *idproto.Literal

+ type InputObjectSpec struct

+ Description string

+ Fields InputSpecs

+ Name string

+ func MustInputSpec(val Type) InputObjectSpec

+ func (spec InputObjectSpec) Install(srv *Server)

+ func (spec InputObjectSpec) Type() *ast.Type

+ func (spec InputObjectSpec) TypeDefinition() *ast.Definition

+ func (spec InputObjectSpec) TypeName() string

+ type InputSpec struct

+ Default Input

+ DeprecatedReason string

+ Description string

+ Name string

+ Sensitive bool

+ Type Input

+ type InputSpecs []InputSpec

+ func (specs InputSpecs) ArgumentDefinitions() []*ast.ArgumentDefinition

+ func (specs InputSpecs) FieldDefinitions() []*ast.FieldDefinition

+ func (specs InputSpecs) Lookup(name string) (InputSpec, bool)

+ type InputType struct

+ type Inputs []NamedInput

+ func (args Inputs) Lookup(name string) (Input, bool)

+ type Instance struct

+ Class Class[T]

+ Constructor *idproto.ID

+ Module *idproto.ID

+ Self T

+ func (o Instance[T]) Type() *ast.Type

+ func (r Instance[T]) ID() *idproto.ID

+ func (r Instance[T]) IDFor(ctx context.Context, sel Selector) (*idproto.ID, error)

+ func (r Instance[T]) ObjectType() ObjectType

+ func (r Instance[T]) Select(ctx context.Context, sel Selector) (val Typed, err error)

+ func (r Instance[T]) String() string

+ func (r Instance[T]) Unwrap() Typed

+ type Int int64

+ func NewInt[T constraints.Integer](val T) Int

+ func (Int) DecodeInput(val any) (Input, error)

+ func (Int) Decoder() InputDecoder

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

+ func (Int) TypeName() string

+ func (i *Int) UnmarshalJSON(p []byte) error

+ func (i Int) Int() int

+ func (i Int) Int64() int64

+ func (i Int) MarshalJSON() ([]byte, error)

+ func (i Int) SetField(v reflect.Value) error

+ func (i Int) ToLiteral() *idproto.Literal

+ func (i Int) TypeDefinition() *ast.Definition

+ type Loadable interface

+ Load func(context.Context, *Server) (Typed, error)

+ type NamedInput struct

+ Name string

+ Value Input

+ func (arg NamedInput) String() string

+ type Nullable struct

+ Valid bool

+ Value T

+ func MapOpt[I Input, R Typed](opt Optional[I], fn func(I) (R, error)) (Nullable[R], error)

+ func NonNull[T Typed](val T) Nullable[T]

+ func Null[T Typed]() Nullable[T]

+ func (n *Nullable[T]) UnmarshalJSON(p []byte) error

+ func (n Nullable[T]) Deref() (Typed, bool)

+ func (n Nullable[T]) MarshalJSON() ([]byte, error)

+ func (n Nullable[T]) Type() *ast.Type

+ type Object interface

+ IDFor func(context.Context, Selector) (*idproto.ID, error)

+ ObjectType func() ObjectType

+ Select func(context.Context, Selector) (Typed, error)

+ type ObjectType interface

+ Extend func(FieldSpec, FieldFunc)

+ IDType func() (IDType, bool)

+ New func(*idproto.ID, Typed) (Object, error)

+ ParseField func(context.Context, *ast.Field, map[string]any) (Selector, *ast.Type, error)

+ Typed func() Typed

+ type Optional struct

+ Valid bool

+ Value I

+ func NoOpt[I Input]() Optional[I]

+ func Opt[I Input](v I) Optional[I]

+ func (n Optional[I]) GetOr(v I) I

+ func (o *Optional[I]) UnmarshalJSON(p []byte) error

+ func (o Optional[I]) DecodeInput(val any) (Input, error)

+ func (o Optional[I]) Decoder() InputDecoder

+ func (o Optional[I]) Deref() (Typed, bool)

+ func (o Optional[I]) MarshalJSON() ([]byte, error)

+ func (o Optional[I]) ToLiteral() *idproto.Literal

+ func (o Optional[I]) ToNullable() Nullable[I]

+ func (o Optional[I]) Type() *ast.Type

+ type ScalarType interface

+ type Selection struct

+ Alias string

+ Selector Selector

+ Subselections []Selection

+ func (sel Selection) Name() string

+ type Selector struct

+ Args []NamedInput

+ Field string

+ Nth int

+ func (sel Selector) AppendTo(id *idproto.ID, spec FieldSpec) *idproto.ID

+ func (sel Selector) String() string

+ type Server struct

+ Cache Cache

+ func NewServer[T Typed](root T) *Server

+ func (s *Server) Around(rec AroundFunc)

+ func (s *Server) Complexity(typeName, field string, childComplexity int, args map[string]interface{}) (int, bool)

+ func (s *Server) Exec(ctx1 context.Context) graphql.ResponseHandler

+ func (s *Server) ExecOp(ctx context.Context, gqlOp *graphql.OperationContext) (map[string]any, error)

+ func (s *Server) InstallDirective(directive DirectiveSpec)

+ func (s *Server) InstallObject(class ObjectType)

+ func (s *Server) InstallScalar(scalar ScalarType)

+ func (s *Server) InstallTypeDef(def TypeDef)

+ func (s *Server) Load(ctx context.Context, id *idproto.ID) (Object, error)

+ func (s *Server) ObjectType(name string) (ObjectType, bool)

+ func (s *Server) Query(ctx context.Context, query string, vars map[string]any) (map[string]any, error)

+ func (s *Server) Resolve(ctx context.Context, self Object, sels ...Selection) (map[string]any, error)

+ func (s *Server) Root() Object

+ func (s *Server) ScalarType(name string) (ScalarType, bool)

+ func (s *Server) Schema() *ast.Schema

+ func (s *Server) Select(ctx context.Context, self Object, dest any, sels ...Selector) error

+ func (s *Server) TypeDef(name string) (TypeDef, bool)

+ type Setter interface

+ SetField func(reflect.Value) error

+ type String string

+ func NewString(val string) String

+ func (String) DecodeInput(val any) (Input, error)

+ func (String) Decoder() InputDecoder

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

+ func (String) TypeName() string

+ func (s *String) UnmarshalJSON(p []byte) error

+ func (s String) MarshalJSON() ([]byte, error)

+ func (s String) SetField(v reflect.Value) error

+ func (s String) String() string

+ func (s String) ToLiteral() *idproto.Literal

+ func (s String) TypeDefinition() *ast.Definition

+ type Type interface

+ TypeName func() string

+ type TypeDef interface

+ type Typed interface

+ Type func() *ast.Type

+ type Wrapper interface

+ Unwrap func() Typed