openapi

Documentation

Overview

Package openapi provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen version v1.9.0 DO NOT EDIT.

Package openapi provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen version v1.9.0 DO NOT EDIT.

Package openapi provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen version v1.9.0 DO NOT EDIT.

Index

• func GetSwagger() (swagger *openapi3.T, err error)
• func GetSwaggerHTML(config *SwaggerConfig) (html string, err error)
• func NewDMAPIConvertTaskRequest(server string, body DMAPIConvertTaskJSONRequestBody) (*http.Request, error)
• func NewDMAPIConvertTaskRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPICreateSourceRequest(server string, body DMAPICreateSourceJSONRequestBody) (*http.Request, error)
• func NewDMAPICreateSourceRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPICreateTaskRequest(server string, body DMAPICreateTaskJSONRequestBody) (*http.Request, error)
• func NewDMAPICreateTaskRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPICreateTaskTemplateRequest(server string, body DMAPICreateTaskTemplateJSONRequestBody) (*http.Request, error)
• func NewDMAPICreateTaskTemplateRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPIDeleteSourceRequest(server string, sourceName string, params *DMAPIDeleteSourceParams) (*http.Request, error)
• func NewDMAPIDeleteTableStructureRequest(server string, taskName string, sourceName string, schemaName string, ...) (*http.Request, error)
• func NewDMAPIDeleteTaskRequest(server string, taskName string, params *DMAPIDeleteTaskParams) (*http.Request, error)
• func NewDMAPIDeleteTaskTemplateRequest(server string, taskName string) (*http.Request, error)
• func NewDMAPIDisableRelayRequest(server string, sourceName string, body DMAPIDisableRelayJSONRequestBody) (*http.Request, error)
• func NewDMAPIDisableRelayRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPIDisableSourceRequest(server string, sourceName string) (*http.Request, error)
• func NewDMAPIEnableRelayRequest(server string, sourceName string, body DMAPIEnableRelayJSONRequestBody) (*http.Request, error)
• func NewDMAPIEnableRelayRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPIEnableSourceRequest(server string, sourceName string) (*http.Request, error)
• func NewDMAPIGetClusterInfoRequest(server string) (*http.Request, error)
• func NewDMAPIGetClusterMasterListRequest(server string) (*http.Request, error)
• func NewDMAPIGetClusterWorkerListRequest(server string) (*http.Request, error)
• func NewDMAPIGetSchemaListByTaskAndSourceRequest(server string, taskName string, sourceName string) (*http.Request, error)
• func NewDMAPIGetSourceListRequest(server string, params *DMAPIGetSourceListParams) (*http.Request, error)
• func NewDMAPIGetSourceRequest(server string, sourceName string, params *DMAPIGetSourceParams) (*http.Request, error)
• func NewDMAPIGetSourceSchemaListRequest(server string, sourceName string) (*http.Request, error)
• func NewDMAPIGetSourceStatusRequest(server string, sourceName string) (*http.Request, error)
• func NewDMAPIGetSourceTableListRequest(server string, sourceName string, schemaName string) (*http.Request, error)
• func NewDMAPIGetTableListByTaskAndSourceRequest(server string, taskName string, sourceName string, schemaName string) (*http.Request, error)
• func NewDMAPIGetTableStructureRequest(server string, taskName string, sourceName string, schemaName string, ...) (*http.Request, error)
• func NewDMAPIGetTaskListRequest(server string, params *DMAPIGetTaskListParams) (*http.Request, error)
• func NewDMAPIGetTaskMigrateTargetsRequest(server string, taskName string, sourceName string, ...) (*http.Request, error)
• func NewDMAPIGetTaskRequest(server string, taskName string, params *DMAPIGetTaskParams) (*http.Request, error)
• func NewDMAPIGetTaskStatusRequest(server string, taskName string, params *DMAPIGetTaskStatusParams) (*http.Request, error)
• func NewDMAPIGetTaskTemplateListRequest(server string) (*http.Request, error)
• func NewDMAPIGetTaskTemplateRequest(server string, taskName string) (*http.Request, error)
• func NewDMAPIImportTaskTemplateRequest(server string, body DMAPIImportTaskTemplateJSONRequestBody) (*http.Request, error)
• func NewDMAPIImportTaskTemplateRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPIOfflineMasterNodeRequest(server string, masterName string) (*http.Request, error)
• func NewDMAPIOfflineWorkerNodeRequest(server string, workerName string) (*http.Request, error)
• func NewDMAPIOperateTableStructureRequest(server string, taskName string, sourceName string, schemaName string, ...) (*http.Request, error)
• func NewDMAPIOperateTableStructureRequestWithBody(server string, taskName string, sourceName string, schemaName string, ...) (*http.Request, error)
• func NewDMAPIPurgeRelayRequest(server string, sourceName string, body DMAPIPurgeRelayJSONRequestBody) (*http.Request, error)
• func NewDMAPIPurgeRelayRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPIStartTaskRequest(server string, taskName string, body DMAPIStartTaskJSONRequestBody) (*http.Request, error)
• func NewDMAPIStartTaskRequestWithBody(server string, taskName string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPIStopTaskRequest(server string, taskName string, body DMAPIStopTaskJSONRequestBody) (*http.Request, error)
• func NewDMAPIStopTaskRequestWithBody(server string, taskName string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPITransferSourceRequest(server string, sourceName string, body DMAPITransferSourceJSONRequestBody) (*http.Request, error)
• func NewDMAPITransferSourceRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPIUpdateClusterInfoRequest(server string, body DMAPIUpdateClusterInfoJSONRequestBody) (*http.Request, error)
• func NewDMAPIUpdateClusterInfoRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPIUpdateSourceRequest(server string, sourceName string, body DMAPIUpdateSourceJSONRequestBody) (*http.Request, error)
• func NewDMAPIUpdateSourceRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPIUpdateTaskRequest(server string, taskName string, body DMAPIUpdateTaskJSONRequestBody) (*http.Request, error)
• func NewDMAPIUpdateTaskRequestWithBody(server string, taskName string, contentType string, body io.Reader) (*http.Request, error)
• func NewDMAPUpdateTaskTemplateRequest(server string, taskName string) (*http.Request, error)
• func NewGetDocHTMLRequest(server string) (*http.Request, error)
• func NewGetDocJSONRequest(server string) (*http.Request, error)
• func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error)
• func RegisterHandlers(router *gin.Engine, si ServerInterface) *gin.Engine
• func RegisterHandlersWithOptions(router *gin.Engine, si ServerInterface, options GinServerOptions) *gin.Engine
• func ZapLogger(log *zap.Logger) gin.HandlerFunc
• type AlertManagerTopology
• type Client
  • func NewClient(server string, opts ...ClientOption) (*Client, error)
  • func (c *Client) DMAPIConvertTask(ctx context.Context, body DMAPIConvertTaskJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIConvertTaskWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPICreateSource(ctx context.Context, body DMAPICreateSourceJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPICreateSourceWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPICreateTask(ctx context.Context, body DMAPICreateTaskJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPICreateTaskTemplate(ctx context.Context, body DMAPICreateTaskTemplateJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPICreateTaskTemplateWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPICreateTaskWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPIDeleteSource(ctx context.Context, sourceName string, params *DMAPIDeleteSourceParams, ...) (*http.Response, error)
  • func (c *Client) DMAPIDeleteTableStructure(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*http.Response, error)
  • func (c *Client) DMAPIDeleteTask(ctx context.Context, taskName string, params *DMAPIDeleteTaskParams, ...) (*http.Response, error)
  • func (c *Client) DMAPIDeleteTaskTemplate(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIDisableRelay(ctx context.Context, sourceName string, body DMAPIDisableRelayJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIDisableRelayWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPIDisableSource(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIEnableRelay(ctx context.Context, sourceName string, body DMAPIEnableRelayJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIEnableRelayWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPIEnableSource(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIGetClusterInfo(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIGetClusterMasterList(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIGetClusterWorkerList(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIGetSchemaListByTaskAndSource(ctx context.Context, taskName string, sourceName string, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetSource(ctx context.Context, sourceName string, params *DMAPIGetSourceParams, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetSourceList(ctx context.Context, params *DMAPIGetSourceListParams, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetSourceSchemaList(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIGetSourceStatus(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIGetSourceTableList(ctx context.Context, sourceName string, schemaName string, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetTableListByTaskAndSource(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetTableStructure(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetTask(ctx context.Context, taskName string, params *DMAPIGetTaskParams, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetTaskList(ctx context.Context, params *DMAPIGetTaskListParams, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetTaskMigrateTargets(ctx context.Context, taskName string, sourceName string, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetTaskStatus(ctx context.Context, taskName string, params *DMAPIGetTaskStatusParams, ...) (*http.Response, error)
  • func (c *Client) DMAPIGetTaskTemplate(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIGetTaskTemplateList(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIImportTaskTemplate(ctx context.Context, body DMAPIImportTaskTemplateJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIImportTaskTemplateWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPIOfflineMasterNode(ctx context.Context, masterName string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIOfflineWorkerNode(ctx context.Context, workerName string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DMAPIOperateTableStructure(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*http.Response, error)
  • func (c *Client) DMAPIOperateTableStructureWithBody(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*http.Response, error)
  • func (c *Client) DMAPIPurgeRelay(ctx context.Context, sourceName string, body DMAPIPurgeRelayJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIPurgeRelayWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPIStartTask(ctx context.Context, taskName string, body DMAPIStartTaskJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIStartTaskWithBody(ctx context.Context, taskName string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPIStopTask(ctx context.Context, taskName string, body DMAPIStopTaskJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIStopTaskWithBody(ctx context.Context, taskName string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPITransferSource(ctx context.Context, sourceName string, ...) (*http.Response, error)
  • func (c *Client) DMAPITransferSourceWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPIUpdateClusterInfo(ctx context.Context, body DMAPIUpdateClusterInfoJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIUpdateClusterInfoWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPIUpdateSource(ctx context.Context, sourceName string, body DMAPIUpdateSourceJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIUpdateSourceWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPIUpdateTask(ctx context.Context, taskName string, body DMAPIUpdateTaskJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) DMAPIUpdateTaskWithBody(ctx context.Context, taskName string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DMAPUpdateTaskTemplate(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) GetDocHTML(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) GetDocJSON(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
• type ClientInterface
• type ClientOption
  • func WithBaseURL(baseURL string) ClientOption
  • func WithHTTPClient(doer HttpRequestDoer) ClientOption
  • func WithRequestEditorFn(fn RequestEditorFn) ClientOption
• type ClientWithResponses
  • func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)
  • func (c *ClientWithResponses) DMAPIConvertTaskWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*DMAPIConvertTaskResponse, error)
  • func (c *ClientWithResponses) DMAPIConvertTaskWithResponse(ctx context.Context, body DMAPIConvertTaskJSONRequestBody, ...) (*DMAPIConvertTaskResponse, error)
  • func (c *ClientWithResponses) DMAPICreateSourceWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*DMAPICreateSourceResponse, error)
  • func (c *ClientWithResponses) DMAPICreateSourceWithResponse(ctx context.Context, body DMAPICreateSourceJSONRequestBody, ...) (*DMAPICreateSourceResponse, error)
  • func (c *ClientWithResponses) DMAPICreateTaskTemplateWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*DMAPICreateTaskTemplateResponse, error)
  • func (c *ClientWithResponses) DMAPICreateTaskTemplateWithResponse(ctx context.Context, body DMAPICreateTaskTemplateJSONRequestBody, ...) (*DMAPICreateTaskTemplateResponse, error)
  • func (c *ClientWithResponses) DMAPICreateTaskWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*DMAPICreateTaskResponse, error)
  • func (c *ClientWithResponses) DMAPICreateTaskWithResponse(ctx context.Context, body DMAPICreateTaskJSONRequestBody, ...) (*DMAPICreateTaskResponse, error)
  • func (c *ClientWithResponses) DMAPIDeleteSourceWithResponse(ctx context.Context, sourceName string, params *DMAPIDeleteSourceParams, ...) (*DMAPIDeleteSourceResponse, error)
  • func (c *ClientWithResponses) DMAPIDeleteTableStructureWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*DMAPIDeleteTableStructureResponse, error)
  • func (c *ClientWithResponses) DMAPIDeleteTaskTemplateWithResponse(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*DMAPIDeleteTaskTemplateResponse, error)
  • func (c *ClientWithResponses) DMAPIDeleteTaskWithResponse(ctx context.Context, taskName string, params *DMAPIDeleteTaskParams, ...) (*DMAPIDeleteTaskResponse, error)
  • func (c *ClientWithResponses) DMAPIDisableRelayWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*DMAPIDisableRelayResponse, error)
  • func (c *ClientWithResponses) DMAPIDisableRelayWithResponse(ctx context.Context, sourceName string, body DMAPIDisableRelayJSONRequestBody, ...) (*DMAPIDisableRelayResponse, error)
  • func (c *ClientWithResponses) DMAPIDisableSourceWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIDisableSourceResponse, error)
  • func (c *ClientWithResponses) DMAPIEnableRelayWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*DMAPIEnableRelayResponse, error)
  • func (c *ClientWithResponses) DMAPIEnableRelayWithResponse(ctx context.Context, sourceName string, body DMAPIEnableRelayJSONRequestBody, ...) (*DMAPIEnableRelayResponse, error)
  • func (c *ClientWithResponses) DMAPIEnableSourceWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIEnableSourceResponse, error)
  • func (c *ClientWithResponses) DMAPIGetClusterInfoWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetClusterInfoResponse, error)
  • func (c *ClientWithResponses) DMAPIGetClusterMasterListWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetClusterMasterListResponse, error)
  • func (c *ClientWithResponses) DMAPIGetClusterWorkerListWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetClusterWorkerListResponse, error)
  • func (c *ClientWithResponses) DMAPIGetSchemaListByTaskAndSourceWithResponse(ctx context.Context, taskName string, sourceName string, ...) (*DMAPIGetSchemaListByTaskAndSourceResponse, error)
  • func (c *ClientWithResponses) DMAPIGetSourceListWithResponse(ctx context.Context, params *DMAPIGetSourceListParams, ...) (*DMAPIGetSourceListResponse, error)
  • func (c *ClientWithResponses) DMAPIGetSourceSchemaListWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIGetSourceSchemaListResponse, error)
  • func (c *ClientWithResponses) DMAPIGetSourceStatusWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIGetSourceStatusResponse, error)
  • func (c *ClientWithResponses) DMAPIGetSourceTableListWithResponse(ctx context.Context, sourceName string, schemaName string, ...) (*DMAPIGetSourceTableListResponse, error)
  • func (c *ClientWithResponses) DMAPIGetSourceWithResponse(ctx context.Context, sourceName string, params *DMAPIGetSourceParams, ...) (*DMAPIGetSourceResponse, error)
  • func (c *ClientWithResponses) DMAPIGetTableListByTaskAndSourceWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*DMAPIGetTableListByTaskAndSourceResponse, error)
  • func (c *ClientWithResponses) DMAPIGetTableStructureWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*DMAPIGetTableStructureResponse, error)
  • func (c *ClientWithResponses) DMAPIGetTaskListWithResponse(ctx context.Context, params *DMAPIGetTaskListParams, ...) (*DMAPIGetTaskListResponse, error)
  • func (c *ClientWithResponses) DMAPIGetTaskMigrateTargetsWithResponse(ctx context.Context, taskName string, sourceName string, ...) (*DMAPIGetTaskMigrateTargetsResponse, error)
  • func (c *ClientWithResponses) DMAPIGetTaskStatusWithResponse(ctx context.Context, taskName string, params *DMAPIGetTaskStatusParams, ...) (*DMAPIGetTaskStatusResponse, error)
  • func (c *ClientWithResponses) DMAPIGetTaskTemplateListWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetTaskTemplateListResponse, error)
  • func (c *ClientWithResponses) DMAPIGetTaskTemplateWithResponse(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*DMAPIGetTaskTemplateResponse, error)
  • func (c *ClientWithResponses) DMAPIGetTaskWithResponse(ctx context.Context, taskName string, params *DMAPIGetTaskParams, ...) (*DMAPIGetTaskResponse, error)
  • func (c *ClientWithResponses) DMAPIImportTaskTemplateWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*DMAPIImportTaskTemplateResponse, error)
  • func (c *ClientWithResponses) DMAPIImportTaskTemplateWithResponse(ctx context.Context, body DMAPIImportTaskTemplateJSONRequestBody, ...) (*DMAPIImportTaskTemplateResponse, error)
  • func (c *ClientWithResponses) DMAPIOfflineMasterNodeWithResponse(ctx context.Context, masterName string, reqEditors ...RequestEditorFn) (*DMAPIOfflineMasterNodeResponse, error)
  • func (c *ClientWithResponses) DMAPIOfflineWorkerNodeWithResponse(ctx context.Context, workerName string, reqEditors ...RequestEditorFn) (*DMAPIOfflineWorkerNodeResponse, error)
  • func (c *ClientWithResponses) DMAPIOperateTableStructureWithBodyWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*DMAPIOperateTableStructureResponse, error)
  • func (c *ClientWithResponses) DMAPIOperateTableStructureWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, ...) (*DMAPIOperateTableStructureResponse, error)
  • func (c *ClientWithResponses) DMAPIPurgeRelayWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*DMAPIPurgeRelayResponse, error)
  • func (c *ClientWithResponses) DMAPIPurgeRelayWithResponse(ctx context.Context, sourceName string, body DMAPIPurgeRelayJSONRequestBody, ...) (*DMAPIPurgeRelayResponse, error)
  • func (c *ClientWithResponses) DMAPIStartTaskWithBodyWithResponse(ctx context.Context, taskName string, contentType string, body io.Reader, ...) (*DMAPIStartTaskResponse, error)
  • func (c *ClientWithResponses) DMAPIStartTaskWithResponse(ctx context.Context, taskName string, body DMAPIStartTaskJSONRequestBody, ...) (*DMAPIStartTaskResponse, error)
  • func (c *ClientWithResponses) DMAPIStopTaskWithBodyWithResponse(ctx context.Context, taskName string, contentType string, body io.Reader, ...) (*DMAPIStopTaskResponse, error)
  • func (c *ClientWithResponses) DMAPIStopTaskWithResponse(ctx context.Context, taskName string, body DMAPIStopTaskJSONRequestBody, ...) (*DMAPIStopTaskResponse, error)
  • func (c *ClientWithResponses) DMAPITransferSourceWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*DMAPITransferSourceResponse, error)
  • func (c *ClientWithResponses) DMAPITransferSourceWithResponse(ctx context.Context, sourceName string, ...) (*DMAPITransferSourceResponse, error)
  • func (c *ClientWithResponses) DMAPIUpdateClusterInfoWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*DMAPIUpdateClusterInfoResponse, error)
  • func (c *ClientWithResponses) DMAPIUpdateClusterInfoWithResponse(ctx context.Context, body DMAPIUpdateClusterInfoJSONRequestBody, ...) (*DMAPIUpdateClusterInfoResponse, error)
  • func (c *ClientWithResponses) DMAPIUpdateSourceWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, ...) (*DMAPIUpdateSourceResponse, error)
  • func (c *ClientWithResponses) DMAPIUpdateSourceWithResponse(ctx context.Context, sourceName string, body DMAPIUpdateSourceJSONRequestBody, ...) (*DMAPIUpdateSourceResponse, error)
  • func (c *ClientWithResponses) DMAPIUpdateTaskWithBodyWithResponse(ctx context.Context, taskName string, contentType string, body io.Reader, ...) (*DMAPIUpdateTaskResponse, error)
  • func (c *ClientWithResponses) DMAPIUpdateTaskWithResponse(ctx context.Context, taskName string, body DMAPIUpdateTaskJSONRequestBody, ...) (*DMAPIUpdateTaskResponse, error)
  • func (c *ClientWithResponses) DMAPUpdateTaskTemplateWithResponse(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*DMAPUpdateTaskTemplateResponse, error)
  • func (c *ClientWithResponses) GetDocHTMLWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetDocHTMLResponse, error)
  • func (c *ClientWithResponses) GetDocJSONWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetDocJSONResponse, error)
• type ClientWithResponsesInterface
• type ClusterMaster
• type ClusterTopology
• type ClusterWorker
• type ConverterTaskRequest
• type ConverterTaskResponse
• type CreateSourceRequest
• type CreateTaskRequest
• type DMAPIConvertTaskJSONBody
• type DMAPIConvertTaskJSONRequestBody
• type DMAPIConvertTaskResponse
  • func ParseDMAPIConvertTaskResponse(rsp *http.Response) (*DMAPIConvertTaskResponse, error)
  • func (r DMAPIConvertTaskResponse) Status() string
  • func (r DMAPIConvertTaskResponse) StatusCode() int
• type DMAPICreateSourceJSONBody
• type DMAPICreateSourceJSONRequestBody
• type DMAPICreateSourceResponse
  • func ParseDMAPICreateSourceResponse(rsp *http.Response) (*DMAPICreateSourceResponse, error)
  • func (r DMAPICreateSourceResponse) Status() string
  • func (r DMAPICreateSourceResponse) StatusCode() int
• type DMAPICreateTaskJSONBody
• type DMAPICreateTaskJSONRequestBody
• type DMAPICreateTaskResponse
  • func ParseDMAPICreateTaskResponse(rsp *http.Response) (*DMAPICreateTaskResponse, error)
  • func (r DMAPICreateTaskResponse) Status() string
  • func (r DMAPICreateTaskResponse) StatusCode() int
• type DMAPICreateTaskTemplateJSONBody
• type DMAPICreateTaskTemplateJSONRequestBody
• type DMAPICreateTaskTemplateResponse
  • func ParseDMAPICreateTaskTemplateResponse(rsp *http.Response) (*DMAPICreateTaskTemplateResponse, error)
  • func (r DMAPICreateTaskTemplateResponse) Status() string
  • func (r DMAPICreateTaskTemplateResponse) StatusCode() int
• type DMAPIDeleteSourceParams
• type DMAPIDeleteSourceResponse
  • func ParseDMAPIDeleteSourceResponse(rsp *http.Response) (*DMAPIDeleteSourceResponse, error)
  • func (r DMAPIDeleteSourceResponse) Status() string
  • func (r DMAPIDeleteSourceResponse) StatusCode() int
• type DMAPIDeleteTableStructureResponse
  • func ParseDMAPIDeleteTableStructureResponse(rsp *http.Response) (*DMAPIDeleteTableStructureResponse, error)
  • func (r DMAPIDeleteTableStructureResponse) Status() string
  • func (r DMAPIDeleteTableStructureResponse) StatusCode() int
• type DMAPIDeleteTaskParams
• type DMAPIDeleteTaskResponse
  • func ParseDMAPIDeleteTaskResponse(rsp *http.Response) (*DMAPIDeleteTaskResponse, error)
  • func (r DMAPIDeleteTaskResponse) Status() string
  • func (r DMAPIDeleteTaskResponse) StatusCode() int
• type DMAPIDeleteTaskTemplateResponse
  • func ParseDMAPIDeleteTaskTemplateResponse(rsp *http.Response) (*DMAPIDeleteTaskTemplateResponse, error)
  • func (r DMAPIDeleteTaskTemplateResponse) Status() string
  • func (r DMAPIDeleteTaskTemplateResponse) StatusCode() int
• type DMAPIDisableRelayJSONBody
• type DMAPIDisableRelayJSONRequestBody
• type DMAPIDisableRelayResponse
  • func ParseDMAPIDisableRelayResponse(rsp *http.Response) (*DMAPIDisableRelayResponse, error)
  • func (r DMAPIDisableRelayResponse) Status() string
  • func (r DMAPIDisableRelayResponse) StatusCode() int
• type DMAPIDisableSourceResponse
  • func ParseDMAPIDisableSourceResponse(rsp *http.Response) (*DMAPIDisableSourceResponse, error)
  • func (r DMAPIDisableSourceResponse) Status() string
  • func (r DMAPIDisableSourceResponse) StatusCode() int
• type DMAPIEnableRelayJSONBody
• type DMAPIEnableRelayJSONRequestBody
• type DMAPIEnableRelayResponse
  • func ParseDMAPIEnableRelayResponse(rsp *http.Response) (*DMAPIEnableRelayResponse, error)
  • func (r DMAPIEnableRelayResponse) Status() string
  • func (r DMAPIEnableRelayResponse) StatusCode() int
• type DMAPIEnableSourceResponse
  • func ParseDMAPIEnableSourceResponse(rsp *http.Response) (*DMAPIEnableSourceResponse, error)
  • func (r DMAPIEnableSourceResponse) Status() string
  • func (r DMAPIEnableSourceResponse) StatusCode() int
• type DMAPIGetClusterInfoResponse
  • func ParseDMAPIGetClusterInfoResponse(rsp *http.Response) (*DMAPIGetClusterInfoResponse, error)
  • func (r DMAPIGetClusterInfoResponse) Status() string
  • func (r DMAPIGetClusterInfoResponse) StatusCode() int
• type DMAPIGetClusterMasterListResponse
  • func ParseDMAPIGetClusterMasterListResponse(rsp *http.Response) (*DMAPIGetClusterMasterListResponse, error)
  • func (r DMAPIGetClusterMasterListResponse) Status() string
  • func (r DMAPIGetClusterMasterListResponse) StatusCode() int
• type DMAPIGetClusterWorkerListResponse
  • func ParseDMAPIGetClusterWorkerListResponse(rsp *http.Response) (*DMAPIGetClusterWorkerListResponse, error)
  • func (r DMAPIGetClusterWorkerListResponse) Status() string
  • func (r DMAPIGetClusterWorkerListResponse) StatusCode() int
• type DMAPIGetSchemaListByTaskAndSourceResponse
  • func ParseDMAPIGetSchemaListByTaskAndSourceResponse(rsp *http.Response) (*DMAPIGetSchemaListByTaskAndSourceResponse, error)
  • func (r DMAPIGetSchemaListByTaskAndSourceResponse) Status() string
  • func (r DMAPIGetSchemaListByTaskAndSourceResponse) StatusCode() int
• type DMAPIGetSourceListParams
• type DMAPIGetSourceListResponse
  • func ParseDMAPIGetSourceListResponse(rsp *http.Response) (*DMAPIGetSourceListResponse, error)
  • func (r DMAPIGetSourceListResponse) Status() string
  • func (r DMAPIGetSourceListResponse) StatusCode() int
• type DMAPIGetSourceParams
• type DMAPIGetSourceResponse
  • func ParseDMAPIGetSourceResponse(rsp *http.Response) (*DMAPIGetSourceResponse, error)
  • func (r DMAPIGetSourceResponse) Status() string
  • func (r DMAPIGetSourceResponse) StatusCode() int
• type DMAPIGetSourceSchemaListResponse
  • func ParseDMAPIGetSourceSchemaListResponse(rsp *http.Response) (*DMAPIGetSourceSchemaListResponse, error)
  • func (r DMAPIGetSourceSchemaListResponse) Status() string
  • func (r DMAPIGetSourceSchemaListResponse) StatusCode() int
• type DMAPIGetSourceStatusResponse
  • func ParseDMAPIGetSourceStatusResponse(rsp *http.Response) (*DMAPIGetSourceStatusResponse, error)
  • func (r DMAPIGetSourceStatusResponse) Status() string
  • func (r DMAPIGetSourceStatusResponse) StatusCode() int
• type DMAPIGetSourceTableListResponse
  • func ParseDMAPIGetSourceTableListResponse(rsp *http.Response) (*DMAPIGetSourceTableListResponse, error)
  • func (r DMAPIGetSourceTableListResponse) Status() string
  • func (r DMAPIGetSourceTableListResponse) StatusCode() int
• type DMAPIGetTableListByTaskAndSourceResponse
  • func ParseDMAPIGetTableListByTaskAndSourceResponse(rsp *http.Response) (*DMAPIGetTableListByTaskAndSourceResponse, error)
  • func (r DMAPIGetTableListByTaskAndSourceResponse) Status() string
  • func (r DMAPIGetTableListByTaskAndSourceResponse) StatusCode() int
• type DMAPIGetTableStructureResponse
  • func ParseDMAPIGetTableStructureResponse(rsp *http.Response) (*DMAPIGetTableStructureResponse, error)
  • func (r DMAPIGetTableStructureResponse) Status() string
  • func (r DMAPIGetTableStructureResponse) StatusCode() int
• type DMAPIGetTaskListParams
• type DMAPIGetTaskListResponse
  • func ParseDMAPIGetTaskListResponse(rsp *http.Response) (*DMAPIGetTaskListResponse, error)
  • func (r DMAPIGetTaskListResponse) Status() string
  • func (r DMAPIGetTaskListResponse) StatusCode() int
• type DMAPIGetTaskMigrateTargetsParams
• type DMAPIGetTaskMigrateTargetsResponse
  • func ParseDMAPIGetTaskMigrateTargetsResponse(rsp *http.Response) (*DMAPIGetTaskMigrateTargetsResponse, error)
  • func (r DMAPIGetTaskMigrateTargetsResponse) Status() string
  • func (r DMAPIGetTaskMigrateTargetsResponse) StatusCode() int
• type DMAPIGetTaskParams
• type DMAPIGetTaskResponse
  • func ParseDMAPIGetTaskResponse(rsp *http.Response) (*DMAPIGetTaskResponse, error)
  • func (r DMAPIGetTaskResponse) Status() string
  • func (r DMAPIGetTaskResponse) StatusCode() int
• type DMAPIGetTaskStatusParams
• type DMAPIGetTaskStatusResponse
  • func ParseDMAPIGetTaskStatusResponse(rsp *http.Response) (*DMAPIGetTaskStatusResponse, error)
  • func (r DMAPIGetTaskStatusResponse) Status() string
  • func (r DMAPIGetTaskStatusResponse) StatusCode() int
• type DMAPIGetTaskTemplateListResponse
  • func ParseDMAPIGetTaskTemplateListResponse(rsp *http.Response) (*DMAPIGetTaskTemplateListResponse, error)
  • func (r DMAPIGetTaskTemplateListResponse) Status() string
  • func (r DMAPIGetTaskTemplateListResponse) StatusCode() int
• type DMAPIGetTaskTemplateResponse
  • func ParseDMAPIGetTaskTemplateResponse(rsp *http.Response) (*DMAPIGetTaskTemplateResponse, error)
  • func (r DMAPIGetTaskTemplateResponse) Status() string
  • func (r DMAPIGetTaskTemplateResponse) StatusCode() int
• type DMAPIImportTaskTemplateJSONBody
• type DMAPIImportTaskTemplateJSONRequestBody
• type DMAPIImportTaskTemplateResponse
  • func ParseDMAPIImportTaskTemplateResponse(rsp *http.Response) (*DMAPIImportTaskTemplateResponse, error)
  • func (r DMAPIImportTaskTemplateResponse) Status() string
  • func (r DMAPIImportTaskTemplateResponse) StatusCode() int
• type DMAPIOfflineMasterNodeResponse
  • func ParseDMAPIOfflineMasterNodeResponse(rsp *http.Response) (*DMAPIOfflineMasterNodeResponse, error)
  • func (r DMAPIOfflineMasterNodeResponse) Status() string
  • func (r DMAPIOfflineMasterNodeResponse) StatusCode() int
• type DMAPIOfflineWorkerNodeResponse
  • func ParseDMAPIOfflineWorkerNodeResponse(rsp *http.Response) (*DMAPIOfflineWorkerNodeResponse, error)
  • func (r DMAPIOfflineWorkerNodeResponse) Status() string
  • func (r DMAPIOfflineWorkerNodeResponse) StatusCode() int
• type DMAPIOperateTableStructureJSONBody
• type DMAPIOperateTableStructureJSONRequestBody
• type DMAPIOperateTableStructureResponse
  • func ParseDMAPIOperateTableStructureResponse(rsp *http.Response) (*DMAPIOperateTableStructureResponse, error)
  • func (r DMAPIOperateTableStructureResponse) Status() string
  • func (r DMAPIOperateTableStructureResponse) StatusCode() int
• type DMAPIPurgeRelayJSONBody
• type DMAPIPurgeRelayJSONRequestBody
• type DMAPIPurgeRelayResponse
  • func ParseDMAPIPurgeRelayResponse(rsp *http.Response) (*DMAPIPurgeRelayResponse, error)
  • func (r DMAPIPurgeRelayResponse) Status() string
  • func (r DMAPIPurgeRelayResponse) StatusCode() int
• type DMAPIStartTaskJSONBody
• type DMAPIStartTaskJSONRequestBody
• type DMAPIStartTaskResponse
  • func ParseDMAPIStartTaskResponse(rsp *http.Response) (*DMAPIStartTaskResponse, error)
  • func (r DMAPIStartTaskResponse) Status() string
  • func (r DMAPIStartTaskResponse) StatusCode() int
• type DMAPIStopTaskJSONBody
• type DMAPIStopTaskJSONRequestBody
• type DMAPIStopTaskResponse
  • func ParseDMAPIStopTaskResponse(rsp *http.Response) (*DMAPIStopTaskResponse, error)
  • func (r DMAPIStopTaskResponse) Status() string
  • func (r DMAPIStopTaskResponse) StatusCode() int
• type DMAPITransferSourceJSONBody
• type DMAPITransferSourceJSONRequestBody
• type DMAPITransferSourceResponse
  • func ParseDMAPITransferSourceResponse(rsp *http.Response) (*DMAPITransferSourceResponse, error)
  • func (r DMAPITransferSourceResponse) Status() string
  • func (r DMAPITransferSourceResponse) StatusCode() int
• type DMAPIUpdateClusterInfoJSONBody
• type DMAPIUpdateClusterInfoJSONRequestBody
• type DMAPIUpdateClusterInfoResponse
  • func ParseDMAPIUpdateClusterInfoResponse(rsp *http.Response) (*DMAPIUpdateClusterInfoResponse, error)
  • func (r DMAPIUpdateClusterInfoResponse) Status() string
  • func (r DMAPIUpdateClusterInfoResponse) StatusCode() int
• type DMAPIUpdateSourceJSONBody
• type DMAPIUpdateSourceJSONRequestBody
• type DMAPIUpdateSourceResponse
  • func ParseDMAPIUpdateSourceResponse(rsp *http.Response) (*DMAPIUpdateSourceResponse, error)
  • func (r DMAPIUpdateSourceResponse) Status() string
  • func (r DMAPIUpdateSourceResponse) StatusCode() int
• type DMAPIUpdateTaskJSONBody
• type DMAPIUpdateTaskJSONRequestBody
• type DMAPIUpdateTaskResponse
  • func ParseDMAPIUpdateTaskResponse(rsp *http.Response) (*DMAPIUpdateTaskResponse, error)
  • func (r DMAPIUpdateTaskResponse) Status() string
  • func (r DMAPIUpdateTaskResponse) StatusCode() int
• type DMAPUpdateTaskTemplateResponse
  • func ParseDMAPUpdateTaskTemplateResponse(rsp *http.Response) (*DMAPUpdateTaskTemplateResponse, error)
  • func (r DMAPUpdateTaskTemplateResponse) Status() string
  • func (r DMAPUpdateTaskTemplateResponse) StatusCode() int
• type DisableRelayRequest
• type DumpStatus
• type EnableRelayRequest
• type ErrorWithMessage
• type GetClusterInfoResponse
• type GetClusterMasterListResponse
• type GetClusterWorkerListResponse
• type GetDocHTMLResponse
  • func ParseGetDocHTMLResponse(rsp *http.Response) (*GetDocHTMLResponse, error)
  • func (r GetDocHTMLResponse) Status() string
  • func (r GetDocHTMLResponse) StatusCode() int
• type GetDocJSONResponse
  • func ParseGetDocJSONResponse(rsp *http.Response) (*GetDocJSONResponse, error)
  • func (r GetDocJSONResponse) Status() string
  • func (r GetDocJSONResponse) StatusCode() int
• type GetSourceListResponse
• type GetSourceStatusResponse
• type GetTaskListResponse
• type GetTaskMigrateTargetsResponse
• type GetTaskStatusResponse
• type GetTaskTableStructureResponse
• type GinServerOptions
• type GrafanaTopology
• type HttpRequestDoer
• type LoadStatus
• type MasterTopology
• type MiddlewareFunc
• type OperateTaskResponse
• type OperateTaskTableStructureRequest
• type PrometheusTopology
• type Purge
• type PurgeRelayRequest
• type RelayConfig
• type RelayStatus
• type RequestEditorFn
• type SchemaNameList
• type Security
• type ServerInterface
• type ServerInterfaceWrapper
  • func (siw *ServerInterfaceWrapper) DMAPIConvertTask(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPICreateSource(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPICreateTask(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPICreateTaskTemplate(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIDeleteSource(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIDeleteTableStructure(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIDeleteTask(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIDeleteTaskTemplate(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIDisableRelay(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIDisableSource(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIEnableRelay(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIEnableSource(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetClusterInfo(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetClusterMasterList(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetClusterWorkerList(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetSchemaListByTaskAndSource(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetSource(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetSourceList(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetSourceSchemaList(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetSourceStatus(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetSourceTableList(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetTableListByTaskAndSource(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetTableStructure(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetTask(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetTaskList(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetTaskMigrateTargets(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetTaskStatus(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetTaskTemplate(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIGetTaskTemplateList(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIImportTaskTemplate(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIOfflineMasterNode(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIOfflineWorkerNode(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIOperateTableStructure(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIPurgeRelay(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIStartTask(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIStopTask(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPITransferSource(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIUpdateClusterInfo(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIUpdateSource(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPIUpdateTask(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) DMAPUpdateTaskTemplate(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) GetDocHTML(c *gin.Context)
  • func (siw *ServerInterfaceWrapper) GetDocJSON(c *gin.Context)
• type ShardingGroup
• type Source
• type SourceNameList
• type SourceStatus
• type StartTaskRequest
• type StopTaskRequest
• type SubTaskStatus
• type SwaggerConfig
  • func NewSwaggerConfig(specJSONPath, swaggerHost string) *SwaggerConfig
• type SyncStatus
• type TableNameList
• type Task
  • func (t *Task) Adjust() error
  • func (t *Task) FromJSON(data []byte) error
  • func (t *Task) ToJSON() ([]byte, error)
• type TaskBinLogFilterRule
• type TaskFullMigrateConf
• type TaskFullMigrateConfAnalyze
• type TaskFullMigrateConfChecksum
• type TaskFullMigrateConfImportMode
• type TaskFullMigrateConfOnDuplicateLogical
• type TaskFullMigrateConfOnDuplicatePhysical
• type TaskIncrMigrateConf
• type TaskMigrateTarget
• type TaskNameList
• type TaskOnDuplicate
• type TaskShardMode
• type TaskSourceConf
• type TaskSourceConfig
• type TaskStage
• type TaskTableMigrateRule
• type TaskTargetDataBase
• type TaskTaskMode
• type TaskTemplateRequest
• type TaskTemplateResponse
• type Task_BinlogFilterRule
  • func (a Task_BinlogFilterRule) Get(fieldName string) (value TaskBinLogFilterRule, found bool)
  • func (a Task_BinlogFilterRule) MarshalJSON() ([]byte, error)
  • func (a *Task_BinlogFilterRule) Set(fieldName string, value TaskBinLogFilterRule)
  • func (a *Task_BinlogFilterRule) UnmarshalJSON(b []byte) error
• type UpdateSourceRequest
• type UpdateTaskRequest
• type WorkerNameList
• type WorkerNameRequest
• type WorkerTopology

Functions

func GetSwagger

func GetSwagger() (swagger *openapi3.T, err error)

GetSwagger returns the Swagger specification corresponding to the generated code in this file. The external references of Swagger specification are resolved. The logic of resolving external references is tightly connected to "import-mapping" feature. Externally referenced files must be embedded in the corresponding golang packages. Urls can be supported but this task was out of the scope.

func GetSwaggerHTML

func GetSwaggerHTML(config *SwaggerConfig) (html string, err error)

GetSwaggerHTML returns the swagger ui html.

func NewDMAPIConvertTaskRequest

func NewDMAPIConvertTaskRequest(server string, body DMAPIConvertTaskJSONRequestBody) (*http.Request, error)

NewDMAPIConvertTaskRequest calls the generic DMAPIConvertTask builder with application/json body

func NewDMAPIConvertTaskRequestWithBody

func NewDMAPIConvertTaskRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIConvertTaskRequestWithBody generates requests for DMAPIConvertTask with any type of body

func NewDMAPICreateSourceRequest

func NewDMAPICreateSourceRequest(server string, body DMAPICreateSourceJSONRequestBody) (*http.Request, error)

NewDMAPICreateSourceRequest calls the generic DMAPICreateSource builder with application/json body

func NewDMAPICreateSourceRequestWithBody

func NewDMAPICreateSourceRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPICreateSourceRequestWithBody generates requests for DMAPICreateSource with any type of body

func NewDMAPICreateTaskRequest

func NewDMAPICreateTaskRequest(server string, body DMAPICreateTaskJSONRequestBody) (*http.Request, error)

NewDMAPICreateTaskRequest calls the generic DMAPICreateTask builder with application/json body

func NewDMAPICreateTaskRequestWithBody

func NewDMAPICreateTaskRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPICreateTaskRequestWithBody generates requests for DMAPICreateTask with any type of body

func NewDMAPICreateTaskTemplateRequest

func NewDMAPICreateTaskTemplateRequest(server string, body DMAPICreateTaskTemplateJSONRequestBody) (*http.Request, error)

NewDMAPICreateTaskTemplateRequest calls the generic DMAPICreateTaskTemplate builder with application/json body

func NewDMAPICreateTaskTemplateRequestWithBody

func NewDMAPICreateTaskTemplateRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPICreateTaskTemplateRequestWithBody generates requests for DMAPICreateTaskTemplate with any type of body

func NewDMAPIDeleteSourceRequest

func NewDMAPIDeleteSourceRequest(server string, sourceName string, params *DMAPIDeleteSourceParams) (*http.Request, error)

NewDMAPIDeleteSourceRequest generates requests for DMAPIDeleteSource

func NewDMAPIDeleteTableStructureRequest

func NewDMAPIDeleteTableStructureRequest(server string, taskName string, sourceName string, schemaName string, tableName string) (*http.Request, error)

NewDMAPIDeleteTableStructureRequest generates requests for DMAPIDeleteTableStructure

func NewDMAPIDeleteTaskRequest

func NewDMAPIDeleteTaskRequest(server string, taskName string, params *DMAPIDeleteTaskParams) (*http.Request, error)

NewDMAPIDeleteTaskRequest generates requests for DMAPIDeleteTask

func NewDMAPIDeleteTaskTemplateRequest

func NewDMAPIDeleteTaskTemplateRequest(server string, taskName string) (*http.Request, error)

NewDMAPIDeleteTaskTemplateRequest generates requests for DMAPIDeleteTaskTemplate

func NewDMAPIDisableRelayRequest

func NewDMAPIDisableRelayRequest(server string, sourceName string, body DMAPIDisableRelayJSONRequestBody) (*http.Request, error)

NewDMAPIDisableRelayRequest calls the generic DMAPIDisableRelay builder with application/json body

func NewDMAPIDisableRelayRequestWithBody

func NewDMAPIDisableRelayRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIDisableRelayRequestWithBody generates requests for DMAPIDisableRelay with any type of body

func NewDMAPIDisableSourceRequest

func NewDMAPIDisableSourceRequest(server string, sourceName string) (*http.Request, error)

NewDMAPIDisableSourceRequest generates requests for DMAPIDisableSource

func NewDMAPIEnableRelayRequest

func NewDMAPIEnableRelayRequest(server string, sourceName string, body DMAPIEnableRelayJSONRequestBody) (*http.Request, error)

NewDMAPIEnableRelayRequest calls the generic DMAPIEnableRelay builder with application/json body

func NewDMAPIEnableRelayRequestWithBody

func NewDMAPIEnableRelayRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIEnableRelayRequestWithBody generates requests for DMAPIEnableRelay with any type of body

func NewDMAPIEnableSourceRequest

func NewDMAPIEnableSourceRequest(server string, sourceName string) (*http.Request, error)

NewDMAPIEnableSourceRequest generates requests for DMAPIEnableSource

func NewDMAPIGetClusterInfoRequest

func NewDMAPIGetClusterInfoRequest(server string) (*http.Request, error)

NewDMAPIGetClusterInfoRequest generates requests for DMAPIGetClusterInfo

func NewDMAPIGetClusterMasterListRequest

func NewDMAPIGetClusterMasterListRequest(server string) (*http.Request, error)

NewDMAPIGetClusterMasterListRequest generates requests for DMAPIGetClusterMasterList

func NewDMAPIGetClusterWorkerListRequest

func NewDMAPIGetClusterWorkerListRequest(server string) (*http.Request, error)

NewDMAPIGetClusterWorkerListRequest generates requests for DMAPIGetClusterWorkerList

func NewDMAPIGetSchemaListByTaskAndSourceRequest

func NewDMAPIGetSchemaListByTaskAndSourceRequest(server string, taskName string, sourceName string) (*http.Request, error)

NewDMAPIGetSchemaListByTaskAndSourceRequest generates requests for DMAPIGetSchemaListByTaskAndSource

func NewDMAPIGetSourceListRequest

func NewDMAPIGetSourceListRequest(server string, params *DMAPIGetSourceListParams) (*http.Request, error)

NewDMAPIGetSourceListRequest generates requests for DMAPIGetSourceList

func NewDMAPIGetSourceRequest

func NewDMAPIGetSourceRequest(server string, sourceName string, params *DMAPIGetSourceParams) (*http.Request, error)

NewDMAPIGetSourceRequest generates requests for DMAPIGetSource

func NewDMAPIGetSourceSchemaListRequest

func NewDMAPIGetSourceSchemaListRequest(server string, sourceName string) (*http.Request, error)

NewDMAPIGetSourceSchemaListRequest generates requests for DMAPIGetSourceSchemaList

func NewDMAPIGetSourceStatusRequest

func NewDMAPIGetSourceStatusRequest(server string, sourceName string) (*http.Request, error)

NewDMAPIGetSourceStatusRequest generates requests for DMAPIGetSourceStatus

func NewDMAPIGetSourceTableListRequest

func NewDMAPIGetSourceTableListRequest(server string, sourceName string, schemaName string) (*http.Request, error)

NewDMAPIGetSourceTableListRequest generates requests for DMAPIGetSourceTableList

func NewDMAPIGetTableListByTaskAndSourceRequest

func NewDMAPIGetTableListByTaskAndSourceRequest(server string, taskName string, sourceName string, schemaName string) (*http.Request, error)

NewDMAPIGetTableListByTaskAndSourceRequest generates requests for DMAPIGetTableListByTaskAndSource

func NewDMAPIGetTableStructureRequest

func NewDMAPIGetTableStructureRequest(server string, taskName string, sourceName string, schemaName string, tableName string) (*http.Request, error)

NewDMAPIGetTableStructureRequest generates requests for DMAPIGetTableStructure

func NewDMAPIGetTaskListRequest

func NewDMAPIGetTaskListRequest(server string, params *DMAPIGetTaskListParams) (*http.Request, error)

NewDMAPIGetTaskListRequest generates requests for DMAPIGetTaskList

func NewDMAPIGetTaskMigrateTargetsRequest

func NewDMAPIGetTaskMigrateTargetsRequest(server string, taskName string, sourceName string, params *DMAPIGetTaskMigrateTargetsParams) (*http.Request, error)

NewDMAPIGetTaskMigrateTargetsRequest generates requests for DMAPIGetTaskMigrateTargets

func NewDMAPIGetTaskRequest

func NewDMAPIGetTaskRequest(server string, taskName string, params *DMAPIGetTaskParams) (*http.Request, error)

NewDMAPIGetTaskRequest generates requests for DMAPIGetTask

func NewDMAPIGetTaskStatusRequest

func NewDMAPIGetTaskStatusRequest(server string, taskName string, params *DMAPIGetTaskStatusParams) (*http.Request, error)

NewDMAPIGetTaskStatusRequest generates requests for DMAPIGetTaskStatus

func NewDMAPIGetTaskTemplateListRequest

func NewDMAPIGetTaskTemplateListRequest(server string) (*http.Request, error)

NewDMAPIGetTaskTemplateListRequest generates requests for DMAPIGetTaskTemplateList

func NewDMAPIGetTaskTemplateRequest

func NewDMAPIGetTaskTemplateRequest(server string, taskName string) (*http.Request, error)

NewDMAPIGetTaskTemplateRequest generates requests for DMAPIGetTaskTemplate

func NewDMAPIImportTaskTemplateRequest

func NewDMAPIImportTaskTemplateRequest(server string, body DMAPIImportTaskTemplateJSONRequestBody) (*http.Request, error)

NewDMAPIImportTaskTemplateRequest calls the generic DMAPIImportTaskTemplate builder with application/json body

func NewDMAPIImportTaskTemplateRequestWithBody

func NewDMAPIImportTaskTemplateRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIImportTaskTemplateRequestWithBody generates requests for DMAPIImportTaskTemplate with any type of body

func NewDMAPIOfflineMasterNodeRequest

func NewDMAPIOfflineMasterNodeRequest(server string, masterName string) (*http.Request, error)

NewDMAPIOfflineMasterNodeRequest generates requests for DMAPIOfflineMasterNode

func NewDMAPIOfflineWorkerNodeRequest

func NewDMAPIOfflineWorkerNodeRequest(server string, workerName string) (*http.Request, error)

NewDMAPIOfflineWorkerNodeRequest generates requests for DMAPIOfflineWorkerNode

func NewDMAPIOperateTableStructureRequest

func NewDMAPIOperateTableStructureRequest(server string, taskName string, sourceName string, schemaName string, tableName string, body DMAPIOperateTableStructureJSONRequestBody) (*http.Request, error)

NewDMAPIOperateTableStructureRequest calls the generic DMAPIOperateTableStructure builder with application/json body

func NewDMAPIOperateTableStructureRequestWithBody

func NewDMAPIOperateTableStructureRequestWithBody(server string, taskName string, sourceName string, schemaName string, tableName string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIOperateTableStructureRequestWithBody generates requests for DMAPIOperateTableStructure with any type of body

func NewDMAPIPurgeRelayRequest

func NewDMAPIPurgeRelayRequest(server string, sourceName string, body DMAPIPurgeRelayJSONRequestBody) (*http.Request, error)

NewDMAPIPurgeRelayRequest calls the generic DMAPIPurgeRelay builder with application/json body

func NewDMAPIPurgeRelayRequestWithBody

func NewDMAPIPurgeRelayRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIPurgeRelayRequestWithBody generates requests for DMAPIPurgeRelay with any type of body

func NewDMAPIStartTaskRequest

func NewDMAPIStartTaskRequest(server string, taskName string, body DMAPIStartTaskJSONRequestBody) (*http.Request, error)

NewDMAPIStartTaskRequest calls the generic DMAPIStartTask builder with application/json body

func NewDMAPIStartTaskRequestWithBody

func NewDMAPIStartTaskRequestWithBody(server string, taskName string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIStartTaskRequestWithBody generates requests for DMAPIStartTask with any type of body

func NewDMAPIStopTaskRequest

func NewDMAPIStopTaskRequest(server string, taskName string, body DMAPIStopTaskJSONRequestBody) (*http.Request, error)

NewDMAPIStopTaskRequest calls the generic DMAPIStopTask builder with application/json body

func NewDMAPIStopTaskRequestWithBody

func NewDMAPIStopTaskRequestWithBody(server string, taskName string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIStopTaskRequestWithBody generates requests for DMAPIStopTask with any type of body

func NewDMAPITransferSourceRequest

func NewDMAPITransferSourceRequest(server string, sourceName string, body DMAPITransferSourceJSONRequestBody) (*http.Request, error)

NewDMAPITransferSourceRequest calls the generic DMAPITransferSource builder with application/json body

func NewDMAPITransferSourceRequestWithBody

func NewDMAPITransferSourceRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPITransferSourceRequestWithBody generates requests for DMAPITransferSource with any type of body

func NewDMAPIUpdateClusterInfoRequest

func NewDMAPIUpdateClusterInfoRequest(server string, body DMAPIUpdateClusterInfoJSONRequestBody) (*http.Request, error)

NewDMAPIUpdateClusterInfoRequest calls the generic DMAPIUpdateClusterInfo builder with application/json body

func NewDMAPIUpdateClusterInfoRequestWithBody

func NewDMAPIUpdateClusterInfoRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIUpdateClusterInfoRequestWithBody generates requests for DMAPIUpdateClusterInfo with any type of body

func NewDMAPIUpdateSourceRequest

func NewDMAPIUpdateSourceRequest(server string, sourceName string, body DMAPIUpdateSourceJSONRequestBody) (*http.Request, error)

NewDMAPIUpdateSourceRequest calls the generic DMAPIUpdateSource builder with application/json body

func NewDMAPIUpdateSourceRequestWithBody

func NewDMAPIUpdateSourceRequestWithBody(server string, sourceName string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIUpdateSourceRequestWithBody generates requests for DMAPIUpdateSource with any type of body

func NewDMAPIUpdateTaskRequest

func NewDMAPIUpdateTaskRequest(server string, taskName string, body DMAPIUpdateTaskJSONRequestBody) (*http.Request, error)

NewDMAPIUpdateTaskRequest calls the generic DMAPIUpdateTask builder with application/json body

func NewDMAPIUpdateTaskRequestWithBody

func NewDMAPIUpdateTaskRequestWithBody(server string, taskName string, contentType string, body io.Reader) (*http.Request, error)

NewDMAPIUpdateTaskRequestWithBody generates requests for DMAPIUpdateTask with any type of body

func NewDMAPUpdateTaskTemplateRequest

func NewDMAPUpdateTaskTemplateRequest(server string, taskName string) (*http.Request, error)

NewDMAPUpdateTaskTemplateRequest generates requests for DMAPUpdateTaskTemplate

func NewGetDocHTMLRequest

func NewGetDocHTMLRequest(server string) (*http.Request, error)

NewGetDocHTMLRequest generates requests for GetDocHTML

func NewGetDocJSONRequest

func NewGetDocJSONRequest(server string) (*http.Request, error)

NewGetDocJSONRequest generates requests for GetDocJSON

func PathToRawSpec

func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error)

Constructs a synthetic filesystem for resolving external references when loading openapi specifications.

func RegisterHandlers

func RegisterHandlers(router *gin.Engine, si ServerInterface) *gin.Engine

RegisterHandlers creates http.Handler with routing matching OpenAPI spec.

func RegisterHandlersWithOptions

func RegisterHandlersWithOptions(router *gin.Engine, si ServerInterface, options GinServerOptions) *gin.Engine

RegisterHandlersWithOptions creates http.Handler with additional options

func ZapLogger

func ZapLogger(log *zap.Logger) gin.HandlerFunc

ZapLogger is a middleware and zap to provide an "access log" like logging for each request.

Types

type AlertManagerTopology

type AlertManagerTopology struct {
	Host string `json:"host"`
	Port int    `json:"port"`
}

AlertManagerTopology defines model for AlertManagerTopology.

type Client

type Client struct {
	// The endpoint of the server conforming to this interface, with scheme,
	// https://api.deepmap.com for example. This can contain a path relative
	// to the server, such as https://api.deepmap.com/dev-test, and all the
	// paths in the swagger spec will be appended to the server.
	Server string

	// Doer for performing requests, typically a *http.Client with any
	// customized settings, such as certificate chains.
	Client HttpRequestDoer

	// A list of callbacks for modifying requests which are generated before sending over
	// the network.
	RequestEditors []RequestEditorFn
}

Client which conforms to the OpenAPI3 specification for this service.

func NewClient

func NewClient(server string, opts ...ClientOption) (*Client, error)

Creates a new Client, with reasonable defaults

func (*Client) DMAPIConvertTask

func (c *Client) DMAPIConvertTask(ctx context.Context, body DMAPIConvertTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIConvertTaskWithBody

func (c *Client) DMAPIConvertTaskWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPICreateSource

func (c *Client) DMAPICreateSource(ctx context.Context, body DMAPICreateSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPICreateSourceWithBody

func (c *Client) DMAPICreateSourceWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPICreateTask

func (c *Client) DMAPICreateTask(ctx context.Context, body DMAPICreateTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPICreateTaskTemplate

func (c *Client) DMAPICreateTaskTemplate(ctx context.Context, body DMAPICreateTaskTemplateJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPICreateTaskTemplateWithBody

func (c *Client) DMAPICreateTaskTemplateWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPICreateTaskWithBody

func (c *Client) DMAPICreateTaskWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIDeleteSource

func (c *Client) DMAPIDeleteSource(ctx context.Context, sourceName string, params *DMAPIDeleteSourceParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIDeleteTableStructure

func (c *Client) DMAPIDeleteTableStructure(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIDeleteTask

func (c *Client) DMAPIDeleteTask(ctx context.Context, taskName string, params *DMAPIDeleteTaskParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIDeleteTaskTemplate

func (c *Client) DMAPIDeleteTaskTemplate(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIDisableRelay

func (c *Client) DMAPIDisableRelay(ctx context.Context, sourceName string, body DMAPIDisableRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIDisableRelayWithBody

func (c *Client) DMAPIDisableRelayWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIDisableSource

func (c *Client) DMAPIDisableSource(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIEnableRelay

func (c *Client) DMAPIEnableRelay(ctx context.Context, sourceName string, body DMAPIEnableRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIEnableRelayWithBody

func (c *Client) DMAPIEnableRelayWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIEnableSource

func (c *Client) DMAPIEnableSource(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetClusterInfo

func (c *Client) DMAPIGetClusterInfo(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetClusterMasterList

func (c *Client) DMAPIGetClusterMasterList(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetClusterWorkerList

func (c *Client) DMAPIGetClusterWorkerList(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetSchemaListByTaskAndSource

func (c *Client) DMAPIGetSchemaListByTaskAndSource(ctx context.Context, taskName string, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetSource

func (c *Client) DMAPIGetSource(ctx context.Context, sourceName string, params *DMAPIGetSourceParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetSourceList

func (c *Client) DMAPIGetSourceList(ctx context.Context, params *DMAPIGetSourceListParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetSourceSchemaList

func (c *Client) DMAPIGetSourceSchemaList(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetSourceStatus

func (c *Client) DMAPIGetSourceStatus(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetSourceTableList

func (c *Client) DMAPIGetSourceTableList(ctx context.Context, sourceName string, schemaName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetTableListByTaskAndSource

func (c *Client) DMAPIGetTableListByTaskAndSource(ctx context.Context, taskName string, sourceName string, schemaName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetTableStructure

func (c *Client) DMAPIGetTableStructure(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetTask

func (c *Client) DMAPIGetTask(ctx context.Context, taskName string, params *DMAPIGetTaskParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetTaskList

func (c *Client) DMAPIGetTaskList(ctx context.Context, params *DMAPIGetTaskListParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetTaskMigrateTargets

func (c *Client) DMAPIGetTaskMigrateTargets(ctx context.Context, taskName string, sourceName string, params *DMAPIGetTaskMigrateTargetsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetTaskStatus

func (c *Client) DMAPIGetTaskStatus(ctx context.Context, taskName string, params *DMAPIGetTaskStatusParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetTaskTemplate

func (c *Client) DMAPIGetTaskTemplate(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIGetTaskTemplateList

func (c *Client) DMAPIGetTaskTemplateList(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIImportTaskTemplate

func (c *Client) DMAPIImportTaskTemplate(ctx context.Context, body DMAPIImportTaskTemplateJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIImportTaskTemplateWithBody

func (c *Client) DMAPIImportTaskTemplateWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIOfflineMasterNode

func (c *Client) DMAPIOfflineMasterNode(ctx context.Context, masterName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIOfflineWorkerNode

func (c *Client) DMAPIOfflineWorkerNode(ctx context.Context, workerName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIOperateTableStructure

func (c *Client) DMAPIOperateTableStructure(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, body DMAPIOperateTableStructureJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIOperateTableStructureWithBody

func (c *Client) DMAPIOperateTableStructureWithBody(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIPurgeRelay

func (c *Client) DMAPIPurgeRelay(ctx context.Context, sourceName string, body DMAPIPurgeRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIPurgeRelayWithBody

func (c *Client) DMAPIPurgeRelayWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIStartTask

func (c *Client) DMAPIStartTask(ctx context.Context, taskName string, body DMAPIStartTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIStartTaskWithBody

func (c *Client) DMAPIStartTaskWithBody(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIStopTask

func (c *Client) DMAPIStopTask(ctx context.Context, taskName string, body DMAPIStopTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIStopTaskWithBody

func (c *Client) DMAPIStopTaskWithBody(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPITransferSource

func (c *Client) DMAPITransferSource(ctx context.Context, sourceName string, body DMAPITransferSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPITransferSourceWithBody

func (c *Client) DMAPITransferSourceWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIUpdateClusterInfo

func (c *Client) DMAPIUpdateClusterInfo(ctx context.Context, body DMAPIUpdateClusterInfoJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIUpdateClusterInfoWithBody

func (c *Client) DMAPIUpdateClusterInfoWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIUpdateSource

func (c *Client) DMAPIUpdateSource(ctx context.Context, sourceName string, body DMAPIUpdateSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIUpdateSourceWithBody

func (c *Client) DMAPIUpdateSourceWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIUpdateTask

func (c *Client) DMAPIUpdateTask(ctx context.Context, taskName string, body DMAPIUpdateTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPIUpdateTaskWithBody

func (c *Client) DMAPIUpdateTaskWithBody(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DMAPUpdateTaskTemplate

func (c *Client) DMAPUpdateTaskTemplate(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetDocHTML

func (c *Client) GetDocHTML(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetDocJSON

func (c *Client) GetDocJSON(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

type ClientInterface

type ClientInterface interface {
	// DMAPIGetClusterInfo request
	DMAPIGetClusterInfo(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIUpdateClusterInfo request with any body
	DMAPIUpdateClusterInfoWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIUpdateClusterInfo(ctx context.Context, body DMAPIUpdateClusterInfoJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetClusterMasterList request
	DMAPIGetClusterMasterList(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIOfflineMasterNode request
	DMAPIOfflineMasterNode(ctx context.Context, masterName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetClusterWorkerList request
	DMAPIGetClusterWorkerList(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIOfflineWorkerNode request
	DMAPIOfflineWorkerNode(ctx context.Context, workerName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetDocJSON request
	GetDocJSON(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetDocHTML request
	GetDocHTML(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetSourceList request
	DMAPIGetSourceList(ctx context.Context, params *DMAPIGetSourceListParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPICreateSource request with any body
	DMAPICreateSourceWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPICreateSource(ctx context.Context, body DMAPICreateSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIDeleteSource request
	DMAPIDeleteSource(ctx context.Context, sourceName string, params *DMAPIDeleteSourceParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetSource request
	DMAPIGetSource(ctx context.Context, sourceName string, params *DMAPIGetSourceParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIUpdateSource request with any body
	DMAPIUpdateSourceWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIUpdateSource(ctx context.Context, sourceName string, body DMAPIUpdateSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIDisableSource request
	DMAPIDisableSource(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIEnableSource request
	DMAPIEnableSource(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIDisableRelay request with any body
	DMAPIDisableRelayWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIDisableRelay(ctx context.Context, sourceName string, body DMAPIDisableRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIEnableRelay request with any body
	DMAPIEnableRelayWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIEnableRelay(ctx context.Context, sourceName string, body DMAPIEnableRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIPurgeRelay request with any body
	DMAPIPurgeRelayWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIPurgeRelay(ctx context.Context, sourceName string, body DMAPIPurgeRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetSourceSchemaList request
	DMAPIGetSourceSchemaList(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetSourceTableList request
	DMAPIGetSourceTableList(ctx context.Context, sourceName string, schemaName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetSourceStatus request
	DMAPIGetSourceStatus(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPITransferSource request with any body
	DMAPITransferSourceWithBody(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPITransferSource(ctx context.Context, sourceName string, body DMAPITransferSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetTaskList request
	DMAPIGetTaskList(ctx context.Context, params *DMAPIGetTaskListParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPICreateTask request with any body
	DMAPICreateTaskWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPICreateTask(ctx context.Context, body DMAPICreateTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIConvertTask request with any body
	DMAPIConvertTaskWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIConvertTask(ctx context.Context, body DMAPIConvertTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetTaskTemplateList request
	DMAPIGetTaskTemplateList(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPICreateTaskTemplate request with any body
	DMAPICreateTaskTemplateWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPICreateTaskTemplate(ctx context.Context, body DMAPICreateTaskTemplateJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIImportTaskTemplate request with any body
	DMAPIImportTaskTemplateWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIImportTaskTemplate(ctx context.Context, body DMAPIImportTaskTemplateJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIDeleteTaskTemplate request
	DMAPIDeleteTaskTemplate(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetTaskTemplate request
	DMAPIGetTaskTemplate(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPUpdateTaskTemplate request
	DMAPUpdateTaskTemplate(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIDeleteTask request
	DMAPIDeleteTask(ctx context.Context, taskName string, params *DMAPIDeleteTaskParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetTask request
	DMAPIGetTask(ctx context.Context, taskName string, params *DMAPIGetTaskParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIUpdateTask request with any body
	DMAPIUpdateTaskWithBody(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIUpdateTask(ctx context.Context, taskName string, body DMAPIUpdateTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetTaskMigrateTargets request
	DMAPIGetTaskMigrateTargets(ctx context.Context, taskName string, sourceName string, params *DMAPIGetTaskMigrateTargetsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetSchemaListByTaskAndSource request
	DMAPIGetSchemaListByTaskAndSource(ctx context.Context, taskName string, sourceName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetTableListByTaskAndSource request
	DMAPIGetTableListByTaskAndSource(ctx context.Context, taskName string, sourceName string, schemaName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIDeleteTableStructure request
	DMAPIDeleteTableStructure(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetTableStructure request
	DMAPIGetTableStructure(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIOperateTableStructure request with any body
	DMAPIOperateTableStructureWithBody(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIOperateTableStructure(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, body DMAPIOperateTableStructureJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIStartTask request with any body
	DMAPIStartTaskWithBody(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIStartTask(ctx context.Context, taskName string, body DMAPIStartTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIGetTaskStatus request
	DMAPIGetTaskStatus(ctx context.Context, taskName string, params *DMAPIGetTaskStatusParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DMAPIStopTask request with any body
	DMAPIStopTaskWithBody(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DMAPIStopTask(ctx context.Context, taskName string, body DMAPIStopTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
}

The interface specification for the client above.

type ClientOption

type ClientOption func(*Client) error

ClientOption allows setting custom parameters during construction

func WithBaseURL

func WithBaseURL(baseURL string) ClientOption

WithBaseURL overrides the baseURL.

func WithHTTPClient

func WithHTTPClient(doer HttpRequestDoer) ClientOption

WithHTTPClient allows overriding the default Doer, which is automatically created using http.Client. This is useful for tests.

func WithRequestEditorFn

func WithRequestEditorFn(fn RequestEditorFn) ClientOption

WithRequestEditorFn allows setting up a callback function, which will be called right before sending the request. This can be used to mutate the request.

type ClientWithResponses

type ClientWithResponses struct {
	ClientInterface
}

ClientWithResponses builds on ClientInterface to offer response payloads

func NewClientWithResponses

func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)

NewClientWithResponses creates a new ClientWithResponses, which wraps Client with return type handling

func (*ClientWithResponses) DMAPIConvertTaskWithBodyWithResponse

func (c *ClientWithResponses) DMAPIConvertTaskWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIConvertTaskResponse, error)

DMAPIConvertTaskWithBodyWithResponse request with arbitrary body returning *DMAPIConvertTaskResponse

func (*ClientWithResponses) DMAPIConvertTaskWithResponse

func (c *ClientWithResponses) DMAPIConvertTaskWithResponse(ctx context.Context, body DMAPIConvertTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIConvertTaskResponse, error)

func (*ClientWithResponses) DMAPICreateSourceWithBodyWithResponse

func (c *ClientWithResponses) DMAPICreateSourceWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPICreateSourceResponse, error)

DMAPICreateSourceWithBodyWithResponse request with arbitrary body returning *DMAPICreateSourceResponse

func (*ClientWithResponses) DMAPICreateSourceWithResponse

func (c *ClientWithResponses) DMAPICreateSourceWithResponse(ctx context.Context, body DMAPICreateSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPICreateSourceResponse, error)

func (*ClientWithResponses) DMAPICreateTaskTemplateWithBodyWithResponse

func (c *ClientWithResponses) DMAPICreateTaskTemplateWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPICreateTaskTemplateResponse, error)

DMAPICreateTaskTemplateWithBodyWithResponse request with arbitrary body returning *DMAPICreateTaskTemplateResponse

func (*ClientWithResponses) DMAPICreateTaskTemplateWithResponse

func (c *ClientWithResponses) DMAPICreateTaskTemplateWithResponse(ctx context.Context, body DMAPICreateTaskTemplateJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPICreateTaskTemplateResponse, error)

func (*ClientWithResponses) DMAPICreateTaskWithBodyWithResponse

func (c *ClientWithResponses) DMAPICreateTaskWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPICreateTaskResponse, error)

DMAPICreateTaskWithBodyWithResponse request with arbitrary body returning *DMAPICreateTaskResponse

func (*ClientWithResponses) DMAPICreateTaskWithResponse

func (c *ClientWithResponses) DMAPICreateTaskWithResponse(ctx context.Context, body DMAPICreateTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPICreateTaskResponse, error)

func (*ClientWithResponses) DMAPIDeleteSourceWithResponse

func (c *ClientWithResponses) DMAPIDeleteSourceWithResponse(ctx context.Context, sourceName string, params *DMAPIDeleteSourceParams, reqEditors ...RequestEditorFn) (*DMAPIDeleteSourceResponse, error)

DMAPIDeleteSourceWithResponse request returning *DMAPIDeleteSourceResponse

func (*ClientWithResponses) DMAPIDeleteTableStructureWithResponse

func (c *ClientWithResponses) DMAPIDeleteTableStructureWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, reqEditors ...RequestEditorFn) (*DMAPIDeleteTableStructureResponse, error)

DMAPIDeleteTableStructureWithResponse request returning *DMAPIDeleteTableStructureResponse

func (*ClientWithResponses) DMAPIDeleteTaskTemplateWithResponse

func (c *ClientWithResponses) DMAPIDeleteTaskTemplateWithResponse(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*DMAPIDeleteTaskTemplateResponse, error)

DMAPIDeleteTaskTemplateWithResponse request returning *DMAPIDeleteTaskTemplateResponse

func (*ClientWithResponses) DMAPIDeleteTaskWithResponse

func (c *ClientWithResponses) DMAPIDeleteTaskWithResponse(ctx context.Context, taskName string, params *DMAPIDeleteTaskParams, reqEditors ...RequestEditorFn) (*DMAPIDeleteTaskResponse, error)

DMAPIDeleteTaskWithResponse request returning *DMAPIDeleteTaskResponse

func (*ClientWithResponses) DMAPIDisableRelayWithBodyWithResponse

func (c *ClientWithResponses) DMAPIDisableRelayWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIDisableRelayResponse, error)

DMAPIDisableRelayWithBodyWithResponse request with arbitrary body returning *DMAPIDisableRelayResponse

func (*ClientWithResponses) DMAPIDisableRelayWithResponse

func (c *ClientWithResponses) DMAPIDisableRelayWithResponse(ctx context.Context, sourceName string, body DMAPIDisableRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIDisableRelayResponse, error)

func (*ClientWithResponses) DMAPIDisableSourceWithResponse

func (c *ClientWithResponses) DMAPIDisableSourceWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIDisableSourceResponse, error)

DMAPIDisableSourceWithResponse request returning *DMAPIDisableSourceResponse

func (*ClientWithResponses) DMAPIEnableRelayWithBodyWithResponse

func (c *ClientWithResponses) DMAPIEnableRelayWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIEnableRelayResponse, error)

DMAPIEnableRelayWithBodyWithResponse request with arbitrary body returning *DMAPIEnableRelayResponse

func (*ClientWithResponses) DMAPIEnableRelayWithResponse

func (c *ClientWithResponses) DMAPIEnableRelayWithResponse(ctx context.Context, sourceName string, body DMAPIEnableRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIEnableRelayResponse, error)

func (*ClientWithResponses) DMAPIEnableSourceWithResponse

func (c *ClientWithResponses) DMAPIEnableSourceWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIEnableSourceResponse, error)

DMAPIEnableSourceWithResponse request returning *DMAPIEnableSourceResponse

func (*ClientWithResponses) DMAPIGetClusterInfoWithResponse

func (c *ClientWithResponses) DMAPIGetClusterInfoWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetClusterInfoResponse, error)

DMAPIGetClusterInfoWithResponse request returning *DMAPIGetClusterInfoResponse

func (*ClientWithResponses) DMAPIGetClusterMasterListWithResponse

func (c *ClientWithResponses) DMAPIGetClusterMasterListWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetClusterMasterListResponse, error)

DMAPIGetClusterMasterListWithResponse request returning *DMAPIGetClusterMasterListResponse

func (*ClientWithResponses) DMAPIGetClusterWorkerListWithResponse

func (c *ClientWithResponses) DMAPIGetClusterWorkerListWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetClusterWorkerListResponse, error)

DMAPIGetClusterWorkerListWithResponse request returning *DMAPIGetClusterWorkerListResponse

func (*ClientWithResponses) DMAPIGetSchemaListByTaskAndSourceWithResponse

func (c *ClientWithResponses) DMAPIGetSchemaListByTaskAndSourceWithResponse(ctx context.Context, taskName string, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIGetSchemaListByTaskAndSourceResponse, error)

DMAPIGetSchemaListByTaskAndSourceWithResponse request returning *DMAPIGetSchemaListByTaskAndSourceResponse

func (*ClientWithResponses) DMAPIGetSourceListWithResponse

func (c *ClientWithResponses) DMAPIGetSourceListWithResponse(ctx context.Context, params *DMAPIGetSourceListParams, reqEditors ...RequestEditorFn) (*DMAPIGetSourceListResponse, error)

DMAPIGetSourceListWithResponse request returning *DMAPIGetSourceListResponse

func (*ClientWithResponses) DMAPIGetSourceSchemaListWithResponse

func (c *ClientWithResponses) DMAPIGetSourceSchemaListWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIGetSourceSchemaListResponse, error)

DMAPIGetSourceSchemaListWithResponse request returning *DMAPIGetSourceSchemaListResponse

func (*ClientWithResponses) DMAPIGetSourceStatusWithResponse

func (c *ClientWithResponses) DMAPIGetSourceStatusWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIGetSourceStatusResponse, error)

DMAPIGetSourceStatusWithResponse request returning *DMAPIGetSourceStatusResponse

func (*ClientWithResponses) DMAPIGetSourceTableListWithResponse

func (c *ClientWithResponses) DMAPIGetSourceTableListWithResponse(ctx context.Context, sourceName string, schemaName string, reqEditors ...RequestEditorFn) (*DMAPIGetSourceTableListResponse, error)

DMAPIGetSourceTableListWithResponse request returning *DMAPIGetSourceTableListResponse

func (*ClientWithResponses) DMAPIGetSourceWithResponse

func (c *ClientWithResponses) DMAPIGetSourceWithResponse(ctx context.Context, sourceName string, params *DMAPIGetSourceParams, reqEditors ...RequestEditorFn) (*DMAPIGetSourceResponse, error)

DMAPIGetSourceWithResponse request returning *DMAPIGetSourceResponse

func (*ClientWithResponses) DMAPIGetTableListByTaskAndSourceWithResponse

func (c *ClientWithResponses) DMAPIGetTableListByTaskAndSourceWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, reqEditors ...RequestEditorFn) (*DMAPIGetTableListByTaskAndSourceResponse, error)

DMAPIGetTableListByTaskAndSourceWithResponse request returning *DMAPIGetTableListByTaskAndSourceResponse

func (*ClientWithResponses) DMAPIGetTableStructureWithResponse

func (c *ClientWithResponses) DMAPIGetTableStructureWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, reqEditors ...RequestEditorFn) (*DMAPIGetTableStructureResponse, error)

DMAPIGetTableStructureWithResponse request returning *DMAPIGetTableStructureResponse

func (*ClientWithResponses) DMAPIGetTaskListWithResponse

func (c *ClientWithResponses) DMAPIGetTaskListWithResponse(ctx context.Context, params *DMAPIGetTaskListParams, reqEditors ...RequestEditorFn) (*DMAPIGetTaskListResponse, error)

DMAPIGetTaskListWithResponse request returning *DMAPIGetTaskListResponse

func (*ClientWithResponses) DMAPIGetTaskMigrateTargetsWithResponse

func (c *ClientWithResponses) DMAPIGetTaskMigrateTargetsWithResponse(ctx context.Context, taskName string, sourceName string, params *DMAPIGetTaskMigrateTargetsParams, reqEditors ...RequestEditorFn) (*DMAPIGetTaskMigrateTargetsResponse, error)

DMAPIGetTaskMigrateTargetsWithResponse request returning *DMAPIGetTaskMigrateTargetsResponse

func (*ClientWithResponses) DMAPIGetTaskStatusWithResponse

func (c *ClientWithResponses) DMAPIGetTaskStatusWithResponse(ctx context.Context, taskName string, params *DMAPIGetTaskStatusParams, reqEditors ...RequestEditorFn) (*DMAPIGetTaskStatusResponse, error)

DMAPIGetTaskStatusWithResponse request returning *DMAPIGetTaskStatusResponse

func (*ClientWithResponses) DMAPIGetTaskTemplateListWithResponse

func (c *ClientWithResponses) DMAPIGetTaskTemplateListWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetTaskTemplateListResponse, error)

DMAPIGetTaskTemplateListWithResponse request returning *DMAPIGetTaskTemplateListResponse

func (*ClientWithResponses) DMAPIGetTaskTemplateWithResponse

func (c *ClientWithResponses) DMAPIGetTaskTemplateWithResponse(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*DMAPIGetTaskTemplateResponse, error)

DMAPIGetTaskTemplateWithResponse request returning *DMAPIGetTaskTemplateResponse

func (*ClientWithResponses) DMAPIGetTaskWithResponse

func (c *ClientWithResponses) DMAPIGetTaskWithResponse(ctx context.Context, taskName string, params *DMAPIGetTaskParams, reqEditors ...RequestEditorFn) (*DMAPIGetTaskResponse, error)

DMAPIGetTaskWithResponse request returning *DMAPIGetTaskResponse

func (*ClientWithResponses) DMAPIImportTaskTemplateWithBodyWithResponse

func (c *ClientWithResponses) DMAPIImportTaskTemplateWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIImportTaskTemplateResponse, error)

DMAPIImportTaskTemplateWithBodyWithResponse request with arbitrary body returning *DMAPIImportTaskTemplateResponse

func (*ClientWithResponses) DMAPIImportTaskTemplateWithResponse

func (c *ClientWithResponses) DMAPIImportTaskTemplateWithResponse(ctx context.Context, body DMAPIImportTaskTemplateJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIImportTaskTemplateResponse, error)

func (*ClientWithResponses) DMAPIOfflineMasterNodeWithResponse

func (c *ClientWithResponses) DMAPIOfflineMasterNodeWithResponse(ctx context.Context, masterName string, reqEditors ...RequestEditorFn) (*DMAPIOfflineMasterNodeResponse, error)

DMAPIOfflineMasterNodeWithResponse request returning *DMAPIOfflineMasterNodeResponse

func (*ClientWithResponses) DMAPIOfflineWorkerNodeWithResponse

func (c *ClientWithResponses) DMAPIOfflineWorkerNodeWithResponse(ctx context.Context, workerName string, reqEditors ...RequestEditorFn) (*DMAPIOfflineWorkerNodeResponse, error)

DMAPIOfflineWorkerNodeWithResponse request returning *DMAPIOfflineWorkerNodeResponse

func (*ClientWithResponses) DMAPIOperateTableStructureWithBodyWithResponse

func (c *ClientWithResponses) DMAPIOperateTableStructureWithBodyWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIOperateTableStructureResponse, error)

DMAPIOperateTableStructureWithBodyWithResponse request with arbitrary body returning *DMAPIOperateTableStructureResponse

func (*ClientWithResponses) DMAPIOperateTableStructureWithResponse

func (c *ClientWithResponses) DMAPIOperateTableStructureWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, body DMAPIOperateTableStructureJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIOperateTableStructureResponse, error)

func (*ClientWithResponses) DMAPIPurgeRelayWithBodyWithResponse

func (c *ClientWithResponses) DMAPIPurgeRelayWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIPurgeRelayResponse, error)

DMAPIPurgeRelayWithBodyWithResponse request with arbitrary body returning *DMAPIPurgeRelayResponse

func (*ClientWithResponses) DMAPIPurgeRelayWithResponse

func (c *ClientWithResponses) DMAPIPurgeRelayWithResponse(ctx context.Context, sourceName string, body DMAPIPurgeRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIPurgeRelayResponse, error)

func (*ClientWithResponses) DMAPIStartTaskWithBodyWithResponse

func (c *ClientWithResponses) DMAPIStartTaskWithBodyWithResponse(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIStartTaskResponse, error)

DMAPIStartTaskWithBodyWithResponse request with arbitrary body returning *DMAPIStartTaskResponse

func (*ClientWithResponses) DMAPIStartTaskWithResponse

func (c *ClientWithResponses) DMAPIStartTaskWithResponse(ctx context.Context, taskName string, body DMAPIStartTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIStartTaskResponse, error)

func (*ClientWithResponses) DMAPIStopTaskWithBodyWithResponse

func (c *ClientWithResponses) DMAPIStopTaskWithBodyWithResponse(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIStopTaskResponse, error)

DMAPIStopTaskWithBodyWithResponse request with arbitrary body returning *DMAPIStopTaskResponse

func (*ClientWithResponses) DMAPIStopTaskWithResponse

func (c *ClientWithResponses) DMAPIStopTaskWithResponse(ctx context.Context, taskName string, body DMAPIStopTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIStopTaskResponse, error)

func (*ClientWithResponses) DMAPITransferSourceWithBodyWithResponse

func (c *ClientWithResponses) DMAPITransferSourceWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPITransferSourceResponse, error)

DMAPITransferSourceWithBodyWithResponse request with arbitrary body returning *DMAPITransferSourceResponse

func (*ClientWithResponses) DMAPITransferSourceWithResponse

func (c *ClientWithResponses) DMAPITransferSourceWithResponse(ctx context.Context, sourceName string, body DMAPITransferSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPITransferSourceResponse, error)

func (*ClientWithResponses) DMAPIUpdateClusterInfoWithBodyWithResponse

func (c *ClientWithResponses) DMAPIUpdateClusterInfoWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIUpdateClusterInfoResponse, error)

DMAPIUpdateClusterInfoWithBodyWithResponse request with arbitrary body returning *DMAPIUpdateClusterInfoResponse

func (*ClientWithResponses) DMAPIUpdateClusterInfoWithResponse

func (c *ClientWithResponses) DMAPIUpdateClusterInfoWithResponse(ctx context.Context, body DMAPIUpdateClusterInfoJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIUpdateClusterInfoResponse, error)

func (*ClientWithResponses) DMAPIUpdateSourceWithBodyWithResponse

func (c *ClientWithResponses) DMAPIUpdateSourceWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIUpdateSourceResponse, error)

DMAPIUpdateSourceWithBodyWithResponse request with arbitrary body returning *DMAPIUpdateSourceResponse

func (*ClientWithResponses) DMAPIUpdateSourceWithResponse

func (c *ClientWithResponses) DMAPIUpdateSourceWithResponse(ctx context.Context, sourceName string, body DMAPIUpdateSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIUpdateSourceResponse, error)

func (*ClientWithResponses) DMAPIUpdateTaskWithBodyWithResponse

func (c *ClientWithResponses) DMAPIUpdateTaskWithBodyWithResponse(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIUpdateTaskResponse, error)

DMAPIUpdateTaskWithBodyWithResponse request with arbitrary body returning *DMAPIUpdateTaskResponse

func (*ClientWithResponses) DMAPIUpdateTaskWithResponse

func (c *ClientWithResponses) DMAPIUpdateTaskWithResponse(ctx context.Context, taskName string, body DMAPIUpdateTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIUpdateTaskResponse, error)

func (*ClientWithResponses) DMAPUpdateTaskTemplateWithResponse

func (c *ClientWithResponses) DMAPUpdateTaskTemplateWithResponse(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*DMAPUpdateTaskTemplateResponse, error)

DMAPUpdateTaskTemplateWithResponse request returning *DMAPUpdateTaskTemplateResponse

func (*ClientWithResponses) GetDocHTMLWithResponse

func (c *ClientWithResponses) GetDocHTMLWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetDocHTMLResponse, error)

GetDocHTMLWithResponse request returning *GetDocHTMLResponse

func (*ClientWithResponses) GetDocJSONWithResponse

func (c *ClientWithResponses) GetDocJSONWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetDocJSONResponse, error)

GetDocJSONWithResponse request returning *GetDocJSONResponse

type ClientWithResponsesInterface

type ClientWithResponsesInterface interface {
	// DMAPIGetClusterInfo request
	DMAPIGetClusterInfoWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetClusterInfoResponse, error)

	// DMAPIUpdateClusterInfo request with any body
	DMAPIUpdateClusterInfoWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIUpdateClusterInfoResponse, error)

	DMAPIUpdateClusterInfoWithResponse(ctx context.Context, body DMAPIUpdateClusterInfoJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIUpdateClusterInfoResponse, error)

	// DMAPIGetClusterMasterList request
	DMAPIGetClusterMasterListWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetClusterMasterListResponse, error)

	// DMAPIOfflineMasterNode request
	DMAPIOfflineMasterNodeWithResponse(ctx context.Context, masterName string, reqEditors ...RequestEditorFn) (*DMAPIOfflineMasterNodeResponse, error)

	// DMAPIGetClusterWorkerList request
	DMAPIGetClusterWorkerListWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetClusterWorkerListResponse, error)

	// DMAPIOfflineWorkerNode request
	DMAPIOfflineWorkerNodeWithResponse(ctx context.Context, workerName string, reqEditors ...RequestEditorFn) (*DMAPIOfflineWorkerNodeResponse, error)

	// GetDocJSON request
	GetDocJSONWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetDocJSONResponse, error)

	// GetDocHTML request
	GetDocHTMLWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetDocHTMLResponse, error)

	// DMAPIGetSourceList request
	DMAPIGetSourceListWithResponse(ctx context.Context, params *DMAPIGetSourceListParams, reqEditors ...RequestEditorFn) (*DMAPIGetSourceListResponse, error)

	// DMAPICreateSource request with any body
	DMAPICreateSourceWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPICreateSourceResponse, error)

	DMAPICreateSourceWithResponse(ctx context.Context, body DMAPICreateSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPICreateSourceResponse, error)

	// DMAPIDeleteSource request
	DMAPIDeleteSourceWithResponse(ctx context.Context, sourceName string, params *DMAPIDeleteSourceParams, reqEditors ...RequestEditorFn) (*DMAPIDeleteSourceResponse, error)

	// DMAPIGetSource request
	DMAPIGetSourceWithResponse(ctx context.Context, sourceName string, params *DMAPIGetSourceParams, reqEditors ...RequestEditorFn) (*DMAPIGetSourceResponse, error)

	// DMAPIUpdateSource request with any body
	DMAPIUpdateSourceWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIUpdateSourceResponse, error)

	DMAPIUpdateSourceWithResponse(ctx context.Context, sourceName string, body DMAPIUpdateSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIUpdateSourceResponse, error)

	// DMAPIDisableSource request
	DMAPIDisableSourceWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIDisableSourceResponse, error)

	// DMAPIEnableSource request
	DMAPIEnableSourceWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIEnableSourceResponse, error)

	// DMAPIDisableRelay request with any body
	DMAPIDisableRelayWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIDisableRelayResponse, error)

	DMAPIDisableRelayWithResponse(ctx context.Context, sourceName string, body DMAPIDisableRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIDisableRelayResponse, error)

	// DMAPIEnableRelay request with any body
	DMAPIEnableRelayWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIEnableRelayResponse, error)

	DMAPIEnableRelayWithResponse(ctx context.Context, sourceName string, body DMAPIEnableRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIEnableRelayResponse, error)

	// DMAPIPurgeRelay request with any body
	DMAPIPurgeRelayWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIPurgeRelayResponse, error)

	DMAPIPurgeRelayWithResponse(ctx context.Context, sourceName string, body DMAPIPurgeRelayJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIPurgeRelayResponse, error)

	// DMAPIGetSourceSchemaList request
	DMAPIGetSourceSchemaListWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIGetSourceSchemaListResponse, error)

	// DMAPIGetSourceTableList request
	DMAPIGetSourceTableListWithResponse(ctx context.Context, sourceName string, schemaName string, reqEditors ...RequestEditorFn) (*DMAPIGetSourceTableListResponse, error)

	// DMAPIGetSourceStatus request
	DMAPIGetSourceStatusWithResponse(ctx context.Context, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIGetSourceStatusResponse, error)

	// DMAPITransferSource request with any body
	DMAPITransferSourceWithBodyWithResponse(ctx context.Context, sourceName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPITransferSourceResponse, error)

	DMAPITransferSourceWithResponse(ctx context.Context, sourceName string, body DMAPITransferSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPITransferSourceResponse, error)

	// DMAPIGetTaskList request
	DMAPIGetTaskListWithResponse(ctx context.Context, params *DMAPIGetTaskListParams, reqEditors ...RequestEditorFn) (*DMAPIGetTaskListResponse, error)

	// DMAPICreateTask request with any body
	DMAPICreateTaskWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPICreateTaskResponse, error)

	DMAPICreateTaskWithResponse(ctx context.Context, body DMAPICreateTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPICreateTaskResponse, error)

	// DMAPIConvertTask request with any body
	DMAPIConvertTaskWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIConvertTaskResponse, error)

	DMAPIConvertTaskWithResponse(ctx context.Context, body DMAPIConvertTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIConvertTaskResponse, error)

	// DMAPIGetTaskTemplateList request
	DMAPIGetTaskTemplateListWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DMAPIGetTaskTemplateListResponse, error)

	// DMAPICreateTaskTemplate request with any body
	DMAPICreateTaskTemplateWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPICreateTaskTemplateResponse, error)

	DMAPICreateTaskTemplateWithResponse(ctx context.Context, body DMAPICreateTaskTemplateJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPICreateTaskTemplateResponse, error)

	// DMAPIImportTaskTemplate request with any body
	DMAPIImportTaskTemplateWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIImportTaskTemplateResponse, error)

	DMAPIImportTaskTemplateWithResponse(ctx context.Context, body DMAPIImportTaskTemplateJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIImportTaskTemplateResponse, error)

	// DMAPIDeleteTaskTemplate request
	DMAPIDeleteTaskTemplateWithResponse(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*DMAPIDeleteTaskTemplateResponse, error)

	// DMAPIGetTaskTemplate request
	DMAPIGetTaskTemplateWithResponse(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*DMAPIGetTaskTemplateResponse, error)

	// DMAPUpdateTaskTemplate request
	DMAPUpdateTaskTemplateWithResponse(ctx context.Context, taskName string, reqEditors ...RequestEditorFn) (*DMAPUpdateTaskTemplateResponse, error)

	// DMAPIDeleteTask request
	DMAPIDeleteTaskWithResponse(ctx context.Context, taskName string, params *DMAPIDeleteTaskParams, reqEditors ...RequestEditorFn) (*DMAPIDeleteTaskResponse, error)

	// DMAPIGetTask request
	DMAPIGetTaskWithResponse(ctx context.Context, taskName string, params *DMAPIGetTaskParams, reqEditors ...RequestEditorFn) (*DMAPIGetTaskResponse, error)

	// DMAPIUpdateTask request with any body
	DMAPIUpdateTaskWithBodyWithResponse(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIUpdateTaskResponse, error)

	DMAPIUpdateTaskWithResponse(ctx context.Context, taskName string, body DMAPIUpdateTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIUpdateTaskResponse, error)

	// DMAPIGetTaskMigrateTargets request
	DMAPIGetTaskMigrateTargetsWithResponse(ctx context.Context, taskName string, sourceName string, params *DMAPIGetTaskMigrateTargetsParams, reqEditors ...RequestEditorFn) (*DMAPIGetTaskMigrateTargetsResponse, error)

	// DMAPIGetSchemaListByTaskAndSource request
	DMAPIGetSchemaListByTaskAndSourceWithResponse(ctx context.Context, taskName string, sourceName string, reqEditors ...RequestEditorFn) (*DMAPIGetSchemaListByTaskAndSourceResponse, error)

	// DMAPIGetTableListByTaskAndSource request
	DMAPIGetTableListByTaskAndSourceWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, reqEditors ...RequestEditorFn) (*DMAPIGetTableListByTaskAndSourceResponse, error)

	// DMAPIDeleteTableStructure request
	DMAPIDeleteTableStructureWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, reqEditors ...RequestEditorFn) (*DMAPIDeleteTableStructureResponse, error)

	// DMAPIGetTableStructure request
	DMAPIGetTableStructureWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, reqEditors ...RequestEditorFn) (*DMAPIGetTableStructureResponse, error)

	// DMAPIOperateTableStructure request with any body
	DMAPIOperateTableStructureWithBodyWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIOperateTableStructureResponse, error)

	DMAPIOperateTableStructureWithResponse(ctx context.Context, taskName string, sourceName string, schemaName string, tableName string, body DMAPIOperateTableStructureJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIOperateTableStructureResponse, error)

	// DMAPIStartTask request with any body
	DMAPIStartTaskWithBodyWithResponse(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIStartTaskResponse, error)

	DMAPIStartTaskWithResponse(ctx context.Context, taskName string, body DMAPIStartTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIStartTaskResponse, error)

	// DMAPIGetTaskStatus request
	DMAPIGetTaskStatusWithResponse(ctx context.Context, taskName string, params *DMAPIGetTaskStatusParams, reqEditors ...RequestEditorFn) (*DMAPIGetTaskStatusResponse, error)

	// DMAPIStopTask request with any body
	DMAPIStopTaskWithBodyWithResponse(ctx context.Context, taskName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DMAPIStopTaskResponse, error)

	DMAPIStopTaskWithResponse(ctx context.Context, taskName string, body DMAPIStopTaskJSONRequestBody, reqEditors ...RequestEditorFn) (*DMAPIStopTaskResponse, error)
}

ClientWithResponsesInterface is the interface specification for the client with responses above.

type ClusterMaster

type ClusterMaster struct {
	// address of the current master node
	Addr string `json:"addr"`

	// online status of this master
	Alive bool `json:"alive"`

	// is this master the leader
	Leader bool   `json:"leader"`
	Name   string `json:"name"`
}

ClusterMaster defines model for ClusterMaster.

type ClusterTopology

type ClusterTopology struct {
	AlertManagerTopology *AlertManagerTopology `json:"alert_manager_topology,omitempty"`
	GrafanaTopology      *GrafanaTopology      `json:"grafana_topology,omitempty"`
	MasterTopologyList   *[]MasterTopology     `json:"master_topology_list,omitempty"`
	PrometheusTopology   *PrometheusTopology   `json:"prometheus_topology,omitempty"`
	WorkerTopologyList   *[]WorkerTopology     `json:"worker_topology_list,omitempty"`
}

ClusterTopology defines model for ClusterTopology.

type ClusterWorker

type ClusterWorker struct {
	// address of the current master node
	Addr string `json:"addr"`

	// source name bound to this worker node
	BoundSourceName string `json:"bound_source_name"`

	// bound stage of this worker node
	BoundStage string `json:"bound_stage"`
	Name       string `json:"name"`
}

ClusterWorker defines model for ClusterWorker.

type ConverterTaskRequest

type ConverterTaskRequest struct {
	// task
	Task *Task `json:"task,omitempty"`

	// config file in yaml format https://docs.pingcap.com/zh/tidb/stable/task-configuration-file-full.
	TaskConfigFile *string `json:"task_config_file,omitempty"`
}

ConverterTaskRequest defines model for ConverterTaskRequest.

type ConverterTaskResponse

type ConverterTaskResponse struct {
	// task
	Task Task `json:"task"`

	// config file in yaml format https://docs.pingcap.com/zh/tidb/stable/task-configuration-file-full.
	TaskConfigFile string `json:"task_config_file"`
}

ConverterTaskResponse defines model for ConverterTaskResponse.

type CreateSourceRequest

type CreateSourceRequest struct {
	// source
	Source     Source  `json:"source"`
	WorkerName *string `json:"worker_name,omitempty"`
}

CreateSourceRequest defines model for CreateSourceRequest.

type CreateTaskRequest

type CreateTaskRequest struct {
	// task
	Task Task `json:"task"`
}

CreateTaskRequest defines model for CreateTaskRequest.

type DMAPIConvertTaskJSONBody

type DMAPIConvertTaskJSONBody ConverterTaskRequest

DMAPIConvertTaskJSONBody defines parameters for DMAPIConvertTask.

type DMAPIConvertTaskJSONRequestBody

type DMAPIConvertTaskJSONRequestBody DMAPIConvertTaskJSONBody

DMAPIConvertTaskJSONRequestBody defines body for DMAPIConvertTask for application/json ContentType.

type DMAPIConvertTaskResponse

type DMAPIConvertTaskResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *ConverterTaskResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIConvertTaskResponse

func ParseDMAPIConvertTaskResponse(rsp *http.Response) (*DMAPIConvertTaskResponse, error)

ParseDMAPIConvertTaskResponse parses an HTTP response from a DMAPIConvertTaskWithResponse call

func (DMAPIConvertTaskResponse) Status

func (r DMAPIConvertTaskResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIConvertTaskResponse) StatusCode

func (r DMAPIConvertTaskResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPICreateSourceJSONBody

type DMAPICreateSourceJSONBody CreateSourceRequest

DMAPICreateSourceJSONBody defines parameters for DMAPICreateSource.

type DMAPICreateSourceJSONRequestBody

type DMAPICreateSourceJSONRequestBody DMAPICreateSourceJSONBody

DMAPICreateSourceJSONRequestBody defines body for DMAPICreateSource for application/json ContentType.

type DMAPICreateSourceResponse

type DMAPICreateSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *Source
	JSON400      *ErrorWithMessage
}

func ParseDMAPICreateSourceResponse

func ParseDMAPICreateSourceResponse(rsp *http.Response) (*DMAPICreateSourceResponse, error)

ParseDMAPICreateSourceResponse parses an HTTP response from a DMAPICreateSourceWithResponse call

func (DMAPICreateSourceResponse) Status

func (r DMAPICreateSourceResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPICreateSourceResponse) StatusCode

func (r DMAPICreateSourceResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPICreateTaskJSONBody

type DMAPICreateTaskJSONBody CreateTaskRequest

DMAPICreateTaskJSONBody defines parameters for DMAPICreateTask.

type DMAPICreateTaskJSONRequestBody

type DMAPICreateTaskJSONRequestBody DMAPICreateTaskJSONBody

DMAPICreateTaskJSONRequestBody defines body for DMAPICreateTask for application/json ContentType.

type DMAPICreateTaskResponse

type DMAPICreateTaskResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *OperateTaskResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPICreateTaskResponse

func ParseDMAPICreateTaskResponse(rsp *http.Response) (*DMAPICreateTaskResponse, error)

ParseDMAPICreateTaskResponse parses an HTTP response from a DMAPICreateTaskWithResponse call

func (DMAPICreateTaskResponse) Status

func (r DMAPICreateTaskResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPICreateTaskResponse) StatusCode

func (r DMAPICreateTaskResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPICreateTaskTemplateJSONBody

type DMAPICreateTaskTemplateJSONBody Task

DMAPICreateTaskTemplateJSONBody defines parameters for DMAPICreateTaskTemplate.

type DMAPICreateTaskTemplateJSONRequestBody

type DMAPICreateTaskTemplateJSONRequestBody DMAPICreateTaskTemplateJSONBody

DMAPICreateTaskTemplateJSONRequestBody defines body for DMAPICreateTaskTemplate for application/json ContentType.

type DMAPICreateTaskTemplateResponse

type DMAPICreateTaskTemplateResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *Task
	JSON400      *ErrorWithMessage
}

func ParseDMAPICreateTaskTemplateResponse

func ParseDMAPICreateTaskTemplateResponse(rsp *http.Response) (*DMAPICreateTaskTemplateResponse, error)

ParseDMAPICreateTaskTemplateResponse parses an HTTP response from a DMAPICreateTaskTemplateWithResponse call

func (DMAPICreateTaskTemplateResponse) Status

func (r DMAPICreateTaskTemplateResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPICreateTaskTemplateResponse) StatusCode

func (r DMAPICreateTaskTemplateResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIDeleteSourceParams

type DMAPIDeleteSourceParams struct {
	// force stop source also stop the related tasks
	Force *bool `json:"force,omitempty"`
}

DMAPIDeleteSourceParams defines parameters for DMAPIDeleteSource.

type DMAPIDeleteSourceResponse

type DMAPIDeleteSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIDeleteSourceResponse

func ParseDMAPIDeleteSourceResponse(rsp *http.Response) (*DMAPIDeleteSourceResponse, error)

ParseDMAPIDeleteSourceResponse parses an HTTP response from a DMAPIDeleteSourceWithResponse call

func (DMAPIDeleteSourceResponse) Status

func (r DMAPIDeleteSourceResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIDeleteSourceResponse) StatusCode

func (r DMAPIDeleteSourceResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIDeleteTableStructureResponse

type DMAPIDeleteTableStructureResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIDeleteTableStructureResponse

func ParseDMAPIDeleteTableStructureResponse(rsp *http.Response) (*DMAPIDeleteTableStructureResponse, error)

ParseDMAPIDeleteTableStructureResponse parses an HTTP response from a DMAPIDeleteTableStructureWithResponse call

func (DMAPIDeleteTableStructureResponse) Status

func (r DMAPIDeleteTableStructureResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIDeleteTableStructureResponse) StatusCode

func (r DMAPIDeleteTableStructureResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIDeleteTaskParams

type DMAPIDeleteTaskParams struct {
	// force stop task even if some subtask is running
	Force *bool `json:"force,omitempty"`
}

DMAPIDeleteTaskParams defines parameters for DMAPIDeleteTask.

type DMAPIDeleteTaskResponse

type DMAPIDeleteTaskResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIDeleteTaskResponse

func ParseDMAPIDeleteTaskResponse(rsp *http.Response) (*DMAPIDeleteTaskResponse, error)

ParseDMAPIDeleteTaskResponse parses an HTTP response from a DMAPIDeleteTaskWithResponse call

func (DMAPIDeleteTaskResponse) Status

func (r DMAPIDeleteTaskResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIDeleteTaskResponse) StatusCode

func (r DMAPIDeleteTaskResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIDeleteTaskTemplateResponse

type DMAPIDeleteTaskTemplateResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIDeleteTaskTemplateResponse

func ParseDMAPIDeleteTaskTemplateResponse(rsp *http.Response) (*DMAPIDeleteTaskTemplateResponse, error)

ParseDMAPIDeleteTaskTemplateResponse parses an HTTP response from a DMAPIDeleteTaskTemplateWithResponse call

func (DMAPIDeleteTaskTemplateResponse) Status

func (r DMAPIDeleteTaskTemplateResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIDeleteTaskTemplateResponse) StatusCode

func (r DMAPIDeleteTaskTemplateResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIDisableRelayJSONBody

type DMAPIDisableRelayJSONBody DisableRelayRequest

DMAPIDisableRelayJSONBody defines parameters for DMAPIDisableRelay.

type DMAPIDisableRelayJSONRequestBody

type DMAPIDisableRelayJSONRequestBody DMAPIDisableRelayJSONBody

DMAPIDisableRelayJSONRequestBody defines body for DMAPIDisableRelay for application/json ContentType.

type DMAPIDisableRelayResponse

type DMAPIDisableRelayResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIDisableRelayResponse

func ParseDMAPIDisableRelayResponse(rsp *http.Response) (*DMAPIDisableRelayResponse, error)

ParseDMAPIDisableRelayResponse parses an HTTP response from a DMAPIDisableRelayWithResponse call

func (DMAPIDisableRelayResponse) Status

func (r DMAPIDisableRelayResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIDisableRelayResponse) StatusCode

func (r DMAPIDisableRelayResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIDisableSourceResponse

type DMAPIDisableSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIDisableSourceResponse

func ParseDMAPIDisableSourceResponse(rsp *http.Response) (*DMAPIDisableSourceResponse, error)

ParseDMAPIDisableSourceResponse parses an HTTP response from a DMAPIDisableSourceWithResponse call

func (DMAPIDisableSourceResponse) Status

func (r DMAPIDisableSourceResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIDisableSourceResponse) StatusCode

func (r DMAPIDisableSourceResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIEnableRelayJSONBody

type DMAPIEnableRelayJSONBody EnableRelayRequest

DMAPIEnableRelayJSONBody defines parameters for DMAPIEnableRelay.

type DMAPIEnableRelayJSONRequestBody

type DMAPIEnableRelayJSONRequestBody DMAPIEnableRelayJSONBody

DMAPIEnableRelayJSONRequestBody defines body for DMAPIEnableRelay for application/json ContentType.

type DMAPIEnableRelayResponse

type DMAPIEnableRelayResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIEnableRelayResponse

func ParseDMAPIEnableRelayResponse(rsp *http.Response) (*DMAPIEnableRelayResponse, error)

ParseDMAPIEnableRelayResponse parses an HTTP response from a DMAPIEnableRelayWithResponse call

func (DMAPIEnableRelayResponse) Status

func (r DMAPIEnableRelayResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIEnableRelayResponse) StatusCode

func (r DMAPIEnableRelayResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIEnableSourceResponse

type DMAPIEnableSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIEnableSourceResponse

func ParseDMAPIEnableSourceResponse(rsp *http.Response) (*DMAPIEnableSourceResponse, error)

ParseDMAPIEnableSourceResponse parses an HTTP response from a DMAPIEnableSourceWithResponse call

func (DMAPIEnableSourceResponse) Status

func (r DMAPIEnableSourceResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIEnableSourceResponse) StatusCode

func (r DMAPIEnableSourceResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetClusterInfoResponse

type DMAPIGetClusterInfoResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetClusterInfoResponse
}

func ParseDMAPIGetClusterInfoResponse

func ParseDMAPIGetClusterInfoResponse(rsp *http.Response) (*DMAPIGetClusterInfoResponse, error)

ParseDMAPIGetClusterInfoResponse parses an HTTP response from a DMAPIGetClusterInfoWithResponse call

func (DMAPIGetClusterInfoResponse) Status

func (r DMAPIGetClusterInfoResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetClusterInfoResponse) StatusCode

func (r DMAPIGetClusterInfoResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetClusterMasterListResponse

type DMAPIGetClusterMasterListResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetClusterMasterListResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetClusterMasterListResponse

func ParseDMAPIGetClusterMasterListResponse(rsp *http.Response) (*DMAPIGetClusterMasterListResponse, error)

ParseDMAPIGetClusterMasterListResponse parses an HTTP response from a DMAPIGetClusterMasterListWithResponse call

func (DMAPIGetClusterMasterListResponse) Status

func (r DMAPIGetClusterMasterListResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetClusterMasterListResponse) StatusCode

func (r DMAPIGetClusterMasterListResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetClusterWorkerListResponse

type DMAPIGetClusterWorkerListResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetClusterWorkerListResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetClusterWorkerListResponse

func ParseDMAPIGetClusterWorkerListResponse(rsp *http.Response) (*DMAPIGetClusterWorkerListResponse, error)

ParseDMAPIGetClusterWorkerListResponse parses an HTTP response from a DMAPIGetClusterWorkerListWithResponse call

func (DMAPIGetClusterWorkerListResponse) Status

func (r DMAPIGetClusterWorkerListResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetClusterWorkerListResponse) StatusCode

func (r DMAPIGetClusterWorkerListResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetSchemaListByTaskAndSourceResponse

type DMAPIGetSchemaListByTaskAndSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *SchemaNameList
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetSchemaListByTaskAndSourceResponse

func ParseDMAPIGetSchemaListByTaskAndSourceResponse(rsp *http.Response) (*DMAPIGetSchemaListByTaskAndSourceResponse, error)

ParseDMAPIGetSchemaListByTaskAndSourceResponse parses an HTTP response from a DMAPIGetSchemaListByTaskAndSourceWithResponse call

func (DMAPIGetSchemaListByTaskAndSourceResponse) Status

func (r DMAPIGetSchemaListByTaskAndSourceResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetSchemaListByTaskAndSourceResponse) StatusCode

func (r DMAPIGetSchemaListByTaskAndSourceResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetSourceListParams

type DMAPIGetSourceListParams struct {
	// list source with status
	WithStatus *bool `json:"with_status,omitempty"`

	// only return the enable-relay source
	EnableRelay *bool `json:"enable_relay,omitempty"`
}

DMAPIGetSourceListParams defines parameters for DMAPIGetSourceList.

type DMAPIGetSourceListResponse

type DMAPIGetSourceListResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetSourceListResponse
}

func ParseDMAPIGetSourceListResponse

func ParseDMAPIGetSourceListResponse(rsp *http.Response) (*DMAPIGetSourceListResponse, error)

ParseDMAPIGetSourceListResponse parses an HTTP response from a DMAPIGetSourceListWithResponse call

func (DMAPIGetSourceListResponse) Status

func (r DMAPIGetSourceListResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetSourceListResponse) StatusCode

func (r DMAPIGetSourceListResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetSourceParams

type DMAPIGetSourceParams struct {
	// list source with status
	WithStatus *bool `json:"with_status,omitempty"`
}

DMAPIGetSourceParams defines parameters for DMAPIGetSource.

type DMAPIGetSourceResponse

type DMAPIGetSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Source
}

func ParseDMAPIGetSourceResponse

func ParseDMAPIGetSourceResponse(rsp *http.Response) (*DMAPIGetSourceResponse, error)

ParseDMAPIGetSourceResponse parses an HTTP response from a DMAPIGetSourceWithResponse call

func (DMAPIGetSourceResponse) Status

func (r DMAPIGetSourceResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetSourceResponse) StatusCode

func (r DMAPIGetSourceResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetSourceSchemaListResponse

type DMAPIGetSourceSchemaListResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *SchemaNameList
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetSourceSchemaListResponse

func ParseDMAPIGetSourceSchemaListResponse(rsp *http.Response) (*DMAPIGetSourceSchemaListResponse, error)

ParseDMAPIGetSourceSchemaListResponse parses an HTTP response from a DMAPIGetSourceSchemaListWithResponse call

func (DMAPIGetSourceSchemaListResponse) Status

func (r DMAPIGetSourceSchemaListResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetSourceSchemaListResponse) StatusCode

func (r DMAPIGetSourceSchemaListResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetSourceStatusResponse

type DMAPIGetSourceStatusResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetSourceStatusResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetSourceStatusResponse

func ParseDMAPIGetSourceStatusResponse(rsp *http.Response) (*DMAPIGetSourceStatusResponse, error)

ParseDMAPIGetSourceStatusResponse parses an HTTP response from a DMAPIGetSourceStatusWithResponse call

func (DMAPIGetSourceStatusResponse) Status

func (r DMAPIGetSourceStatusResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetSourceStatusResponse) StatusCode

func (r DMAPIGetSourceStatusResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetSourceTableListResponse

type DMAPIGetSourceTableListResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *TableNameList
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetSourceTableListResponse

func ParseDMAPIGetSourceTableListResponse(rsp *http.Response) (*DMAPIGetSourceTableListResponse, error)

ParseDMAPIGetSourceTableListResponse parses an HTTP response from a DMAPIGetSourceTableListWithResponse call

func (DMAPIGetSourceTableListResponse) Status

func (r DMAPIGetSourceTableListResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetSourceTableListResponse) StatusCode

func (r DMAPIGetSourceTableListResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetTableListByTaskAndSourceResponse

type DMAPIGetTableListByTaskAndSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *TableNameList
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetTableListByTaskAndSourceResponse

func ParseDMAPIGetTableListByTaskAndSourceResponse(rsp *http.Response) (*DMAPIGetTableListByTaskAndSourceResponse, error)

ParseDMAPIGetTableListByTaskAndSourceResponse parses an HTTP response from a DMAPIGetTableListByTaskAndSourceWithResponse call

func (DMAPIGetTableListByTaskAndSourceResponse) Status

func (r DMAPIGetTableListByTaskAndSourceResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetTableListByTaskAndSourceResponse) StatusCode

func (r DMAPIGetTableListByTaskAndSourceResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetTableStructureResponse

type DMAPIGetTableStructureResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetTaskTableStructureResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetTableStructureResponse

func ParseDMAPIGetTableStructureResponse(rsp *http.Response) (*DMAPIGetTableStructureResponse, error)

ParseDMAPIGetTableStructureResponse parses an HTTP response from a DMAPIGetTableStructureWithResponse call

func (DMAPIGetTableStructureResponse) Status

func (r DMAPIGetTableStructureResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetTableStructureResponse) StatusCode

func (r DMAPIGetTableStructureResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetTaskListParams

type DMAPIGetTaskListParams struct {
	// get task with status
	WithStatus *bool `json:"with_status,omitempty"`

	// filter by task stage
	Stage *TaskStage `json:"stage,omitempty"`

	// filter by source name
	SourceNameList *SourceNameList `json:"source_name_list,omitempty"`
}

DMAPIGetTaskListParams defines parameters for DMAPIGetTaskList.

type DMAPIGetTaskListResponse

type DMAPIGetTaskListResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetTaskListResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetTaskListResponse

func ParseDMAPIGetTaskListResponse(rsp *http.Response) (*DMAPIGetTaskListResponse, error)

ParseDMAPIGetTaskListResponse parses an HTTP response from a DMAPIGetTaskListWithResponse call

func (DMAPIGetTaskListResponse) Status

func (r DMAPIGetTaskListResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetTaskListResponse) StatusCode

func (r DMAPIGetTaskListResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetTaskMigrateTargetsParams

type DMAPIGetTaskMigrateTargetsParams struct {
	SchemaPattern *string `json:"schema_pattern,omitempty"`
	TablePattern  *string `json:"table_pattern,omitempty"`
}

DMAPIGetTaskMigrateTargetsParams defines parameters for DMAPIGetTaskMigrateTargets.

type DMAPIGetTaskMigrateTargetsResponse

type DMAPIGetTaskMigrateTargetsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetTaskMigrateTargetsResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetTaskMigrateTargetsResponse

func ParseDMAPIGetTaskMigrateTargetsResponse(rsp *http.Response) (*DMAPIGetTaskMigrateTargetsResponse, error)

ParseDMAPIGetTaskMigrateTargetsResponse parses an HTTP response from a DMAPIGetTaskMigrateTargetsWithResponse call

func (DMAPIGetTaskMigrateTargetsResponse) Status

func (r DMAPIGetTaskMigrateTargetsResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetTaskMigrateTargetsResponse) StatusCode

func (r DMAPIGetTaskMigrateTargetsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetTaskParams

type DMAPIGetTaskParams struct {
	// get task with status
	WithStatus *bool `json:"with_status,omitempty"`
}

DMAPIGetTaskParams defines parameters for DMAPIGetTask.

type DMAPIGetTaskResponse

type DMAPIGetTaskResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Task
}

func ParseDMAPIGetTaskResponse

func ParseDMAPIGetTaskResponse(rsp *http.Response) (*DMAPIGetTaskResponse, error)

ParseDMAPIGetTaskResponse parses an HTTP response from a DMAPIGetTaskWithResponse call

func (DMAPIGetTaskResponse) Status

func (r DMAPIGetTaskResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetTaskResponse) StatusCode

func (r DMAPIGetTaskResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetTaskStatusParams

type DMAPIGetTaskStatusParams struct {
	// source name list
	SourceNameList *SourceNameList `json:"source_name_list,omitempty"`
}

DMAPIGetTaskStatusParams defines parameters for DMAPIGetTaskStatus.

type DMAPIGetTaskStatusResponse

type DMAPIGetTaskStatusResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetTaskStatusResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetTaskStatusResponse

func ParseDMAPIGetTaskStatusResponse(rsp *http.Response) (*DMAPIGetTaskStatusResponse, error)

ParseDMAPIGetTaskStatusResponse parses an HTTP response from a DMAPIGetTaskStatusWithResponse call

func (DMAPIGetTaskStatusResponse) Status

func (r DMAPIGetTaskStatusResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetTaskStatusResponse) StatusCode

func (r DMAPIGetTaskStatusResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetTaskTemplateListResponse

type DMAPIGetTaskTemplateListResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetTaskListResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetTaskTemplateListResponse

func ParseDMAPIGetTaskTemplateListResponse(rsp *http.Response) (*DMAPIGetTaskTemplateListResponse, error)

ParseDMAPIGetTaskTemplateListResponse parses an HTTP response from a DMAPIGetTaskTemplateListWithResponse call

func (DMAPIGetTaskTemplateListResponse) Status

func (r DMAPIGetTaskTemplateListResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetTaskTemplateListResponse) StatusCode

func (r DMAPIGetTaskTemplateListResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIGetTaskTemplateResponse

type DMAPIGetTaskTemplateResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Task
	JSON400      *ErrorWithMessage
}

func ParseDMAPIGetTaskTemplateResponse

func ParseDMAPIGetTaskTemplateResponse(rsp *http.Response) (*DMAPIGetTaskTemplateResponse, error)

ParseDMAPIGetTaskTemplateResponse parses an HTTP response from a DMAPIGetTaskTemplateWithResponse call

func (DMAPIGetTaskTemplateResponse) Status

func (r DMAPIGetTaskTemplateResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIGetTaskTemplateResponse) StatusCode

func (r DMAPIGetTaskTemplateResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIImportTaskTemplateJSONBody

type DMAPIImportTaskTemplateJSONBody TaskTemplateRequest

DMAPIImportTaskTemplateJSONBody defines parameters for DMAPIImportTaskTemplate.

type DMAPIImportTaskTemplateJSONRequestBody

type DMAPIImportTaskTemplateJSONRequestBody DMAPIImportTaskTemplateJSONBody

DMAPIImportTaskTemplateJSONRequestBody defines body for DMAPIImportTaskTemplate for application/json ContentType.

type DMAPIImportTaskTemplateResponse

type DMAPIImportTaskTemplateResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON202      *TaskTemplateResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIImportTaskTemplateResponse

func ParseDMAPIImportTaskTemplateResponse(rsp *http.Response) (*DMAPIImportTaskTemplateResponse, error)

ParseDMAPIImportTaskTemplateResponse parses an HTTP response from a DMAPIImportTaskTemplateWithResponse call

func (DMAPIImportTaskTemplateResponse) Status

func (r DMAPIImportTaskTemplateResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIImportTaskTemplateResponse) StatusCode

func (r DMAPIImportTaskTemplateResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIOfflineMasterNodeResponse

type DMAPIOfflineMasterNodeResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIOfflineMasterNodeResponse

func ParseDMAPIOfflineMasterNodeResponse(rsp *http.Response) (*DMAPIOfflineMasterNodeResponse, error)

ParseDMAPIOfflineMasterNodeResponse parses an HTTP response from a DMAPIOfflineMasterNodeWithResponse call

func (DMAPIOfflineMasterNodeResponse) Status

func (r DMAPIOfflineMasterNodeResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIOfflineMasterNodeResponse) StatusCode

func (r DMAPIOfflineMasterNodeResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIOfflineWorkerNodeResponse

type DMAPIOfflineWorkerNodeResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIOfflineWorkerNodeResponse

func ParseDMAPIOfflineWorkerNodeResponse(rsp *http.Response) (*DMAPIOfflineWorkerNodeResponse, error)

ParseDMAPIOfflineWorkerNodeResponse parses an HTTP response from a DMAPIOfflineWorkerNodeWithResponse call

func (DMAPIOfflineWorkerNodeResponse) Status

func (r DMAPIOfflineWorkerNodeResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIOfflineWorkerNodeResponse) StatusCode

func (r DMAPIOfflineWorkerNodeResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIOperateTableStructureJSONBody

type DMAPIOperateTableStructureJSONBody OperateTaskTableStructureRequest

DMAPIOperateTableStructureJSONBody defines parameters for DMAPIOperateTableStructure.

type DMAPIOperateTableStructureJSONRequestBody

type DMAPIOperateTableStructureJSONRequestBody DMAPIOperateTableStructureJSONBody

DMAPIOperateTableStructureJSONRequestBody defines body for DMAPIOperateTableStructure for application/json ContentType.

type DMAPIOperateTableStructureResponse

type DMAPIOperateTableStructureResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIOperateTableStructureResponse

func ParseDMAPIOperateTableStructureResponse(rsp *http.Response) (*DMAPIOperateTableStructureResponse, error)

ParseDMAPIOperateTableStructureResponse parses an HTTP response from a DMAPIOperateTableStructureWithResponse call

func (DMAPIOperateTableStructureResponse) Status

func (r DMAPIOperateTableStructureResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIOperateTableStructureResponse) StatusCode

func (r DMAPIOperateTableStructureResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIPurgeRelayJSONBody

type DMAPIPurgeRelayJSONBody PurgeRelayRequest

DMAPIPurgeRelayJSONBody defines parameters for DMAPIPurgeRelay.

type DMAPIPurgeRelayJSONRequestBody

type DMAPIPurgeRelayJSONRequestBody DMAPIPurgeRelayJSONBody

DMAPIPurgeRelayJSONRequestBody defines body for DMAPIPurgeRelay for application/json ContentType.

type DMAPIPurgeRelayResponse

type DMAPIPurgeRelayResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIPurgeRelayResponse

func ParseDMAPIPurgeRelayResponse(rsp *http.Response) (*DMAPIPurgeRelayResponse, error)

ParseDMAPIPurgeRelayResponse parses an HTTP response from a DMAPIPurgeRelayWithResponse call

func (DMAPIPurgeRelayResponse) Status

func (r DMAPIPurgeRelayResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIPurgeRelayResponse) StatusCode

func (r DMAPIPurgeRelayResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIStartTaskJSONBody

type DMAPIStartTaskJSONBody StartTaskRequest

DMAPIStartTaskJSONBody defines parameters for DMAPIStartTask.

type DMAPIStartTaskJSONRequestBody

type DMAPIStartTaskJSONRequestBody DMAPIStartTaskJSONBody

DMAPIStartTaskJSONRequestBody defines body for DMAPIStartTask for application/json ContentType.

type DMAPIStartTaskResponse

type DMAPIStartTaskResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIStartTaskResponse

func ParseDMAPIStartTaskResponse(rsp *http.Response) (*DMAPIStartTaskResponse, error)

ParseDMAPIStartTaskResponse parses an HTTP response from a DMAPIStartTaskWithResponse call

func (DMAPIStartTaskResponse) Status

func (r DMAPIStartTaskResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIStartTaskResponse) StatusCode

func (r DMAPIStartTaskResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIStopTaskJSONBody

type DMAPIStopTaskJSONBody StopTaskRequest

DMAPIStopTaskJSONBody defines parameters for DMAPIStopTask.

type DMAPIStopTaskJSONRequestBody

type DMAPIStopTaskJSONRequestBody DMAPIStopTaskJSONBody

DMAPIStopTaskJSONRequestBody defines body for DMAPIStopTask for application/json ContentType.

type DMAPIStopTaskResponse

type DMAPIStopTaskResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPIStopTaskResponse

func ParseDMAPIStopTaskResponse(rsp *http.Response) (*DMAPIStopTaskResponse, error)

ParseDMAPIStopTaskResponse parses an HTTP response from a DMAPIStopTaskWithResponse call

func (DMAPIStopTaskResponse) Status

func (r DMAPIStopTaskResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIStopTaskResponse) StatusCode

func (r DMAPIStopTaskResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPITransferSourceJSONBody

type DMAPITransferSourceJSONBody WorkerNameRequest

DMAPITransferSourceJSONBody defines parameters for DMAPITransferSource.

type DMAPITransferSourceJSONRequestBody

type DMAPITransferSourceJSONRequestBody DMAPITransferSourceJSONBody

DMAPITransferSourceJSONRequestBody defines body for DMAPITransferSource for application/json ContentType.

type DMAPITransferSourceResponse

type DMAPITransferSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorWithMessage
}

func ParseDMAPITransferSourceResponse

func ParseDMAPITransferSourceResponse(rsp *http.Response) (*DMAPITransferSourceResponse, error)

ParseDMAPITransferSourceResponse parses an HTTP response from a DMAPITransferSourceWithResponse call

func (DMAPITransferSourceResponse) Status

func (r DMAPITransferSourceResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPITransferSourceResponse) StatusCode

func (r DMAPITransferSourceResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIUpdateClusterInfoJSONBody

type DMAPIUpdateClusterInfoJSONBody ClusterTopology

DMAPIUpdateClusterInfoJSONBody defines parameters for DMAPIUpdateClusterInfo.

type DMAPIUpdateClusterInfoJSONRequestBody

type DMAPIUpdateClusterInfoJSONRequestBody DMAPIUpdateClusterInfoJSONBody

DMAPIUpdateClusterInfoJSONRequestBody defines body for DMAPIUpdateClusterInfo for application/json ContentType.

type DMAPIUpdateClusterInfoResponse

type DMAPIUpdateClusterInfoResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetClusterInfoResponse
}

func ParseDMAPIUpdateClusterInfoResponse

func ParseDMAPIUpdateClusterInfoResponse(rsp *http.Response) (*DMAPIUpdateClusterInfoResponse, error)

ParseDMAPIUpdateClusterInfoResponse parses an HTTP response from a DMAPIUpdateClusterInfoWithResponse call

func (DMAPIUpdateClusterInfoResponse) Status

func (r DMAPIUpdateClusterInfoResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIUpdateClusterInfoResponse) StatusCode

func (r DMAPIUpdateClusterInfoResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIUpdateSourceJSONBody

type DMAPIUpdateSourceJSONBody UpdateSourceRequest

DMAPIUpdateSourceJSONBody defines parameters for DMAPIUpdateSource.

type DMAPIUpdateSourceJSONRequestBody

type DMAPIUpdateSourceJSONRequestBody DMAPIUpdateSourceJSONBody

DMAPIUpdateSourceJSONRequestBody defines body for DMAPIUpdateSource for application/json ContentType.

type DMAPIUpdateSourceResponse

type DMAPIUpdateSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Source
	JSON400      *ErrorWithMessage
}

func ParseDMAPIUpdateSourceResponse

func ParseDMAPIUpdateSourceResponse(rsp *http.Response) (*DMAPIUpdateSourceResponse, error)

ParseDMAPIUpdateSourceResponse parses an HTTP response from a DMAPIUpdateSourceWithResponse call

func (DMAPIUpdateSourceResponse) Status

func (r DMAPIUpdateSourceResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIUpdateSourceResponse) StatusCode

func (r DMAPIUpdateSourceResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPIUpdateTaskJSONBody

type DMAPIUpdateTaskJSONBody UpdateTaskRequest

DMAPIUpdateTaskJSONBody defines parameters for DMAPIUpdateTask.

type DMAPIUpdateTaskJSONRequestBody

type DMAPIUpdateTaskJSONRequestBody DMAPIUpdateTaskJSONBody

DMAPIUpdateTaskJSONRequestBody defines body for DMAPIUpdateTask for application/json ContentType.

type DMAPIUpdateTaskResponse

type DMAPIUpdateTaskResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *OperateTaskResponse
	JSON400      *ErrorWithMessage
}

func ParseDMAPIUpdateTaskResponse

func ParseDMAPIUpdateTaskResponse(rsp *http.Response) (*DMAPIUpdateTaskResponse, error)

ParseDMAPIUpdateTaskResponse parses an HTTP response from a DMAPIUpdateTaskWithResponse call

func (DMAPIUpdateTaskResponse) Status

func (r DMAPIUpdateTaskResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPIUpdateTaskResponse) StatusCode

func (r DMAPIUpdateTaskResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DMAPUpdateTaskTemplateResponse

type DMAPUpdateTaskTemplateResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Task
	JSON400      *ErrorWithMessage
}

func ParseDMAPUpdateTaskTemplateResponse

func ParseDMAPUpdateTaskTemplateResponse(rsp *http.Response) (*DMAPUpdateTaskTemplateResponse, error)

ParseDMAPUpdateTaskTemplateResponse parses an HTTP response from a DMAPUpdateTaskTemplateWithResponse call

func (DMAPUpdateTaskTemplateResponse) Status

func (r DMAPUpdateTaskTemplateResponse) Status() string

Status returns HTTPResponse.Status

func (DMAPUpdateTaskTemplateResponse) StatusCode

func (r DMAPUpdateTaskTemplateResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DisableRelayRequest

type DisableRelayRequest struct {
	// worker name list
	WorkerNameList *WorkerNameList `json:"worker_name_list,omitempty"`
}

action to stop a relay request

type DumpStatus

type DumpStatus struct {
	Bps               int64   `json:"bps"`
	CompletedTables   float64 `json:"completed_tables"`
	EstimateTotalRows float64 `json:"estimate_total_rows"`
	FinishedBytes     float64 `json:"finished_bytes"`
	FinishedRows      float64 `json:"finished_rows"`
	Progress          string  `json:"progress"`
	TotalTables       int64   `json:"total_tables"`
}

status of dump unit

type EnableRelayRequest

type EnableRelayRequest struct {
	// starting GTID of the upstream binlog
	RelayBinlogGtid *string `json:"relay_binlog_gtid"`

	// starting filename of the upstream binlog
	RelayBinlogName *string `json:"relay_binlog_name"`

	// the directory where the relay log is stored
	RelayDir *string `json:"relay_dir"`

	// worker name list
	WorkerNameList *WorkerNameList `json:"worker_name_list,omitempty"`
}

action to start a relay request

type ErrorWithMessage

type ErrorWithMessage struct {
	// error code
	ErrorCode int `json:"error_code"`

	// error message
	ErrorMsg string `json:"error_msg"`
}

operation error

type GetClusterInfoResponse

type GetClusterInfoResponse struct {
	// cluster id
	ClusterId uint64           `json:"cluster_id"`
	Topology  *ClusterTopology `json:"topology,omitempty"`
}

GetClusterInfoResponse defines model for GetClusterInfoResponse.

type GetClusterMasterListResponse

type GetClusterMasterListResponse struct {
	Data  []ClusterMaster `json:"data"`
	Total int             `json:"total"`
}

GetClusterMasterListResponse defines model for GetClusterMasterListResponse.

type GetClusterWorkerListResponse

type GetClusterWorkerListResponse struct {
	Data  []ClusterWorker `json:"data"`
	Total int             `json:"total"`
}

GetClusterWorkerListResponse defines model for GetClusterWorkerListResponse.

type GetDocHTMLResponse

type GetDocHTMLResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseGetDocHTMLResponse

func ParseGetDocHTMLResponse(rsp *http.Response) (*GetDocHTMLResponse, error)

ParseGetDocHTMLResponse parses an HTTP response from a GetDocHTMLWithResponse call

func (GetDocHTMLResponse) Status

func (r GetDocHTMLResponse) Status() string

Status returns HTTPResponse.Status

func (GetDocHTMLResponse) StatusCode

func (r GetDocHTMLResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetDocJSONResponse

type GetDocJSONResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseGetDocJSONResponse

func ParseGetDocJSONResponse(rsp *http.Response) (*GetDocJSONResponse, error)

ParseGetDocJSONResponse parses an HTTP response from a GetDocJSONWithResponse call

func (GetDocJSONResponse) Status

func (r GetDocJSONResponse) Status() string

Status returns HTTPResponse.Status

func (GetDocJSONResponse) StatusCode

func (r GetDocJSONResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetSourceListResponse

type GetSourceListResponse struct {
	Data  []Source `json:"data"`
	Total int      `json:"total"`
}

GetSourceListResponse defines model for GetSourceListResponse.

type GetSourceStatusResponse

type GetSourceStatusResponse struct {
	Data  []SourceStatus `json:"data"`
	Total int            `json:"total"`
}

GetSourceStatusResponse defines model for GetSourceStatusResponse.

type GetTaskListResponse

type GetTaskListResponse struct {
	Data  []Task `json:"data"`
	Total int    `json:"total"`
}

GetTaskListResponse defines model for GetTaskListResponse.

type GetTaskMigrateTargetsResponse

type GetTaskMigrateTargetsResponse struct {
	Data  []TaskMigrateTarget `json:"data"`
	Total int                 `json:"total"`
}

GetTaskMigrateTargetsResponse defines model for GetTaskMigrateTargetsResponse.

type GetTaskStatusResponse

type GetTaskStatusResponse struct {
	Data  []SubTaskStatus `json:"data"`
	Total int             `json:"total"`
}

GetTaskStatusResponse defines model for GetTaskStatusResponse.

type GetTaskTableStructureResponse

type GetTaskTableStructureResponse struct {
	SchemaCreateSql *string `json:"schema_create_sql,omitempty"`
	SchemaName      *string `json:"schema_name,omitempty"`
	TableName       string  `json:"table_name"`
}

GetTaskTableStructureResponse defines model for GetTaskTableStructureResponse.

type GinServerOptions

type GinServerOptions struct {
	BaseURL     string
	Middlewares []MiddlewareFunc
}

GinServerOptions provides options for the Gin server.

type GrafanaTopology

type GrafanaTopology struct {
	Host string `json:"host"`
	Port int    `json:"port"`
}

GrafanaTopology defines model for GrafanaTopology.

type HttpRequestDoer

type HttpRequestDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

Doer performs HTTP requests.

The standard http.Client implements this interface.

type LoadStatus

type LoadStatus struct {
	Bps            int64  `json:"bps"`
	FinishedBytes  int64  `json:"finished_bytes"`
	MetaBinlog     string `json:"meta_binlog"`
	MetaBinlogGtid string `json:"meta_binlog_gtid"`
	Progress       string `json:"progress"`
	TotalBytes     int64  `json:"total_bytes"`
}

status of load unit

type MasterTopology

type MasterTopology struct {
	Host string `json:"host"`
	Name string `json:"name"`
	Port int    `json:"port"`
}

MasterTopology defines model for MasterTopology.

type MiddlewareFunc

type MiddlewareFunc func(c *gin.Context)

type OperateTaskResponse

type OperateTaskResponse struct {
	// pre-check result
	CheckResult string `json:"check_result"`

	// task
	Task Task `json:"task"`
}

OperateTaskResponse defines model for OperateTaskResponse.

type OperateTaskTableStructureRequest

type OperateTaskTableStructureRequest struct {
	// Writes the schema to the checkpoint so that DM can load it after restarting the task
	Flush *bool `json:"flush,omitempty"`

	// sql you want to operate
	SqlContent string `json:"sql_content"`

	// Updates the optimistic sharding metadata with this schema only used when an error occurs in the optimistic sharding DDL mode
	Sync *bool `json:"sync,omitempty"`
}

action to operate table request

type PrometheusTopology

type PrometheusTopology struct {
	Host string `json:"host"`
	Port int    `json:"port"`
}

PrometheusTopology defines model for PrometheusTopology.

type Purge

type Purge struct {
	// expiration time of relay log
	Expires *int64 `json:"expires"`

	// The interval to periodically check if the relay log is expired, default value: 3600, in seconds
	Interval *int64 `json:"interval"`

	// Minimum free disk space, in GB
	RemainSpace *int64 `json:"remain_space"`
}

relay log cleanup policy configuration

type PurgeRelayRequest

type PurgeRelayRequest struct {
	// starting filename of the upstream binlog
	RelayBinlogName string `json:"relay_binlog_name"`

	// specify relay sub directory for relay_binlog_name. If not specified, the latest one will be used. Sample format: 2ae76434-f79f-11e8-bde2-0242ac130008.000001
	RelayDir *string `json:"relay_dir"`
}

action to stop a relay request

type RelayConfig

type RelayConfig struct {
	EnableRelay *bool `json:"enable_relay,omitempty"`

	// starting GTID of the upstream binlog
	RelayBinlogGtid *string `json:"relay_binlog_gtid"`

	// starting filename of the upstream binlog
	RelayBinlogName *string `json:"relay_binlog_name"`

	// the directory where the relay log is stored
	RelayDir *string `json:"relay_dir"`
}

the config of relay

type RelayStatus

type RelayStatus struct {
	// upstream binlog file information
	MasterBinlog string `json:"master_binlog"`

	// GTID of the upstream
	MasterBinlogGtid string `json:"master_binlog_gtid"`

	// relay current GTID
	RelayBinlogGtid string `json:"relay_binlog_gtid"`

	// whether to catch up with upstream progress
	RelayCatchUpMaster bool `json:"relay_catch_up_master"`

	// the directory where the relay log is stored
	RelayDir string `json:"relay_dir"`

	// current status
	Stage string `json:"stage"`
}

status of relay log

type RequestEditorFn

type RequestEditorFn func(ctx context.Context, req *http.Request) error

RequestEditorFn is the function signature for the RequestEditor callback function

type SchemaNameList

type SchemaNameList []string

schema name list

type Security

type Security struct {
	// Common Name of SSL certificates
	CertAllowedCn *[]string `json:"cert_allowed_cn,omitempty"`

	// certificate file content
	SslCaContent string `json:"ssl_ca_content"`

	// File content of PEM format/X509 format certificates
	SslCertContent string `json:"ssl_cert_content"`

	// Content of the private key file in X509 format
	SslKeyContent string `json:"ssl_key_content"`
}

data source ssl configuration, the field will be hidden when getting the data source configuration from the interface

type ServerInterface

type ServerInterface interface {
	// get cluster info such as cluster id
	// (GET /api/v1/cluster/info)
	DMAPIGetClusterInfo(c *gin.Context)
	// update cluster info.
	// (PUT /api/v1/cluster/info)
	DMAPIUpdateClusterInfo(c *gin.Context)
	// get cluster master node list
	// (GET /api/v1/cluster/masters)
	DMAPIGetClusterMasterList(c *gin.Context)
	// offline master node
	// (DELETE /api/v1/cluster/masters/{master-name})
	DMAPIOfflineMasterNode(c *gin.Context, masterName string)
	// get cluster worker node list
	// (GET /api/v1/cluster/workers)
	DMAPIGetClusterWorkerList(c *gin.Context)
	// offline worker node
	// (DELETE /api/v1/cluster/workers/{worker-name})
	DMAPIOfflineWorkerNode(c *gin.Context, workerName string)
	// get doc json
	// (GET /api/v1/dm.json)
	GetDocJSON(c *gin.Context)
	// get doc html
	// (GET /api/v1/docs)
	GetDocHTML(c *gin.Context)
	// get data source list
	// (GET /api/v1/sources)
	DMAPIGetSourceList(c *gin.Context, params DMAPIGetSourceListParams)
	// create and enable a new data source
	// (POST /api/v1/sources)
	DMAPICreateSource(c *gin.Context)
	// delete a data source
	// (DELETE /api/v1/sources/{source-name})
	DMAPIDeleteSource(c *gin.Context, sourceName string, params DMAPIDeleteSourceParams)
	// get source
	// (GET /api/v1/sources/{source-name})
	DMAPIGetSource(c *gin.Context, sourceName string, params DMAPIGetSourceParams)
	// update a data source
	// (PUT /api/v1/sources/{source-name})
	DMAPIUpdateSource(c *gin.Context, sourceName string)
	// disable a data source
	// (POST /api/v1/sources/{source-name}/disable)
	DMAPIDisableSource(c *gin.Context, sourceName string)
	// enable a data source
	// (POST /api/v1/sources/{source-name}/enable)
	DMAPIEnableSource(c *gin.Context, sourceName string)
	// disable relay log function for the data source
	// (POST /api/v1/sources/{source-name}/relay/disable)
	DMAPIDisableRelay(c *gin.Context, sourceName string)
	// enable relay log function for the data source
	// (POST /api/v1/sources/{source-name}/relay/enable)
	DMAPIEnableRelay(c *gin.Context, sourceName string)
	// purge relay log
	// (POST /api/v1/sources/{source-name}/relay/purge)
	DMAPIPurgeRelay(c *gin.Context, sourceName string)
	// get source schema list
	// (GET /api/v1/sources/{source-name}/schemas)
	DMAPIGetSourceSchemaList(c *gin.Context, sourceName string)
	// get source table list
	// (GET /api/v1/sources/{source-name}/schemas/{schema-name})
	DMAPIGetSourceTableList(c *gin.Context, sourceName string, schemaName string)
	// get the current status of the data source
	// (GET /api/v1/sources/{source-name}/status)
	DMAPIGetSourceStatus(c *gin.Context, sourceName string)
	// transfer source to a free worker
	// (POST /api/v1/sources/{source-name}/transfer)
	DMAPITransferSource(c *gin.Context, sourceName string)
	// get task list
	// (GET /api/v1/tasks)
	DMAPIGetTaskList(c *gin.Context, params DMAPIGetTaskListParams)
	// create a task
	// (POST /api/v1/tasks)
	DMAPICreateTask(c *gin.Context)
	// Turn task into the format of a configuration file or vice versa.
	// (POST /api/v1/tasks/converters)
	DMAPIConvertTask(c *gin.Context)
	// get task template list
	// (GET /api/v1/tasks/templates)
	DMAPIGetTaskTemplateList(c *gin.Context)
	// create task template
	// (POST /api/v1/tasks/templates)
	DMAPICreateTaskTemplate(c *gin.Context)
	// import task template
	// (POST /api/v1/tasks/templates/import)
	DMAPIImportTaskTemplate(c *gin.Context)
	// delete task template template
	// (DELETE /api/v1/tasks/templates/{task-name})
	DMAPIDeleteTaskTemplate(c *gin.Context, taskName string)
	// get task template template
	// (GET /api/v1/tasks/templates/{task-name})
	DMAPIGetTaskTemplate(c *gin.Context, taskName string)
	// update task template template
	// (PUT /api/v1/tasks/templates/{task-name})
	DMAPUpdateTaskTemplate(c *gin.Context, taskName string)
	// delete a task
	// (DELETE /api/v1/tasks/{task-name})
	DMAPIDeleteTask(c *gin.Context, taskName string, params DMAPIDeleteTaskParams)
	// get a task
	// (GET /api/v1/tasks/{task-name})
	DMAPIGetTask(c *gin.Context, taskName string, params DMAPIGetTaskParams)
	// update a task
	// (PUT /api/v1/tasks/{task-name})
	DMAPIUpdateTask(c *gin.Context, taskName string)
	// get task source table and target table route relation
	// (GET /api/v1/tasks/{task-name}/sources/{source-name}/migrate_targets)
	DMAPIGetTaskMigrateTargets(c *gin.Context, taskName string, sourceName string, params DMAPIGetTaskMigrateTargetsParams)
	// get task source schema list
	// (GET /api/v1/tasks/{task-name}/sources/{source-name}/schemas)
	DMAPIGetSchemaListByTaskAndSource(c *gin.Context, taskName string, sourceName string)
	// get task source table list
	// (GET /api/v1/tasks/{task-name}/sources/{source-name}/schemas/{schema-name})
	DMAPIGetTableListByTaskAndSource(c *gin.Context, taskName string, sourceName string, schemaName string)
	// delete task source table structure
	// (DELETE /api/v1/tasks/{task-name}/sources/{source-name}/schemas/{schema-name}/{table-name})
	DMAPIDeleteTableStructure(c *gin.Context, taskName string, sourceName string, schemaName string, tableName string)
	// get task source table structure
	// (GET /api/v1/tasks/{task-name}/sources/{source-name}/schemas/{schema-name}/{table-name})
	DMAPIGetTableStructure(c *gin.Context, taskName string, sourceName string, schemaName string, tableName string)
	// operate task source table structure
	// (PUT /api/v1/tasks/{task-name}/sources/{source-name}/schemas/{schema-name}/{table-name})
	DMAPIOperateTableStructure(c *gin.Context, taskName string, sourceName string, schemaName string, tableName string)
	// start a task
	// (POST /api/v1/tasks/{task-name}/start)
	DMAPIStartTask(c *gin.Context, taskName string)
	// get task status
	// (GET /api/v1/tasks/{task-name}/status)
	DMAPIGetTaskStatus(c *gin.Context, taskName string, params DMAPIGetTaskStatusParams)
	// stop a task
	// (POST /api/v1/tasks/{task-name}/stop)
	DMAPIStopTask(c *gin.Context, taskName string)
}

ServerInterface represents all server handlers.

type ServerInterfaceWrapper

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
}

ServerInterfaceWrapper converts contexts to parameters.

func (*ServerInterfaceWrapper) DMAPIConvertTask

func (siw *ServerInterfaceWrapper) DMAPIConvertTask(c *gin.Context)

DMAPIConvertTask operation middleware

func (*ServerInterfaceWrapper) DMAPICreateSource

func (siw *ServerInterfaceWrapper) DMAPICreateSource(c *gin.Context)

DMAPICreateSource operation middleware

func (*ServerInterfaceWrapper) DMAPICreateTask

func (siw *ServerInterfaceWrapper) DMAPICreateTask(c *gin.Context)

DMAPICreateTask operation middleware

func (*ServerInterfaceWrapper) DMAPICreateTaskTemplate

func (siw *ServerInterfaceWrapper) DMAPICreateTaskTemplate(c *gin.Context)

DMAPICreateTaskTemplate operation middleware

func (*ServerInterfaceWrapper) DMAPIDeleteSource

func (siw *ServerInterfaceWrapper) DMAPIDeleteSource(c *gin.Context)

DMAPIDeleteSource operation middleware

func (*ServerInterfaceWrapper) DMAPIDeleteTableStructure

func (siw *ServerInterfaceWrapper) DMAPIDeleteTableStructure(c *gin.Context)

DMAPIDeleteTableStructure operation middleware

func (*ServerInterfaceWrapper) DMAPIDeleteTask

func (siw *ServerInterfaceWrapper) DMAPIDeleteTask(c *gin.Context)

DMAPIDeleteTask operation middleware

func (*ServerInterfaceWrapper) DMAPIDeleteTaskTemplate

func (siw *ServerInterfaceWrapper) DMAPIDeleteTaskTemplate(c *gin.Context)

DMAPIDeleteTaskTemplate operation middleware

func (*ServerInterfaceWrapper) DMAPIDisableRelay

func (siw *ServerInterfaceWrapper) DMAPIDisableRelay(c *gin.Context)

DMAPIDisableRelay operation middleware

func (*ServerInterfaceWrapper) DMAPIDisableSource

func (siw *ServerInterfaceWrapper) DMAPIDisableSource(c *gin.Context)

DMAPIDisableSource operation middleware

func (*ServerInterfaceWrapper) DMAPIEnableRelay

func (siw *ServerInterfaceWrapper) DMAPIEnableRelay(c *gin.Context)

DMAPIEnableRelay operation middleware

func (*ServerInterfaceWrapper) DMAPIEnableSource

func (siw *ServerInterfaceWrapper) DMAPIEnableSource(c *gin.Context)

DMAPIEnableSource operation middleware

func (*ServerInterfaceWrapper) DMAPIGetClusterInfo

func (siw *ServerInterfaceWrapper) DMAPIGetClusterInfo(c *gin.Context)

DMAPIGetClusterInfo operation middleware

func (*ServerInterfaceWrapper) DMAPIGetClusterMasterList

func (siw *ServerInterfaceWrapper) DMAPIGetClusterMasterList(c *gin.Context)

DMAPIGetClusterMasterList operation middleware

func (*ServerInterfaceWrapper) DMAPIGetClusterWorkerList

func (siw *ServerInterfaceWrapper) DMAPIGetClusterWorkerList(c *gin.Context)

DMAPIGetClusterWorkerList operation middleware

func (*ServerInterfaceWrapper) DMAPIGetSchemaListByTaskAndSource

func (siw *ServerInterfaceWrapper) DMAPIGetSchemaListByTaskAndSource(c *gin.Context)

DMAPIGetSchemaListByTaskAndSource operation middleware

func (*ServerInterfaceWrapper) DMAPIGetSource

func (siw *ServerInterfaceWrapper) DMAPIGetSource(c *gin.Context)

DMAPIGetSource operation middleware

func (*ServerInterfaceWrapper) DMAPIGetSourceList

func (siw *ServerInterfaceWrapper) DMAPIGetSourceList(c *gin.Context)

DMAPIGetSourceList operation middleware

func (*ServerInterfaceWrapper) DMAPIGetSourceSchemaList

func (siw *ServerInterfaceWrapper) DMAPIGetSourceSchemaList(c *gin.Context)

DMAPIGetSourceSchemaList operation middleware

func (*ServerInterfaceWrapper) DMAPIGetSourceStatus

func (siw *ServerInterfaceWrapper) DMAPIGetSourceStatus(c *gin.Context)

DMAPIGetSourceStatus operation middleware

func (*ServerInterfaceWrapper) DMAPIGetSourceTableList

func (siw *ServerInterfaceWrapper) DMAPIGetSourceTableList(c *gin.Context)

DMAPIGetSourceTableList operation middleware

func (*ServerInterfaceWrapper) DMAPIGetTableListByTaskAndSource

func (siw *ServerInterfaceWrapper) DMAPIGetTableListByTaskAndSource(c *gin.Context)

DMAPIGetTableListByTaskAndSource operation middleware

func (*ServerInterfaceWrapper) DMAPIGetTableStructure

func (siw *ServerInterfaceWrapper) DMAPIGetTableStructure(c *gin.Context)

DMAPIGetTableStructure operation middleware

func (*ServerInterfaceWrapper) DMAPIGetTask

func (siw *ServerInterfaceWrapper) DMAPIGetTask(c *gin.Context)

DMAPIGetTask operation middleware

func (*ServerInterfaceWrapper) DMAPIGetTaskList

func (siw *ServerInterfaceWrapper) DMAPIGetTaskList(c *gin.Context)

DMAPIGetTaskList operation middleware

func (*ServerInterfaceWrapper) DMAPIGetTaskMigrateTargets

func (siw *ServerInterfaceWrapper) DMAPIGetTaskMigrateTargets(c *gin.Context)

DMAPIGetTaskMigrateTargets operation middleware

func (*ServerInterfaceWrapper) DMAPIGetTaskStatus

func (siw *ServerInterfaceWrapper) DMAPIGetTaskStatus(c *gin.Context)

DMAPIGetTaskStatus operation middleware

func (*ServerInterfaceWrapper) DMAPIGetTaskTemplate

func (siw *ServerInterfaceWrapper) DMAPIGetTaskTemplate(c *gin.Context)

DMAPIGetTaskTemplate operation middleware

func (*ServerInterfaceWrapper) DMAPIGetTaskTemplateList

func (siw *ServerInterfaceWrapper) DMAPIGetTaskTemplateList(c *gin.Context)

DMAPIGetTaskTemplateList operation middleware

func (*ServerInterfaceWrapper) DMAPIImportTaskTemplate

func (siw *ServerInterfaceWrapper) DMAPIImportTaskTemplate(c *gin.Context)

DMAPIImportTaskTemplate operation middleware

func (*ServerInterfaceWrapper) DMAPIOfflineMasterNode

func (siw *ServerInterfaceWrapper) DMAPIOfflineMasterNode(c *gin.Context)

DMAPIOfflineMasterNode operation middleware

func (*ServerInterfaceWrapper) DMAPIOfflineWorkerNode

func (siw *ServerInterfaceWrapper) DMAPIOfflineWorkerNode(c *gin.Context)

DMAPIOfflineWorkerNode operation middleware

func (*ServerInterfaceWrapper) DMAPIOperateTableStructure

func (siw *ServerInterfaceWrapper) DMAPIOperateTableStructure(c *gin.Context)

DMAPIOperateTableStructure operation middleware

func (*ServerInterfaceWrapper) DMAPIPurgeRelay

func (siw *ServerInterfaceWrapper) DMAPIPurgeRelay(c *gin.Context)

DMAPIPurgeRelay operation middleware

func (*ServerInterfaceWrapper) DMAPIStartTask

func (siw *ServerInterfaceWrapper) DMAPIStartTask(c *gin.Context)

DMAPIStartTask operation middleware

func (*ServerInterfaceWrapper) DMAPIStopTask

func (siw *ServerInterfaceWrapper) DMAPIStopTask(c *gin.Context)

DMAPIStopTask operation middleware

func (*ServerInterfaceWrapper) DMAPITransferSource

func (siw *ServerInterfaceWrapper) DMAPITransferSource(c *gin.Context)

DMAPITransferSource operation middleware

func (*ServerInterfaceWrapper) DMAPIUpdateClusterInfo

func (siw *ServerInterfaceWrapper) DMAPIUpdateClusterInfo(c *gin.Context)

DMAPIUpdateClusterInfo operation middleware

func (*ServerInterfaceWrapper) DMAPIUpdateSource

func (siw *ServerInterfaceWrapper) DMAPIUpdateSource(c *gin.Context)

DMAPIUpdateSource operation middleware

func (*ServerInterfaceWrapper) DMAPIUpdateTask

func (siw *ServerInterfaceWrapper) DMAPIUpdateTask(c *gin.Context)

DMAPIUpdateTask operation middleware

func (*ServerInterfaceWrapper) DMAPUpdateTaskTemplate

func (siw *ServerInterfaceWrapper) DMAPUpdateTaskTemplate(c *gin.Context)

DMAPUpdateTaskTemplate operation middleware

func (*ServerInterfaceWrapper) GetDocHTML

func (siw *ServerInterfaceWrapper) GetDocHTML(c *gin.Context)

GetDocHTML operation middleware

func (*ServerInterfaceWrapper) GetDocJSON

func (siw *ServerInterfaceWrapper) GetDocJSON(c *gin.Context)

GetDocJSON operation middleware

type ShardingGroup

type ShardingGroup struct {
	DdlList       []string `json:"ddl_list"`
	FirstLocation string   `json:"first_location"`
	Synced        []string `json:"synced"`
	Target        string   `json:"target"`
	Unsynced      []string `json:"unsynced"`
}

ShardingGroup defines model for ShardingGroup.

type Source

type Source struct {
	// whether this source is enabled
	Enable bool `json:"enable"`

	// whether to use GTID to pull binlogs from upstream
	EnableGtid bool `json:"enable_gtid"`

	// flavor of this source
	Flavor *string `json:"flavor,omitempty"`

	// source address
	Host string `json:"host"`

	// source password
	Password *string `json:"password"`

	// source port
	Port int `json:"port"`

	// relay log cleanup policy configuration
	Purge *Purge `json:"purge,omitempty"`

	// the config of relay
	RelayConfig *RelayConfig `json:"relay_config,omitempty"`

	// data source ssl configuration, the field will be hidden when getting the data source configuration from the interface
	Security *Security `json:"security"`

	// source name
	SourceName string          `json:"source_name"`
	StatusList *[]SourceStatus `json:"status_list,omitempty"`

	// task name list
	TaskNameList *TaskNameList `json:"task_name_list,omitempty"`

	// source username
	User string `json:"user"`
}

source

type SourceNameList

type SourceNameList []string

source name list

type SourceStatus

type SourceStatus struct {
	// error message when something wrong
	ErrorMsg *string `json:"error_msg,omitempty"`

	// status of relay log
	RelayStatus *RelayStatus `json:"relay_status,omitempty"`

	// source name
	SourceName string `json:"source_name"`

	// The worker currently bound to the source
	WorkerName string `json:"worker_name"`
}

source status

type StartTaskRequest

type StartTaskRequest struct {
	// whether to remove meta database in downstream database
	RemoveMeta *bool `json:"remove_meta,omitempty"`

	// time duration of safe mode
	SafeModeTimeDuration *string `json:"safe_mode_time_duration,omitempty"`

	// source name list
	SourceNameList *SourceNameList `json:"source_name_list,omitempty"`

	// task start time
	StartTime *string `json:"start_time,omitempty"`
}

StartTaskRequest defines model for StartTaskRequest.

type StopTaskRequest

type StopTaskRequest struct {
	// source name list
	SourceNameList *SourceNameList `json:"source_name_list,omitempty"`

	// time duration waiting task stop
	TimeoutDuration *string `json:"timeout_duration,omitempty"`
}

StopTaskRequest defines model for StopTaskRequest.

type SubTaskStatus

type SubTaskStatus struct {
	// status of dump unit
	DumpStatus *DumpStatus `json:"dump_status,omitempty"`

	// error message when something wrong
	ErrorMsg *string `json:"error_msg,omitempty"`

	// status of load unit
	LoadStatus *LoadStatus `json:"load_status,omitempty"`

	// task name
	Name string `json:"name"`

	// source name
	SourceName string    `json:"source_name"`
	Stage      TaskStage `json:"stage"`

	// status of sync unit
	SyncStatus *SyncStatus `json:"sync_status,omitempty"`

	// task unit type
	Unit                string  `json:"unit"`
	UnresolvedDdlLockId *string `json:"unresolved_ddl_lock_id,omitempty"`

	// worker name
	WorkerName string `json:"worker_name"`
}

SubTaskStatus defines model for SubTaskStatus.

type SwaggerConfig

type SwaggerConfig struct {
	// SpecJsonPath the url to find the spec
	SpecJSONPath string
	// SwaggerHost for the js that generates the swagger ui site, defaults to: http://petstore3.swagger.io/
	SwaggerHost string
}

SwaggerConfig configures the SwaggerDoc middlewares.

func NewSwaggerConfig

func NewSwaggerConfig(specJSONPath, swaggerHost string) *SwaggerConfig

NewSwaggerConfig return swaggerConfig.

type SyncStatus

type SyncStatus struct {
	BinlogType string `json:"binlog_type"`

	// sharding DDL which current is blocking
	BlockingDdls        []string `json:"blocking_ddls"`
	DumpIoTotalBytes    uint64   `json:"dump_io_total_bytes"`
	IoTotalBytes        uint64   `json:"io_total_bytes"`
	MasterBinlog        string   `json:"master_binlog"`
	MasterBinlogGtid    string   `json:"master_binlog_gtid"`
	RecentTps           int64    `json:"recent_tps"`
	SecondsBehindMaster int64    `json:"seconds_behind_master"`
	Synced              bool     `json:"synced"`
	SyncerBinlog        string   `json:"syncer_binlog"`
	SyncerBinlogGtid    string   `json:"syncer_binlog_gtid"`
	TotalEvents         int64    `json:"total_events"`
	TotalTps            int64    `json:"total_tps"`

	// sharding groups which current are un-resolved
	UnresolvedGroups []ShardingGroup `json:"unresolved_groups"`
}

status of sync unit

type TableNameList

type TableNameList []string

schema name list

type Task

type Task struct {
	BinlogFilterRule *Task_BinlogFilterRule `json:"binlog_filter_rule,omitempty"`

	// whether to enable support for the online ddl plugin
	EnhanceOnlineSchemaChange bool `json:"enhance_online_schema_change"`

	// ignore precheck items
	IgnoreCheckingItems *[]string `json:"ignore_checking_items,omitempty"`

	// downstream database for storing meta information
	MetaSchema *string `json:"meta_schema,omitempty"`

	// task name
	Name string `json:"name"`

	// how to handle conflicted data
	OnDuplicate TaskOnDuplicate `json:"on_duplicate"`

	// the way to coordinate DDL
	ShardMode *TaskShardMode `json:"shard_mode,omitempty"`

	// source-related configuration
	SourceConfig TaskSourceConfig `json:"source_config"`
	StatusList   *[]SubTaskStatus `json:"status_list,omitempty"`

	// whether to enable strict optimistic shard mode
	StrictOptimisticShardMode *bool `json:"strict_optimistic_shard_mode,omitempty"`

	// table migrate rule
	TableMigrateRule []TaskTableMigrateRule `json:"table_migrate_rule"`

	// downstream database configuration
	TargetConfig TaskTargetDataBase `json:"target_config"`

	// migrate mode
	TaskMode TaskTaskMode `json:"task_mode"`
}

task

func (*Task) Adjust

func (t *Task) Adjust() error

Adjust adjusts task and set default value.

func (*Task) FromJSON

func (t *Task) FromJSON(data []byte) error

FromJSON unmarshal json to task.

func (*Task) ToJSON

func (t *Task) ToJSON() ([]byte, error)

ToJSON marshal json to task.

type TaskBinLogFilterRule

type TaskBinLogFilterRule struct {
	// event type
	IgnoreEvent *[]string `json:"ignore_event,omitempty"`

	// sql pattern to filter
	IgnoreSql *[]string `json:"ignore_sql,omitempty"`
}

Filtering rules at binlog level

type TaskFullMigrateConf

type TaskFullMigrateConf struct {
	// to control checksum of physical import
	Analyze *TaskFullMigrateConfAnalyze `json:"analyze,omitempty"`

	// to control checksum of physical import
	Checksum *TaskFullMigrateConfChecksum `json:"checksum,omitempty"`

	// to control compress kv pairs of physical import
	CompressKvPairs *string `json:"compress-kv-pairs,omitempty"`

	// to control the way in which data is exported for consistency assurance
	Consistency *string `json:"consistency,omitempty"`

	// storage dir name
	DataDir *string `json:"data_dir,omitempty"`

	// disk quota for physical import
	DiskQuota *string `json:"disk_quota,omitempty"`

	// full export of concurrent
	ExportThreads *int `json:"export_threads,omitempty"`

	// to control import mode of full import
	ImportMode *TaskFullMigrateConfImportMode `json:"import_mode,omitempty"`

	// full import of concurrent
	ImportThreads *int `json:"import_threads,omitempty"`

	// to control the duplication resolution when meet duplicate rows for logical import
	OnDuplicateLogical *TaskFullMigrateConfOnDuplicateLogical `json:"on_duplicate_logical,omitempty"`

	// to control the duplication resolution when meet duplicate rows for physical import
	OnDuplicatePhysical *TaskFullMigrateConfOnDuplicatePhysical `json:"on_duplicate_physical,omitempty"`

	// address of pd
	PdAddr *string `json:"pd_addr,omitempty"`

	// to control range concurrency of physical import
	RangeConcurrency *int `json:"range_concurrency,omitempty"`

	// sorting dir name for physical import
	SortingDir *string `json:"sorting_dir,omitempty"`
}

configuration of full migrate tasks

type TaskFullMigrateConfAnalyze

type TaskFullMigrateConfAnalyze string

to control checksum of physical import

const (
	TaskFullMigrateConfAnalyzeOff TaskFullMigrateConfAnalyze = "off"

	TaskFullMigrateConfAnalyzeOptional TaskFullMigrateConfAnalyze = "optional"

	TaskFullMigrateConfAnalyzeRequired TaskFullMigrateConfAnalyze = "required"
)

Defines values for TaskFullMigrateConfAnalyze.

type TaskFullMigrateConfChecksum

type TaskFullMigrateConfChecksum string

to control checksum of physical import

const (
	TaskFullMigrateConfChecksumOff TaskFullMigrateConfChecksum = "off"

	TaskFullMigrateConfChecksumOptional TaskFullMigrateConfChecksum = "optional"

	TaskFullMigrateConfChecksumRequired TaskFullMigrateConfChecksum = "required"
)

Defines values for TaskFullMigrateConfChecksum.

type TaskFullMigrateConfImportMode

type TaskFullMigrateConfImportMode string

to control import mode of full import

const (
	TaskFullMigrateConfImportModeLogical TaskFullMigrateConfImportMode = "logical"

	TaskFullMigrateConfImportModePhysical TaskFullMigrateConfImportMode = "physical"
)

Defines values for TaskFullMigrateConfImportMode.

type TaskFullMigrateConfOnDuplicateLogical

type TaskFullMigrateConfOnDuplicateLogical string

to control the duplication resolution when meet duplicate rows for logical import

const (
	TaskFullMigrateConfOnDuplicateLogicalError TaskFullMigrateConfOnDuplicateLogical = "error"

	TaskFullMigrateConfOnDuplicateLogicalIgnore TaskFullMigrateConfOnDuplicateLogical = "ignore"

	TaskFullMigrateConfOnDuplicateLogicalReplace TaskFullMigrateConfOnDuplicateLogical = "replace"
)

Defines values for TaskFullMigrateConfOnDuplicateLogical.

type TaskFullMigrateConfOnDuplicatePhysical

type TaskFullMigrateConfOnDuplicatePhysical string

to control the duplication resolution when meet duplicate rows for physical import

const (
	TaskFullMigrateConfOnDuplicatePhysicalManual TaskFullMigrateConfOnDuplicatePhysical = "manual"

	TaskFullMigrateConfOnDuplicatePhysicalNone TaskFullMigrateConfOnDuplicatePhysical = "none"
)

Defines values for TaskFullMigrateConfOnDuplicatePhysical.

type TaskIncrMigrateConf

type TaskIncrMigrateConf struct {
	// incremental synchronization of batch execution sql quantities
	ReplBatch *int `json:"repl_batch,omitempty"`

	// incremental task of concurrent
	ReplThreads *int `json:"repl_threads,omitempty"`
}

configuration of incremental tasks

type TaskMigrateTarget

type TaskMigrateTarget struct {
	SourceSchema string `json:"source_schema"`
	SourceTable  string `json:"source_table"`
	TargetSchema string `json:"target_schema"`
	TargetTable  string `json:"target_table"`
}

task migrate targets

type TaskNameList

type TaskNameList []string

task name list

type TaskOnDuplicate

type TaskOnDuplicate string

how to handle conflicted data

const (
	TaskOnDuplicateError TaskOnDuplicate = "error"

	TaskOnDuplicateIgnore TaskOnDuplicate = "ignore"

	TaskOnDuplicateReplace TaskOnDuplicate = "replace"
)

Defines values for TaskOnDuplicate.

type TaskShardMode

type TaskShardMode string

the way to coordinate DDL

const (
	TaskShardModeOptimistic TaskShardMode = "optimistic"

	TaskShardModePessimistic TaskShardMode = "pessimistic"
)

Defines values for TaskShardMode.

type TaskSourceConf

type TaskSourceConf struct {
	BinlogGtid *string `json:"binlog_gtid,omitempty"`
	BinlogName *string `json:"binlog_name,omitempty"`
	BinlogPos  *int    `json:"binlog_pos,omitempty"`

	// source name
	SourceName string `json:"source_name"`
}

TaskSourceConf defines model for TaskSourceConf.

type TaskSourceConfig

type TaskSourceConfig struct {
	// configuration of full migrate tasks
	FullMigrateConf *TaskFullMigrateConf `json:"full_migrate_conf,omitempty"`

	// configuration of incremental tasks
	IncrMigrateConf *TaskIncrMigrateConf `json:"incr_migrate_conf,omitempty"`

	// source configuration
	SourceConf []TaskSourceConf `json:"source_conf"`
}

source-related configuration

type TaskStage

type TaskStage string

TaskStage defines model for TaskStage.

const (
	TaskStageFinished TaskStage = "Finished"

	TaskStagePaused TaskStage = "Paused"

	TaskStageRunning TaskStage = "Running"

	TaskStageStopped TaskStage = "Stopped"
)

Defines values for TaskStage.

type TaskTableMigrateRule

type TaskTableMigrateRule struct {
	// filter rule name
	BinlogFilterRule *[]string `json:"binlog_filter_rule,omitempty"`

	// source-related configuration
	Source struct {
		// schema name, wildcard support
		Schema string `json:"schema"`

		// source name
		SourceName string `json:"source_name"`

		// table name, wildcard support
		Table string `json:"table"`
	} `json:"source"`

	// downstream-related configuration
	Target *struct {
		// schema name, does not support wildcards
		Schema *string `json:"schema,omitempty"`

		// table name, does not support wildcards
		Table *string `json:"table,omitempty"`
	} `json:"target,omitempty"`
}

upstream table to downstream migrate rules

type TaskTargetDataBase

type TaskTargetDataBase struct {
	// source address
	Host string `json:"host"`

	// source password
	Password string `json:"password"`

	// source port
	Port int `json:"port"`

	// data source ssl configuration, the field will be hidden when getting the data source configuration from the interface
	Security *Security `json:"security"`

	// source username
	User string `json:"user"`
}

downstream database configuration

type TaskTaskMode

type TaskTaskMode string

migrate mode

const (
	TaskTaskModeAll TaskTaskMode = "all"

	TaskTaskModeDump TaskTaskMode = "dump"

	TaskTaskModeFull TaskTaskMode = "full"

	TaskTaskModeIncremental TaskTaskMode = "incremental"

	TaskTaskModeLoad TaskTaskMode = "load"
)

Defines values for TaskTaskMode.

type TaskTemplateRequest

type TaskTemplateRequest struct {
	// whether to overwrite task template template
	Overwrite bool `json:"overwrite"`
}

TaskTemplateRequest defines model for TaskTemplateRequest.

type TaskTemplateResponse

type TaskTemplateResponse struct {
	FailedTaskList []struct {
		ErrorMsg string `json:"error_msg"`
		TaskName string `json:"task_name"`
	} `json:"failed_task_list"`
	SuccessTaskList []string `json:"success_task_list"`
}

TaskTemplateResponse defines model for TaskTemplateResponse.

type Task_BinlogFilterRule

type Task_BinlogFilterRule struct {
	AdditionalProperties map[string]TaskBinLogFilterRule `json:"-"`
}

Task_BinlogFilterRule defines model for Task.BinlogFilterRule.

func (Task_BinlogFilterRule) Get

func (a Task_BinlogFilterRule) Get(fieldName string) (value TaskBinLogFilterRule, found bool)

Getter for additional properties for Task_BinlogFilterRule. Returns the specified element and whether it was found

func (Task_BinlogFilterRule) MarshalJSON

func (a Task_BinlogFilterRule) MarshalJSON() ([]byte, error)

Override default JSON handling for Task_BinlogFilterRule to handle AdditionalProperties

func (*Task_BinlogFilterRule) Set

func (a *Task_BinlogFilterRule) Set(fieldName string, value TaskBinLogFilterRule)

Setter for additional properties for Task_BinlogFilterRule

func (*Task_BinlogFilterRule) UnmarshalJSON

func (a *Task_BinlogFilterRule) UnmarshalJSON(b []byte) error

Override default JSON handling for Task_BinlogFilterRule to handle AdditionalProperties

type UpdateSourceRequest

type UpdateSourceRequest struct {
	// source
	Source Source `json:"source"`
}

UpdateSourceRequest defines model for UpdateSourceRequest.

type UpdateTaskRequest

type UpdateTaskRequest struct {
	// task
	Task Task `json:"task"`
}

UpdateTaskRequest defines model for UpdateTaskRequest.

type WorkerNameList

type WorkerNameList []string

worker name list

type WorkerNameRequest

type WorkerNameRequest struct {
	// worker name
	WorkerName string `json:"worker_name"`
}

requests related to workers

type WorkerTopology

type WorkerTopology struct {
	Host string `json:"host"`
	Name string `json:"name"`
	Port int    `json:"port"`
}

WorkerTopology defines model for WorkerTopology.