Versions in this module Expand all Collapse all v2 v2.0.2 Jan 29, 2024 v2.0.1 Jan 29, 2024 Changes in this version + const EntityInterfacesDefinition + const ProtocolGraphQLTWS + const ProtocolGraphQLWS + var DefaultPostProcessingConfiguration = resolve.PostProcessingConfiguration + var EntitiesPostProcessingConfiguration = resolve.PostProcessingConfiguration + var SingleEntityPostProcessingConfiguration = resolve.PostProcessingConfiguration + func ConfigJson(config Configuration) json.RawMessage + func EntityInterfacesPlanConfiguration(factory plan.PlannerFactory) *plan.Configuration + type Configuration struct + CustomScalarTypeFields []SingleTypeField + Federation FederationConfiguration + Fetch FetchConfiguration + Subscription SubscriptionConfiguration + UpstreamSchema string + func (c *Configuration) ApplyDefaults() + type ConnectionHandler interface + StartBlocking func(sub Subscription) + SubscribeCH func() chan<- Subscription + type DefaultSubscriptionClientFactory struct + func (d *DefaultSubscriptionClientFactory) NewSubscriptionClient(httpClient, streamingClient *http.Client, engineCtx context.Context, ...) GraphQLSubscriptionClient + type Factory struct + HTTPClient *http.Client + Logger abstractlogger.Logger + OnWsConnectionInitCallback *OnWsConnectionInitCallback + StreamingClient *http.Client + SubscriptionClient *SubscriptionClient + func (f *Factory) Planner(ctx context.Context) plan.DataSourcePlanner + 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 + UniqueRequestID func(ctx *resolve.Context, options GraphQLSubscriptionOptions, hash *xxhash.Digest) (err error) + type GraphQLSubscriptionClientFactory interface + NewSubscriptionClient func(httpClient, streamingClient *http.Client, engineCtx context.Context, ...) GraphQLSubscriptionClient + type GraphQLSubscriptionOptions struct + Body GraphQLBody + ForwardedClientHeaderNames []string + ForwardedClientHeaderRegularExpressions []*regexp.Regexp + Header http.Header + InitialPayload json.RawMessage + SSEMethodPost bool + URL string + UseSSE bool + type OnWsConnectionInitCallback func(ctx context.Context, url string, header http.Header) (json.RawMessage, error) + type Options func(options *opts) + func WithLogger(log abstractlogger.Logger) Options + func WithOnWsConnectionInitCallback(callback *OnWsConnectionInitCallback) Options + func WithReadTimeout(timeout time.Duration) Options + func WithWSSubProtocol(protocol string) Options + type Planner struct + func (p *Planner) ConfigureFetch() resolve.FetchConfiguration + func (p *Planner) ConfigureSubscription() plan.SubscriptionConfiguration + func (p *Planner) DataSourcePlanningBehavior() plan.DataSourcePlanningBehavior + func (p *Planner) DebugPrint(args ...interface{}) + func (p *Planner) DownstreamResponseFieldAlias(downstreamFieldRef int) (alias string, exists bool) + func (p *Planner) EnableDebug() + func (p *Planner) EnableQueryPlanLogging() + func (p *Planner) EnterArgument(_ int) + func (p *Planner) EnterDirective(ref int) + func (p *Planner) EnterDocument(_, _ *ast.Document) + func (p *Planner) EnterField(ref int) + func (p *Planner) EnterInlineFragment(ref int) + func (p *Planner) EnterOperationDefinition(ref int) + func (p *Planner) EnterSelectionSet(ref int) + func (p *Planner) EnterVariableDefinition(ref int) + func (p *Planner) ID() (id int) + func (p *Planner) LeaveDocument(_, _ *ast.Document) + func (p *Planner) LeaveField(ref int) + func (p *Planner) LeaveInlineFragment(ref int) + func (p *Planner) LeaveOperationDefinition(_ int) + func (p *Planner) LeaveSelectionSet(ref int) + func (p *Planner) LeaveVariableDefinition(_ int) + func (p *Planner) Register(visitor *plan.Visitor, configuration plan.DataSourceConfiguration, ...) error + func (p *Planner) SetID(id int) + func (p *Planner) UpstreamSchema(dataSourceConfig plan.DataSourceConfiguration) *ast.Document + type SingleTypeField struct + FieldName string + TypeName string + type Source struct + func (s *Source) Load(ctx context.Context, input []byte, writer io.Writer) (err error) + type Subscription struct + type SubscriptionClient struct + func NewGraphQLSubscriptionClient(httpClient, streamingClient *http.Client, engineCtx context.Context, ...) *SubscriptionClient + func (c *SubscriptionClient) Subscribe(reqCtx *resolve.Context, options GraphQLSubscriptionOptions, ...) error + func (c *SubscriptionClient) UniqueRequestID(ctx *resolve.Context, options GraphQLSubscriptionOptions, hash *xxhash.Digest) (err error) + type SubscriptionConfiguration struct + ForwardedClientHeaderNames []string + ForwardedClientHeaderRegularExpressions []*regexp.Regexp + SSEMethodPost bool + URL string + UseSSE bool + type SubscriptionSource struct + func (s *SubscriptionSource) Start(ctx *resolve.Context, input []byte, updater resolve.SubscriptionUpdater) error + func (s *SubscriptionSource) UniqueRequestID(ctx *resolve.Context, input []byte, xxh *xxhash.Digest) (err error)
Go to main page