graphql_datasource

type Batch struct {
	// contains filtered or unexported fields
}

type BatchFactory struct{}

type Configuration struct {
	Fetch                  FetchConfiguration
	Subscription           SubscriptionConfiguration
	Federation             FederationConfiguration
	UpstreamSchema         string
	CustomScalarTypeFields []SingleTypeField
}

type ConnectionHandler interface {
	StartBlocking(sub Subscription)
	SubscribeCH() chan<- Subscription
}

type DefaultSubscriptionClientFactory struct{}

type Factory struct {
	BatchFactory               resolve.DataSourceBatchFactory
	HTTPClient                 *http.Client
	StreamingClient            *http.Client
	OnWsConnectionInitCallback *OnWsConnectionInitCallback
	SubscriptionClient         *SubscriptionClient
}

type FederationConfiguration struct {
	Enabled    bool
	ServiceSDL string
}

type FetchConfiguration struct {
	URL    string
	Method string
	Header http.Header
}

type GraphQLBody struct {
	Query         string          `json:"query,omitempty"`
	OperationName string          `json:"operationName,omitempty"`
	Variables     json.RawMessage `json:"variables,omitempty"`
	Extensions    json.RawMessage `json:"extensions,omitempty"`
}

type GraphQLSubscriptionClient interface {
	Subscribe(ctx context.Context, options GraphQLSubscriptionOptions, next chan<- []byte) error
}

type GraphQLSubscriptionClientFactory interface {
	NewSubscriptionClient(httpClient, streamingClient *http.Client, engineCtx context.Context, options ...Options) GraphQLSubscriptionClient
}

type GraphQLSubscriptionOptions struct {
	URL           string      `json:"url"`
	Body          GraphQLBody `json:"body"`
	Header        http.Header `json:"header"`
	UseSSE        bool        `json:"use_sse"`
	SSEMethodPost bool        `json:"sse_method_post"`
}

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

type Options func(options *opts)

type Planner struct {
	// contains filtered or unexported fields
}

type SingleTypeField struct {
	TypeName  string
	FieldName string
}

type Source struct {
	// contains filtered or unexported fields
}

type Subscription struct {
	// contains filtered or unexported fields
}

type SubscriptionClient struct {
	// contains filtered or unexported fields
}

type SubscriptionConfiguration struct {
	URL           string
	UseSSE        bool
	SSEMethodPost bool
}

type SubscriptionSource struct {
	// contains filtered or unexported fields
}