staticdatasource

Documentation

Index

• type Configuration
• type Factory
  • func (f *Factory[T]) Context() context.Context
  • func (f *Factory[T]) Planner(logger abstractlogger.Logger) plan.DataSourcePlanner[T]
  • func (f *Factory[T]) UpstreamSchema(dataSourceConfig plan.DataSourceConfiguration[T]) (*ast.Document, bool)
• 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(downstreamFieldRef int) (alias string, exists bool)
  • func (p *Planner[T]) ID() (id int)
  • func (p *Planner[T]) Register(_ *plan.Visitor, configuration plan.DataSourceConfiguration[T], ...) error
  • func (p *Planner[T]) SetID(id int)
• type Source
  • func (Source) Load(ctx context.Context, input []byte, out *bytes.Buffer) (err error)
  • func (Source) LoadWithFiles(ctx context.Context, input []byte, files []httpclient.File, out *bytes.Buffer) (err error)

Types

type Configuration

type Configuration struct {
	Data string `json:"data"`
}

type Factory

type Factory[T Configuration] struct{}

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]

func (*Factory[T]) UpstreamSchema

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

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(downstreamFieldRef int) (alias string, exists bool)

func (*Planner[T]) ID

func (p *Planner[T]) ID() (id int)

func (*Planner[T]) Register

func (p *Planner[T]) Register(_ *plan.Visitor, configuration plan.DataSourceConfiguration[T], _ plan.DataSourcePlannerConfiguration) error

func (*Planner[T]) SetID

func (p *Planner[T]) SetID(id int)

type Source

type Source struct{}

func (Source) Load

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

func (Source) LoadWithFiles

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