oas_datasource

Documentation

Index

• func ConfigJSON(config Configuration) json.RawMessage
• type Configuration
• type Factory
  • func (f *Factory) Planner(ctx context.Context) plan.DataSourcePlanner
• type FetchConfiguration
• type Planner
  • 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
• type Source
  • func (s *Source) Load(ctx context.Context, input []byte, w io.Writer) (err error)
• type StatusCodeTypeMapping
• type SubscriptionConfiguration

Functions

func ConfigJSON

func ConfigJSON(config Configuration) json.RawMessage

Types

type Configuration

type Configuration struct {
	Fetch                  FetchConfiguration
	Subscription           SubscriptionConfiguration
	StatusCodeTypeMappings []StatusCodeTypeMapping
	DefaultTypeName        string
}

type Factory

type Factory struct {
	Client *http.Client
}

func (*Factory) Planner

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

type FetchConfiguration

type FetchConfiguration struct {
	URL           string
	Method        string
	Header        http.Header
	Query         []QueryConfiguration
	Body          string
	URLEncodeBody bool `json:"url_encode_body"`
}

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(_ int) (alias string, exists bool)

func (*Planner) EnterField

func (p *Planner) EnterField(ref int)

func (*Planner) EnterOperationDefinition

func (p *Planner) EnterOperationDefinition(ref int)

func (*Planner) Register

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

type QueryConfiguration

type QueryConfiguration struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type Source

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

func (*Source) Load

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

type StatusCodeTypeMapping

type StatusCodeTypeMapping struct {
	StatusCode                   int
	StatusCodeByteString         []byte
	InjectStatusCodeIntoResponse bool
	TypeNameStringBytes          []byte
}

type SubscriptionConfiguration

type SubscriptionConfiguration struct {
	PollingIntervalMillis   int64
	SkipPublishSameResponse bool
}