openapi

package

Go to main page

Versions in this module

v1

v1.0.22

May 27, 2025

v1.0.21

May 22, 2025

v1.0.20

May 14, 2025

v0

v0.0.19

Feb 13, 2025

Changes in this version

type CsvMigrateParam

+ GarbledCharReplace *string

type SqlMigrateParam

+ GarbledCharReplace *string

type StatementMigrateParam

+ GarbledCharReplace *string

v0.0.18

Dec 18, 2024

v0.0.17

Dec 16, 2024

Changes in this version

+ const APICdcConsumePath

+ type APIDeleteCdcConsumeJSONRequestBody = RequestDeleteParam

+ type APIListCdcConsumeJSONRequestBody = RequestPostParam

+ type APIPutCdcConsumeJSONRequestBody = CdcConsumeTask

+ type CdcConsumeParam struct

+ CallTimeout *uint64

+ EnableCheckpoint *bool

+ IdleResolvedThreshold *uint64

+ MessageCompression *string

+ ServerAddress *[]string

+ SubscribeTopic *string

+ TableThread *uint64

+ type CdcConsumeTask struct

+ CaseFieldRule *CaseFieldRule

+ CdcConsumeParam *CdcConsumeParam

+ Comment *string

+ DatasourceNameS *string

+ DatasourceNameT *string

+ SchemaRouteRule *SchemaRouteRule

+ TaskName *string

type ServerInterface

+ APIDeleteCdcConsume func(c *gin.Context)

+ APIListCdcConsume func(c *gin.Context)

+ APIPutCdcConsume func(c *gin.Context)

type ServerInterfaceWrapper

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

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

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

v0.0.16

Nov 12, 2024

Changes in this version

type Task

+ HostIP *string

v0.0.15

Oct 25, 2024

Changes in this version

type SqlMigrateParam

+ EnablePrepareStmt *bool

type StatementMigrateParam

+ EnablePrepareStmt *bool

v0.0.14

Sep 23, 2024

Changes in this version

type CsvMigrateParam

+ CsvImportParams *map[string]string

+ EnableImportFeature *bool

v0.0.13

Sep 6, 2024

Changes in this version

type DataCompareParam

+ Separator *string

v0.0.12

Aug 26, 2024

v0.0.11

Aug 24, 2024

v0.0.10

Aug 23, 2024

v0.0.9

Aug 22, 2024

Changes in this version

type CsvMigrateParam

+ WriteThread *uint64

type DataCompareRule

+ CompareConditionRangeS *string

+ CompareConditionRangeT *string

type DataScanParam

+ WriteThread *uint64

type SchemaRouteRule

+ ExcludeSequenceS *[]string

+ IncludeSequenceS *[]string

type SqlMigrateParam

+ EnableCheckpoint *bool

+ WriteThread *uint64

type StatementMigrateParam

+ WriteThread *uint64

type StructCompareParam

+ IgnoreCaseCompare *bool

v0.0.8

Aug 8, 2024

Changes in this version

type AssessMigrateParam

+ CallTimeout *uint64

type DataCompareParam

+ DisableMd5Checksum *bool

type DataCompareRule

+ SqlHintS *string

+ SqlHintT *string

type StructCompareParam

+ CallTimeout *uint64

type StructMigrateParam

+ CallTimeout *uint64

v0.0.7

Jul 24, 2024

Changes in this version

type DataCompareParam

+ ChunkSize *uint64

+ EnableCollationSetting *bool

+ IgnoreConditionFields *[]string

+ RepairStmtFlow *string

type DataCompareRule

+ CompareConditionField *string

+ CompareConditionRange *string

+ IgnoreConditionFields *[]string

+ IgnoreSelectFields *[]string

type Datasource

+ DbName *string

+ SessionParams *string

v0.0.6

Jul 8, 2024

Changes in this version

type DataCompareParam

+ WriteThread *uint64

type Database

+ InitThread *uint64

v0.0.5

Jun 26, 2024

v0.0.4

Jun 25, 2024

Changes in this version

type DataCompareParam

+ ConsistentReadPointS *string

+ ConsistentReadPointT *string

type SqlMigrateParam

+ EnableSafeMode *bool

type StatementMigrateParam

+ EnableSafeMode *bool

v0.0.3

Jun 21, 2024

v0.0.2

Jun 18, 2024

v0.0.1

Jun 15, 2024

Changes in this version

type StructMigrateParam

+ EnableCheckpoint *bool

v0.0.0

Jun 8, 2024

Changes in this version

+ const APIAssessMigratePath

+ const APICsvMigratePath

+ const APIDataComparePath

+ const APIDataScanPath

+ const APIDatabasePath

+ const APIDatasourcePath

+ const APISqlMigratePath

+ const APIStmtMigratePath

+ const APIStructComparePath

+ const APIStructMigratePath

+ const APITaskPath

+ const DBMSAPIBasePath

+ const DebugAPIBasePath

+ const RequestDELETEMethod

+ const RequestGETMethod

+ const RequestPOSTMethod

+ const RequestPUTMethod

+ const ResponseResultStatusFailed

+ const ResponseResultStatusSuccess

+ func GetGinHTTPResponse(c *gin.Context) string

+ func GetHTTPDebugHandler() http.Handler

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

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

+ func RegisterHandlers(router gin.IRouter, si ServerInterface)

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

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

+ type APIDeleteAssessMigrateJSONRequestBody = RequestDeleteParam

+ type APIDeleteCsvMigrateJSONRequestBody = RequestDeleteParam

+ type APIDeleteDataCompareJSONRequestBody = RequestDeleteParam

+ type APIDeleteDataScanJSONRequestBody = RequestDeleteParam

+ type APIDeleteDatasourceJSONRequestBody = RequestDeleteParam

+ type APIDeleteSqlMigrateJSONRequestBody = RequestDeleteParam

+ type APIDeleteStmtMigrateJSONRequestBody = RequestDeleteParam

+ type APIDeleteStructCompareJSONRequestBody = RequestDeleteParam

+ type APIDeleteStructMigrateJSONRequestBody = RequestDeleteParam

+ type APIListAssessMigrateJSONRequestBody = RequestPostParam

+ type APIListCsvMigrateJSONRequestBody = RequestPostParam

+ type APIListDataCompareJSONRequestBody = RequestPostParam

+ type APIListDataScanJSONRequestBody = RequestPostParam

+ type APIListDatasourceJSONRequestBody = RequestPostParam

+ type APIListSqlMigrateJSONRequestBody = RequestPostParam

+ type APIListStmtMigrateJSONRequestBody = RequestPostParam

+ type APIListStructCompareJSONRequestBody = RequestPostParam

+ type APIListStructMigrateJSONRequestBody = RequestPostParam

+ type APIPostTaskJSONRequestBody = Task

+ type APIPutAssessMigrateJSONRequestBody = AssessMigrateTask

+ type APIPutCsvMigrateJSONRequestBody = CsvMigrateTask

+ type APIPutDataCompareJSONRequestBody = DataCompareTask

+ type APIPutDataScanJSONRequestBody = DataScanTask

+ type APIPutDatabaseJSONRequestBody = Database

+ type APIPutDatasourceJSONRequestBody = NewDatasource

+ type APIPutSqlMigrateJSONRequestBody = SqlMigrateTask

+ type APIPutStmtMigrateJSONRequestBody = StmtMigrateTask

+ type APIPutStructCompareJSONRequestBody = StructCompareTask

+ type APIPutStructMigrateJSONRequestBody = StructMigrateTask

+ type AssessMigrateParam struct

+ CaseFieldRuleS *string

+ SchemaNameS *string

+ type AssessMigrateTask struct

+ AssessMigrateParam *AssessMigrateParam

+ Comment *string

+ DatasourceNameS *string

+ DatasourceNameT *string

+ TaskName *string

+ type CaseFieldRule struct

+ CaseFieldRuleS *string

+ CaseFieldRuleT *string

+ type ColumnStructRule struct

+ ColumnNameS *string

+ ColumnTypeS *string

+ ColumnTypeT *string

+ DefaultValueS *string

+ DefaultValueT *string

+ SchemaNameS *string

+ TableNameS *string

+ type CsvMigrateParam struct

+ BatchSize *uint64

+ CallTimeout *uint64

+ ChunkSize *uint64

+ DataCharsetT *string

+ Delimiter *string

+ DiskUsageFactor *string

+ EnableCheckpoint *bool

+ EnableConsistentRead *bool

+ EscapeBackslash *bool

+ Header *bool

+ NullValue *string

+ OutputDir *string

+ Separator *string

+ SqlHintS *string

+ SqlThreadS *uint64

+ TableThread *uint64

+ Terminator *string

+ type CsvMigrateTask struct

+ CaseFieldRule *CaseFieldRule

+ Comment *string

+ CsvMigrateParam *CsvMigrateParam

+ DataMigrateRules *[]DataMigrateRule

+ DatasourceNameS *string

+ DatasourceNameT *string

+ SchemaRouteRule *SchemaRouteRule

+ TaskName *string

+ type DataCompareParam struct

+ BatchSize *uint64

+ CallTimeout *uint64

+ EnableCheckpoint *bool

+ EnableConsistentRead *bool

+ OnlyCompareRow *bool

+ SqlHintS *string

+ SqlHintT *string

+ SqlThread *uint64

+ TableThread *uint64

+ type DataCompareRule struct

+ CompareField *string

+ CompareRange *string

+ IgnoreFields *[]string

+ TableNameS *string

+ type DataCompareTask struct

+ CaseFieldRule *CaseFieldRule

+ Comment *string

+ DataCompareParam *DataCompareParam

+ DataCompareRules *[]DataCompareRule

+ DatasourceNameS *string

+ DatasourceNameT *string

+ SchemaRouteRule *SchemaRouteRule

+ TaskName *string

+ type DataMigrateRule struct

+ EnableChunkStrategy *bool

+ SqlHintS *string

+ TableNameS *string

+ WhereRange *string

+ type DataScanParam struct

+ BatchSize *uint64

+ CallTimeout *uint64

+ ChunkSize *uint64

+ EnableCheckpoint *bool

+ EnableConsistentRead *bool

+ SqlHintS *string

+ SqlThreadS *uint64

+ TableSamplerateS *uint64

+ TableThread *uint64

+ type DataScanRule struct

+ SqlHintS *string

+ TableNameS *string

+ TableSamplerateS *uint64

+ type DataScanTask struct

+ CaseFieldRule *CaseFieldRule

+ Comment *string

+ DataScanParam *DataScanParam

+ DataScanRules *[]DataScanRule

+ DatasourceNameS *string

+ DatasourceNameT *string

+ SchemaRouteRule *SchemaRouteRule

+ TaskName *string

+ type Database struct

+ Host *string

+ Password *string

+ Port *uint64

+ Schema *string

+ SlowThreshold *uint64

+ Username *string

+ type Datasource struct

+ Comment *string

+ ConnectCharset *string

+ ConnectParams *string

+ ConnectStatus *string

+ DatasourceName *string

+ DbType *string

+ Host *string

+ Password *string

+ PdbName *string

+ Port *uint64

+ ServiceName *string

+ Username *string

+ type GinServerOptions struct

+ BaseURL string

+ ErrorHandler func(*gin.Context, error, int)

+ Middlewares []MiddlewareFunc

+ type MiddlewareFunc func(c *gin.Context)

+ type NewDatasource struct

+ Datasource *[]Datasource

+ type RequestDeleteParam struct

+ Param *[]string

+ type RequestPostParam struct

+ Page *uint64

+ PageSize *uint64

+ Param *string

+ type Response struct

+ Code uint64

+ Data string

+ Error string

+ type SchemaRouteRule struct

+ ExcludeTableS *[]string

+ IncludeTableS *[]string

+ SchemaNameS *string

+ SchemaNameT *string

+ TableRouteRules *[]TableRouteRule

+ type SchemaStructRule struct

+ ColumnTypeS *string

+ ColumnTypeT *string

+ DefaultValueS *string

+ DefaultValueT *string

+ SchemaNameS *string

+ type ServerInterface interface

+ APIDeleteAssessMigrate func(c *gin.Context)

+ APIDeleteCsvMigrate func(c *gin.Context)

+ APIDeleteDataCompare func(c *gin.Context)

+ APIDeleteDataScan func(c *gin.Context)

+ APIDeleteDatabase func(c *gin.Context)

+ APIDeleteDatasource func(c *gin.Context)

+ APIDeleteSqlMigrate func(c *gin.Context)

+ APIDeleteStmtMigrate func(c *gin.Context)

+ APIDeleteStructCompare func(c *gin.Context)

+ APIDeleteStructMigrate func(c *gin.Context)

+ APIListAssessMigrate func(c *gin.Context)

+ APIListCsvMigrate func(c *gin.Context)

+ APIListDataCompare func(c *gin.Context)

+ APIListDataScan func(c *gin.Context)

+ APIListDatabase func(c *gin.Context)

+ APIListDatasource func(c *gin.Context)

+ APIListSqlMigrate func(c *gin.Context)

+ APIListStmtMigrate func(c *gin.Context)

+ APIListStructCompare func(c *gin.Context)

+ APIListStructMigrate func(c *gin.Context)

+ APIPostTask func(c *gin.Context)

+ APIPutAssessMigrate func(c *gin.Context)

+ APIPutCsvMigrate func(c *gin.Context)

+ APIPutDataCompare func(c *gin.Context)

+ APIPutDataScan func(c *gin.Context)

+ APIPutDatabase func(c *gin.Context)

+ APIPutDatasource func(c *gin.Context)

+ APIPutSqlMigrate func(c *gin.Context)

+ APIPutStmtMigrate func(c *gin.Context)

+ APIPutStructCompare func(c *gin.Context)

+ APIPutStructMigrate func(c *gin.Context)

+ type ServerInterfaceWrapper struct

+ ErrorHandler func(*gin.Context, error, int)

+ Handler ServerInterface

+ HandlerMiddlewares []MiddlewareFunc

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type SqlMigrateParam struct

+ BatchSize *uint64

+ CallTimeout *uint64

+ EnableConsistentRead *bool

+ SqlHintT *string

+ SqlThreadS *uint64

+ SqlThreadT *uint64

+ type SqlMigrateRule struct

+ CaseFieldRuleT *string

+ ColumnRouteRules *map[string]string

+ SchemaNameT *string

+ SqlHintT *string

+ SqlQueryS *string

+ TableNameT *string

+ type SqlMigrateTask struct

+ CaseFieldRule *CaseFieldRule

+ Comment *string

+ DatasourceNameS *string

+ DatasourceNameT *string

+ SqlMigrateParam *SqlMigrateParam

+ SqlMigrateRules *[]SqlMigrateRule

+ TaskName *string

+ type StatementMigrateParam struct

+ BatchSize *uint64

+ CallTimeout *uint64

+ ChunkSize *uint64

+ EnableCheckpoint *bool

+ EnableConsistentRead *bool

+ SqlHintS *string

+ SqlHintT *string

+ SqlThreadS *uint64

+ SqlThreadT *uint64

+ TableThread *uint64

+ type StmtMigrateTask struct

+ CaseFieldRule *CaseFieldRule

+ Comment *string

+ DataMigrateRules *[]DataMigrateRule

+ DatasourceNameS *string

+ DatasourceNameT *string

+ SchemaRouteRule *SchemaRouteRule

+ StatementMigrateParam *StatementMigrateParam

+ TaskName *string

+ type StructCompareParam struct

+ CompareThread *uint64

+ EnableCheckpoint *bool

+ type StructCompareRule struct

+ ColumnStructRules *[]ColumnStructRule

+ SchemaStructRules *[]SchemaStructRule

+ TableStructRules *[]TableStructRule

+ TaskStructRules *[]TaskStructRule

+ type StructCompareTask struct

+ CaseFieldRule *CaseFieldRule

+ Comment *string

+ DatasourceNameS *string

+ DatasourceNameT *string

+ SchemaRouteRule *SchemaRouteRule

+ StructCompareParam *StructCompareParam

+ StructCompareRule *StructCompareRule

+ TaskName *string

+ type StructMigrateParam struct

+ CreateIfNotExist *bool

+ EnableDirectCreate *bool

+ MigrateThread *uint64

+ type StructMigrateRule struct

+ ColumnStructRules *[]ColumnStructRule

+ SchemaStructRules *[]SchemaStructRule

+ TableAttrsRules *[]TableAttrsRule

+ TableStructRules *[]TableStructRule

+ TaskStructRules *[]TaskStructRule

+ type StructMigrateTask struct

+ CaseFieldRule *CaseFieldRule

+ Comment *string

+ DatasourceNameS *string

+ DatasourceNameT *string

+ SchemaRouteRule *SchemaRouteRule

+ StructMigrateParam *StructMigrateParam

+ StructMigrateRule *StructMigrateRule

+ TaskName *string

+ type TableAttrsRule struct

+ SchemaNameS *string

+ TableAttrsT *string

+ TableNamesS *[]string

+ type TableRouteRule struct

+ ColumnRouteRules *map[string]string

+ TableNameS *string

+ TableNameT *string

+ type TableStructRule struct

+ ColumnTypeS *string

+ ColumnTypeT *string

+ DefaultValueS *string

+ DefaultValueT *string

+ SchemaNameS *string

+ TableNameS *string

+ type Task struct

+ Express *string

+ Operate *string

+ TaskName *string

+ type TaskStructRule struct

+ ColumnTypeS *string

+ ColumnTypeT *string

+ DefaultValueS *string

+ DefaultValueT *string

v0.0.0-beta.3

Jun 7, 2024

v0.0.0-beta.2

Jun 7, 2024

v0.0.0-beta.1

Jun 7, 2024

v0.0.0-beta

May 23, 2024

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