universal_client

Feb 22, 2021

Changes in this version

+ var ErrNotFound = errors.New("Resource not found")

+ var ErrTODO = errors.New("TODO: This feature is not implemented yet")

+ func AddHeaders(q map[string]string) func(*http.Request)

+ func AddQuery(q map[string]string) func(*http.Request)

+ func CreateOrUpdateWebhook(c UniversalClient, spec *tykv1alpha1.WebhookSpec) error

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

+ func DoReload(c UniversalClient, fn func(u UniversalClient) error) error

+ func Error(res *http.Response) error

+ func IgnoreNotFound(err error) error

+ func IsNotFound(err error) bool

+ func IsTODO(err error) bool

+ func JSON(res *http.Response, o interface{}) error

+ func RunRequestKase(t *testing.T, e environmet.Env, fn func(Client) error, kase ...Kase)

+ func SetHeaders(q map[string]string) func(*http.Request)

+ type Client struct

+ BeforeRequest func(*http.Request)

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

+ Env environmet.Env

+ Log logr.Logger

+ func (c Client) Call(method, url string, body io.Reader, fn ...func(*http.Request)) (*http.Response, error)

+ func (c Client) Delete(url string, body io.Reader, fn ...func(*http.Request)) (*http.Response, error)

+ func (c Client) Environment() environmet.Env

+ func (c Client) Get(url string, body io.Reader, fn ...func(*http.Request)) (*http.Response, error)

+ func (c Client) JSON(method, url string, body interface{}, fn ...func(*http.Request)) (*http.Response, error)

+ func (c Client) Post(url string, body io.Reader, fn ...func(*http.Request)) (*http.Response, error)

+ func (c Client) PostJSON(url string, body interface{}, fn ...func(*http.Request)) (*http.Response, error)

+ func (c Client) PutJSON(url string, body interface{}, fn ...func(*http.Request)) (*http.Response, error)

+ func (c Client) Request(method, url string, body io.Reader) (*http.Request, error)

+ type Kase struct

+ Name string

+ Request RequestKase

+ Response *ResponseKase

+ type RequestKase struct

+ Callback func(*testing.T, *http.Request)

+ Headers map[string]string

+ Method string

+ Path string

+ type ResponseKase struct

+ Body string

+ Callback func(*testing.T, *http.Response)

+ Headers map[string]string

+ type UniversalApi interface

+ All func() ([]v1.APIDefinitionSpec, error)

+ Create func(spec *v1.APIDefinitionSpec) error

+ Delete func(id string) error

+ Get func(apiID string) (*v1.APIDefinitionSpec, error)

+ Update func(def *v1.APIDefinitionSpec) error

+ type UniversalCertificate interface

+ All func() ([]string, error)

+ Delete func(id string) error

+ Exists func(id string) bool

+ Upload func(key []byte, crt []byte) (id string, err error)

+ type UniversalClient interface

+ Api func() UniversalApi

+ Certificate func() UniversalCertificate

+ Environment func() environmet.Env

+ HotReload func() error

+ Organization func() UniversalOrganization

+ SecurityPolicy func() UniversalSecurityPolicy

+ Webhook func() UniversalWebhook

+ type UniversalOrganization interface

+ GetID func() string

+ type UniversalSecurityPolicy interface

+ All func() ([]tykv1alpha1.SecurityPolicySpec, error)

+ Create func(def *tykv1alpha1.SecurityPolicySpec) error

+ Delete func(id string) error

+ Get func(id string) (*tykv1alpha1.SecurityPolicySpec, error)

+ Update func(def *tykv1alpha1.SecurityPolicySpec) error

+ type UniversalWebhook interface

+ All func() ([]tykv1alpha1.WebhookSpec, error)

+ Create func(*tykv1alpha1.WebhookSpec) error

+ Delete func(id string) error

+ Get func(id string) (*tykv1alpha1.WebhookSpec, error)

+ Update func(def *tykv1alpha1.WebhookSpec) error