Versions in this module Expand all Collapse all v0 v0.1.0 Dec 13, 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 ApiAlterConnectorOffsetsRequest struct + ApiService *DefaultAPIService + func (r ApiAlterConnectorOffsetsRequest) ConnectorOffsets(connectorOffsets ConnectorOffsets) ApiAlterConnectorOffsetsRequest + func (r ApiAlterConnectorOffsetsRequest) Execute() (*http.Response, error) + type ApiCreateConnectorRequest struct + ApiService *DefaultAPIService + func (r ApiCreateConnectorRequest) CreateConnectorRequest(createConnectorRequest CreateConnectorRequest) ApiCreateConnectorRequest + func (r ApiCreateConnectorRequest) Execute() (*ConnectorInfo, *http.Response, error) + type ApiDestroyConnectorRequest struct + ApiService *DefaultAPIService + func (r ApiDestroyConnectorRequest) Execute() (*http.Response, error) + type ApiGetConnectorActiveTopicsRequest struct + ApiService *DefaultAPIService + func (r ApiGetConnectorActiveTopicsRequest) Execute() (*map[string]ConnectorActiveTopicsValue, *http.Response, error) + type ApiGetConnectorConfigDefRequest struct + ApiService *DefaultAPIService + func (r ApiGetConnectorConfigDefRequest) Execute() ([]ConfigKeyInfo, *http.Response, error) + type ApiGetConnectorConfigRequest struct + ApiService *DefaultAPIService + func (r ApiGetConnectorConfigRequest) Execute() (map[string]string, *http.Response, error) + type ApiGetConnectorRequest struct + ApiService *DefaultAPIService + func (r ApiGetConnectorRequest) Execute() (*ConnectorInfo, *http.Response, error) + type ApiGetConnectorStatusRequest struct + ApiService *DefaultAPIService + func (r ApiGetConnectorStatusRequest) Execute() (*ConnectorStateInfo, *http.Response, error) + type ApiGetLoggerRequest struct + ApiService *DefaultAPIService + func (r ApiGetLoggerRequest) Execute() (*http.Response, error) + type ApiGetOffsetsRequest struct + ApiService *DefaultAPIService + func (r ApiGetOffsetsRequest) Execute() (*ConnectorOffsets, *http.Response, error) + type ApiGetTaskConfigsRequest struct + ApiService *DefaultAPIService + func (r ApiGetTaskConfigsRequest) Execute() ([]TaskInfo, *http.Response, error) + type ApiGetTaskStatusRequest struct + ApiService *DefaultAPIService + func (r ApiGetTaskStatusRequest) Execute() (*TaskState, *http.Response, error) + type ApiGetTasksConfigRequest struct + ApiService *DefaultAPIService + func (r ApiGetTasksConfigRequest) Execute() (*map[string]map[string]string, *http.Response, error) + type ApiHealthCheckRequest struct + ApiService *DefaultAPIService + func (r ApiHealthCheckRequest) Execute() (*http.Response, error) + type ApiListConnectorPluginsRequest struct + ApiService *DefaultAPIService + func (r ApiListConnectorPluginsRequest) ConnectorsOnly(connectorsOnly bool) ApiListConnectorPluginsRequest + func (r ApiListConnectorPluginsRequest) Execute() ([]PluginInfo, *http.Response, error) + type ApiListConnectorsRequest struct + ApiService *DefaultAPIService + func (r ApiListConnectorsRequest) Execute() ([]string, *http.Response, error) + type ApiListLoggersRequest struct + ApiService *DefaultAPIService + func (r ApiListLoggersRequest) Execute() (*http.Response, error) + type ApiPatchConnectorConfigRequest struct + ApiService *DefaultAPIService + func (r ApiPatchConnectorConfigRequest) Execute() (*http.Response, error) + func (r ApiPatchConnectorConfigRequest) RequestBody(requestBody map[string]string) ApiPatchConnectorConfigRequest + type ApiPauseConnectorRequest struct + ApiService *DefaultAPIService + func (r ApiPauseConnectorRequest) Execute() (*http.Response, error) + type ApiPutConnectorConfigRequest struct + ApiService *DefaultAPIService + func (r ApiPutConnectorConfigRequest) Body(body map[string]string) ApiPutConnectorConfigRequest + func (r ApiPutConnectorConfigRequest) Execute() (*ConnectorInfo, *http.Response, error) + type ApiResetConnectorActiveTopicsRequest struct + ApiService *DefaultAPIService + func (r ApiResetConnectorActiveTopicsRequest) Execute() (*http.Response, error) + type ApiResetConnectorOffsetsRequest struct + ApiService *DefaultAPIService + func (r ApiResetConnectorOffsetsRequest) Execute() (*http.Response, error) + type ApiRestartConnectorRequest struct + ApiService *DefaultAPIService + func (r ApiRestartConnectorRequest) Execute() (*http.Response, error) + func (r ApiRestartConnectorRequest) IncludeTasks(includeTasks bool) ApiRestartConnectorRequest + func (r ApiRestartConnectorRequest) OnlyFailed(onlyFailed bool) ApiRestartConnectorRequest + type ApiRestartTaskRequest struct + ApiService *DefaultAPIService + func (r ApiRestartTaskRequest) Execute() (*http.Response, error) + type ApiResumeConnectorRequest struct + ApiService *DefaultAPIService + func (r ApiResumeConnectorRequest) Execute() (*http.Response, error) + type ApiServerInfoRequest struct + ApiService *DefaultAPIService + func (r ApiServerInfoRequest) Execute() (*ServerInfo, *http.Response, error) + type ApiSetLevelRequest struct + ApiService *DefaultAPIService + func (r ApiSetLevelRequest) Execute() (*http.Response, error) + func (r ApiSetLevelRequest) RequestBody(requestBody map[string]string) ApiSetLevelRequest + func (r ApiSetLevelRequest) Scope(scope string) ApiSetLevelRequest + type ApiStopConnectorRequest struct + ApiService *DefaultAPIService + func (r ApiStopConnectorRequest) Execute() (*http.Response, error) + type ApiValidateConfigsRequest struct + ApiService *DefaultAPIService + func (r ApiValidateConfigsRequest) Execute() (*ConfigInfos, *http.Response, error) + func (r ApiValidateConfigsRequest) RequestBody(requestBody map[string]string) ApiValidateConfigsRequest + type BasicAuth struct + Password string + UserName string + type ConfigInfo struct + Definition *ConfigKeyInfo + Value *ConfigValueInfo + func NewConfigInfo() *ConfigInfo + func NewConfigInfoWithDefaults() *ConfigInfo + func (o *ConfigInfo) GetDefinition() ConfigKeyInfo + func (o *ConfigInfo) GetDefinitionOk() (*ConfigKeyInfo, bool) + func (o *ConfigInfo) GetValue() ConfigValueInfo + func (o *ConfigInfo) GetValueOk() (*ConfigValueInfo, bool) + func (o *ConfigInfo) HasDefinition() bool + func (o *ConfigInfo) HasValue() bool + func (o *ConfigInfo) SetDefinition(v ConfigKeyInfo) + func (o *ConfigInfo) SetValue(v ConfigValueInfo) + func (o ConfigInfo) MarshalJSON() ([]byte, error) + func (o ConfigInfo) ToMap() (map[string]interface{}, error) + type ConfigInfos struct + Configs []ConfigInfo + ErrorCount *int32 + Groups []string + Name *string + func NewConfigInfos() *ConfigInfos + func NewConfigInfosWithDefaults() *ConfigInfos + func (o *ConfigInfos) GetConfigs() []ConfigInfo + func (o *ConfigInfos) GetConfigsOk() ([]ConfigInfo, bool) + func (o *ConfigInfos) GetErrorCount() int32 + func (o *ConfigInfos) GetErrorCountOk() (*int32, bool) + func (o *ConfigInfos) GetGroups() []string + func (o *ConfigInfos) GetGroupsOk() ([]string, bool) + func (o *ConfigInfos) GetName() string + func (o *ConfigInfos) GetNameOk() (*string, bool) + func (o *ConfigInfos) HasConfigs() bool + func (o *ConfigInfos) HasErrorCount() bool + func (o *ConfigInfos) HasGroups() bool + func (o *ConfigInfos) HasName() bool + func (o *ConfigInfos) SetConfigs(v []ConfigInfo) + func (o *ConfigInfos) SetErrorCount(v int32) + func (o *ConfigInfos) SetGroups(v []string) + func (o *ConfigInfos) SetName(v string) + func (o ConfigInfos) MarshalJSON() ([]byte, error) + func (o ConfigInfos) ToMap() (map[string]interface{}, error) + type ConfigKeyInfo struct + DefaultValue *string + Dependents []string + DisplayName *string + Documentation *string + Group *string + Importance *string + Name *string + Order *int32 + OrderInGroup *int32 + Required *bool + Type *string + Width *string + func NewConfigKeyInfo() *ConfigKeyInfo + func NewConfigKeyInfoWithDefaults() *ConfigKeyInfo + func (o *ConfigKeyInfo) GetDefaultValue() string + func (o *ConfigKeyInfo) GetDefaultValueOk() (*string, bool) + func (o *ConfigKeyInfo) GetDependents() []string + func (o *ConfigKeyInfo) GetDependentsOk() ([]string, bool) + func (o *ConfigKeyInfo) GetDisplayName() string + func (o *ConfigKeyInfo) GetDisplayNameOk() (*string, bool) + func (o *ConfigKeyInfo) GetDocumentation() string + func (o *ConfigKeyInfo) GetDocumentationOk() (*string, bool) + func (o *ConfigKeyInfo) GetGroup() string + func (o *ConfigKeyInfo) GetGroupOk() (*string, bool) + func (o *ConfigKeyInfo) GetImportance() string + func (o *ConfigKeyInfo) GetImportanceOk() (*string, bool) + func (o *ConfigKeyInfo) GetName() string + func (o *ConfigKeyInfo) GetNameOk() (*string, bool) + func (o *ConfigKeyInfo) GetOrder() int32 + func (o *ConfigKeyInfo) GetOrderInGroup() int32 + func (o *ConfigKeyInfo) GetOrderInGroupOk() (*int32, bool) + func (o *ConfigKeyInfo) GetOrderOk() (*int32, bool) + func (o *ConfigKeyInfo) GetRequired() bool + func (o *ConfigKeyInfo) GetRequiredOk() (*bool, bool) + func (o *ConfigKeyInfo) GetType() string + func (o *ConfigKeyInfo) GetTypeOk() (*string, bool) + func (o *ConfigKeyInfo) GetWidth() string + func (o *ConfigKeyInfo) GetWidthOk() (*string, bool) + func (o *ConfigKeyInfo) HasDefaultValue() bool + func (o *ConfigKeyInfo) HasDependents() bool + func (o *ConfigKeyInfo) HasDisplayName() bool + func (o *ConfigKeyInfo) HasDocumentation() bool + func (o *ConfigKeyInfo) HasGroup() bool + func (o *ConfigKeyInfo) HasImportance() bool + func (o *ConfigKeyInfo) HasName() bool + func (o *ConfigKeyInfo) HasOrder() bool + func (o *ConfigKeyInfo) HasOrderInGroup() bool + func (o *ConfigKeyInfo) HasRequired() bool + func (o *ConfigKeyInfo) HasType() bool + func (o *ConfigKeyInfo) HasWidth() bool + func (o *ConfigKeyInfo) SetDefaultValue(v string) + func (o *ConfigKeyInfo) SetDependents(v []string) + func (o *ConfigKeyInfo) SetDisplayName(v string) + func (o *ConfigKeyInfo) SetDocumentation(v string) + func (o *ConfigKeyInfo) SetGroup(v string) + func (o *ConfigKeyInfo) SetImportance(v string) + func (o *ConfigKeyInfo) SetName(v string) + func (o *ConfigKeyInfo) SetOrder(v int32) + func (o *ConfigKeyInfo) SetOrderInGroup(v int32) + func (o *ConfigKeyInfo) SetRequired(v bool) + func (o *ConfigKeyInfo) SetType(v string) + func (o *ConfigKeyInfo) SetWidth(v string) + func (o ConfigKeyInfo) MarshalJSON() ([]byte, error) + func (o ConfigKeyInfo) ToMap() (map[string]interface{}, error) + type ConfigValueInfo struct + Errors []string + Name *string + RecommendedValues []string + Value *string + Visible *bool + func NewConfigValueInfo() *ConfigValueInfo + func NewConfigValueInfoWithDefaults() *ConfigValueInfo + func (o *ConfigValueInfo) GetErrors() []string + func (o *ConfigValueInfo) GetErrorsOk() ([]string, bool) + func (o *ConfigValueInfo) GetName() string + func (o *ConfigValueInfo) GetNameOk() (*string, bool) + func (o *ConfigValueInfo) GetRecommendedValues() []string + func (o *ConfigValueInfo) GetRecommendedValuesOk() ([]string, bool) + func (o *ConfigValueInfo) GetValue() string + func (o *ConfigValueInfo) GetValueOk() (*string, bool) + func (o *ConfigValueInfo) GetVisible() bool + func (o *ConfigValueInfo) GetVisibleOk() (*bool, bool) + func (o *ConfigValueInfo) HasErrors() bool + func (o *ConfigValueInfo) HasName() bool + func (o *ConfigValueInfo) HasRecommendedValues() bool + func (o *ConfigValueInfo) HasValue() bool + func (o *ConfigValueInfo) HasVisible() bool + func (o *ConfigValueInfo) SetErrors(v []string) + func (o *ConfigValueInfo) SetName(v string) + func (o *ConfigValueInfo) SetRecommendedValues(v []string) + func (o *ConfigValueInfo) SetValue(v string) + func (o *ConfigValueInfo) SetVisible(v bool) + func (o ConfigValueInfo) MarshalJSON() ([]byte, error) + func (o ConfigValueInfo) ToMap() (map[string]interface{}, error) + 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 ConnectorActiveTopicsValue struct + Topics []string + func NewConnectorActiveTopicsValue() *ConnectorActiveTopicsValue + func NewConnectorActiveTopicsValueWithDefaults() *ConnectorActiveTopicsValue + func (o *ConnectorActiveTopicsValue) GetTopics() []string + func (o *ConnectorActiveTopicsValue) GetTopicsOk() ([]string, bool) + func (o *ConnectorActiveTopicsValue) HasTopics() bool + func (o *ConnectorActiveTopicsValue) SetTopics(v []string) + func (o ConnectorActiveTopicsValue) MarshalJSON() ([]byte, error) + func (o ConnectorActiveTopicsValue) ToMap() (map[string]interface{}, error) + type ConnectorInfo struct + Config *map[string]string + Name *string + Tasks []ConnectorTaskId + Type *string + func NewConnectorInfo() *ConnectorInfo + func NewConnectorInfoWithDefaults() *ConnectorInfo + func (o *ConnectorInfo) GetConfig() map[string]string + func (o *ConnectorInfo) GetConfigOk() (*map[string]string, bool) + func (o *ConnectorInfo) GetName() string + func (o *ConnectorInfo) GetNameOk() (*string, bool) + func (o *ConnectorInfo) GetTasks() []ConnectorTaskId + func (o *ConnectorInfo) GetTasksOk() ([]ConnectorTaskId, bool) + func (o *ConnectorInfo) GetType() string + func (o *ConnectorInfo) GetTypeOk() (*string, bool) + func (o *ConnectorInfo) HasConfig() bool + func (o *ConnectorInfo) HasName() bool + func (o *ConnectorInfo) HasTasks() bool + func (o *ConnectorInfo) HasType() bool + func (o *ConnectorInfo) SetConfig(v map[string]string) + func (o *ConnectorInfo) SetName(v string) + func (o *ConnectorInfo) SetTasks(v []ConnectorTaskId) + func (o *ConnectorInfo) SetType(v string) + func (o ConnectorInfo) MarshalJSON() ([]byte, error) + func (o ConnectorInfo) ToMap() (map[string]interface{}, error) + type ConnectorOffset struct + Offset map[string]map[string]interface{} + Partition map[string]map[string]interface{} + func NewConnectorOffset() *ConnectorOffset + func NewConnectorOffsetWithDefaults() *ConnectorOffset + func (o *ConnectorOffset) GetOffset() map[string]map[string]interface{} + func (o *ConnectorOffset) GetOffsetOk() (map[string]map[string]interface{}, bool) + func (o *ConnectorOffset) GetPartition() map[string]map[string]interface{} + func (o *ConnectorOffset) GetPartitionOk() (map[string]map[string]interface{}, bool) + func (o *ConnectorOffset) HasOffset() bool + func (o *ConnectorOffset) HasPartition() bool + func (o *ConnectorOffset) SetOffset(v map[string]map[string]interface{}) + func (o *ConnectorOffset) SetPartition(v map[string]map[string]interface{}) + func (o ConnectorOffset) MarshalJSON() ([]byte, error) + func (o ConnectorOffset) ToMap() (map[string]interface{}, error) + type ConnectorOffsets struct + Offsets []ConnectorOffset + func NewConnectorOffsets() *ConnectorOffsets + func NewConnectorOffsetsWithDefaults() *ConnectorOffsets + func (o *ConnectorOffsets) GetOffsets() []ConnectorOffset + func (o *ConnectorOffsets) GetOffsetsOk() ([]ConnectorOffset, bool) + func (o *ConnectorOffsets) HasOffsets() bool + func (o *ConnectorOffsets) SetOffsets(v []ConnectorOffset) + func (o ConnectorOffsets) MarshalJSON() ([]byte, error) + func (o ConnectorOffsets) ToMap() (map[string]interface{}, error) + type ConnectorState struct + Msg *string + State *string + Trace *string + WorkerId *string + func NewConnectorState() *ConnectorState + func NewConnectorStateWithDefaults() *ConnectorState + func (o *ConnectorState) GetMsg() string + func (o *ConnectorState) GetMsgOk() (*string, bool) + func (o *ConnectorState) GetState() string + func (o *ConnectorState) GetStateOk() (*string, bool) + func (o *ConnectorState) GetTrace() string + func (o *ConnectorState) GetTraceOk() (*string, bool) + func (o *ConnectorState) GetWorkerId() string + func (o *ConnectorState) GetWorkerIdOk() (*string, bool) + func (o *ConnectorState) HasMsg() bool + func (o *ConnectorState) HasState() bool + func (o *ConnectorState) HasTrace() bool + func (o *ConnectorState) HasWorkerId() bool + func (o *ConnectorState) SetMsg(v string) + func (o *ConnectorState) SetState(v string) + func (o *ConnectorState) SetTrace(v string) + func (o *ConnectorState) SetWorkerId(v string) + func (o ConnectorState) MarshalJSON() ([]byte, error) + func (o ConnectorState) ToMap() (map[string]interface{}, error) + type ConnectorStateInfo struct + Connector *ConnectorState + Name *string + Tasks []TaskState + Type *string + func NewConnectorStateInfo() *ConnectorStateInfo + func NewConnectorStateInfoWithDefaults() *ConnectorStateInfo + func (o *ConnectorStateInfo) GetConnector() ConnectorState + func (o *ConnectorStateInfo) GetConnectorOk() (*ConnectorState, bool) + func (o *ConnectorStateInfo) GetName() string + func (o *ConnectorStateInfo) GetNameOk() (*string, bool) + func (o *ConnectorStateInfo) GetTasks() []TaskState + func (o *ConnectorStateInfo) GetTasksOk() ([]TaskState, bool) + func (o *ConnectorStateInfo) GetType() string + func (o *ConnectorStateInfo) GetTypeOk() (*string, bool) + func (o *ConnectorStateInfo) HasConnector() bool + func (o *ConnectorStateInfo) HasName() bool + func (o *ConnectorStateInfo) HasTasks() bool + func (o *ConnectorStateInfo) HasType() bool + func (o *ConnectorStateInfo) SetConnector(v ConnectorState) + func (o *ConnectorStateInfo) SetName(v string) + func (o *ConnectorStateInfo) SetTasks(v []TaskState) + func (o *ConnectorStateInfo) SetType(v string) + func (o ConnectorStateInfo) MarshalJSON() ([]byte, error) + func (o ConnectorStateInfo) ToMap() (map[string]interface{}, error) + type ConnectorTaskId struct + Connector *string + Task *int32 + func NewConnectorTaskId() *ConnectorTaskId + func NewConnectorTaskIdWithDefaults() *ConnectorTaskId + func (o *ConnectorTaskId) GetConnector() string + func (o *ConnectorTaskId) GetConnectorOk() (*string, bool) + func (o *ConnectorTaskId) GetTask() int32 + func (o *ConnectorTaskId) GetTaskOk() (*int32, bool) + func (o *ConnectorTaskId) HasConnector() bool + func (o *ConnectorTaskId) HasTask() bool + func (o *ConnectorTaskId) SetConnector(v string) + func (o *ConnectorTaskId) SetTask(v int32) + func (o ConnectorTaskId) MarshalJSON() ([]byte, error) + func (o ConnectorTaskId) ToMap() (map[string]interface{}, error) + type CreateConnectorRequest struct + Config *map[string]string + InitialState *string + Name *string + func NewCreateConnectorRequest() *CreateConnectorRequest + func NewCreateConnectorRequestWithDefaults() *CreateConnectorRequest + func (o *CreateConnectorRequest) GetConfig() map[string]string + func (o *CreateConnectorRequest) GetConfigOk() (*map[string]string, bool) + func (o *CreateConnectorRequest) GetInitialState() string + func (o *CreateConnectorRequest) GetInitialStateOk() (*string, bool) + func (o *CreateConnectorRequest) GetName() string + func (o *CreateConnectorRequest) GetNameOk() (*string, bool) + func (o *CreateConnectorRequest) HasConfig() bool + func (o *CreateConnectorRequest) HasInitialState() bool + func (o *CreateConnectorRequest) HasName() bool + func (o *CreateConnectorRequest) SetConfig(v map[string]string) + func (o *CreateConnectorRequest) SetInitialState(v string) + func (o *CreateConnectorRequest) SetName(v string) + func (o CreateConnectorRequest) MarshalJSON() ([]byte, error) + func (o CreateConnectorRequest) ToMap() (map[string]interface{}, error) + type DefaultAPIService service + func (a *DefaultAPIService) AlterConnectorOffsets(ctx context.Context, connector string) ApiAlterConnectorOffsetsRequest + func (a *DefaultAPIService) AlterConnectorOffsetsExecute(r ApiAlterConnectorOffsetsRequest) (*http.Response, error) + func (a *DefaultAPIService) CreateConnector(ctx context.Context) ApiCreateConnectorRequest + func (a *DefaultAPIService) CreateConnectorExecute(r ApiCreateConnectorRequest) (*ConnectorInfo, *http.Response, error) + func (a *DefaultAPIService) DestroyConnector(ctx context.Context, connector string) ApiDestroyConnectorRequest + func (a *DefaultAPIService) DestroyConnectorExecute(r ApiDestroyConnectorRequest) (*http.Response, error) + func (a *DefaultAPIService) GetConnector(ctx context.Context, connector string) ApiGetConnectorRequest + func (a *DefaultAPIService) GetConnectorActiveTopics(ctx context.Context, connector string) ApiGetConnectorActiveTopicsRequest + func (a *DefaultAPIService) GetConnectorActiveTopicsExecute(r ApiGetConnectorActiveTopicsRequest) (*map[string]ConnectorActiveTopicsValue, *http.Response, error) + func (a *DefaultAPIService) GetConnectorConfig(ctx context.Context, connector string) ApiGetConnectorConfigRequest + func (a *DefaultAPIService) GetConnectorConfigDef(ctx context.Context, pluginName string) ApiGetConnectorConfigDefRequest + func (a *DefaultAPIService) GetConnectorConfigDefExecute(r ApiGetConnectorConfigDefRequest) ([]ConfigKeyInfo, *http.Response, error) + func (a *DefaultAPIService) GetConnectorConfigExecute(r ApiGetConnectorConfigRequest) (map[string]string, *http.Response, error) + func (a *DefaultAPIService) GetConnectorExecute(r ApiGetConnectorRequest) (*ConnectorInfo, *http.Response, error) + func (a *DefaultAPIService) GetConnectorStatus(ctx context.Context, connector string) ApiGetConnectorStatusRequest + func (a *DefaultAPIService) GetConnectorStatusExecute(r ApiGetConnectorStatusRequest) (*ConnectorStateInfo, *http.Response, error) + func (a *DefaultAPIService) GetLogger(ctx context.Context, logger string) ApiGetLoggerRequest + func (a *DefaultAPIService) GetLoggerExecute(r ApiGetLoggerRequest) (*http.Response, error) + func (a *DefaultAPIService) GetOffsets(ctx context.Context, connector string) ApiGetOffsetsRequest + func (a *DefaultAPIService) GetOffsetsExecute(r ApiGetOffsetsRequest) (*ConnectorOffsets, *http.Response, error) + func (a *DefaultAPIService) GetTaskConfigs(ctx context.Context, connector string) ApiGetTaskConfigsRequest + func (a *DefaultAPIService) GetTaskConfigsExecute(r ApiGetTaskConfigsRequest) ([]TaskInfo, *http.Response, error) + func (a *DefaultAPIService) GetTaskStatus(ctx context.Context, connector string, task int32) ApiGetTaskStatusRequest + func (a *DefaultAPIService) GetTaskStatusExecute(r ApiGetTaskStatusRequest) (*TaskState, *http.Response, error) + func (a *DefaultAPIService) GetTasksConfig(ctx context.Context, connector string) ApiGetTasksConfigRequest + func (a *DefaultAPIService) GetTasksConfigExecute(r ApiGetTasksConfigRequest) (*map[string]map[string]string, *http.Response, error) + func (a *DefaultAPIService) HealthCheck(ctx context.Context) ApiHealthCheckRequest + func (a *DefaultAPIService) HealthCheckExecute(r ApiHealthCheckRequest) (*http.Response, error) + func (a *DefaultAPIService) ListConnectorPlugins(ctx context.Context) ApiListConnectorPluginsRequest + func (a *DefaultAPIService) ListConnectorPluginsExecute(r ApiListConnectorPluginsRequest) ([]PluginInfo, *http.Response, error) + func (a *DefaultAPIService) ListConnectors(ctx context.Context) ApiListConnectorsRequest + func (a *DefaultAPIService) ListConnectorsExecute(r ApiListConnectorsRequest) ([]string, *http.Response, error) + func (a *DefaultAPIService) ListLoggers(ctx context.Context) ApiListLoggersRequest + func (a *DefaultAPIService) ListLoggersExecute(r ApiListLoggersRequest) (*http.Response, error) + func (a *DefaultAPIService) PatchConnectorConfig(ctx context.Context, connector string) ApiPatchConnectorConfigRequest + func (a *DefaultAPIService) PatchConnectorConfigExecute(r ApiPatchConnectorConfigRequest) (*http.Response, error) + func (a *DefaultAPIService) PauseConnector(ctx context.Context, connector string) ApiPauseConnectorRequest + func (a *DefaultAPIService) PauseConnectorExecute(r ApiPauseConnectorRequest) (*http.Response, error) + func (a *DefaultAPIService) PutConnectorConfig(ctx context.Context, connector string) ApiPutConnectorConfigRequest + func (a *DefaultAPIService) PutConnectorConfigExecute(r ApiPutConnectorConfigRequest) (*ConnectorInfo, *http.Response, error) + func (a *DefaultAPIService) ResetConnectorActiveTopics(ctx context.Context, connector string) ApiResetConnectorActiveTopicsRequest + func (a *DefaultAPIService) ResetConnectorActiveTopicsExecute(r ApiResetConnectorActiveTopicsRequest) (*http.Response, error) + func (a *DefaultAPIService) ResetConnectorOffsets(ctx context.Context, connector string) ApiResetConnectorOffsetsRequest + func (a *DefaultAPIService) ResetConnectorOffsetsExecute(r ApiResetConnectorOffsetsRequest) (*http.Response, error) + func (a *DefaultAPIService) RestartConnector(ctx context.Context, connector string) ApiRestartConnectorRequest + func (a *DefaultAPIService) RestartConnectorExecute(r ApiRestartConnectorRequest) (*http.Response, error) + func (a *DefaultAPIService) RestartTask(ctx context.Context, connector string, task int32) ApiRestartTaskRequest + func (a *DefaultAPIService) RestartTaskExecute(r ApiRestartTaskRequest) (*http.Response, error) + func (a *DefaultAPIService) ResumeConnector(ctx context.Context, connector string) ApiResumeConnectorRequest + func (a *DefaultAPIService) ResumeConnectorExecute(r ApiResumeConnectorRequest) (*http.Response, error) + func (a *DefaultAPIService) ServerInfo(ctx context.Context) ApiServerInfoRequest + func (a *DefaultAPIService) ServerInfoExecute(r ApiServerInfoRequest) (*ServerInfo, *http.Response, error) + func (a *DefaultAPIService) SetLevel(ctx context.Context, logger string) ApiSetLevelRequest + func (a *DefaultAPIService) SetLevelExecute(r ApiSetLevelRequest) (*http.Response, error) + func (a *DefaultAPIService) StopConnector(ctx context.Context, connector string) ApiStopConnectorRequest + func (a *DefaultAPIService) StopConnectorExecute(r ApiStopConnectorRequest) (*http.Response, error) + func (a *DefaultAPIService) ValidateConfigs(ctx context.Context, pluginName string) ApiValidateConfigsRequest + func (a *DefaultAPIService) ValidateConfigsExecute(r ApiValidateConfigsRequest) (*ConfigInfos, *http.Response, 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 NullableConfigInfo struct + func NewNullableConfigInfo(val *ConfigInfo) *NullableConfigInfo + func (v *NullableConfigInfo) Set(val *ConfigInfo) + func (v *NullableConfigInfo) UnmarshalJSON(src []byte) error + func (v *NullableConfigInfo) Unset() + func (v NullableConfigInfo) Get() *ConfigInfo + func (v NullableConfigInfo) IsSet() bool + func (v NullableConfigInfo) MarshalJSON() ([]byte, error) + type NullableConfigInfos struct + func NewNullableConfigInfos(val *ConfigInfos) *NullableConfigInfos + func (v *NullableConfigInfos) Set(val *ConfigInfos) + func (v *NullableConfigInfos) UnmarshalJSON(src []byte) error + func (v *NullableConfigInfos) Unset() + func (v NullableConfigInfos) Get() *ConfigInfos + func (v NullableConfigInfos) IsSet() bool + func (v NullableConfigInfos) MarshalJSON() ([]byte, error) + type NullableConfigKeyInfo struct + func NewNullableConfigKeyInfo(val *ConfigKeyInfo) *NullableConfigKeyInfo + func (v *NullableConfigKeyInfo) Set(val *ConfigKeyInfo) + func (v *NullableConfigKeyInfo) UnmarshalJSON(src []byte) error + func (v *NullableConfigKeyInfo) Unset() + func (v NullableConfigKeyInfo) Get() *ConfigKeyInfo + func (v NullableConfigKeyInfo) IsSet() bool + func (v NullableConfigKeyInfo) MarshalJSON() ([]byte, error) + type NullableConfigValueInfo struct + func NewNullableConfigValueInfo(val *ConfigValueInfo) *NullableConfigValueInfo + func (v *NullableConfigValueInfo) Set(val *ConfigValueInfo) + func (v *NullableConfigValueInfo) UnmarshalJSON(src []byte) error + func (v *NullableConfigValueInfo) Unset() + func (v NullableConfigValueInfo) Get() *ConfigValueInfo + func (v NullableConfigValueInfo) IsSet() bool + func (v NullableConfigValueInfo) MarshalJSON() ([]byte, error) + type NullableConnectorActiveTopicsValue struct + func NewNullableConnectorActiveTopicsValue(val *ConnectorActiveTopicsValue) *NullableConnectorActiveTopicsValue + func (v *NullableConnectorActiveTopicsValue) Set(val *ConnectorActiveTopicsValue) + func (v *NullableConnectorActiveTopicsValue) UnmarshalJSON(src []byte) error + func (v *NullableConnectorActiveTopicsValue) Unset() + func (v NullableConnectorActiveTopicsValue) Get() *ConnectorActiveTopicsValue + func (v NullableConnectorActiveTopicsValue) IsSet() bool + func (v NullableConnectorActiveTopicsValue) MarshalJSON() ([]byte, error) + type NullableConnectorInfo struct + func NewNullableConnectorInfo(val *ConnectorInfo) *NullableConnectorInfo + func (v *NullableConnectorInfo) Set(val *ConnectorInfo) + func (v *NullableConnectorInfo) UnmarshalJSON(src []byte) error + func (v *NullableConnectorInfo) Unset() + func (v NullableConnectorInfo) Get() *ConnectorInfo + func (v NullableConnectorInfo) IsSet() bool + func (v NullableConnectorInfo) MarshalJSON() ([]byte, error) + type NullableConnectorOffset struct + func NewNullableConnectorOffset(val *ConnectorOffset) *NullableConnectorOffset + func (v *NullableConnectorOffset) Set(val *ConnectorOffset) + func (v *NullableConnectorOffset) UnmarshalJSON(src []byte) error + func (v *NullableConnectorOffset) Unset() + func (v NullableConnectorOffset) Get() *ConnectorOffset + func (v NullableConnectorOffset) IsSet() bool + func (v NullableConnectorOffset) MarshalJSON() ([]byte, error) + type NullableConnectorOffsets struct + func NewNullableConnectorOffsets(val *ConnectorOffsets) *NullableConnectorOffsets + func (v *NullableConnectorOffsets) Set(val *ConnectorOffsets) + func (v *NullableConnectorOffsets) UnmarshalJSON(src []byte) error + func (v *NullableConnectorOffsets) Unset() + func (v NullableConnectorOffsets) Get() *ConnectorOffsets + func (v NullableConnectorOffsets) IsSet() bool + func (v NullableConnectorOffsets) MarshalJSON() ([]byte, error) + type NullableConnectorState struct + func NewNullableConnectorState(val *ConnectorState) *NullableConnectorState + func (v *NullableConnectorState) Set(val *ConnectorState) + func (v *NullableConnectorState) UnmarshalJSON(src []byte) error + func (v *NullableConnectorState) Unset() + func (v NullableConnectorState) Get() *ConnectorState + func (v NullableConnectorState) IsSet() bool + func (v NullableConnectorState) MarshalJSON() ([]byte, error) + type NullableConnectorStateInfo struct + func NewNullableConnectorStateInfo(val *ConnectorStateInfo) *NullableConnectorStateInfo + func (v *NullableConnectorStateInfo) Set(val *ConnectorStateInfo) + func (v *NullableConnectorStateInfo) UnmarshalJSON(src []byte) error + func (v *NullableConnectorStateInfo) Unset() + func (v NullableConnectorStateInfo) Get() *ConnectorStateInfo + func (v NullableConnectorStateInfo) IsSet() bool + func (v NullableConnectorStateInfo) MarshalJSON() ([]byte, error) + type NullableConnectorTaskId struct + func NewNullableConnectorTaskId(val *ConnectorTaskId) *NullableConnectorTaskId + func (v *NullableConnectorTaskId) Set(val *ConnectorTaskId) + func (v *NullableConnectorTaskId) UnmarshalJSON(src []byte) error + func (v *NullableConnectorTaskId) Unset() + func (v NullableConnectorTaskId) Get() *ConnectorTaskId + func (v NullableConnectorTaskId) IsSet() bool + func (v NullableConnectorTaskId) MarshalJSON() ([]byte, error) + type NullableCreateConnectorRequest struct + func NewNullableCreateConnectorRequest(val *CreateConnectorRequest) *NullableCreateConnectorRequest + func (v *NullableCreateConnectorRequest) Set(val *CreateConnectorRequest) + func (v *NullableCreateConnectorRequest) UnmarshalJSON(src []byte) error + func (v *NullableCreateConnectorRequest) Unset() + func (v NullableCreateConnectorRequest) Get() *CreateConnectorRequest + func (v NullableCreateConnectorRequest) IsSet() bool + func (v NullableCreateConnectorRequest) 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 NullablePluginInfo struct + func NewNullablePluginInfo(val *PluginInfo) *NullablePluginInfo + func (v *NullablePluginInfo) Set(val *PluginInfo) + func (v *NullablePluginInfo) UnmarshalJSON(src []byte) error + func (v *NullablePluginInfo) Unset() + func (v NullablePluginInfo) Get() *PluginInfo + func (v NullablePluginInfo) IsSet() bool + func (v NullablePluginInfo) MarshalJSON() ([]byte, error) + type NullableServerInfo struct + func NewNullableServerInfo(val *ServerInfo) *NullableServerInfo + func (v *NullableServerInfo) Set(val *ServerInfo) + func (v *NullableServerInfo) UnmarshalJSON(src []byte) error + func (v *NullableServerInfo) Unset() + func (v NullableServerInfo) Get() *ServerInfo + func (v NullableServerInfo) IsSet() bool + func (v NullableServerInfo) 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 NullableTaskInfo struct + func NewNullableTaskInfo(val *TaskInfo) *NullableTaskInfo + func (v *NullableTaskInfo) Set(val *TaskInfo) + func (v *NullableTaskInfo) UnmarshalJSON(src []byte) error + func (v *NullableTaskInfo) Unset() + func (v NullableTaskInfo) Get() *TaskInfo + func (v NullableTaskInfo) IsSet() bool + func (v NullableTaskInfo) MarshalJSON() ([]byte, error) + type NullableTaskState struct + func NewNullableTaskState(val *TaskState) *NullableTaskState + func (v *NullableTaskState) Set(val *TaskState) + func (v *NullableTaskState) UnmarshalJSON(src []byte) error + func (v *NullableTaskState) Unset() + func (v NullableTaskState) Get() *TaskState + func (v NullableTaskState) IsSet() bool + func (v NullableTaskState) 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 PluginInfo struct + Class *string + Type *string + Version *string + func NewPluginInfo() *PluginInfo + func NewPluginInfoWithDefaults() *PluginInfo + func (o *PluginInfo) GetClass() string + func (o *PluginInfo) GetClassOk() (*string, bool) + func (o *PluginInfo) GetType() string + func (o *PluginInfo) GetTypeOk() (*string, bool) + func (o *PluginInfo) GetVersion() string + func (o *PluginInfo) GetVersionOk() (*string, bool) + func (o *PluginInfo) HasClass() bool + func (o *PluginInfo) HasType() bool + func (o *PluginInfo) HasVersion() bool + func (o *PluginInfo) SetClass(v string) + func (o *PluginInfo) SetType(v string) + func (o *PluginInfo) SetVersion(v string) + func (o PluginInfo) MarshalJSON() ([]byte, error) + func (o PluginInfo) 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 ServerInfo struct + Commit *string + KafkaClusterId *string + Version *string + func NewServerInfo() *ServerInfo + func NewServerInfoWithDefaults() *ServerInfo + func (o *ServerInfo) GetCommit() string + func (o *ServerInfo) GetCommitOk() (*string, bool) + func (o *ServerInfo) GetKafkaClusterId() string + func (o *ServerInfo) GetKafkaClusterIdOk() (*string, bool) + func (o *ServerInfo) GetVersion() string + func (o *ServerInfo) GetVersionOk() (*string, bool) + func (o *ServerInfo) HasCommit() bool + func (o *ServerInfo) HasKafkaClusterId() bool + func (o *ServerInfo) HasVersion() bool + func (o *ServerInfo) SetCommit(v string) + func (o *ServerInfo) SetKafkaClusterId(v string) + func (o *ServerInfo) SetVersion(v string) + func (o ServerInfo) MarshalJSON() ([]byte, error) + func (o ServerInfo) ToMap() (map[string]interface{}, error) + type ServerVariable struct + DefaultValue string + Description string + EnumValues []string + type TaskInfo struct + Config *map[string]string + Id *ConnectorTaskId + func NewTaskInfo() *TaskInfo + func NewTaskInfoWithDefaults() *TaskInfo + func (o *TaskInfo) GetConfig() map[string]string + func (o *TaskInfo) GetConfigOk() (*map[string]string, bool) + func (o *TaskInfo) GetId() ConnectorTaskId + func (o *TaskInfo) GetIdOk() (*ConnectorTaskId, bool) + func (o *TaskInfo) HasConfig() bool + func (o *TaskInfo) HasId() bool + func (o *TaskInfo) SetConfig(v map[string]string) + func (o *TaskInfo) SetId(v ConnectorTaskId) + func (o TaskInfo) MarshalJSON() ([]byte, error) + func (o TaskInfo) ToMap() (map[string]interface{}, error) + type TaskState struct + Id *int32 + Msg *string + State *string + Trace *string + WorkerId *string + func NewTaskState() *TaskState + func NewTaskStateWithDefaults() *TaskState + func (o *TaskState) GetId() int32 + func (o *TaskState) GetIdOk() (*int32, bool) + func (o *TaskState) GetMsg() string + func (o *TaskState) GetMsgOk() (*string, bool) + func (o *TaskState) GetState() string + func (o *TaskState) GetStateOk() (*string, bool) + func (o *TaskState) GetTrace() string + func (o *TaskState) GetTraceOk() (*string, bool) + func (o *TaskState) GetWorkerId() string + func (o *TaskState) GetWorkerIdOk() (*string, bool) + func (o *TaskState) HasId() bool + func (o *TaskState) HasMsg() bool + func (o *TaskState) HasState() bool + func (o *TaskState) HasTrace() bool + func (o *TaskState) HasWorkerId() bool + func (o *TaskState) SetId(v int32) + func (o *TaskState) SetMsg(v string) + func (o *TaskState) SetState(v string) + func (o *TaskState) SetTrace(v string) + func (o *TaskState) SetWorkerId(v string) + func (o TaskState) MarshalJSON() ([]byte, error) + func (o TaskState) ToMap() (map[string]interface{}, error)
Go to main page