adminclient

package

Go to main page

Versions in this module

v0

v0.5.0

Jun 13, 2024

Changes in this version

type APIClient

+ FunctionStoreAPI *FunctionStoreAPIService

+ type ApiReloadFunctionsRequest struct

+ ApiService *FunctionStoreAPIService

+ func (r ApiReloadFunctionsRequest) Execute() (*http.Response, error)

+ type FunctionStoreAPIService service

+ func (a *FunctionStoreAPIService) ReloadFunctions(ctx context.Context) ApiReloadFunctionsRequest

+ func (a *FunctionStoreAPIService) ReloadFunctionsExecute(r ApiReloadFunctionsRequest) (*http.Response, error)

type ModelRuntimeConfig

+ func (o *ModelRuntimeConfig) UnmarshalJSON(data []byte) (err error)

type ModelTubeConfig

+ func (o *ModelTubeConfig) UnmarshalJSON(data []byte) (err error)

v0.4.0

May 7, 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

+ FunctionAPI *FunctionAPIService

+ HttpTubeAPI *HttpTubeAPIService

+ StateAPI *StateAPIService

+ StatusAPI *StatusAPIService

+ TubeAPI *TubeAPIService

+ 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 ApiConsumeMessageRequest struct

+ ApiService *TubeAPIService

+ func (r ApiConsumeMessageRequest) Execute() (string, *http.Response, error)

+ type ApiCreateFunctionRequest struct

+ ApiService *FunctionAPIService

+ func (r ApiCreateFunctionRequest) Body(body ModelFunction) ApiCreateFunctionRequest

+ func (r ApiCreateFunctionRequest) Execute() (*http.Response, error)

+ type ApiDeleteFunctionRequest struct

+ ApiService *FunctionAPIService

+ func (r ApiDeleteFunctionRequest) Execute() (*http.Response, error)

+ type ApiDeleteNamespacedFunctionRequest struct

+ ApiService *FunctionAPIService

+ func (r ApiDeleteNamespacedFunctionRequest) Execute() (*http.Response, error)

+ type ApiGetAllFunctionsRequest struct

+ ApiService *FunctionAPIService

+ func (r ApiGetAllFunctionsRequest) Execute() ([]string, *http.Response, error)

+ type ApiGetStateRequest struct

+ ApiService *StateAPIService

+ func (r ApiGetStateRequest) Execute() (string, *http.Response, error)

+ type ApiGetStatusRequest struct

+ ApiService *StatusAPIService

+ func (r ApiGetStatusRequest) Execute() (*http.Response, error)

+ type ApiProduceMessageRequest struct

+ ApiService *TubeAPIService

+ func (r ApiProduceMessageRequest) Body(body string) ApiProduceMessageRequest

+ func (r ApiProduceMessageRequest) Execute() (*http.Response, error)

+ type ApiSetStateRequest struct

+ ApiService *StateAPIService

+ func (r ApiSetStateRequest) Body(body string) ApiSetStateRequest

+ func (r ApiSetStateRequest) Execute() (*http.Response, error)

+ type ApiTriggerHttpTubeEndpointRequest struct

+ ApiService *HttpTubeAPIService

+ func (r ApiTriggerHttpTubeEndpointRequest) Body(body string) ApiTriggerHttpTubeEndpointRequest

+ func (r ApiTriggerHttpTubeEndpointRequest) 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 FunctionAPIService service

+ func (a *FunctionAPIService) CreateFunction(ctx context.Context) ApiCreateFunctionRequest

+ func (a *FunctionAPIService) CreateFunctionExecute(r ApiCreateFunctionRequest) (*http.Response, error)

+ func (a *FunctionAPIService) DeleteFunction(ctx context.Context, name string) ApiDeleteFunctionRequest

+ func (a *FunctionAPIService) DeleteFunctionExecute(r ApiDeleteFunctionRequest) (*http.Response, error)

+ func (a *FunctionAPIService) DeleteNamespacedFunction(ctx context.Context, name string, namespace string) ApiDeleteNamespacedFunctionRequest

+ func (a *FunctionAPIService) DeleteNamespacedFunctionExecute(r ApiDeleteNamespacedFunctionRequest) (*http.Response, error)

+ func (a *FunctionAPIService) GetAllFunctions(ctx context.Context) ApiGetAllFunctionsRequest

+ func (a *FunctionAPIService) GetAllFunctionsExecute(r ApiGetAllFunctionsRequest) ([]string, *http.Response, error)

+ type GenericOpenAPIError struct

+ func (e GenericOpenAPIError) Body() []byte

+ func (e GenericOpenAPIError) Error() string

+ func (e GenericOpenAPIError) Model() interface{}

+ type HttpTubeAPIService service

+ func (a *HttpTubeAPIService) TriggerHttpTubeEndpoint(ctx context.Context, endpoint string) ApiTriggerHttpTubeEndpointRequest

+ func (a *HttpTubeAPIService) TriggerHttpTubeEndpointExecute(r ApiTriggerHttpTubeEndpointRequest) (*http.Response, error)

+ type MappedNullable interface

+ ToMap func() (map[string]interface{}, error)

+ type ModelFunction struct

+ Config *map[string]string

+ Name string

+ Namespace *string

+ Replicas int32

+ Runtime ModelRuntimeConfig

+ Sink *ModelTubeConfig

+ Source []ModelTubeConfig

+ func NewModelFunction(name string, replicas int32, runtime ModelRuntimeConfig) *ModelFunction

+ func NewModelFunctionWithDefaults() *ModelFunction

+ func (o *ModelFunction) GetConfig() map[string]string

+ func (o *ModelFunction) GetConfigOk() (*map[string]string, bool)

+ func (o *ModelFunction) GetName() string

+ func (o *ModelFunction) GetNameOk() (*string, bool)

+ func (o *ModelFunction) GetNamespace() string

+ func (o *ModelFunction) GetNamespaceOk() (*string, bool)

+ func (o *ModelFunction) GetReplicas() int32

+ func (o *ModelFunction) GetReplicasOk() (*int32, bool)

+ func (o *ModelFunction) GetRuntime() ModelRuntimeConfig

+ func (o *ModelFunction) GetRuntimeOk() (*ModelRuntimeConfig, bool)

+ func (o *ModelFunction) GetSink() ModelTubeConfig

+ func (o *ModelFunction) GetSinkOk() (*ModelTubeConfig, bool)

+ func (o *ModelFunction) GetSource() []ModelTubeConfig

+ func (o *ModelFunction) GetSourceOk() ([]ModelTubeConfig, bool)

+ func (o *ModelFunction) HasConfig() bool

+ func (o *ModelFunction) HasNamespace() bool

+ func (o *ModelFunction) HasSink() bool

+ func (o *ModelFunction) HasSource() bool

+ func (o *ModelFunction) SetConfig(v map[string]string)

+ func (o *ModelFunction) SetName(v string)

+ func (o *ModelFunction) SetNamespace(v string)

+ func (o *ModelFunction) SetReplicas(v int32)

+ func (o *ModelFunction) SetRuntime(v ModelRuntimeConfig)

+ func (o *ModelFunction) SetSink(v ModelTubeConfig)

+ func (o *ModelFunction) SetSource(v []ModelTubeConfig)

+ func (o *ModelFunction) UnmarshalJSON(data []byte) (err error)

+ func (o ModelFunction) MarshalJSON() ([]byte, error)

+ func (o ModelFunction) ToMap() (map[string]interface{}, error)

+ type ModelRuntimeConfig struct

+ Config map[string]interface{}

+ Type *string

+ func NewModelRuntimeConfig() *ModelRuntimeConfig

+ func NewModelRuntimeConfigWithDefaults() *ModelRuntimeConfig

+ func (o *ModelRuntimeConfig) GetConfig() map[string]interface{}

+ func (o *ModelRuntimeConfig) GetConfigOk() (map[string]interface{}, bool)

+ func (o *ModelRuntimeConfig) GetType() string

+ func (o *ModelRuntimeConfig) GetTypeOk() (*string, bool)

+ func (o *ModelRuntimeConfig) HasConfig() bool

+ func (o *ModelRuntimeConfig) HasType() bool

+ func (o *ModelRuntimeConfig) SetConfig(v map[string]interface{})

+ func (o *ModelRuntimeConfig) SetType(v string)

+ func (o ModelRuntimeConfig) MarshalJSON() ([]byte, error)

+ func (o ModelRuntimeConfig) ToMap() (map[string]interface{}, error)

+ type ModelTubeConfig struct

+ Config map[string]interface{}

+ Type *string

+ func NewModelTubeConfig() *ModelTubeConfig

+ func NewModelTubeConfigWithDefaults() *ModelTubeConfig

+ func (o *ModelTubeConfig) GetConfig() map[string]interface{}

+ func (o *ModelTubeConfig) GetConfigOk() (map[string]interface{}, bool)

+ func (o *ModelTubeConfig) GetType() string

+ func (o *ModelTubeConfig) GetTypeOk() (*string, bool)

+ func (o *ModelTubeConfig) HasConfig() bool

+ func (o *ModelTubeConfig) HasType() bool

+ func (o *ModelTubeConfig) SetConfig(v map[string]interface{})

+ func (o *ModelTubeConfig) SetType(v string)

+ func (o ModelTubeConfig) MarshalJSON() ([]byte, error)

+ func (o ModelTubeConfig) ToMap() (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 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 NullableModelFunction struct

+ func NewNullableModelFunction(val *ModelFunction) *NullableModelFunction

+ func (v *NullableModelFunction) Set(val *ModelFunction)

+ func (v *NullableModelFunction) UnmarshalJSON(src []byte) error

+ func (v *NullableModelFunction) Unset()

+ func (v NullableModelFunction) Get() *ModelFunction

+ func (v NullableModelFunction) IsSet() bool

+ func (v NullableModelFunction) MarshalJSON() ([]byte, error)

+ type NullableModelRuntimeConfig struct

+ func NewNullableModelRuntimeConfig(val *ModelRuntimeConfig) *NullableModelRuntimeConfig

+ func (v *NullableModelRuntimeConfig) Set(val *ModelRuntimeConfig)

+ func (v *NullableModelRuntimeConfig) UnmarshalJSON(src []byte) error

+ func (v *NullableModelRuntimeConfig) Unset()

+ func (v NullableModelRuntimeConfig) Get() *ModelRuntimeConfig

+ func (v NullableModelRuntimeConfig) IsSet() bool

+ func (v NullableModelRuntimeConfig) MarshalJSON() ([]byte, error)

+ type NullableModelTubeConfig struct

+ func NewNullableModelTubeConfig(val *ModelTubeConfig) *NullableModelTubeConfig

+ func (v *NullableModelTubeConfig) Set(val *ModelTubeConfig)

+ func (v *NullableModelTubeConfig) UnmarshalJSON(src []byte) error

+ func (v *NullableModelTubeConfig) Unset()

+ func (v NullableModelTubeConfig) Get() *ModelTubeConfig

+ func (v NullableModelTubeConfig) IsSet() bool

+ func (v NullableModelTubeConfig) MarshalJSON() ([]byte, error)

+ type NullableRestfulspecSchemaType struct

+ func NewNullableRestfulspecSchemaType(val *RestfulspecSchemaType) *NullableRestfulspecSchemaType

+ func (v *NullableRestfulspecSchemaType) Set(val *RestfulspecSchemaType)

+ func (v *NullableRestfulspecSchemaType) UnmarshalJSON(src []byte) error

+ func (v *NullableRestfulspecSchemaType) Unset()

+ func (v NullableRestfulspecSchemaType) Get() *RestfulspecSchemaType

+ func (v NullableRestfulspecSchemaType) IsSet() bool

+ func (v NullableRestfulspecSchemaType) 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 RestfulspecSchemaType struct

+ Format string

+ RawType string

+ func NewRestfulspecSchemaType(format string, rawType string) *RestfulspecSchemaType

+ func NewRestfulspecSchemaTypeWithDefaults() *RestfulspecSchemaType

+ func (o *RestfulspecSchemaType) GetFormat() string

+ func (o *RestfulspecSchemaType) GetFormatOk() (*string, bool)

+ func (o *RestfulspecSchemaType) GetRawType() string

+ func (o *RestfulspecSchemaType) GetRawTypeOk() (*string, bool)

+ func (o *RestfulspecSchemaType) SetFormat(v string)

+ func (o *RestfulspecSchemaType) SetRawType(v string)

+ func (o *RestfulspecSchemaType) UnmarshalJSON(data []byte) (err error)

+ func (o RestfulspecSchemaType) MarshalJSON() ([]byte, error)

+ func (o RestfulspecSchemaType) 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 StateAPIService service

+ func (a *StateAPIService) GetState(ctx context.Context, key string) ApiGetStateRequest

+ func (a *StateAPIService) GetStateExecute(r ApiGetStateRequest) (string, *http.Response, error)

+ func (a *StateAPIService) SetState(ctx context.Context, key string) ApiSetStateRequest

+ func (a *StateAPIService) SetStateExecute(r ApiSetStateRequest) (*http.Response, error)

+ type StatusAPIService service

+ func (a *StatusAPIService) GetStatus(ctx context.Context) ApiGetStatusRequest

+ func (a *StatusAPIService) GetStatusExecute(r ApiGetStatusRequest) (*http.Response, error)

+ type TubeAPIService service

+ func (a *TubeAPIService) ConsumeMessage(ctx context.Context, name string) ApiConsumeMessageRequest

+ func (a *TubeAPIService) ConsumeMessageExecute(r ApiConsumeMessageRequest) (string, *http.Response, error)

+ func (a *TubeAPIService) ProduceMessage(ctx context.Context, name string) ApiProduceMessageRequest

+ func (a *TubeAPIService) ProduceMessageExecute(r ApiProduceMessageRequest) (*http.Response, error)

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