plan

Documentation

Index

• func AnalyzePlanKind(operation, definition *ast.Document, operationName string) (subscription, streaming bool, error error)
• type ArgumentConfiguration
• type ArgumentsConfigurations
  • func (a ArgumentsConfigurations) ForName(argName string) *ArgumentConfiguration
• type Configuration
• type DataSourceConfiguration
  • func (d *DataSourceConfiguration) HasRootNode(typeName, fieldName string) bool
• type DataSourcePlanner
• type FetchConfiguration
• type FieldConfiguration
• type FieldConfigurations
  • func (f FieldConfigurations) ForTypeField(typeName, fieldName string) *FieldConfiguration
• type FieldMapping
• type Kind
• type Plan
• type Planner
  • func NewPlanner(config Configuration) *Planner
  • func (p *Planner) Plan(operation, definition *ast.Document, operationName string, ...) (plan Plan)
  • func (p *Planner) SetConfig(config Configuration)
• type PlannerFactory
• type SourceType
• type StreamingResponsePlan
  • func (_ *StreamingResponsePlan) PlanKind() Kind
  • func (s *StreamingResponsePlan) SetFlushInterval(interval int64)
• type SubscriptionConfiguration
• type SubscriptionResponsePlan
  • func (_ *SubscriptionResponsePlan) PlanKind() Kind
  • func (s *SubscriptionResponsePlan) SetFlushInterval(interval int64)
• type SynchronousResponsePlan
  • func (_ *SynchronousResponsePlan) PlanKind() Kind
  • func (s *SynchronousResponsePlan) SetFlushInterval(interval int64)
• type TypeField
• type Visitor
  • func (v *Visitor) AllowVisitor(kind astvisitor.VisitorKind, ref int, visitor interface{}) bool
  • func (v *Visitor) EnterDirective(ref int)
  • func (v *Visitor) EnterDocument(operation, definition *ast.Document)
  • func (v *Visitor) EnterField(ref int)
  • func (v *Visitor) EnterOperationDefinition(ref int)
  • func (v *Visitor) EnterSelectionSet(ref int)
  • func (v *Visitor) LeaveDocument(operation, definition *ast.Document)
  • func (v *Visitor) LeaveField(ref int)
  • func (v *Visitor) LeaveSelectionSet(ref int)

Functions

func AnalyzePlanKind

func AnalyzePlanKind(operation, definition *ast.Document, operationName string) (subscription, streaming bool, error error)

Types

type ArgumentConfiguration

type ArgumentConfiguration struct {
	Name       string
	SourceType SourceType
	SourcePath []string
}

type ArgumentsConfigurations

type ArgumentsConfigurations []ArgumentConfiguration

func (ArgumentsConfigurations) ForName

func (a ArgumentsConfigurations) ForName(argName string) *ArgumentConfiguration

type Configuration

type Configuration struct {
	DefaultFlushInterval int64
	DataSources          []DataSourceConfiguration
	Fields               FieldConfigurations
	Schema               string
}

type DataSourceConfiguration

type DataSourceConfiguration struct {
	RootNodes                  []TypeField
	ChildNodes                 []TypeField
	Factory                    PlannerFactory
	OverrideFieldPathFromAlias bool
	Custom                     json.RawMessage
}

func (*DataSourceConfiguration) HasRootNode

func (d *DataSourceConfiguration) HasRootNode(typeName, fieldName string) bool

type DataSourcePlanner

type DataSourcePlanner interface {
	Register(visitor *Visitor, customConfiguration json.RawMessage, isNested bool) error
	ConfigureFetch() FetchConfiguration
	ConfigureSubscription() SubscriptionConfiguration
}

type FetchConfiguration

type FetchConfiguration struct {
	Input                string
	Variables            resolve.Variables
	DataSource           resolve.DataSource
	DisallowSingleFlight bool
}

type FieldConfiguration

type FieldConfiguration struct {
	TypeName                          string
	FieldName                         string
	DisableDefaultMapping             bool
	Path                              []string
	RespectOverrideFieldPathFromAlias bool
	Arguments                         ArgumentsConfigurations
	RequiresFields                    []string
}

type FieldConfigurations

type FieldConfigurations []FieldConfiguration

func (FieldConfigurations) ForTypeField

func (f FieldConfigurations) ForTypeField(typeName, fieldName string) *FieldConfiguration

type FieldMapping

type FieldMapping struct {
	TypeName                          string
	FieldName                         string
	DisableDefaultMapping             bool
	Path                              []string
	RespectOverrideFieldPathFromAlias bool
}

type Kind

type Kind int

const (
	SynchronousResponseKind Kind = iota + 1
	StreamingResponseKind
	SubscriptionResponseKind
)

type Plan

type Plan interface {
	PlanKind() Kind
	SetFlushInterval(interval int64)
}

type Planner

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

func NewPlanner

func NewPlanner(config Configuration) *Planner

func (*Planner) Plan

func (p *Planner) Plan(operation, definition *ast.Document, operationName string, report *operationreport.Report) (plan Plan)

func (*Planner) SetConfig

func (p *Planner) SetConfig(config Configuration)

type PlannerFactory

type PlannerFactory interface {
	Planner() DataSourcePlanner
}

type SourceType

type SourceType string

const (
	ObjectFieldSource   SourceType = "object_field"
	FieldArgumentSource SourceType = "field_argument"
)

type StreamingResponsePlan

type StreamingResponsePlan struct {
	Response      resolve.GraphQLStreamingResponse
	FlushInterval int64
}

func (*StreamingResponsePlan) PlanKind

func (_ *StreamingResponsePlan) PlanKind() Kind

func (*StreamingResponsePlan) SetFlushInterval

func (s *StreamingResponsePlan) SetFlushInterval(interval int64)

type SubscriptionConfiguration

type SubscriptionConfiguration struct {
	Input                 string
	SubscriptionManagerID string
	Variables             resolve.Variables
}

type SubscriptionResponsePlan

type SubscriptionResponsePlan struct {
	Response      resolve.GraphQLSubscription
	FlushInterval int64
}

func (*SubscriptionResponsePlan) PlanKind

func (_ *SubscriptionResponsePlan) PlanKind() Kind

func (*SubscriptionResponsePlan) SetFlushInterval

func (s *SubscriptionResponsePlan) SetFlushInterval(interval int64)

type SynchronousResponsePlan

type SynchronousResponsePlan struct {
	Response      *resolve.GraphQLResponse
	FlushInterval int64
}

func (*SynchronousResponsePlan) PlanKind

func (_ *SynchronousResponsePlan) PlanKind() Kind

func (*SynchronousResponsePlan) SetFlushInterval

func (s *SynchronousResponsePlan) SetFlushInterval(interval int64)

type TypeField

type TypeField struct {
	TypeName   string
	FieldNames []string
}

type Visitor

type Visitor struct {
	Operation, Definition *ast.Document
	Walker                *astvisitor.Walker
	Importer              astimport.Importer
	Config                Configuration

	OperationName string
	// contains filtered or unexported fields
}

func (*Visitor) AllowVisitor

func (v *Visitor) AllowVisitor(kind astvisitor.VisitorKind, ref int, visitor interface{}) bool

func (*Visitor) EnterDirective

func (v *Visitor) EnterDirective(ref int)

func (*Visitor) EnterDocument

func (v *Visitor) EnterDocument(operation, definition *ast.Document)

func (*Visitor) EnterField

func (v *Visitor) EnterField(ref int)

func (*Visitor) EnterOperationDefinition

func (v *Visitor) EnterOperationDefinition(ref int)

func (*Visitor) EnterSelectionSet

func (v *Visitor) EnterSelectionSet(ref int)

func (*Visitor) LeaveDocument

func (v *Visitor) LeaveDocument(operation, definition *ast.Document)

func (*Visitor) LeaveField

func (v *Visitor) LeaveField(ref int)

func (*Visitor) LeaveSelectionSet

func (v *Visitor) LeaveSelectionSet(ref int)