graphql_datasource

Documentation

Index

• func ConfigJson(config Configuration) json.RawMessage
• 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 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) 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) LeaveDocument(operation, definition *ast.Document)
  • func (p *Planner) LeaveField(ref int)
  • func (p *Planner) LeaveInlineFragment(ref int)
  • func (p *Planner) LeaveOperationDefinition(ref int)
  • func (p *Planner) LeaveSelectionSet(ref int)
  • func (p *Planner) Register(visitor *plan.Visitor, config json.RawMessage, isNested bool) 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) *WebSocketGraphQLSubscriptionClient
  • func (c *WebSocketGraphQLSubscriptionClient) Subscribe(ctx context.Context, options GraphQLSubscriptionOptions, next chan<- []byte) error

Functions

func ConfigJson

func ConfigJson(config Configuration) json.RawMessage

Types

type Configuration

type Configuration struct {
	Fetch        FetchConfiguration
	Subscription SubscriptionConfiguration
	Federation   FederationConfiguration
}

func (*Configuration) ApplyDefaults

func (c *Configuration) ApplyDefaults()

type Factory

type Factory struct {
	Client *http.Client
}

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 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) 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) 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(ref int)

func (*Planner) LeaveOperationDefinition

func (p *Planner) LeaveOperationDefinition(ref int)

func (*Planner) LeaveSelectionSet

func (p *Planner) LeaveSelectionSet(ref int)

func (*Planner) Register

func (p *Planner) Register(visitor *plan.Visitor, config json.RawMessage, 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
}

func NewWebSocketGraphQLSubscriptionClient

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

func (*WebSocketGraphQLSubscriptionClient) Subscribe

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