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 Configuration struct + Fetch FetchConfiguration + Subscription SubscriptionConfiguration + type Factory struct + Client *http.Client + func (f *Factory) Planner(ctx context.Context) plan.DataSourcePlanner + type FetchConfiguration struct + Body string + Header http.Header + Method string + Query []QueryConfiguration + URL string + 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(_ int) (alias string, exists bool) + func (p *Planner) EnterField(ref int) + func (p *Planner) EnterOperationDefinition(ref int) + func (p *Planner) Register(visitor *plan.Visitor, configuration plan.DataSourceConfiguration, ...) error + type QueryConfiguration struct + Name string + Value string + type Source struct + func (s *Source) Load(ctx context.Context, input []byte, w io.Writer) (err error) + type SubscriptionConfiguration struct + PollingIntervalMillis int64 + SkipPublishSameResponse bool