Versions in this module Expand all Collapse all v0 v0.3.0 Mar 8, 2024 Changes in this version + var ContextOperationServerIndices = contextKey("serverOperationIndices") + var ContextOperationServerVariables = contextKey("serverOperationVariables") + var ContextServerIndex = contextKey("serverIndex") + var ContextServerVariables = contextKey("serverVariables") + var JsonCheck = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?json)`) + var XmlCheck = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?xml)`) + func CacheExpires(r *http.Response) time.Time + func IsNil(i interface{}) bool + func PtrBool(v bool) *bool + func PtrFloat32(v float32) *float32 + func PtrFloat64(v float64) *float64 + func PtrInt(v int) *int + func PtrInt32(v int32) *int32 + func PtrInt64(v int64) *int64 + func PtrString(v string) *string + func PtrTime(v time.Time) *time.Time + type APIClient struct + DefaultAPI *DefaultAPIService + func NewAPIClient(cfg *Configuration) *APIClient + func (c *APIClient) GetConfig() *Configuration + type APIKey struct + Key string + Prefix string + type APIResponse struct + Message string + Method string + Operation string + Payload []byte + RequestURL string + func NewAPIResponse(r *http.Response) *APIResponse + func NewAPIResponseWithError(errorMessage string) *APIResponse + type ApiApiV1ConsumeQueueNameGetRequest struct + ApiService *DefaultAPIService + func (r ApiApiV1ConsumeQueueNameGetRequest) Execute() (string, *http.Response, error) + type ApiApiV1FunctionFunctionNameDeleteRequest struct + ApiService *DefaultAPIService + func (r ApiApiV1FunctionFunctionNameDeleteRequest) Execute() (*http.Response, error) + type ApiApiV1FunctionFunctionNamePostRequest struct + ApiService *DefaultAPIService + func (r ApiApiV1FunctionFunctionNamePostRequest) Execute() (*http.Response, error) + func (r ApiApiV1FunctionFunctionNamePostRequest) Function(function Function) ApiApiV1FunctionFunctionNamePostRequest + type ApiApiV1FunctionsGetRequest struct + ApiService *DefaultAPIService + func (r ApiApiV1FunctionsGetRequest) Execute() ([]string, *http.Response, error) + type ApiApiV1ProduceQueueNamePutRequest struct + ApiService *DefaultAPIService + func (r ApiApiV1ProduceQueueNamePutRequest) Body(body string) ApiApiV1ProduceQueueNamePutRequest + func (r ApiApiV1ProduceQueueNamePutRequest) Execute() (*http.Response, error) + type BasicAuth struct + Password string + UserName string + type Configuration struct + Debug bool + DefaultHeader map[string]string + HTTPClient *http.Client + Host string + OperationServers map[string]ServerConfigurations + Scheme string + Servers ServerConfigurations + UserAgent string + func NewConfiguration() *Configuration + func (c *Configuration) AddDefaultHeader(key string, value string) + func (c *Configuration) ServerURL(index int, variables map[string]string) (string, error) + func (c *Configuration) ServerURLWithContext(ctx context.Context, endpoint string) (string, error) + type DefaultAPIService service + func (a *DefaultAPIService) ApiV1ConsumeQueueNameGet(ctx context.Context, queueName string) ApiApiV1ConsumeQueueNameGetRequest + func (a *DefaultAPIService) ApiV1ConsumeQueueNameGetExecute(r ApiApiV1ConsumeQueueNameGetRequest) (string, *http.Response, error) + func (a *DefaultAPIService) ApiV1FunctionFunctionNameDelete(ctx context.Context, functionName string) ApiApiV1FunctionFunctionNameDeleteRequest + func (a *DefaultAPIService) ApiV1FunctionFunctionNameDeleteExecute(r ApiApiV1FunctionFunctionNameDeleteRequest) (*http.Response, error) + func (a *DefaultAPIService) ApiV1FunctionFunctionNamePost(ctx context.Context, functionName string) ApiApiV1FunctionFunctionNamePostRequest + func (a *DefaultAPIService) ApiV1FunctionFunctionNamePostExecute(r ApiApiV1FunctionFunctionNamePostRequest) (*http.Response, error) + func (a *DefaultAPIService) ApiV1FunctionsGet(ctx context.Context) ApiApiV1FunctionsGetRequest + func (a *DefaultAPIService) ApiV1FunctionsGetExecute(r ApiApiV1FunctionsGetRequest) ([]string, *http.Response, error) + func (a *DefaultAPIService) ApiV1ProduceQueueNamePut(ctx context.Context, queueName string) ApiApiV1ProduceQueueNamePutRequest + func (a *DefaultAPIService) ApiV1ProduceQueueNamePutExecute(r ApiApiV1ProduceQueueNamePutRequest) (*http.Response, error) + type Function struct + Config *map[string]string + Inputs []string + Name *string + Output string + Replicas int32 + Runtime *FunctionRuntime + Sink *FunctionSource + Source *FunctionSource + func NewFunction(inputs []string, output string, replicas int32) *Function + func NewFunctionWithDefaults() *Function + func (o *Function) GetConfig() map[string]string + func (o *Function) GetConfigOk() (*map[string]string, bool) + func (o *Function) GetInputs() []string + func (o *Function) GetInputsOk() ([]string, bool) + func (o *Function) GetName() string + func (o *Function) GetNameOk() (*string, bool) + func (o *Function) GetOutput() string + func (o *Function) GetOutputOk() (*string, bool) + func (o *Function) GetReplicas() int32 + func (o *Function) GetReplicasOk() (*int32, bool) + func (o *Function) GetRuntime() FunctionRuntime + func (o *Function) GetRuntimeOk() (*FunctionRuntime, bool) + func (o *Function) GetSink() FunctionSource + func (o *Function) GetSinkOk() (*FunctionSource, bool) + func (o *Function) GetSource() FunctionSource + func (o *Function) GetSourceOk() (*FunctionSource, bool) + func (o *Function) HasConfig() bool + func (o *Function) HasName() bool + func (o *Function) HasRuntime() bool + func (o *Function) HasSink() bool + func (o *Function) HasSource() bool + func (o *Function) SetConfig(v map[string]string) + func (o *Function) SetInputs(v []string) + func (o *Function) SetName(v string) + func (o *Function) SetOutput(v string) + func (o *Function) SetReplicas(v int32) + func (o *Function) SetRuntime(v FunctionRuntime) + func (o *Function) SetSink(v FunctionSource) + func (o *Function) SetSource(v FunctionSource) + func (o *Function) UnmarshalJSON(data []byte) (err error) + func (o Function) MarshalJSON() ([]byte, error) + func (o Function) ToMap() (map[string]interface{}, error) + type FunctionRuntime struct + Config map[string]interface{} + Type NullableString + func NewFunctionRuntime() *FunctionRuntime + func NewFunctionRuntimeWithDefaults() *FunctionRuntime + func (o *FunctionRuntime) GetConfig() map[string]interface{} + func (o *FunctionRuntime) GetConfigOk() (map[string]interface{}, bool) + func (o *FunctionRuntime) GetType() string + func (o *FunctionRuntime) GetTypeOk() (*string, bool) + func (o *FunctionRuntime) HasConfig() bool + func (o *FunctionRuntime) HasType() bool + func (o *FunctionRuntime) SetConfig(v map[string]interface{}) + func (o *FunctionRuntime) SetType(v string) + func (o *FunctionRuntime) SetTypeNil() + func (o *FunctionRuntime) UnsetType() + func (o FunctionRuntime) MarshalJSON() ([]byte, error) + func (o FunctionRuntime) ToMap() (map[string]interface{}, error) + type FunctionSource struct + Config map[string]interface{} + Type NullableString + func NewFunctionSource() *FunctionSource + func NewFunctionSourceWithDefaults() *FunctionSource + func (o *FunctionSource) GetConfig() map[string]interface{} + func (o *FunctionSource) GetConfigOk() (map[string]interface{}, bool) + func (o *FunctionSource) GetType() string + func (o *FunctionSource) GetTypeOk() (*string, bool) + func (o *FunctionSource) HasConfig() bool + func (o *FunctionSource) HasType() bool + func (o *FunctionSource) SetConfig(v map[string]interface{}) + func (o *FunctionSource) SetType(v string) + func (o *FunctionSource) SetTypeNil() + func (o *FunctionSource) UnsetType() + func (o FunctionSource) MarshalJSON() ([]byte, error) + func (o FunctionSource) ToMap() (map[string]interface{}, error) + type GenericOpenAPIError struct + func (e GenericOpenAPIError) Body() []byte + func (e GenericOpenAPIError) Error() string + func (e GenericOpenAPIError) Model() interface{} + type MappedNullable interface + ToMap func() (map[string]interface{}, error) + type NullableBool struct + func NewNullableBool(val *bool) *NullableBool + func (v *NullableBool) Set(val *bool) + func (v *NullableBool) UnmarshalJSON(src []byte) error + func (v *NullableBool) Unset() + func (v NullableBool) Get() *bool + func (v NullableBool) IsSet() bool + func (v NullableBool) MarshalJSON() ([]byte, error) + type NullableFloat32 struct + func NewNullableFloat32(val *float32) *NullableFloat32 + func (v *NullableFloat32) Set(val *float32) + func (v *NullableFloat32) UnmarshalJSON(src []byte) error + func (v *NullableFloat32) Unset() + func (v NullableFloat32) Get() *float32 + func (v NullableFloat32) IsSet() bool + func (v NullableFloat32) MarshalJSON() ([]byte, error) + type NullableFloat64 struct + func NewNullableFloat64(val *float64) *NullableFloat64 + func (v *NullableFloat64) Set(val *float64) + func (v *NullableFloat64) UnmarshalJSON(src []byte) error + func (v *NullableFloat64) Unset() + func (v NullableFloat64) Get() *float64 + func (v NullableFloat64) IsSet() bool + func (v NullableFloat64) MarshalJSON() ([]byte, error) + type NullableFunction struct + func NewNullableFunction(val *Function) *NullableFunction + func (v *NullableFunction) Set(val *Function) + func (v *NullableFunction) UnmarshalJSON(src []byte) error + func (v *NullableFunction) Unset() + func (v NullableFunction) Get() *Function + func (v NullableFunction) IsSet() bool + func (v NullableFunction) MarshalJSON() ([]byte, error) + type NullableFunctionRuntime struct + func NewNullableFunctionRuntime(val *FunctionRuntime) *NullableFunctionRuntime + func (v *NullableFunctionRuntime) Set(val *FunctionRuntime) + func (v *NullableFunctionRuntime) UnmarshalJSON(src []byte) error + func (v *NullableFunctionRuntime) Unset() + func (v NullableFunctionRuntime) Get() *FunctionRuntime + func (v NullableFunctionRuntime) IsSet() bool + func (v NullableFunctionRuntime) MarshalJSON() ([]byte, error) + type NullableFunctionSource struct + func NewNullableFunctionSource(val *FunctionSource) *NullableFunctionSource + func (v *NullableFunctionSource) Set(val *FunctionSource) + func (v *NullableFunctionSource) UnmarshalJSON(src []byte) error + func (v *NullableFunctionSource) Unset() + func (v NullableFunctionSource) Get() *FunctionSource + func (v NullableFunctionSource) IsSet() bool + func (v NullableFunctionSource) MarshalJSON() ([]byte, error) + type NullableInt struct + func NewNullableInt(val *int) *NullableInt + func (v *NullableInt) Set(val *int) + func (v *NullableInt) UnmarshalJSON(src []byte) error + func (v *NullableInt) Unset() + func (v NullableInt) Get() *int + func (v NullableInt) IsSet() bool + func (v NullableInt) MarshalJSON() ([]byte, error) + type NullableInt32 struct + func NewNullableInt32(val *int32) *NullableInt32 + func (v *NullableInt32) Set(val *int32) + func (v *NullableInt32) UnmarshalJSON(src []byte) error + func (v *NullableInt32) Unset() + func (v NullableInt32) Get() *int32 + func (v NullableInt32) IsSet() bool + func (v NullableInt32) MarshalJSON() ([]byte, error) + type NullableInt64 struct + func NewNullableInt64(val *int64) *NullableInt64 + func (v *NullableInt64) Set(val *int64) + func (v *NullableInt64) UnmarshalJSON(src []byte) error + func (v *NullableInt64) Unset() + func (v NullableInt64) Get() *int64 + func (v NullableInt64) IsSet() bool + func (v NullableInt64) MarshalJSON() ([]byte, error) + type NullableRuntimeConfig struct + func NewNullableRuntimeConfig(val *RuntimeConfig) *NullableRuntimeConfig + func (v *NullableRuntimeConfig) Set(val *RuntimeConfig) + func (v *NullableRuntimeConfig) UnmarshalJSON(src []byte) error + func (v *NullableRuntimeConfig) Unset() + func (v NullableRuntimeConfig) Get() *RuntimeConfig + func (v NullableRuntimeConfig) IsSet() bool + func (v NullableRuntimeConfig) MarshalJSON() ([]byte, error) + type NullableString struct + func NewNullableString(val *string) *NullableString + func (v *NullableString) Set(val *string) + func (v *NullableString) UnmarshalJSON(src []byte) error + func (v *NullableString) Unset() + func (v NullableString) Get() *string + func (v NullableString) IsSet() bool + func (v NullableString) MarshalJSON() ([]byte, error) + type NullableTime struct + func NewNullableTime(val *time.Time) *NullableTime + func (v *NullableTime) Set(val *time.Time) + func (v *NullableTime) UnmarshalJSON(src []byte) error + func (v *NullableTime) Unset() + func (v NullableTime) Get() *time.Time + func (v NullableTime) IsSet() bool + func (v NullableTime) MarshalJSON() ([]byte, error) + type NullableTubeConfig struct + func NewNullableTubeConfig(val *TubeConfig) *NullableTubeConfig + func (v *NullableTubeConfig) Set(val *TubeConfig) + func (v *NullableTubeConfig) UnmarshalJSON(src []byte) error + func (v *NullableTubeConfig) Unset() + func (v NullableTubeConfig) Get() *TubeConfig + func (v NullableTubeConfig) IsSet() bool + func (v NullableTubeConfig) MarshalJSON() ([]byte, error) + type RuntimeConfig struct + Config map[string]interface{} + Type NullableString + func NewRuntimeConfig() *RuntimeConfig + func NewRuntimeConfigWithDefaults() *RuntimeConfig + func (o *RuntimeConfig) GetConfig() map[string]interface{} + func (o *RuntimeConfig) GetConfigOk() (map[string]interface{}, bool) + func (o *RuntimeConfig) GetType() string + func (o *RuntimeConfig) GetTypeOk() (*string, bool) + func (o *RuntimeConfig) HasConfig() bool + func (o *RuntimeConfig) HasType() bool + func (o *RuntimeConfig) SetConfig(v map[string]interface{}) + func (o *RuntimeConfig) SetType(v string) + func (o *RuntimeConfig) SetTypeNil() + func (o *RuntimeConfig) UnsetType() + func (o RuntimeConfig) MarshalJSON() ([]byte, error) + func (o RuntimeConfig) ToMap() (map[string]interface{}, error) + type ServerConfiguration struct + Description string + URL string + Variables map[string]ServerVariable + type ServerConfigurations []ServerConfiguration + func (sc ServerConfigurations) URL(index int, variables map[string]string) (string, error) + type ServerVariable struct + DefaultValue string + Description string + EnumValues []string + type TubeConfig struct + Config map[string]interface{} + Type NullableString + func NewTubeConfig() *TubeConfig + func NewTubeConfigWithDefaults() *TubeConfig + func (o *TubeConfig) GetConfig() map[string]interface{} + func (o *TubeConfig) GetConfigOk() (map[string]interface{}, bool) + func (o *TubeConfig) GetType() string + func (o *TubeConfig) GetTypeOk() (*string, bool) + func (o *TubeConfig) HasConfig() bool + func (o *TubeConfig) HasType() bool + func (o *TubeConfig) SetConfig(v map[string]interface{}) + func (o *TubeConfig) SetType(v string) + func (o *TubeConfig) SetTypeNil() + func (o *TubeConfig) UnsetType() + func (o TubeConfig) MarshalJSON() ([]byte, error) + func (o TubeConfig) ToMap() (map[string]interface{}, error)