datasource

Documentation

Index

• Constants
• func NewHypDSFactory(ctx context.Context) plan.PlannerFactory[HypDSConfig]
• type HypDSConfig
• type HypDSPlanner
  • func (p *HypDSPlanner) ConfigureFetch() resolve.FetchConfiguration
  • func (p *HypDSPlanner) ConfigureSubscription() plan.SubscriptionConfiguration
  • func (p *HypDSPlanner) DataSourcePlanningBehavior() plan.DataSourcePlanningBehavior
  • func (p *HypDSPlanner) DownstreamResponseFieldAlias(downstreamFieldRef int) (alias string, exists bool)
  • func (p *HypDSPlanner) EnterDocument(operation, definition *ast.Document)
  • func (p *HypDSPlanner) EnterField(ref int)
  • func (p *HypDSPlanner) ID() (id int)
  • func (p *HypDSPlanner) LeaveDocument(operation, definition *ast.Document)
  • func (p *HypDSPlanner) Register(visitor *plan.Visitor, configuration plan.DataSourceConfiguration[HypDSConfig], ...) error
  • func (p *HypDSPlanner) SetID(id int)
  • func (p *HypDSPlanner) UpstreamSchema(dataSourceConfig plan.DataSourceConfiguration[HypDSConfig]) (*ast.Document, bool)
• type ModusDataSource
  • func (ds *ModusDataSource) Load(ctx context.Context, input []byte, out *bytes.Buffer) error
  • func (*ModusDataSource) LoadWithFiles(ctx context.Context, input []byte, files []httpclient.File, out *bytes.Buffer) (err error)

Constants

const DataSourceName = "ModusDataSource"

Functions

func NewHypDSFactory

func NewHypDSFactory(ctx context.Context) plan.PlannerFactory[HypDSConfig]

Types

type HypDSConfig

type HypDSConfig struct {
	WasmHost          wasmhost.WasmHost
	FieldsToFunctions map[string]string
	MapTypes          []string
}

type HypDSPlanner

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

func (*HypDSPlanner) ConfigureFetch

func (p *HypDSPlanner) ConfigureFetch() resolve.FetchConfiguration

func (*HypDSPlanner) ConfigureSubscription

func (p *HypDSPlanner) ConfigureSubscription() plan.SubscriptionConfiguration

func (*HypDSPlanner) DataSourcePlanningBehavior

func (p *HypDSPlanner) DataSourcePlanningBehavior() plan.DataSourcePlanningBehavior

func (*HypDSPlanner) DownstreamResponseFieldAlias

func (p *HypDSPlanner) DownstreamResponseFieldAlias(downstreamFieldRef int) (alias string, exists bool)

func (*HypDSPlanner) EnterDocument

func (p *HypDSPlanner) EnterDocument(operation, definition *ast.Document)

func (*HypDSPlanner) EnterField

func (p *HypDSPlanner) EnterField(ref int)

func (*HypDSPlanner) ID

func (p *HypDSPlanner) ID() (id int)

func (*HypDSPlanner) LeaveDocument

func (p *HypDSPlanner) LeaveDocument(operation, definition *ast.Document)

func (*HypDSPlanner) Register

func (p *HypDSPlanner) Register(visitor *plan.Visitor, configuration plan.DataSourceConfiguration[HypDSConfig], dspc plan.DataSourcePlannerConfiguration) error

func (*HypDSPlanner) SetID

func (p *HypDSPlanner) SetID(id int)

func (*HypDSPlanner) UpstreamSchema

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

type ModusDataSource

type ModusDataSource struct {
	WasmHost wasmhost.WasmHost
}

func (*ModusDataSource) Load

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

func (*ModusDataSource) LoadWithFiles

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