Versions in this module Expand all Collapse all v1 v1.41.0 Jun 27, 2022 Changes in this version + func ConfigJson(config Configuration) json.RawMessage + type Batch struct + func (b *Batch) Demultiplex(responseBufPair *resolve.BufPair, bufPairs []*resolve.BufPair) (err error) + func (b *Batch) Input() *fastbuffer.FastBuffer + type BatchFactory struct + func NewBatchFactory() *BatchFactory + func (b *BatchFactory) CreateBatch(inputs [][]byte) (resolve.DataSourceBatch, error) + type Configuration struct + Federation FederationConfiguration + Fetch FetchConfiguration + Subscription SubscriptionConfiguration + UpstreamSchema string + func (c *Configuration) ApplyDefaults() + type Factory struct + BatchFactory resolve.DataSourceBatchFactory + HTTPClient *http.Client + 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 + OperationName string + Query string + Variables json.RawMessage + type GraphQLSubscriptionClient interface + Subscribe func(ctx context.Context, options GraphQLSubscriptionOptions, next chan<- []byte) error + type GraphQLSubscriptionOptions struct + Body GraphQLBody + Header http.Header + URL string + type Options func(options *opts) + func WithLogger(log abstractlogger.Logger) Options + func WithReadTimeout(timeout time.Duration) Options + type Planner struct + func (p *Planner) ConfigureFetch() plan.FetchConfiguration + func (p *Planner) ConfigureSubscription() plan.SubscriptionConfiguration + func (p *Planner) DataSourcePlanningBehavior() plan.DataSourcePlanningBehavior + func (p *Planner) DownstreamResponseFieldAlias(downstreamFieldRef int) (alias string, exists bool) + func (p *Planner) EnterArgument(ref int) + func (p *Planner) EnterDirective(ref int) + func (p *Planner) EnterDocument(operation, definition *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) LeaveDocument(operation, definition *ast.Document) + func (p *Planner) LeaveField(ref int) + func (p *Planner) LeaveInlineFragment(_ int) + func (p *Planner) LeaveOperationDefinition(ref int) + func (p *Planner) LeaveSelectionSet(ref int) + func (p *Planner) LeaveVariableDefinition(_ int) + func (p *Planner) Register(visitor *plan.Visitor, configuration plan.DataSourceConfiguration, ...) error + type Source struct + func (s *Source) Load(ctx context.Context, input []byte, writer io.Writer) (err error) + type SubscriptionConfiguration struct + URL string + type SubscriptionSource struct + func (s *SubscriptionSource) Start(ctx context.Context, input []byte, next chan<- []byte) error + type WebSocketGraphQLSubscriptionClient struct + func NewWebSocketGraphQLSubscriptionClient(httpClient *http.Client, ctx context.Context, options ...Options) *WebSocketGraphQLSubscriptionClient + func (c *WebSocketGraphQLSubscriptionClient) Subscribe(ctx context.Context, options GraphQLSubscriptionOptions, next chan<- []byte) error
Go to main page