graphql_datasource

package

v1.41.0 Latest Latest Go to latest Published: Jun 27, 2022 License: MIT Imports: 27 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pvormste/graphql-go-tools

Links

Open Source Insights

Documentation ¶

Index ¶

func ConfigJson(config Configuration) json.RawMessage
type Batch
- func (b *Batch) Demultiplex(responseBufPair *resolve.BufPair, bufPairs []*resolve.BufPair) (err error)
- func (b *Batch) Input() *fastbuffer.FastBuffer
type BatchFactory
- func NewBatchFactory() *BatchFactory
- func (b *BatchFactory) CreateBatch(inputs [][]byte) (resolve.DataSourceBatch, error)
type Configuration
- func (c *Configuration) ApplyDefaults()
type Factory
- func (f *Factory) Planner(ctx context.Context) plan.DataSourcePlanner
type FederationConfiguration
type FetchConfiguration
type GraphQLBody
type GraphQLSubscriptionClient
type GraphQLSubscriptionOptions
type Options
- func WithLogger(log abstractlogger.Logger) Options
- func WithReadTimeout(timeout time.Duration) Options
type Planner
- 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
- func (s *Source) Load(ctx context.Context, input []byte, writer io.Writer) (err error)
type SubscriptionConfiguration
type SubscriptionSource
- func (s *SubscriptionSource) Start(ctx context.Context, input []byte, next chan<- []byte) error
type WebSocketGraphQLSubscriptionClient
- func NewWebSocketGraphQLSubscriptionClient(httpClient *http.Client, ctx context.Context, options ...Options) *WebSocketGraphQLSubscriptionClient
- func (c *WebSocketGraphQLSubscriptionClient) Subscribe(ctx context.Context, options GraphQLSubscriptionOptions, next chan<- []byte) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConfigJson ¶

func ConfigJson(config Configuration) json.RawMessage

Types ¶

type Batch ¶

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

func (*Batch) Demultiplex ¶

func (b *Batch) Demultiplex(responseBufPair *resolve.BufPair, bufPairs []*resolve.BufPair) (err error)

func (*Batch) Input ¶

func (b *Batch) Input() *fastbuffer.FastBuffer

type BatchFactory ¶

type BatchFactory struct{}

func NewBatchFactory ¶

func NewBatchFactory() *BatchFactory

func (*BatchFactory) CreateBatch ¶

func (b *BatchFactory) CreateBatch(inputs [][]byte) (resolve.DataSourceBatch, error)

type Configuration ¶

type Configuration struct {
	Fetch          FetchConfiguration
	Subscription   SubscriptionConfiguration
	Federation     FederationConfiguration
	UpstreamSchema string
}

func (*Configuration) ApplyDefaults ¶

func (c *Configuration) ApplyDefaults()

type Factory ¶

type Factory struct {
	BatchFactory resolve.DataSourceBatchFactory
	HTTPClient   *http.Client
	// contains filtered or unexported fields
}

func (*Factory) Planner ¶

func (f *Factory) Planner(ctx context.Context) plan.DataSourcePlanner

type FederationConfiguration ¶

type FederationConfiguration struct {
	Enabled    bool
	ServiceSDL string
}

type FetchConfiguration ¶

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

type GraphQLBody ¶

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

type GraphQLSubscriptionClient ¶

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

type GraphQLSubscriptionOptions ¶

type GraphQLSubscriptionOptions struct {
	URL    string      `json:"url"`
	Body   GraphQLBody `json:"body"`
	Header http.Header `json:"header"`
}

type Options ¶

type Options func(options *opts)

func WithLogger ¶

func WithLogger(log abstractlogger.Logger) Options

func WithReadTimeout ¶

func WithReadTimeout(timeout time.Duration) Options

type Planner ¶

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

func (*Planner) ConfigureFetch ¶

func (p *Planner) ConfigureFetch() plan.FetchConfiguration

func (*Planner) ConfigureSubscription ¶

func (p *Planner) ConfigureSubscription() plan.SubscriptionConfiguration

func (*Planner) DataSourcePlanningBehavior ¶

func (p *Planner) DataSourcePlanningBehavior() plan.DataSourcePlanningBehavior

func (*Planner) DownstreamResponseFieldAlias ¶

func (p *Planner) DownstreamResponseFieldAlias(downstreamFieldRef int) (alias string, exists bool)

func (*Planner) EnterArgument ¶

func (p *Planner) EnterArgument(ref int)

func (*Planner) EnterDirective ¶

func (p *Planner) EnterDirective(ref int)

func (*Planner) EnterDocument ¶

func (p *Planner) EnterDocument(operation, definition *ast.Document)

func (*Planner) EnterField ¶

func (p *Planner) EnterField(ref int)

func (*Planner) EnterInlineFragment ¶

func (p *Planner) EnterInlineFragment(ref int)

func (*Planner) EnterOperationDefinition ¶

func (p *Planner) EnterOperationDefinition(ref int)

func (*Planner) EnterSelectionSet ¶

func (p *Planner) EnterSelectionSet(ref int)

func (*Planner) EnterVariableDefinition ¶

func (p *Planner) EnterVariableDefinition(ref int)

func (*Planner) LeaveDocument ¶

func (p *Planner) LeaveDocument(operation, definition *ast.Document)

func (*Planner) LeaveField ¶

func (p *Planner) LeaveField(ref int)

func (*Planner) LeaveInlineFragment ¶

func (p *Planner) LeaveInlineFragment(_ int)

func (*Planner) LeaveOperationDefinition ¶

func (p *Planner) LeaveOperationDefinition(ref int)

func (*Planner) LeaveSelectionSet ¶

func (p *Planner) LeaveSelectionSet(ref int)

func (*Planner) LeaveVariableDefinition ¶

func (p *Planner) LeaveVariableDefinition(_ int)

func (*Planner) Register ¶

func (p *Planner) Register(visitor *plan.Visitor, configuration plan.DataSourceConfiguration, isNested bool) error

type Source ¶

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

func (*Source) Load ¶

func (s *Source) Load(ctx context.Context, input []byte, writer io.Writer) (err error)

type SubscriptionConfiguration ¶

type SubscriptionConfiguration struct {
	URL string
}

type SubscriptionSource ¶

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

func (*SubscriptionSource) Start ¶

func (s *SubscriptionSource) Start(ctx context.Context, input []byte, next chan<- []byte) error

type WebSocketGraphQLSubscriptionClient ¶

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

WebSocketGraphQLSubscriptionClient is a WebSocket client that allows running multiple subscriptions via the same WebSocket Connection It takes care of de-duplicating WebSocket connections to the same origin under certain circumstances If Hash(URL,Body,Headers) result in the same result, an existing WS connection is re-used

func NewWebSocketGraphQLSubscriptionClient ¶

func NewWebSocketGraphQLSubscriptionClient(httpClient *http.Client, ctx context.Context, options ...Options) *WebSocketGraphQLSubscriptionClient

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

Subscribe initiates a new GraphQL Subscription with the origin Each WebSocket (WS) to an origin is uniquely identified by the Hash(URL,Headers,Body) If an existing WS with the same ID (Hash) exists, it is being re-used If no connection exists, the client initiates a new one and sends the "init" and "connection ack" messages

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL