master

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Overview

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.

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

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	FlagSet       *flag.FlagSet             `json:"-"`
	ConfigFile    string                    `toml:"config-file" json:"config-file"`
	MasterOptions *configutil.MasterOptions `toml:"master" json:"master"`
	LogConfig     *logger.Config            `toml:"log" json:"log"`

	PrintVersion bool `json:"-"`
}

Config is the configuration for dbms-master

func NewConfig 

func NewConfig() *Config

func (*Config) Parse 

func (c *Config) Parse(args []string) error

func (*Config) String 

func (c *Config) String() string

type Server 

type Server struct {
	*Config

	// UnimplementedMasterServer
	pb.UnimplementedMasterServer
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(cfg *Config) *Server

NewServer creates a new server

func (*Server) APIDeleteAssessMigrate 

func (s *Server) APIDeleteAssessMigrate(c *gin.Context)

func (*Server) APIDeleteCsvMigrate 

func (s *Server) APIDeleteCsvMigrate(c *gin.Context)

func (*Server) APIDeleteDataCompare 

func (s *Server) APIDeleteDataCompare(c *gin.Context)

func (*Server) APIDeleteDataScan 

func (s *Server) APIDeleteDataScan(c *gin.Context)

func (*Server) APIDeleteDatabase 

func (s *Server) APIDeleteDatabase(c *gin.Context)

func (*Server) APIDeleteDatasource 

func (s *Server) APIDeleteDatasource(c *gin.Context)

func (*Server) APIDeleteSqlMigrate 

func (s *Server) APIDeleteSqlMigrate(c *gin.Context)

func (*Server) APIDeleteStmtMigrate 

func (s *Server) APIDeleteStmtMigrate(c *gin.Context)

func (*Server) APIDeleteStructCompare 

func (s *Server) APIDeleteStructCompare(c *gin.Context)

func (*Server) APIDeleteStructMigrate 

func (s *Server) APIDeleteStructMigrate(c *gin.Context)

func (*Server) APIListAssessMigrate 

func (s *Server) APIListAssessMigrate(c *gin.Context)

func (*Server) APIListCsvMigrate 

func (s *Server) APIListCsvMigrate(c *gin.Context)

func (*Server) APIListDataCompare 

func (s *Server) APIListDataCompare(c *gin.Context)

func (*Server) APIListDataScan 

func (s *Server) APIListDataScan(c *gin.Context)

func (*Server) APIListDatabase 

func (s *Server) APIListDatabase(c *gin.Context)

func (*Server) APIListDatasource 

func (s *Server) APIListDatasource(c *gin.Context)

func (*Server) APIListSqlMigrate 

func (s *Server) APIListSqlMigrate(c *gin.Context)

func (*Server) APIListStmtMigrate 

func (s *Server) APIListStmtMigrate(c *gin.Context)

func (*Server) APIListStructCompare 

func (s *Server) APIListStructCompare(c *gin.Context)

func (*Server) APIListStructMigrate 

func (s *Server) APIListStructMigrate(c *gin.Context)

func (*Server) APIPostTask 

func (s *Server) APIPostTask(c *gin.Context)

func (*Server) APIPutAssessMigrate 

func (s *Server) APIPutAssessMigrate(c *gin.Context)

func (*Server) APIPutCsvMigrate 

func (s *Server) APIPutCsvMigrate(c *gin.Context)

func (*Server) APIPutDataCompare 

func (s *Server) APIPutDataCompare(c *gin.Context)

func (*Server) APIPutDataScan 

func (s *Server) APIPutDataScan(c *gin.Context)

func (*Server) APIPutDatabase 

func (s *Server) APIPutDatabase(c *gin.Context)

func (*Server) APIPutDatasource 

func (s *Server) APIPutDatasource(c *gin.Context)

func (*Server) APIPutSqlMigrate 

func (s *Server) APIPutSqlMigrate(c *gin.Context)

func (*Server) APIPutStmtMigrate 

func (s *Server) APIPutStmtMigrate(c *gin.Context)

func (*Server) APIPutStructCompare 

func (s *Server) APIPutStructCompare(c *gin.Context)

func (*Server) APIPutStructMigrate 

func (s *Server) APIPutStructMigrate(c *gin.Context)

func (*Server) Close 

func (s *Server) Close()

Close the RPC server, this function can be called multiple times.

func (*Server) DeleteAssessMigrateTask 

func (s *Server) DeleteAssessMigrateTask(ctx context.Context, req *pb.DeleteAssessMigrateTaskRequest) (*pb.DeleteAssessMigrateTaskResponse, error)

func (*Server) DeleteCsvMigrateTask 

func (s *Server) DeleteCsvMigrateTask(ctx context.Context, req *pb.DeleteCsvMigrateTaskRequest) (*pb.DeleteCsvMigrateTaskResponse, error)

func (*Server) DeleteDataCompareTask 

func (s *Server) DeleteDataCompareTask(ctx context.Context, req *pb.DeleteDataCompareTaskRequest) (*pb.DeleteDataCompareTaskResponse, error)

func (*Server) DeleteDataScanTask 

func (s *Server) DeleteDataScanTask(ctx context.Context, req *pb.DeleteDataScanTaskRequest) (*pb.DeleteDataScanTaskResponse, error)

func (*Server) DeleteDatabase 

func (s *Server) DeleteDatabase(ctx context.Context, req *pb.DeleteDatabaseRequest) (*pb.DeleteDatabaseResponse, error)

func (*Server) DeleteDatasource 

func (s *Server) DeleteDatasource(ctx context.Context, req *pb.DeleteDatasourceRequest) (*pb.DeleteDatasourceResponse, error)

func (*Server) DeleteSqlMigrateTask 

func (s *Server) DeleteSqlMigrateTask(ctx context.Context, req *pb.DeleteSqlMigrateTaskRequest) (*pb.DeleteSqlMigrateTaskResponse, error)

func (*Server) DeleteStmtMigrateTask 

func (s *Server) DeleteStmtMigrateTask(ctx context.Context, req *pb.DeleteStmtMigrateTaskRequest) (*pb.DeleteStmtMigrateTaskResponse, error)

func (*Server) DeleteStructCompareTask 

func (s *Server) DeleteStructCompareTask(ctx context.Context, req *pb.DeleteStructCompareTaskRequest) (*pb.DeleteStructCompareTaskResponse, error)

func (*Server) DeleteStructMigrateTask 

func (s *Server) DeleteStructMigrateTask(ctx context.Context, req *pb.DeleteStructMigrateTaskRequest) (*pb.DeleteStructMigrateTaskResponse, error)

func (*Server) OperateTask 

func (s *Server) OperateTask(ctx context.Context, req *pb.OperateTaskRequest) (*pb.OperateTaskResponse, error)

OperateTask implements MasterServer.OperateTask.

func (*Server) ShowAssessMigrateTask 

func (s *Server) ShowAssessMigrateTask(ctx context.Context, req *pb.ShowAssessMigrateTaskRequest) (*pb.ShowAssessMigrateTaskResponse, error)

func (*Server) ShowCsvMigrateTask 

func (s *Server) ShowCsvMigrateTask(ctx context.Context, req *pb.ShowCsvMigrateTaskRequest) (*pb.ShowCsvMigrateTaskResponse, error)

func (*Server) ShowDataCompareTask 

func (s *Server) ShowDataCompareTask(ctx context.Context, req *pb.ShowDataCompareTaskRequest) (*pb.ShowDataCompareTaskResponse, error)

func (*Server) ShowDataScanTask 

func (s *Server) ShowDataScanTask(ctx context.Context, req *pb.ShowDataScanTaskRequest) (*pb.ShowDataScanTaskResponse, error)

func (*Server) ShowDatabase 

func (s *Server) ShowDatabase(ctx context.Context, req *pb.ShowDatabaseRequest) (*pb.ShowDatabaseResponse, error)

func (*Server) ShowDatasource 

func (s *Server) ShowDatasource(ctx context.Context, req *pb.ShowDatasourceRequest) (*pb.ShowDatasourceResponse, error)

func (*Server) ShowSqlMigrateTask 

func (s *Server) ShowSqlMigrateTask(ctx context.Context, req *pb.ShowSqlMigrateTaskRequest) (*pb.ShowSqlMigrateTaskResponse, error)

func (*Server) ShowStmtMigrateTask 

func (s *Server) ShowStmtMigrateTask(ctx context.Context, req *pb.ShowStmtMigrateTaskRequest) (*pb.ShowStmtMigrateTaskResponse, error)

func (*Server) ShowStructCompareTask 

func (s *Server) ShowStructCompareTask(ctx context.Context, req *pb.ShowStructCompareTaskRequest) (*pb.ShowStructCompareTaskResponse, error)

func (*Server) ShowStructMigrateTask 

func (s *Server) ShowStructMigrateTask(ctx context.Context, req *pb.ShowStructMigrateTaskRequest) (*pb.ShowStructMigrateTaskResponse, error)

func (*Server) Start 

func (s *Server) Start(ctx context.Context) error

Start starts to serving

func (*Server) UpsertAssessMigrateTask 

func (s *Server) UpsertAssessMigrateTask(ctx context.Context, req *pb.UpsertAssessMigrateTaskRequest) (*pb.UpsertAssessMigrateTaskResponse, error)

func (*Server) UpsertCsvMigrateTask 

func (s *Server) UpsertCsvMigrateTask(ctx context.Context, req *pb.UpsertCsvMigrateTaskRequest) (*pb.UpsertCsvMigrateTaskResponse, error)

func (*Server) UpsertDataCompareTask 

func (s *Server) UpsertDataCompareTask(ctx context.Context, req *pb.UpsertDataCompareTaskRequest) (*pb.UpsertDataCompareTaskResponse, error)

func (*Server) UpsertDataScanTask 

func (s *Server) UpsertDataScanTask(ctx context.Context, req *pb.UpsertDataScanTaskRequest) (*pb.UpsertDataScanTaskResponse, error)

func (*Server) UpsertDatabase 

func (s *Server) UpsertDatabase(ctx context.Context, req *pb.UpsertDatabaseRequest) (*pb.UpsertDatabaseResponse, error)

UpsertDatabase implements MasterServer.UpsertDatabase

func (*Server) UpsertDatasource 

func (s *Server) UpsertDatasource(ctx context.Context, req *pb.UpsertDatasourceRequest) (*pb.UpsertDatasourceResponse, error)

UpsertDatasource implements MasterServer.UpsertDatasource

func (*Server) UpsertSqlMigrateTask 

func (s *Server) UpsertSqlMigrateTask(ctx context.Context, req *pb.UpsertSqlMigrateTaskRequest) (*pb.UpsertSqlMigrateTaskResponse, error)

func (*Server) UpsertStmtMigrateTask 

func (s *Server) UpsertStmtMigrateTask(ctx context.Context, req *pb.UpsertStmtMigrateTaskRequest) (*pb.UpsertStmtMigrateTaskResponse, error)

func (*Server) UpsertStructCompareTask 

func (s *Server) UpsertStructCompareTask(ctx context.Context, req *pb.UpsertStructCompareTaskRequest) (*pb.UpsertStructCompareTaskResponse, error)

func (*Server) UpsertStructMigrateTask 

func (s *Server) UpsertStructMigrateTask(ctx context.Context, req *pb.UpsertStructMigrateTaskRequest) (*pb.UpsertStructMigrateTaskResponse, error)

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.