openapi

package
v0.0.17 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

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

Code generated by github.com/oapi-codegen/oapi-codegen/v2 version v2.3.0 DO NOT EDIT.

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

Code generated by github.com/oapi-codegen/oapi-codegen/v2 version v2.3.0 DO NOT EDIT.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	// DebugAPIBasePath api debug base path
	DebugAPIBasePath = "/debug"
	// DBMSAPIBasePath api dbms api base path
	DBMSAPIBasePath = "/api/v1/"
)
View Source 
const (
	APIDatabasePath      = "database"
	APIDatasourcePath    = "datasource"
	APITaskPath          = "task"
	APIStructMigratePath = "structMigrate"
	APIStmtMigratePath   = "stmtMigrate"
	APISqlMigratePath    = "sqlMigrate"
	APICsvMigratePath    = "csvMigrate"
	APIDataComparePath   = "dataCompare"
	APIAssessMigratePath = "assessMigrate"
	APIStructComparePath = "structCompare"
	APIDataScanPath      = "dataScan"
	APICdcConsumePath    = "cdcConsume"
)
View Source 
const (
	RequestPUTMethod    = "PUT"
	RequestPOSTMethod   = "POST"
	RequestGETMethod    = "GET"
	RequestDELETEMethod = "DELETE"
)
View Source 
const (
	ResponseResultStatusSuccess = "success"
	ResponseResultStatusFailed  = "failed"
)

Variables

This section is empty.

Functions

func GetGinHTTPResponse 

func GetGinHTTPResponse(c *gin.Context) string

GetGinHTTPResponse gets gin http response

func GetHTTPDebugHandler 

func GetHTTPDebugHandler() http.Handler

GetHTTPDebugHandler returns a HTTP handler to handle debug information.

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 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.IRouter, si ServerInterface)

RegisterHandlers creates http.Handler with routing matching OpenAPI spec.

func RegisterHandlersWithOptions 

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

RegisterHandlersWithOptions creates http.Handler with additional options

func Request 

func Request(method, url string, body []byte) ([]byte, error)

Types

type APIDeleteAssessMigrateJSONRequestBody 

type APIDeleteAssessMigrateJSONRequestBody = RequestDeleteParam

APIDeleteAssessMigrateJSONRequestBody defines body for APIDeleteAssessMigrate for application/json ContentType.

type APIDeleteCdcConsumeJSONRequestBody added in v0.0.17 

type APIDeleteCdcConsumeJSONRequestBody = RequestDeleteParam

APIDeleteCdcConsumeJSONRequestBody defines body for APIDeleteCdcConsume for application/json ContentType.

type APIDeleteCsvMigrateJSONRequestBody 

type APIDeleteCsvMigrateJSONRequestBody = RequestDeleteParam

APIDeleteCsvMigrateJSONRequestBody defines body for APIDeleteCsvMigrate for application/json ContentType.

type APIDeleteDataCompareJSONRequestBody 

type APIDeleteDataCompareJSONRequestBody = RequestDeleteParam

APIDeleteDataCompareJSONRequestBody defines body for APIDeleteDataCompare for application/json ContentType.

type APIDeleteDataScanJSONRequestBody 

type APIDeleteDataScanJSONRequestBody = RequestDeleteParam

APIDeleteDataScanJSONRequestBody defines body for APIDeleteDataScan for application/json ContentType.

type APIDeleteDatasourceJSONRequestBody 

type APIDeleteDatasourceJSONRequestBody = RequestDeleteParam

APIDeleteDatasourceJSONRequestBody defines body for APIDeleteDatasource for application/json ContentType.

type APIDeleteSqlMigrateJSONRequestBody 

type APIDeleteSqlMigrateJSONRequestBody = RequestDeleteParam

APIDeleteSqlMigrateJSONRequestBody defines body for APIDeleteSqlMigrate for application/json ContentType.

type APIDeleteStmtMigrateJSONRequestBody 

type APIDeleteStmtMigrateJSONRequestBody = RequestDeleteParam

APIDeleteStmtMigrateJSONRequestBody defines body for APIDeleteStmtMigrate for application/json ContentType.

type APIDeleteStructCompareJSONRequestBody 

type APIDeleteStructCompareJSONRequestBody = RequestDeleteParam

APIDeleteStructCompareJSONRequestBody defines body for APIDeleteStructCompare for application/json ContentType.

type APIDeleteStructMigrateJSONRequestBody 

type APIDeleteStructMigrateJSONRequestBody = RequestDeleteParam

APIDeleteStructMigrateJSONRequestBody defines body for APIDeleteStructMigrate for application/json ContentType.

type APIListAssessMigrateJSONRequestBody 

type APIListAssessMigrateJSONRequestBody = RequestPostParam

APIListAssessMigrateJSONRequestBody defines body for APIListAssessMigrate for application/json ContentType.

type APIListCdcConsumeJSONRequestBody added in v0.0.17 

type APIListCdcConsumeJSONRequestBody = RequestPostParam

APIListCdcConsumeJSONRequestBody defines body for APIListCdcConsume for application/json ContentType.

type APIListCsvMigrateJSONRequestBody 

type APIListCsvMigrateJSONRequestBody = RequestPostParam

APIListCsvMigrateJSONRequestBody defines body for APIListCsvMigrate for application/json ContentType.

type APIListDataCompareJSONRequestBody 

type APIListDataCompareJSONRequestBody = RequestPostParam

APIListDataCompareJSONRequestBody defines body for APIListDataCompare for application/json ContentType.

type APIListDataScanJSONRequestBody 

type APIListDataScanJSONRequestBody = RequestPostParam

APIListDataScanJSONRequestBody defines body for APIListDataScan for application/json ContentType.

type APIListDatasourceJSONRequestBody 

type APIListDatasourceJSONRequestBody = RequestPostParam

APIListDatasourceJSONRequestBody defines body for APIListDatasource for application/json ContentType.

type APIListSqlMigrateJSONRequestBody 

type APIListSqlMigrateJSONRequestBody = RequestPostParam

APIListSqlMigrateJSONRequestBody defines body for APIListSqlMigrate for application/json ContentType.

type APIListStmtMigrateJSONRequestBody 

type APIListStmtMigrateJSONRequestBody = RequestPostParam

APIListStmtMigrateJSONRequestBody defines body for APIListStmtMigrate for application/json ContentType.

type APIListStructCompareJSONRequestBody 

type APIListStructCompareJSONRequestBody = RequestPostParam

APIListStructCompareJSONRequestBody defines body for APIListStructCompare for application/json ContentType.

type APIListStructMigrateJSONRequestBody 

type APIListStructMigrateJSONRequestBody = RequestPostParam

APIListStructMigrateJSONRequestBody defines body for APIListStructMigrate for application/json ContentType.

type APIPostTaskJSONRequestBody 

type APIPostTaskJSONRequestBody = Task

APIPostTaskJSONRequestBody defines body for APIPostTask for application/json ContentType.

type APIPutAssessMigrateJSONRequestBody 

type APIPutAssessMigrateJSONRequestBody = AssessMigrateTask

APIPutAssessMigrateJSONRequestBody defines body for APIPutAssessMigrate for application/json ContentType.

type APIPutCdcConsumeJSONRequestBody added in v0.0.17 

type APIPutCdcConsumeJSONRequestBody = CdcConsumeTask

APIPutCdcConsumeJSONRequestBody defines body for APIPutCdcConsume for application/json ContentType.

type APIPutCsvMigrateJSONRequestBody 

type APIPutCsvMigrateJSONRequestBody = CsvMigrateTask

APIPutCsvMigrateJSONRequestBody defines body for APIPutCsvMigrate for application/json ContentType.

type APIPutDataCompareJSONRequestBody 

type APIPutDataCompareJSONRequestBody = DataCompareTask

APIPutDataCompareJSONRequestBody defines body for APIPutDataCompare for application/json ContentType.

type APIPutDataScanJSONRequestBody 

type APIPutDataScanJSONRequestBody = DataScanTask

APIPutDataScanJSONRequestBody defines body for APIPutDataScan for application/json ContentType.

type APIPutDatabaseJSONRequestBody 

type APIPutDatabaseJSONRequestBody = Database

APIPutDatabaseJSONRequestBody defines body for APIPutDatabase for application/json ContentType.

type APIPutDatasourceJSONRequestBody 

type APIPutDatasourceJSONRequestBody = NewDatasource

APIPutDatasourceJSONRequestBody defines body for APIPutDatasource for application/json ContentType.

type APIPutSqlMigrateJSONRequestBody 

type APIPutSqlMigrateJSONRequestBody = SqlMigrateTask

APIPutSqlMigrateJSONRequestBody defines body for APIPutSqlMigrate for application/json ContentType.

type APIPutStmtMigrateJSONRequestBody 

type APIPutStmtMigrateJSONRequestBody = StmtMigrateTask

APIPutStmtMigrateJSONRequestBody defines body for APIPutStmtMigrate for application/json ContentType.

type APIPutStructCompareJSONRequestBody 

type APIPutStructCompareJSONRequestBody = StructCompareTask

APIPutStructCompareJSONRequestBody defines body for APIPutStructCompare for application/json ContentType.

type APIPutStructMigrateJSONRequestBody 

type APIPutStructMigrateJSONRequestBody = StructMigrateTask

APIPutStructMigrateJSONRequestBody defines body for APIPutStructMigrate for application/json ContentType.

type AssessMigrateParam 

type AssessMigrateParam struct {
	CallTimeout    *uint64 `json:"callTimeout,omitempty"`
	CaseFieldRuleS *string `json:"caseFieldRuleS,omitempty"`
	SchemaNameS    *string `json:"schemaNameS,omitempty"`
}

AssessMigrateParam defines model for AssessMigrateParam.

type AssessMigrateTask 

type AssessMigrateTask struct {
	AssessMigrateParam *AssessMigrateParam `json:"assessMigrateParam,omitempty"`
	Comment            *string             `json:"comment"`
	DatasourceNameS    *string             `json:"datasourceNameS,omitempty"`
	DatasourceNameT    *string             `json:"datasourceNameT,omitempty"`
	TaskName           *string             `json:"taskName,omitempty"`
}

AssessMigrateTask defines model for AssessMigrateTask.

type CaseFieldRule 

type CaseFieldRule struct {
	CaseFieldRuleS *string `json:"caseFieldRuleS,omitempty"`
	CaseFieldRuleT *string `json:"caseFieldRuleT,omitempty"`
}

CaseFieldRule defines model for CaseFieldRule.

type CdcConsumeParam added in v0.0.17 

type CdcConsumeParam struct {
	CallTimeout           *uint64   `json:"callTimeout,omitempty"`
	EnableCheckpoint      *bool     `json:"enableCheckpoint,omitempty"`
	IdleResolvedThreshold *uint64   `json:"idleResolvedThreshold,omitempty"`
	MessageCompression    *string   `json:"messageCompression,omitempty"`
	ServerAddress         *[]string `json:"serverAddress,omitempty"`
	SubscribeTopic        *string   `json:"subscribeTopic,omitempty"`
	TableThread           *uint64   `json:"tableThread,omitempty"`
}

CdcConsumeParam defines model for CdcConsumeParam.

type CdcConsumeTask added in v0.0.17 

type CdcConsumeTask struct {
	CaseFieldRule   *CaseFieldRule   `json:"caseFieldRule,omitempty"`
	CdcConsumeParam *CdcConsumeParam `json:"cdcConsumeParam,omitempty"`
	Comment         *string          `json:"comment"`
	DatasourceNameS *string          `json:"datasourceNameS,omitempty"`
	DatasourceNameT *string          `json:"datasourceNameT,omitempty"`
	SchemaRouteRule *SchemaRouteRule `json:"schemaRouteRule,omitempty"`
	TaskName        *string          `json:"taskName,omitempty"`
}

CdcConsumeTask defines model for CdcConsumeTask.

type ColumnStructRule 

type ColumnStructRule struct {
	ColumnNameS   *string `json:"columnNameS,omitempty"`
	ColumnTypeS   *string `json:"columnTypeS"`
	ColumnTypeT   *string `json:"columnTypeT"`
	DefaultValueS *string `json:"defaultValueS"`
	DefaultValueT *string `json:"defaultValueT"`
	SchemaNameS   *string `json:"schemaNameS,omitempty"`
	TableNameS    *string `json:"tableNameS,omitempty"`
}

ColumnStructRule defines model for ColumnStructRule.

type CsvMigrateParam 

type CsvMigrateParam struct {
	BatchSize            *uint64            `json:"batchSize,omitempty"`
	CallTimeout          *uint64            `json:"callTimeout,omitempty"`
	ChunkSize            *uint64            `json:"chunkSize,omitempty"`
	CsvImportParams      *map[string]string `json:"csvImportParams"`
	DataCharsetT         *string            `json:"dataCharsetT,omitempty"`
	Delimiter            *string            `json:"delimiter,omitempty"`
	DiskUsageFactor      *string            `json:"diskUsageFactor,omitempty"`
	EnableCheckpoint     *bool              `json:"enableCheckpoint,omitempty"`
	EnableConsistentRead *bool              `json:"enableConsistentRead,omitempty"`
	EnableImportFeature  *bool              `json:"enableImportFeature,omitempty"`
	EscapeBackslash      *bool              `json:"escapeBackslash,omitempty"`
	Header               *bool              `json:"header,omitempty"`
	NullValue            *string            `json:"nullValue,omitempty"`
	OutputDir            *string            `json:"outputDir,omitempty"`
	Separator            *string            `json:"separator,omitempty"`
	SqlHintS             *string            `json:"sqlHintS,omitempty"`
	SqlThreadS           *uint64            `json:"sqlThreadS,omitempty"`
	TableThread          *uint64            `json:"tableThread,omitempty"`
	Terminator           *string            `json:"terminator,omitempty"`
	WriteThread          *uint64            `json:"writeThread,omitempty"`
}

CsvMigrateParam defines model for CsvMigrateParam.

type CsvMigrateTask 

type CsvMigrateTask struct {
	CaseFieldRule    *CaseFieldRule     `json:"caseFieldRule,omitempty"`
	Comment          *string            `json:"comment"`
	CsvMigrateParam  *CsvMigrateParam   `json:"csvMigrateParam,omitempty"`
	DataMigrateRules *[]DataMigrateRule `json:"dataMigrateRules"`
	DatasourceNameS  *string            `json:"datasourceNameS,omitempty"`
	DatasourceNameT  *string            `json:"datasourceNameT,omitempty"`
	SchemaRouteRule  *SchemaRouteRule   `json:"schemaRouteRule,omitempty"`
	TaskName         *string            `json:"taskName,omitempty"`
}

CsvMigrateTask defines model for CsvMigrateTask.

type DataCompareParam 

type DataCompareParam struct {
	BatchSize              *uint64   `json:"batchSize,omitempty"`
	CallTimeout            *uint64   `json:"callTimeout,omitempty"`
	ChunkSize              *uint64   `json:"chunkSize,omitempty"`
	ConsistentReadPointS   *string   `json:"consistentReadPointS,omitempty"`
	ConsistentReadPointT   *string   `json:"consistentReadPointT,omitempty"`
	DisableMd5Checksum     *bool     `json:"disableMd5Checksum,omitempty"`
	EnableCheckpoint       *bool     `json:"enableCheckpoint,omitempty"`
	EnableCollationSetting *bool     `json:"enableCollationSetting,omitempty"`
	EnableConsistentRead   *bool     `json:"enableConsistentRead,omitempty"`
	IgnoreConditionFields  *[]string `json:"ignoreConditionFields,omitempty"`
	OnlyCompareRow         *bool     `json:"onlyCompareRow,omitempty"`
	RepairStmtFlow         *string   `json:"repairStmtFlow,omitempty"`
	Separator              *string   `json:"separator,omitempty"`
	SqlHintS               *string   `json:"sqlHintS,omitempty"`
	SqlHintT               *string   `json:"sqlHintT,omitempty"`
	SqlThread              *uint64   `json:"sqlThread,omitempty"`
	TableThread            *uint64   `json:"tableThread,omitempty"`
	WriteThread            *uint64   `json:"writeThread,omitempty"`
}

DataCompareParam defines model for DataCompareParam.

type DataCompareRule 

type DataCompareRule struct {
	CompareConditionField  *string   `json:"compareConditionField,omitempty"`
	CompareConditionRangeS *string   `json:"compareConditionRangeS,omitempty"`
	CompareConditionRangeT *string   `json:"compareConditionRangeT,omitempty"`
	IgnoreConditionFields  *[]string `json:"ignoreConditionFields,omitempty"`
	IgnoreSelectFields     *[]string `json:"ignoreSelectFields,omitempty"`
	SqlHintS               *string   `json:"sqlHintS,omitempty"`
	SqlHintT               *string   `json:"sqlHintT,omitempty"`
	TableNameS             *string   `json:"tableNameS,omitempty"`
}

DataCompareRule defines model for DataCompareRule.

type DataCompareTask 

type DataCompareTask struct {
	CaseFieldRule    *CaseFieldRule     `json:"caseFieldRule,omitempty"`
	Comment          *string            `json:"comment"`
	DataCompareParam *DataCompareParam  `json:"dataCompareParam,omitempty"`
	DataCompareRules *[]DataCompareRule `json:"dataCompareRules"`
	DatasourceNameS  *string            `json:"datasourceNameS,omitempty"`
	DatasourceNameT  *string            `json:"datasourceNameT,omitempty"`
	SchemaRouteRule  *SchemaRouteRule   `json:"schemaRouteRule,omitempty"`
	TaskName         *string            `json:"taskName,omitempty"`
}

DataCompareTask defines model for DataCompareTask.

type DataMigrateRule 

type DataMigrateRule struct {
	EnableChunkStrategy *bool   `json:"enableChunkStrategy,omitempty"`
	SqlHintS            *string `json:"sqlHintS,omitempty"`
	TableNameS          *string `json:"tableNameS,omitempty"`
	WhereRange          *string `json:"whereRange,omitempty"`
}

DataMigrateRule defines model for DataMigrateRule.

type DataScanParam 

type DataScanParam struct {
	BatchSize            *uint64 `json:"batchSize,omitempty"`
	CallTimeout          *uint64 `json:"callTimeout,omitempty"`
	ChunkSize            *uint64 `json:"chunkSize,omitempty"`
	EnableCheckpoint     *bool   `json:"enableCheckpoint,omitempty"`
	EnableConsistentRead *bool   `json:"enableConsistentRead,omitempty"`
	SqlHintS             *string `json:"sqlHintS,omitempty"`
	SqlThreadS           *uint64 `json:"sqlThreadS,omitempty"`
	TableSamplerateS     *uint64 `json:"tableSamplerateS,omitempty"`
	TableThread          *uint64 `json:"tableThread,omitempty"`
	WriteThread          *uint64 `json:"writeThread,omitempty"`
}

DataScanParam defines model for DataScanParam.

type DataScanRule 

type DataScanRule struct {
	SqlHintS         *string `json:"sqlHintS,omitempty"`
	TableNameS       *string `json:"tableNameS,omitempty"`
	TableSamplerateS *uint64 `json:"tableSamplerateS,omitempty"`
}

DataScanRule defines model for DataScanRule.

type DataScanTask 

type DataScanTask struct {
	CaseFieldRule   *CaseFieldRule   `json:"caseFieldRule,omitempty"`
	Comment         *string          `json:"comment"`
	DataScanParam   *DataScanParam   `json:"dataScanParam,omitempty"`
	DataScanRules   *[]DataScanRule  `json:"dataScanRules"`
	DatasourceNameS *string          `json:"datasourceNameS,omitempty"`
	DatasourceNameT *string          `json:"datasourceNameT,omitempty"`
	SchemaRouteRule *SchemaRouteRule `json:"schemaRouteRule,omitempty"`
	TaskName        *string          `json:"taskName,omitempty"`
}

DataScanTask defines model for DataScanTask.

type Database 

type Database struct {
	Host          *string `json:"host,omitempty"`
	InitThread    *uint64 `json:"initThread,omitempty"`
	Password      *string `json:"password,omitempty"`
	Port          *uint64 `json:"port,omitempty"`
	Schema        *string `json:"schema,omitempty"`
	SlowThreshold *uint64 `json:"slowThreshold,omitempty"`
	Username      *string `json:"username,omitempty"`
}

Database defines model for Database.

type Datasource 

type Datasource struct {
	Comment        *string `json:"comment"`
	ConnectCharset *string `json:"connectCharset,omitempty"`
	ConnectParams  *string `json:"connectParams"`
	ConnectStatus  *string `json:"connectStatus"`
	DatasourceName *string `json:"datasourceName,omitempty"`
	DbName         *string `json:"dbName"`
	DbType         *string `json:"dbType,omitempty"`
	Host           *string `json:"host,omitempty"`
	Password       *string `json:"password,omitempty"`
	PdbName        *string `json:"pdbName"`
	Port           *uint64 `json:"port,omitempty"`
	ServiceName    *string `json:"serviceName"`
	SessionParams  *string `json:"sessionParams"`
	Username       *string `json:"username,omitempty"`
}

Datasource defines model for Datasource.

type GinServerOptions 

type GinServerOptions struct {
	BaseURL      string
	Middlewares  []MiddlewareFunc
	ErrorHandler func(*gin.Context, error, int)
}

GinServerOptions provides options for the Gin server.

type MiddlewareFunc 

type MiddlewareFunc func(c *gin.Context)

type NewDatasource 

type NewDatasource struct {
	Datasource *[]Datasource `json:"datasource,omitempty"`
}

NewDatasource defines model for NewDatasource.

type RequestDeleteParam 

type RequestDeleteParam struct {
	Param *[]string `json:"param,omitempty"`
}

RequestDeleteParam defines model for RequestDeleteParam.

type RequestPostParam 

type RequestPostParam struct {
	Page     *uint64 `json:"page,omitempty"`
	PageSize *uint64 `json:"pageSize,omitempty"`
	Param    *string `json:"param,omitempty"`
}

RequestPostParam defines model for RequestPostParam.

type Response 

type Response struct {
	Code  uint64 `json:"code"`
	Data  string `json:"data"`
	Error string `json:"error"`
}

Response defines model for Response.

type SchemaRouteRule 

type SchemaRouteRule struct {
	ExcludeSequenceS *[]string         `json:"excludeSequenceS"`
	ExcludeTableS    *[]string         `json:"excludeTableS"`
	IncludeSequenceS *[]string         `json:"includeSequenceS"`
	IncludeTableS    *[]string         `json:"includeTableS"`
	SchemaNameS      *string           `json:"schemaNameS,omitempty"`
	SchemaNameT      *string           `json:"schemaNameT,omitempty"`
	TableRouteRules  *[]TableRouteRule `json:"tableRouteRules"`
}

SchemaRouteRule defines model for SchemaRouteRule.

type SchemaStructRule 

type SchemaStructRule struct {
	ColumnTypeS   *string `json:"columnTypeS"`
	ColumnTypeT   *string `json:"columnTypeT"`
	DefaultValueS *string `json:"defaultValueS"`
	DefaultValueT *string `json:"defaultValueT"`
	SchemaNameS   *string `json:"schemaNameS,omitempty"`
}

SchemaStructRule defines model for SchemaStructRule.

type ServerInterface 

type ServerInterface interface {

	// (DELETE /database)
	APIDeleteDatabase(c *gin.Context)

	// (GET /database)
	APIListDatabase(c *gin.Context)

	// (PUT /database)
	APIPutDatabase(c *gin.Context)

	// (DELETE /datasource)
	APIDeleteDatasource(c *gin.Context)

	// (POST /datasource)
	APIListDatasource(c *gin.Context)

	// (PUT /datasource)
	APIPutDatasource(c *gin.Context)

	// (POST /task)
	APIPostTask(c *gin.Context)

	// (DELETE /task/assessMigrate)
	APIDeleteAssessMigrate(c *gin.Context)

	// (POST /task/assessMigrate)
	APIListAssessMigrate(c *gin.Context)

	// (PUT /task/assessMigrate)
	APIPutAssessMigrate(c *gin.Context)

	// (DELETE /task/cdcConsume)
	APIDeleteCdcConsume(c *gin.Context)

	// (POST /task/cdcConsume)
	APIListCdcConsume(c *gin.Context)

	// (PUT /task/cdcConsume)
	APIPutCdcConsume(c *gin.Context)

	// (DELETE /task/csvMigrate)
	APIDeleteCsvMigrate(c *gin.Context)

	// (POST /task/csvMigrate)
	APIListCsvMigrate(c *gin.Context)

	// (PUT /task/csvMigrate)
	APIPutCsvMigrate(c *gin.Context)

	// (DELETE /task/dataCompare)
	APIDeleteDataCompare(c *gin.Context)

	// (POST /task/dataCompare)
	APIListDataCompare(c *gin.Context)

	// (PUT /task/dataCompare)
	APIPutDataCompare(c *gin.Context)

	// (DELETE /task/dataScan)
	APIDeleteDataScan(c *gin.Context)

	// (POST /task/dataScan)
	APIListDataScan(c *gin.Context)

	// (PUT /task/dataScan)
	APIPutDataScan(c *gin.Context)

	// (DELETE /task/sqlMigrate)
	APIDeleteSqlMigrate(c *gin.Context)

	// (POST /task/sqlMigrate)
	APIListSqlMigrate(c *gin.Context)

	// (PUT /task/sqlMigrate)
	APIPutSqlMigrate(c *gin.Context)

	// (DELETE /task/stmtMigrate)
	APIDeleteStmtMigrate(c *gin.Context)

	// (POST /task/stmtMigrate)
	APIListStmtMigrate(c *gin.Context)

	// (PUT /task/stmtMigrate)
	APIPutStmtMigrate(c *gin.Context)

	// (DELETE /task/structCompare)
	APIDeleteStructCompare(c *gin.Context)

	// (POST /task/structCompare)
	APIListStructCompare(c *gin.Context)

	// (PUT /task/structCompare)
	APIPutStructCompare(c *gin.Context)

	// (DELETE /task/structMigrate)
	APIDeleteStructMigrate(c *gin.Context)

	// (POST /task/structMigrate)
	APIListStructMigrate(c *gin.Context)

	// (PUT /task/structMigrate)
	APIPutStructMigrate(c *gin.Context)
}

ServerInterface represents all server handlers.

type ServerInterfaceWrapper 

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
	ErrorHandler       func(*gin.Context, error, int)
}

ServerInterfaceWrapper converts contexts to parameters.

func (*ServerInterfaceWrapper) APIDeleteAssessMigrate 

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

APIDeleteAssessMigrate operation middleware

func (*ServerInterfaceWrapper) APIDeleteCdcConsume added in v0.0.17 

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

APIDeleteCdcConsume operation middleware

func (*ServerInterfaceWrapper) APIDeleteCsvMigrate 

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

APIDeleteCsvMigrate operation middleware

func (*ServerInterfaceWrapper) APIDeleteDataCompare 

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

APIDeleteDataCompare operation middleware

func (*ServerInterfaceWrapper) APIDeleteDataScan 

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

APIDeleteDataScan operation middleware

func (*ServerInterfaceWrapper) APIDeleteDatabase 

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

APIDeleteDatabase operation middleware

func (*ServerInterfaceWrapper) APIDeleteDatasource 

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

APIDeleteDatasource operation middleware

func (*ServerInterfaceWrapper) APIDeleteSqlMigrate 

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

APIDeleteSqlMigrate operation middleware

func (*ServerInterfaceWrapper) APIDeleteStmtMigrate 

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

APIDeleteStmtMigrate operation middleware

func (*ServerInterfaceWrapper) APIDeleteStructCompare 

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

APIDeleteStructCompare operation middleware

func (*ServerInterfaceWrapper) APIDeleteStructMigrate 

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

APIDeleteStructMigrate operation middleware

func (*ServerInterfaceWrapper) APIListAssessMigrate 

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

APIListAssessMigrate operation middleware

func (*ServerInterfaceWrapper) APIListCdcConsume added in v0.0.17 

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

APIListCdcConsume operation middleware

func (*ServerInterfaceWrapper) APIListCsvMigrate 

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

APIListCsvMigrate operation middleware

func (*ServerInterfaceWrapper) APIListDataCompare 

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

APIListDataCompare operation middleware

func (*ServerInterfaceWrapper) APIListDataScan 

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

APIListDataScan operation middleware

func (*ServerInterfaceWrapper) APIListDatabase 

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

APIListDatabase operation middleware

func (*ServerInterfaceWrapper) APIListDatasource 

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

APIListDatasource operation middleware

func (*ServerInterfaceWrapper) APIListSqlMigrate 

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

APIListSqlMigrate operation middleware

func (*ServerInterfaceWrapper) APIListStmtMigrate 

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

APIListStmtMigrate operation middleware

func (*ServerInterfaceWrapper) APIListStructCompare 

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

APIListStructCompare operation middleware

func (*ServerInterfaceWrapper) APIListStructMigrate 

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

APIListStructMigrate operation middleware

func (*ServerInterfaceWrapper) APIPostTask 

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

APIPostTask operation middleware

func (*ServerInterfaceWrapper) APIPutAssessMigrate 

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

APIPutAssessMigrate operation middleware

func (*ServerInterfaceWrapper) APIPutCdcConsume added in v0.0.17 

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

APIPutCdcConsume operation middleware

func (*ServerInterfaceWrapper) APIPutCsvMigrate 

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

APIPutCsvMigrate operation middleware

func (*ServerInterfaceWrapper) APIPutDataCompare 

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

APIPutDataCompare operation middleware

func (*ServerInterfaceWrapper) APIPutDataScan 

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

APIPutDataScan operation middleware

func (*ServerInterfaceWrapper) APIPutDatabase 

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

APIPutDatabase operation middleware

func (*ServerInterfaceWrapper) APIPutDatasource 

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

APIPutDatasource operation middleware

func (*ServerInterfaceWrapper) APIPutSqlMigrate 

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

APIPutSqlMigrate operation middleware

func (*ServerInterfaceWrapper) APIPutStmtMigrate 

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

APIPutStmtMigrate operation middleware

func (*ServerInterfaceWrapper) APIPutStructCompare 

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

APIPutStructCompare operation middleware

func (*ServerInterfaceWrapper) APIPutStructMigrate 

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

APIPutStructMigrate operation middleware

type SqlMigrateParam 

type SqlMigrateParam struct {
	BatchSize            *uint64 `json:"batchSize,omitempty"`
	CallTimeout          *uint64 `json:"callTimeout,omitempty"`
	EnableCheckpoint     *bool   `json:"enableCheckpoint,omitempty"`
	EnableConsistentRead *bool   `json:"enableConsistentRead,omitempty"`
	EnablePrepareStmt    *bool   `json:"enablePrepareStmt,omitempty"`
	EnableSafeMode       *bool   `json:"enableSafeMode,omitempty"`
	SqlHintT             *string `json:"sqlHintT,omitempty"`
	SqlThreadS           *uint64 `json:"sqlThreadS,omitempty"`
	SqlThreadT           *uint64 `json:"sqlThreadT,omitempty"`
	WriteThread          *uint64 `json:"writeThread,omitempty"`
}

SqlMigrateParam defines model for SqlMigrateParam.

type SqlMigrateRule 

type SqlMigrateRule struct {
	CaseFieldRuleT   *string            `json:"caseFieldRuleT,omitempty"`
	ColumnRouteRules *map[string]string `json:"columnRouteRules"`
	SchemaNameT      *string            `json:"schemaNameT,omitempty"`
	SqlHintT         *string            `json:"sqlHintT,omitempty"`
	SqlQueryS        *string            `json:"sqlQueryS,omitempty"`
	TableNameT       *string            `json:"tableNameT,omitempty"`
}

SqlMigrateRule defines model for SqlMigrateRule.

type SqlMigrateTask 

type SqlMigrateTask struct {
	CaseFieldRule   *CaseFieldRule    `json:"caseFieldRule,omitempty"`
	Comment         *string           `json:"comment"`
	DatasourceNameS *string           `json:"datasourceNameS,omitempty"`
	DatasourceNameT *string           `json:"datasourceNameT,omitempty"`
	SqlMigrateParam *SqlMigrateParam  `json:"sqlMigrateParam,omitempty"`
	SqlMigrateRules *[]SqlMigrateRule `json:"sqlMigrateRules"`
	TaskName        *string           `json:"taskName,omitempty"`
}

SqlMigrateTask defines model for SqlMigrateTask.

type StatementMigrateParam 

type StatementMigrateParam struct {
	BatchSize            *uint64 `json:"batchSize,omitempty"`
	CallTimeout          *uint64 `json:"callTimeout,omitempty"`
	ChunkSize            *uint64 `json:"chunkSize,omitempty"`
	EnableCheckpoint     *bool   `json:"enableCheckpoint,omitempty"`
	EnableConsistentRead *bool   `json:"enableConsistentRead,omitempty"`
	EnablePrepareStmt    *bool   `json:"enablePrepareStmt,omitempty"`
	EnableSafeMode       *bool   `json:"enableSafeMode,omitempty"`
	SqlHintS             *string `json:"sqlHintS,omitempty"`
	SqlHintT             *string `json:"sqlHintT,omitempty"`
	SqlThreadS           *uint64 `json:"sqlThreadS,omitempty"`
	SqlThreadT           *uint64 `json:"sqlThreadT,omitempty"`
	TableThread          *uint64 `json:"tableThread,omitempty"`
	WriteThread          *uint64 `json:"writeThread,omitempty"`
}

StatementMigrateParam defines model for StatementMigrateParam.

type StmtMigrateTask 

type StmtMigrateTask struct {
	DataMigrateRules      *[]DataMigrateRule     `json:"DataMigrateRules"`
	CaseFieldRule         *CaseFieldRule         `json:"caseFieldRule,omitempty"`
	Comment               *string                `json:"comment"`
	DatasourceNameS       *string                `json:"datasourceNameS,omitempty"`
	DatasourceNameT       *string                `json:"datasourceNameT,omitempty"`
	SchemaRouteRule       *SchemaRouteRule       `json:"schemaRouteRule,omitempty"`
	StatementMigrateParam *StatementMigrateParam `json:"statementMigrateParam,omitempty"`
	TaskName              *string                `json:"taskName,omitempty"`
}

StmtMigrateTask defines model for StmtMigrateTask.

type StructCompareParam 

type StructCompareParam struct {
	CallTimeout       *uint64 `json:"callTimeout,omitempty"`
	CompareThread     *uint64 `json:"compareThread,omitempty"`
	EnableCheckpoint  *bool   `json:"enableCheckpoint,omitempty"`
	IgnoreCaseCompare *bool   `json:"ignoreCaseCompare,omitempty"`
}

StructCompareParam defines model for StructCompareParam.

type StructCompareRule 

type StructCompareRule struct {
	ColumnStructRules *[]ColumnStructRule `json:"columnStructRules"`
	SchemaStructRules *[]SchemaStructRule `json:"schemaStructRules"`
	TableStructRules  *[]TableStructRule  `json:"tableStructRules"`
	TaskStructRules   *[]TaskStructRule   `json:"taskStructRules"`
}

StructCompareRule defines model for StructCompareRule.

type StructCompareTask 

type StructCompareTask struct {
	CaseFieldRule      *CaseFieldRule      `json:"caseFieldRule,omitempty"`
	Comment            *string             `json:"comment"`
	DatasourceNameS    *string             `json:"datasourceNameS,omitempty"`
	DatasourceNameT    *string             `json:"datasourceNameT,omitempty"`
	SchemaRouteRule    *SchemaRouteRule    `json:"schemaRouteRule,omitempty"`
	StructCompareParam *StructCompareParam `json:"structCompareParam,omitempty"`
	StructCompareRule  *StructCompareRule  `json:"structCompareRule,omitempty"`
	TaskName           *string             `json:"taskName,omitempty"`
}

StructCompareTask defines model for StructCompareTask.

type StructMigrateParam 

type StructMigrateParam struct {
	CallTimeout        *uint64 `json:"callTimeout,omitempty"`
	CreateIfNotExist   *bool   `json:"createIfNotExist,omitempty"`
	EnableCheckpoint   *bool   `json:"enableCheckpoint,omitempty"`
	EnableDirectCreate *bool   `json:"enableDirectCreate,omitempty"`
	MigrateThread      *uint64 `json:"migrateThread,omitempty"`
}

StructMigrateParam defines model for StructMigrateParam.

type StructMigrateRule 

type StructMigrateRule struct {
	ColumnStructRules *[]ColumnStructRule `json:"columnStructRules"`
	SchemaStructRules *[]SchemaStructRule `json:"schemaStructRules"`
	TableAttrsRules   *[]TableAttrsRule   `json:"tableAttrsRules"`
	TableStructRules  *[]TableStructRule  `json:"tableStructRules"`
	TaskStructRules   *[]TaskStructRule   `json:"taskStructRules"`
}

StructMigrateRule defines model for StructMigrateRule.

type StructMigrateTask 

type StructMigrateTask struct {
	CaseFieldRule      *CaseFieldRule      `json:"caseFieldRule,omitempty"`
	Comment            *string             `json:"comment"`
	DatasourceNameS    *string             `json:"datasourceNameS,omitempty"`
	DatasourceNameT    *string             `json:"datasourceNameT,omitempty"`
	SchemaRouteRule    *SchemaRouteRule    `json:"schemaRouteRule,omitempty"`
	StructMigrateParam *StructMigrateParam `json:"structMigrateParam,omitempty"`
	StructMigrateRule  *StructMigrateRule  `json:"structMigrateRule,omitempty"`
	TaskName           *string             `json:"taskName,omitempty"`
}

StructMigrateTask defines model for StructMigrateTask.

type TableAttrsRule 

type TableAttrsRule struct {
	SchemaNameS *string   `json:"schemaNameS,omitempty"`
	TableAttrsT *string   `json:"tableAttrsT"`
	TableNamesS *[]string `json:"tableNamesS"`
}

TableAttrsRule defines model for TableAttrsRule.

type TableRouteRule 

type TableRouteRule struct {
	ColumnRouteRules *map[string]string `json:"columnRouteRules"`
	TableNameS       *string            `json:"tableNameS,omitempty"`
	TableNameT       *string            `json:"tableNameT,omitempty"`
}

TableRouteRule defines model for TableRouteRule.

type TableStructRule 

type TableStructRule struct {
	ColumnTypeS   *string `json:"columnTypeS"`
	ColumnTypeT   *string `json:"columnTypeT"`
	DefaultValueS *string `json:"defaultValueS"`
	DefaultValueT *string `json:"defaultValueT"`
	SchemaNameS   *string `json:"schemaNameS,omitempty"`
	TableNameS    *string `json:"tableNameS,omitempty"`
}

TableStructRule defines model for TableStructRule.

type Task 

type Task struct {
	Express  *string `json:"express,omitempty"`
	HostIP   *string `json:"hostIP"`
	Operate  *string `json:"operate,omitempty"`
	TaskName *string `json:"taskName,omitempty"`
}

Task defines model for Task.

type TaskStructRule 

type TaskStructRule struct {
	ColumnTypeS   *string `json:"columnTypeS"`
	ColumnTypeT   *string `json:"columnTypeT"`
	DefaultValueS *string `json:"defaultValueS"`
	DefaultValueT *string `json:"defaultValueT"`
}

TaskStructRule defines model for TaskStructRule.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.