exec

Documentation

Index

• type Execution
  • func (r *Execution) AddError(err error)
  • func (this *Execution) CreateSelectionResolversForFragment(ctx context.Context, parentSelectionResolver *SelectionResolver, ...)
  • func (this *Execution) Execute() error
  • func (this *Execution) FireSubscriptionClose()
  • func (this *Execution) FireSubscriptionEvent(value reflect.Value, err error)
  • func (this *Execution) GetContext() context.Context
  • func (this *Execution) GetDocument() *schema.QueryDocument
  • func (this *Execution) GetLimiter() *chan byte
  • func (this *Execution) GetOperation() *schema.Operation
  • func (this *Execution) GetQuery() string
  • func (this *Execution) GetRoot() interface{}
  • func (this *Execution) GetSchema() *schema.Schema
  • func (this *Execution) GetVars() map[string]interface{}
  • func (this *Execution) HandlePanic(path []string) error
• type ExecutionResult
• type SelectionResolver
  • func (this *SelectionResolver) Path() []string

Types

type Execution

type Execution struct {
	Query     string
	Vars      map[string]interface{}
	Schema    *schema.Schema
	Doc       *schema.QueryDocument
	Operation *schema.Operation

	Tracer   trace.Tracer
	Logger   log.Logger
	Root     interface{}
	VarTypes map[string]*introspection.Type
	Context  context.Context
	Resolver resolvers.Resolver
	Mu       sync.Mutex

	MaxParallelism int

	FireSubscriptionEventFunc func(d json.RawMessage, e qerrors.ErrorList)
	FireSubscriptionCloseFunc func()
	TryCast                   func(value reflect.Value, toType string) (v reflect.Value, ok bool)
	// contains filtered or unexported fields
}

func (*Execution) AddError

func (r *Execution) AddError(err error)

func (*Execution) CreateSelectionResolversForFragment

func (this *Execution) CreateSelectionResolversForFragment(ctx context.Context, parentSelectionResolver *SelectionResolver, fragment *schema.Fragment, parentType schema.Type, parentValue reflect.Value, selectionResolvers *linkedmap.LinkedMap)

func (*Execution) Execute

func (this *Execution) Execute() error

func (*Execution) FireSubscriptionClose

func (this *Execution) FireSubscriptionClose()

func (*Execution) FireSubscriptionEvent

func (this *Execution) FireSubscriptionEvent(value reflect.Value, err error)

This is called by subscription resolvers to send out a subscription event.

func (*Execution) GetContext

func (this *Execution) GetContext() context.Context

func (*Execution) GetDocument

func (this *Execution) GetDocument() *schema.QueryDocument

func (*Execution) GetLimiter

func (this *Execution) GetLimiter() *chan byte

func (*Execution) GetOperation

func (this *Execution) GetOperation() *schema.Operation

func (*Execution) GetQuery

func (this *Execution) GetQuery() string

func (*Execution) GetRoot

func (this *Execution) GetRoot() interface{}

func (*Execution) GetSchema

func (this *Execution) GetSchema() *schema.Schema

func (*Execution) GetVars

func (this *Execution) GetVars() map[string]interface{}

func (*Execution) HandlePanic

func (this *Execution) HandlePanic(path []string) error

type ExecutionResult

type ExecutionResult struct {
	Errors qerrors.ErrorList
	Data   *bytes.Buffer
}

type SelectionResolver

type SelectionResolver struct {
	Resolution resolvers.Resolution
	// contains filtered or unexported fields
}

func (*SelectionResolver) Path

func (this *SelectionResolver) Path() []string