graphql_datasource

Dec 2, 2022

retracted

Changes in this version

type GraphQLSubscriptionOptions

+ SSEMethodPost bool

type SubscriptionConfiguration

+ SSEMethodPost bool

Nov 17, 2022

retracted

Changes in this version

+ const ProtocolGraphQLTWS

+ const ProtocolGraphQLWS

type Configuration

+ CustomScalarTypeFields []SingleTypeField

+ type DefaultSubscriptionClientFactory struct

+ func (d *DefaultSubscriptionClientFactory) NewSubscriptionClient(httpClient, streamingClient *http.Client, engineCtx context.Context, ...) GraphQLSubscriptionClient

type Factory

+ SubscriptionClient *SubscriptionClient

+ type GraphQLSubscriptionClientFactory interface

+ NewSubscriptionClient func(httpClient, streamingClient *http.Client, engineCtx context.Context, ...) GraphQLSubscriptionClient

+ type SingleTypeField struct

+ FieldName string

+ TypeName string

Oct 14, 2022

retracted

Changes in this version

type Factory

+ OnWsConnectionInitCallback *OnWsConnectionInitCallback

+ type OnWsConnectionInitCallback func(ctx context.Context, url string, header http.Header) (json.RawMessage, error)

type Options

+ func WithOnWsConnectionInitCallback(callback *OnWsConnectionInitCallback) Options

Sep 28, 2022

retracted

Changes in this version

type Factory

+ StreamingClient *http.Client

Sep 26, 2022

retracted

Changes in this version

+ type ConnectionHandler interface

+ StartBlocking func(sub Subscription)

+ SubscribeCH func() chan<- Subscription

type GraphQLBody

+ Extensions json.RawMessage

type GraphQLSubscriptionOptions

+ UseSSE bool

type Options

+ func WithWSSubProtocol(protocol string) Options

+ type Subscription struct

+ type SubscriptionClient struct

+ func NewGraphQLSubscriptionClient(httpClient *http.Client, engineCtx context.Context, options ...Options) *SubscriptionClient

+ func (c *SubscriptionClient) Subscribe(reqCtx context.Context, options GraphQLSubscriptionOptions, next chan<- []byte) error

type SubscriptionConfiguration

+ UseSSE bool

Aug 16, 2022

retracted

Changes in this version

+ const MessageTypeComplete

+ const MessageTypeConnectionAck

+ const MessageTypeConnectionError

+ const MessageTypeConnectionKeepAlive

+ const MessageTypeData

+ const MessageTypeError

+ 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