introspection_datasource

Documentation

Index

• Constants
• type Configuration
• type Factory
  • func NewFactory[T Configuration](introspectionData *introspection.Data) *Factory[T]
  • func (f *Factory[T]) Context() context.Context
  • func (f *Factory[T]) Planner(logger abstractlogger.Logger) plan.DataSourcePlanner[T]
• type IntrospectionConfigFactory
  • func NewIntrospectionConfigFactory(schema *ast.Document) (*IntrospectionConfigFactory, error)
  • func (f *IntrospectionConfigFactory) BuildDataSourceConfigurations() []plan.DataSource
  • func (f *IntrospectionConfigFactory) BuildFieldConfigurations() (planFields plan.FieldConfigurations)
• type Planner
  • func (p *Planner[T]) ConfigureFetch() resolve.FetchConfiguration
  • func (p *Planner[T]) ConfigureSubscription() plan.SubscriptionConfiguration
  • func (p *Planner[T]) DataSourcePlanningBehavior() plan.DataSourcePlanningBehavior
  • func (p *Planner[T]) DownstreamResponseFieldAlias(_ int) (alias string, exists bool)
  • func (p *Planner[T]) EnterField(ref int)
  • func (p *Planner[T]) Register(visitor *plan.Visitor, dataSourceConfiguration plan.DataSourceConfiguration[T], ...) error
  • func (p *Planner[T]) UpstreamSchema(dataSourceConfig plan.DataSourceConfiguration[T]) (*ast.Document, bool)
• type Source
  • func (s *Source) Load(ctx context.Context, input []byte, out *bytes.Buffer) (err error)
  • func (s *Source) LoadWithFiles(ctx context.Context, input []byte, files []httpclient.File, out *bytes.Buffer) (err error)

Constants

const (
	SchemaRequestType requestType = iota + 1
	TypeRequestType
	TypeFieldsRequestType
	TypeEnumValuesRequestType
)

Types

type Configuration

type Configuration struct {
	SourceType string
}

type Factory

type Factory[T Configuration] struct {
	// contains filtered or unexported fields
}

func NewFactory

func NewFactory[T Configuration](introspectionData *introspection.Data) *Factory[T]

func (*Factory[T]) Context

func (f *Factory[T]) Context() context.Context

func (*Factory[T]) Planner

func (f *Factory[T]) Planner(logger abstractlogger.Logger) plan.DataSourcePlanner[T]

type IntrospectionConfigFactory

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

func NewIntrospectionConfigFactory

func NewIntrospectionConfigFactory(schema *ast.Document) (*IntrospectionConfigFactory, error)

func (*IntrospectionConfigFactory) BuildDataSourceConfigurations

func (f *IntrospectionConfigFactory) BuildDataSourceConfigurations() []plan.DataSource

func (*IntrospectionConfigFactory) BuildFieldConfigurations

func (f *IntrospectionConfigFactory) BuildFieldConfigurations() (planFields plan.FieldConfigurations)

type Planner

type Planner[T Configuration] struct {
	// contains filtered or unexported fields
}

func (*Planner[T]) ConfigureFetch

func (p *Planner[T]) ConfigureFetch() resolve.FetchConfiguration

func (*Planner[T]) ConfigureSubscription

func (p *Planner[T]) ConfigureSubscription() plan.SubscriptionConfiguration

func (*Planner[T]) DataSourcePlanningBehavior

func (p *Planner[T]) DataSourcePlanningBehavior() plan.DataSourcePlanningBehavior

func (*Planner[T]) DownstreamResponseFieldAlias

func (p *Planner[T]) DownstreamResponseFieldAlias(_ int) (alias string, exists bool)

func (*Planner[T]) EnterField

func (p *Planner[T]) EnterField(ref int)

func (*Planner[T]) Register

func (p *Planner[T]) Register(visitor *plan.Visitor, dataSourceConfiguration plan.DataSourceConfiguration[T], dataSourcePlannerConfiguration plan.DataSourcePlannerConfiguration) error

func (*Planner[T]) UpstreamSchema

func (p *Planner[T]) UpstreamSchema(dataSourceConfig plan.DataSourceConfiguration[T]) (*ast.Document, bool)

type Source

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

func (*Source) Load

func (s *Source) Load(ctx context.Context, input []byte, out *bytes.Buffer) (err error)

func (*Source) LoadWithFiles

func (s *Source) LoadWithFiles(ctx context.Context, input []byte, files []httpclient.File, out *bytes.Buffer) (err error)