Versions in this module Expand all Collapse all v1 v1.41.0 Jun 27, 2022 Changes in this version + var RootFieldName = []byte("root_field_name") + var RootTypeName = []byte("root_type_name") + func DefaultHttpClient() *http.Client + type Argument interface + ArgName func() []byte + type BasePlanner struct + Args []Argument + Config PlannerConfiguration + Definition *ast.Document + Log abstractlogger.Logger + Operation *ast.Document + RootField rootField + Walker *astvisitor.Walker + func NewBaseDataSourcePlanner(schema []byte, config PlannerConfiguration, logger abstractlogger.Logger) (*BasePlanner, error) + func (b *BasePlanner) Configure(operation, definition *ast.Document, walker *astvisitor.Walker) + func (b *BasePlanner) RegisterDataSourcePlannerFactory(dataSourceName string, factory PlannerFactoryFactory) (err error) + type ContextVariableArgument struct + Name []byte + VariableName []byte + func (c *ContextVariableArgument) ArgName() []byte + type CorePlanner interface + Configure func(operation, definition *ast.Document, walker *astvisitor.Walker) + Plan func(args []Argument) (DataSource, []Argument) + type DataSource interface + Resolve func(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type GraphQLDataSource struct + Client *http.Client + Hooks Hooks + Log log.Logger + WhitelistedSchemes []string + func (g *GraphQLDataSource) Resolve(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type GraphQLDataSourceConfig struct + Method *string + URL string + type GraphQLDataSourcePlanner struct + func (g *GraphQLDataSourcePlanner) EnterArgument(ref int) + func (g *GraphQLDataSourcePlanner) EnterDocument(operation, definition *ast.Document) + func (g *GraphQLDataSourcePlanner) EnterField(ref int) + func (g *GraphQLDataSourcePlanner) EnterInlineFragment(ref int) + func (g *GraphQLDataSourcePlanner) EnterSelectionSet(ref int) + func (g *GraphQLDataSourcePlanner) LeaveField(ref int) + func (g *GraphQLDataSourcePlanner) LeaveInlineFragment(ref int) + func (g *GraphQLDataSourcePlanner) LeaveSelectionSet(ref int) + func (g *GraphQLDataSourcePlanner) Plan(args []Argument) (DataSource, []Argument) + type GraphQLDataSourcePlannerFactory struct + func (g *GraphQLDataSourcePlannerFactory) DataSourcePlanner() Planner + type GraphQLDataSourcePlannerFactoryFactory struct + Client *http.Client + Hooks Hooks + WhitelistedSchemes []string + func (g GraphQLDataSourcePlannerFactoryFactory) Initialize(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type GraphqlRequest struct + OperationName string + Query string + Variables json.RawMessage + type HookContext struct + FieldName string + TypeName string + type Hooks struct + PostReceiveHttpHook PostReceiveHttpHook + PreSendHttpHook PreSendHttpHook + type HttpJsonDataSource struct + Client *http.Client + Hooks Hooks + Log log.Logger + WhitelistedSchemes []string + func (r *HttpJsonDataSource) Resolve(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type HttpJsonDataSourceConfig struct + Body *string + DefaultTypeName *string + Headers []HttpJsonDataSourceConfigHeader + Method *string + StatusCodeTypeNameMappings []StatusCodeTypeNameMapping + URL string + type HttpJsonDataSourceConfigHeader struct + Key string + Value string + type HttpJsonDataSourcePlanner struct + func (h *HttpJsonDataSourcePlanner) EnterArgument(ref int) + func (h *HttpJsonDataSourcePlanner) EnterDocument(operation, definition *ast.Document) + func (h *HttpJsonDataSourcePlanner) EnterField(ref int) + func (h *HttpJsonDataSourcePlanner) EnterInlineFragment(ref int) + func (h *HttpJsonDataSourcePlanner) EnterSelectionSet(ref int) + func (h *HttpJsonDataSourcePlanner) LeaveField(ref int) + func (h *HttpJsonDataSourcePlanner) LeaveInlineFragment(ref int) + func (h *HttpJsonDataSourcePlanner) LeaveSelectionSet(ref int) + func (h *HttpJsonDataSourcePlanner) Plan(args []Argument) (DataSource, []Argument) + type HttpJsonDataSourcePlannerFactory struct + func (h *HttpJsonDataSourcePlannerFactory) DataSourcePlanner() Planner + type HttpJsonDataSourcePlannerFactoryFactory struct + Client *http.Client + Hooks Hooks + WhitelistedSchemes []string + func (h *HttpJsonDataSourcePlannerFactoryFactory) Initialize(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type HttpPollingStreamDataSource struct + Delay time.Duration + Log log.Logger + func (h *HttpPollingStreamDataSource) Resolve(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type HttpPollingStreamDataSourceConfiguration struct + DelaySeconds *int + Host string + URL string + type HttpPollingStreamDataSourcePlanner struct + func (h *HttpPollingStreamDataSourcePlanner) EnterArgument(ref int) + func (h *HttpPollingStreamDataSourcePlanner) EnterDocument(operation, definition *ast.Document) + func (h *HttpPollingStreamDataSourcePlanner) EnterField(ref int) + func (h *HttpPollingStreamDataSourcePlanner) EnterInlineFragment(ref int) + func (h *HttpPollingStreamDataSourcePlanner) EnterSelectionSet(ref int) + func (h *HttpPollingStreamDataSourcePlanner) LeaveField(ref int) + func (h *HttpPollingStreamDataSourcePlanner) LeaveInlineFragment(ref int) + func (h *HttpPollingStreamDataSourcePlanner) LeaveSelectionSet(ref int) + func (h *HttpPollingStreamDataSourcePlanner) Plan(args []Argument) (DataSource, []Argument) + type HttpPollingStreamDataSourcePlannerFactory struct + func (h HttpPollingStreamDataSourcePlannerFactory) DataSourcePlanner() Planner + type HttpPollingStreamDataSourcePlannerFactoryFactory struct + func (h HttpPollingStreamDataSourcePlannerFactoryFactory) Initialize(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type ListArgument struct + Arguments []Argument + Name []byte + func (l ListArgument) ArgName() []byte + type MQTTDataSource struct + func (m *MQTTDataSource) Resolve(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type MQTTDataSourceConfig struct + BrokerAddr string + ClientID string + Topic string + type MQTTDataSourcePlanner struct + func (n *MQTTDataSourcePlanner) EnterArgument(ref int) + func (n *MQTTDataSourcePlanner) EnterDocument(operation, definition *ast.Document) + func (n *MQTTDataSourcePlanner) EnterField(ref int) + func (n *MQTTDataSourcePlanner) EnterInlineFragment(ref int) + func (n *MQTTDataSourcePlanner) EnterSelectionSet(ref int) + func (n *MQTTDataSourcePlanner) LeaveField(ref int) + func (n *MQTTDataSourcePlanner) LeaveInlineFragment(ref int) + func (n *MQTTDataSourcePlanner) LeaveSelectionSet(ref int) + func (n *MQTTDataSourcePlanner) Plan(args []Argument) (DataSource, []Argument) + type MQTTDataSourcePlannerFactory struct + func (m MQTTDataSourcePlannerFactory) DataSourcePlanner() Planner + type MQTTDataSourcePlannerFactoryFactory struct + func (M MQTTDataSourcePlannerFactoryFactory) Initialize(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type MappingConfiguration struct + Disabled bool + Path string + type NatsDataSource struct + func (d *NatsDataSource) Resolve(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type NatsDataSourceConfig struct + Addr string + Topic string + type NatsDataSourcePlanner struct + func (n *NatsDataSourcePlanner) Plan([]Argument) (DataSource, []Argument) + type NatsDataSourcePlannerFactory struct + func (n NatsDataSourcePlannerFactory) DataSourcePlanner() Planner + type NatsDataSourcePlannerFactoryFactory struct + func (n NatsDataSourcePlannerFactoryFactory) Initialize(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type ObjectVariableArgument struct + Name []byte + PathSelector PathSelector + func (o *ObjectVariableArgument) ArgName() []byte + type PathSelector struct + Path string + type PipelineDataSource struct + Log log.Logger + Pipeline pipe.Pipeline + func (r *PipelineDataSource) Resolve(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type PipelineDataSourceConfig struct + ConfigFilePath *string + ConfigString *string + InputJSON string + type PipelineDataSourcePlanner struct + func (h *PipelineDataSourcePlanner) EnterArgument(ref int) + func (h *PipelineDataSourcePlanner) EnterDocument(operation, definition *ast.Document) + func (h *PipelineDataSourcePlanner) EnterField(ref int) + func (h *PipelineDataSourcePlanner) EnterInlineFragment(ref int) + func (h *PipelineDataSourcePlanner) EnterSelectionSet(ref int) + func (h *PipelineDataSourcePlanner) LeaveField(ref int) + func (h *PipelineDataSourcePlanner) LeaveInlineFragment(ref int) + func (h *PipelineDataSourcePlanner) LeaveSelectionSet(ref int) + func (h *PipelineDataSourcePlanner) Plan(args []Argument) (DataSource, []Argument) + type PipelineDataSourcePlannerFactory struct + func (p PipelineDataSourcePlannerFactory) DataSourcePlanner() Planner + type PipelineDataSourcePlannerFactoryFactory struct + func (p PipelineDataSourcePlannerFactoryFactory) Initialize(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type Planner interface + func SimpleDataSourcePlanner(core CorePlanner) Planner + type PlannerConfiguration struct + TypeFieldConfigurations []TypeFieldConfiguration + func (p *PlannerConfiguration) DataSourcePlannerFactoryForTypeField(typeName, fieldName string) PlannerFactory + func (p *PlannerConfiguration) MappingForTypeField(typeName, fieldName string) *MappingConfiguration + type PlannerFactory interface + DataSourcePlanner func() Planner + type PlannerFactoryFactory interface + Initialize func(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type PlannerVisitors interface + type PostReceiveHttpHook interface + Execute func(ctx HookContext, resp *http.Response, body []byte) + type PreSendHttpHook interface + Execute func(ctx HookContext, req *http.Request) + type ResolverArgs interface + ByKey func(key []byte) []byte + Dump func() []string + Keys func() [][]byte + type SchemaDataSource struct + SchemaBytes []byte + func (s *SchemaDataSource) Resolve(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type SchemaDataSourcePlanner struct + func (s *SchemaDataSourcePlanner) Plan(args []Argument) (DataSource, []Argument) + type SchemaDataSourcePlannerConfig struct + type SchemaDataSourcePlannerFactory struct + func (s SchemaDataSourcePlannerFactory) DataSourcePlanner() Planner + type SchemaDataSourcePlannerFactoryFactory struct + func (s SchemaDataSourcePlannerFactoryFactory) Initialize(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type SourceConfig struct + Config json.RawMessage + Name string + type StaticDataSource struct + Data []byte + func (s StaticDataSource) Resolve(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type StaticDataSourceConfig struct + Data string + type StaticDataSourcePlanner struct + func (s *StaticDataSourcePlanner) Plan(args []Argument) (DataSource, []Argument) + type StaticDataSourcePlannerFactory struct + func (s StaticDataSourcePlannerFactory) DataSourcePlanner() Planner + type StaticDataSourcePlannerFactoryFactory struct + func (s StaticDataSourcePlannerFactoryFactory) Initialize(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type StaticVariableArgument struct + Name []byte + Value []byte + func (s *StaticVariableArgument) ArgName() []byte + type StatusCodeTypeNameMapping struct + StatusCode int + TypeName string + type TypeDataSource struct + func (t *TypeDataSource) Resolve(ctx context.Context, args ResolverArgs, out io.Writer) (n int, err error) + type TypeDataSourcePlanner struct + func (t *TypeDataSourcePlanner) Plan(args []Argument) (DataSource, []Argument) + type TypeDataSourcePlannerConfig struct + type TypeDataSourcePlannerFactory struct + func (t TypeDataSourcePlannerFactory) DataSourcePlanner() Planner + type TypeDataSourcePlannerFactoryFactory struct + func (t TypeDataSourcePlannerFactoryFactory) Initialize(base BasePlanner, configReader io.Reader) (PlannerFactory, error) + type TypeFieldConfiguration struct + DataSource SourceConfig + DataSourcePlannerFactory PlannerFactory + FieldName string + Mapping *MappingConfiguration + TypeName string
Go to main page