apiaggregator

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

type Pipeline struct {
	// Name is the name of pipeline in EG
	Name string `yaml:"name" jsonschema:"required"`

	// Method is the HTTP method for requesting this pipeline.
	Method string `yaml:"method" jsonschema:"omitempty,format=httpmethod"`

	// Path is the HTTP request path adaptor for requesting this pipeline.
	Path *pathadaptor.Spec `yaml:"path,omitempty" jsonschema:"omitempty"`

	// Header is the HTTP header adaptor for requestring this pipeline.
	Header *httpheader.AdaptSpec `yaml:"header,omitempty" jsonschema:"omitempty"`

	// DisableBody discart this pipeline's response body if it set to true.
	DisableBody bool `yaml:"disableBody" jsonschema:"omitempty"`
	// contains filtered or unexported fields
}

type Spec struct {
	// MaxBodyBytes in [0, 10MB]
	MaxBodyBytes int64 `yaml:"maxBodyBytes" jsonschema:"omitempty,minimum=0,maximum=102400"`

	// PartialSucceed indicates wether Whether regards the result of the original request as successful
	// or not when a request to some of the API pipelines fails.
	PartialSucceed bool `yaml:"partialSucceed"`

	// Timeout is the request duration for each APIs.
	Timeout string `yaml:"timeout" jsonschema:"omitempty,format=duration"`

	// MergeResponse indicates whether to merge JSON response bodies or not.
	MergeResponse bool `yaml:"mergeResponse"`

	// User describes HTTP service target via an existing Pipeline.
	Pipelines []*Pipeline `yaml:"pipelines" jsonschema:"required"`
	// contains filtered or unexported fields
}