internal

package

Go to main page

Versions in this module

v0

v0.8.1

Dec 28, 2024

Changes in this version

type DistributedResponse

+ func (dr DistributedResponse[T]) ToMap() map[string]any

v0.8.0

Dec 27, 2024

Changes in this version

type UpstreamManager

+ func (um *UpstreamManager) CreateHTTPClient(requests *RequestBuilderResults) *HTTPClient

v0.7.0

Dec 16, 2024

Changes in this version

+ const ProcedureSendHTTPRequest

+ const ScalarRawHTTPMethod

+ func ApplyDefaultConnectorSchema(input *schema.SchemaResponse, ...) (*schema.SchemaResponse, rest.OperationInfo)

+ func IsSensitiveHeader(name string) bool

+ type RawRequestBuilder struct

+ func NewRawRequestBuilder(operation schema.MutationOperation, ...) *RawRequestBuilder

+ func (rqe *RawRequestBuilder) Build() (*RequestBuilderResults, error)

+ func (rqe *RawRequestBuilder) Explain() (*schema.ExplainResponse, error)

v0.7.0-beta.1

Dec 16, 2024

v0.6.1

Dec 12, 2024

v0.6.0

Dec 10, 2024

Changes in this version

+ type RequestBuilderResults struct

+ Operation *rest.OperationInfo

+ Requests []*RetryableRequest

+ Schema *configuration.NDCHttpRuntimeSchema

type Server

+ ArgumentPresets *argument.ArgumentPresets

type UpstreamManager

+ func (um *UpstreamManager) BuildRequests(runtimeSchema *configuration.NDCHttpRuntimeSchema, operationName string, ...) (*RequestBuilderResults, error)

v0.5.0

Dec 2, 2024

Changes in this version

type RetryableRequest

+ Namespace string

+ type Server struct

+ Credentials map[string]security.Credential

+ HTTPClient *http.Client

+ Headers map[string]string

+ Security rest.AuthSecurities

+ URL *url.URL

+ type UpstreamManager struct

+ func NewUpstreamManager(httpClient *http.Client, config *configuration.Configuration) *UpstreamManager

+ func (sm *UpstreamManager) BuildDistributedRequestsWithOptions(request *RetryableRequest, httpOptions *HTTPOptions) ([]RetryableRequest, error)

+ func (sm *UpstreamManager) ExecuteRequest(ctx context.Context, request *RetryableRequest, namespace string) (*http.Response, context.CancelFunc, error)

+ func (sm *UpstreamManager) InjectMockRequestSettings(req *http.Request, namespace string, securities rest.AuthSecurities)

+ func (sm *UpstreamManager) Register(ctx context.Context, namespace string, rawSettings *rest.NDCHttpSettings) error

+ type UpstreamSetting struct

v0.4.0

Nov 24, 2024

Changes in this version

+ const EncodingASCII

+ const EncodingBase64

+ func MaskString(input string) string

+ func UnwrapNullableType(input schema.Type) (schema.TypeEncoder, bool, error)

+ type DataURI struct

+ Data string

+ MediaType string

+ Parameters map[string]string

+ func DecodeDataURI(input string) (*DataURI, error)

+ type DistributedError struct

+ Server string

+ func (de DistributedError) Error() string

+ type DistributedResponse struct

+ Errors []DistributedError

+ Results []DistributedResult[T]

+ func NewDistributedResponse[T any]() *DistributedResponse[T]

+ type DistributedResult struct

+ Data T

+ Server string

+ type Doer interface

+ Do func(req *http.Request) (*http.Response, error)

+ type HTTPClient struct

+ func NewHTTPClient(client Doer, httpSchema *rest.NDCHttpSchema, ...) *HTTPClient

+ func (client *HTTPClient) Send(ctx context.Context, request *RetryableRequest, selection schema.NestedField, ...) (any, http.Header, error)

+ func (client *HTTPClient) SetTracer(tracer *connector.Tracer)

+ type HTTPOptions struct

+ Concurrency uint

+ Distributed bool

+ Explain bool

+ Parallel bool

+ Servers []string

+ Settings *rest.NDCHttpSettings

+ func (ro *HTTPOptions) FromValue(value any) error

+ type Key struct

+ func NewIndexKey(index int) Key

+ func NewKey(key string) Key

+ func (k Key) Index() *int

+ func (k Key) IsEmpty() bool

+ func (k Key) Key() string

+ func (k Key) String() string

+ type Keys []Key

+ func (ks Keys) String() string

+ type MetadataCollection []configuration.NDCHttpRuntimeSchema

+ func (rms MetadataCollection) GetFunction(name string) (*rest.OperationInfo, configuration.NDCHttpRuntimeSchema, error)

+ func (rms MetadataCollection) GetProcedure(name string) (*rest.OperationInfo, configuration.NDCHttpRuntimeSchema, error)

+ type MultipartWriter struct

+ func NewMultipartWriter(w io.Writer) *MultipartWriter

+ func (w *MultipartWriter) WriteDataURI(name string, value any, headers http.Header) error

+ func (w *MultipartWriter) WriteField(fieldName, value string, headers http.Header) error

+ func (w *MultipartWriter) WriteJSON(fieldName string, value any, headers http.Header) error

+ type ParameterItem struct

+ func NewParameterItem(keys Keys, values []string) ParameterItem

+ func (ssp *ParameterItem) Add(key Key, value string)

+ func (ssp *ParameterItem) AddKey(key Key)

+ func (ssp *ParameterItem) AddKeys(keys []Key)

+ func (ssp *ParameterItem) AddValue(value string)

+ func (ssp *ParameterItem) AddValues(values []string)

+ func (ssp *ParameterItem) PrependKey(key Key)

+ func (ssp *ParameterItem) PrependKeys(keys []Key)

+ func (ssp *ParameterItem) PrependValue(value string)

+ func (ssp *ParameterItem) PrependValues(values []string)

+ func (ssp ParameterItem) Keys() Keys

+ func (ssp ParameterItem) String() string

+ func (ssp ParameterItem) Values() []string

+ type ParameterItems []ParameterItem

+ func (ssp *ParameterItems) Add(keys []Key, values []string)

+ func (ssp ParameterItems) Find(keys []Key) *ParameterItem

+ func (ssp ParameterItems) FindDefault() *ParameterItem

+ func (ssp ParameterItems) FindIndex(keys []Key) int

+ func (ssp ParameterItems) String() string

+ type RequestBuilder struct

+ Arguments map[string]any

+ Operation *rest.OperationInfo

+ Runtime rest.RuntimeSettings

+ Schema *rest.NDCHttpSchema

+ func NewRequestBuilder(restSchema *rest.NDCHttpSchema, operation *rest.OperationInfo, ...) *RequestBuilder

+ func (c *RequestBuilder) Build() (*RetryableRequest, error)

+ type RetryableRequest struct

+ Body io.ReadSeeker

+ ContentLength int64

+ ContentType string

+ Headers http.Header

+ RawRequest *rest.Request

+ Runtime rest.RuntimeSettings

+ ServerID string

+ URL url.URL

+ func BuildDistributedRequestsWithOptions(request *RetryableRequest, httpOptions *HTTPOptions) ([]RetryableRequest, error)

+ func (r *RetryableRequest) CreateRequest(ctx context.Context) (*http.Request, context.CancelFunc, error)

+ type XMLDecoder struct

+ func NewXMLDecoder(httpSchema *rest.NDCHttpSchema) *XMLDecoder

+ func (c *XMLDecoder) Decode(r io.Reader, resultType schema.Type) (any, error)

+ type XMLEncoder struct

+ func NewXMLEncoder(httpSchema *rest.NDCHttpSchema) *XMLEncoder

+ func (c *XMLEncoder) Encode(bodyInfo *rest.ArgumentInfo, bodyData any) ([]byte, error)

v0.4.0-beta.1

Nov 11, 2024

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