Versions in this module Expand all Collapse all v2 v2.0.3 Jan 16, 2026 v2.0.2 Jan 16, 2026 Changes in this version + const EntityInterfacesDefinition + const ProtocolGraphQLTWS + const ProtocolGraphQLWS + var DefaultPostProcessingConfiguration = resolve.PostProcessingConfiguration + var EntitiesPostProcessingConfiguration = resolve.PostProcessingConfiguration + var SingleEntityPostProcessingConfiguration = resolve.PostProcessingConfiguration + func EntityInterfacesPlanConfiguration(t *testing.T, factory plan.PlannerFactory[Configuration]) *plan.Configuration + func EntityInterfacesPlanConfigurationBench(t *testing.B, factory plan.PlannerFactory[Configuration]) *plan.Configuration + func IsDefaultGraphQLSubscriptionClient(client GraphQLSubscriptionClient) bool + type Configuration struct + func NewConfiguration(input ConfigurationInput) (Configuration, error) + func (c *Configuration) FederationConfiguration() *FederationConfiguration + func (c *Configuration) IsFederationEnabled() bool + func (c *Configuration) IsGRPC() bool + func (c *Configuration) UpstreamSchema() (*ast.Document, error) + type ConfigurationInput struct + CustomScalarTypeFields []SingleTypeField + Fetch *FetchConfiguration + GRPC *grpcdatasource.GRPCConfiguration + SchemaConfiguration *SchemaConfiguration + Subscription *SubscriptionConfiguration + type ConnectionHandler interface + ClientClose func() + HandleMessage func(data []byte) (done bool) + Ping func() + ServerClose func() + StartBlocking func() error + Subscribe func() error + type DefaultSubscriptionClientFactory struct + func (d *DefaultSubscriptionClientFactory) NewSubscriptionClient(httpClient, streamingClient *http.Client, engineCtx context.Context, ...) GraphQLSubscriptionClient + type Factory struct + func NewFactory(executionContext context.Context, httpClient *http.Client, ...) (*Factory[Configuration], error) + func NewFactoryGRPC(executionContext context.Context, grpcClient grpc.ClientConnInterface) (*Factory[Configuration], error) + func NewFactoryGRPCClientProvider(executionContext context.Context, ...) (*Factory[Configuration], error) + func (f *Factory[T]) Context() context.Context + func (f *Factory[T]) Planner(logger abstractlogger.Logger) plan.DataSourcePlanner[T] + func (f *Factory[T]) PlanningBehavior() plan.DataSourcePlanningBehavior + func (f *Factory[T]) UpstreamSchema(dataSourceConfig plan.DataSourceConfiguration[T]) (*ast.Document, bool) + type FederationConfiguration struct + Enabled bool + ServiceSDL string + type FetchConfiguration struct + Header http.Header + Method string + URL string + type GraphQLBody struct + Extensions json.RawMessage + OperationName string + Query string + Variables json.RawMessage + type GraphQLSubscriptionClient interface + Subscribe func(ctx *resolve.Context, options GraphQLSubscriptionOptions, ...) error + SubscribeAsync func(ctx *resolve.Context, id uint64, options GraphQLSubscriptionOptions, ...) error + UniqueRequestID func(ctx *resolve.Context, options GraphQLSubscriptionOptions, hash *xxhash.Digest) (err error) + Unsubscribe func(id uint64) + func NewGraphQLSubscriptionClient(httpClient, streamingClient *http.Client, engineCtx context.Context, ...) GraphQLSubscriptionClient + type GraphQLSubscriptionClientFactory interface + NewSubscriptionClient func(httpClient, streamingClient *http.Client, engineCtx context.Context, ...) GraphQLSubscriptionClient + type GraphQLSubscriptionOptions struct + Body GraphQLBody + ForwardedClientHeaderNames []string + ForwardedClientHeaderRegularExpressions []RegularExpression + Header http.Header + InitialPayload json.RawMessage + SSEMethodPost bool + URL string + UseSSE bool + WsSubProtocol string + type InvalidWsSubprotocolError struct + InvalidProtocol string + func NewInvalidWsSubprotocolError(invalidProtocol string) InvalidWsSubprotocolError + func (e InvalidWsSubprotocolError) Error() string + type NetPollConfiguration struct + BufferSize int + Enable bool + MaxEventWorkers int + TickInterval time.Duration + WaitForNumEvents int + func (e *NetPollConfiguration) ApplyDefaults() + type OnWsConnectionInitCallback func(ctx context.Context, url string, header http.Header) (json.RawMessage, error) + type Options func(options *opts) + func WithFrameTimeout(timeout time.Duration) Options + func WithLogger(log abstractlogger.Logger) Options + func WithNetPollConfiguration(config NetPollConfiguration) Options + func WithPingInterval(interval time.Duration) Options + func WithPingTimeout(timeout time.Duration) Options + func WithReadTimeout(timeout time.Duration) Options + type Planner struct + func (p *Planner[T]) ConfigureFetch() resolve.FetchConfiguration + func (p *Planner[T]) ConfigureSubscription() plan.SubscriptionConfiguration + func (p *Planner[T]) DebugPrint(args ...interface{}) + func (p *Planner[T]) DownstreamResponseFieldAlias(downstreamFieldRef int) (alias string, exists bool) + func (p *Planner[T]) EnableDebug() + func (p *Planner[T]) EnableDebugQueryPlanLogging() + func (p *Planner[T]) EnableSubgraphRequestMinifier() + func (p *Planner[T]) EnterArgument(_ int) + func (p *Planner[T]) EnterDirective(ref int) + func (p *Planner[T]) EnterDocument(_, _ *ast.Document) + func (p *Planner[T]) EnterField(ref int) + func (p *Planner[T]) EnterInlineFragment(ref int) + func (p *Planner[T]) EnterOperationDefinition(ref int) + func (p *Planner[T]) EnterSelectionSet(ref int) + func (p *Planner[T]) EnterVariableDefinition(ref int) + func (p *Planner[T]) ID() (id int) + func (p *Planner[T]) IncludeQueryPlanInFetchConfiguration() + func (p *Planner[T]) LeaveDocument(_, _ *ast.Document) + func (p *Planner[T]) LeaveField(ref int) + func (p *Planner[T]) LeaveInlineFragment(ref int) + func (p *Planner[T]) LeaveOperationDefinition(_ int) + func (p *Planner[T]) LeaveSelectionSet(ref int) + func (p *Planner[T]) LeaveVariableDefinition(_ int) + func (p *Planner[T]) Register(visitor *plan.Visitor, configuration plan.DataSourceConfiguration[T], ...) error + func (p *Planner[T]) SetID(id int) + type RegularExpression struct + NegateMatch bool + Pattern *regexp.Regexp + type SchemaConfiguration struct + func NewSchemaConfiguration(upstreamSchema string, federationCfg *FederationConfiguration) (*SchemaConfiguration, error) + func (c *SchemaConfiguration) FederationServiceSDL() string + func (c *SchemaConfiguration) IsFederationEnabled() bool + type SingleTypeField struct + FieldName string + TypeName string + type Source struct + 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.FileUpload, ...) (err error) + type SubscriptionConfiguration struct + ForwardedClientHeaderNames []string + ForwardedClientHeaderRegularExpressions []RegularExpression + Header http.Header + SSEMethodPost bool + StartupHooks []SubscriptionOnStartFn + URL string + UseSSE bool + WsSubProtocol string + type SubscriptionOnStartFn func(ctx resolve.StartupHookContext, input []byte) (err error) + type SubscriptionSource struct + func (s *SubscriptionSource) AsyncStart(ctx *resolve.Context, id uint64, input []byte, ...) error + func (s *SubscriptionSource) AsyncStop(id uint64) + func (s *SubscriptionSource) Start(ctx *resolve.Context, input []byte, updater resolve.SubscriptionUpdater) error + func (s *SubscriptionSource) SubscriptionOnStart(ctx resolve.StartupHookContext, input []byte) error + func (s *SubscriptionSource) UniqueRequestID(ctx *resolve.Context, input []byte, xxh *xxhash.Digest) (err error) + type UpgradeRequestError struct + StatusCode int + URL string + func (u *UpgradeRequestError) Error() string
Go to main page