migration

Documentation

Index

• Variables
• func RegisterMigrationMySQLServiceServer(s *grpc.Server, srv MigrationMySQLServiceServer)
• type MigrateAllMasterSchemaRequest
  • func (*MigrateAllMasterSchemaRequest) Descriptor() ([]byte, []int)
  • func (*MigrateAllMasterSchemaRequest) ProtoMessage()
  • func (x *MigrateAllMasterSchemaRequest) ProtoReflect() protoreflect.Message
  • func (x *MigrateAllMasterSchemaRequest) Reset()
  • func (x *MigrateAllMasterSchemaRequest) String() string
• type MigrateAllMasterSchemaResponse
  • func (*MigrateAllMasterSchemaResponse) Descriptor() ([]byte, []int)
  • func (*MigrateAllMasterSchemaResponse) ProtoMessage()
  • func (x *MigrateAllMasterSchemaResponse) ProtoReflect() protoreflect.Message
  • func (x *MigrateAllMasterSchemaResponse) Reset()
  • func (x *MigrateAllMasterSchemaResponse) String() string
• type MigrationMySQLServiceClient
  • func NewMigrationMySQLServiceClient(cc grpc.ClientConnInterface) MigrationMySQLServiceClient
• type MigrationMySQLServiceServer
• type RollbackMasterSchemaRequest
  • func (*RollbackMasterSchemaRequest) Descriptor() ([]byte, []int)
  • func (x *RollbackMasterSchemaRequest) GetStep() int64
  • func (*RollbackMasterSchemaRequest) ProtoMessage()
  • func (x *RollbackMasterSchemaRequest) ProtoReflect() protoreflect.Message
  • func (x *RollbackMasterSchemaRequest) Reset()
  • func (x *RollbackMasterSchemaRequest) String() string
• type RollbackMasterSchemaResponse
  • func (*RollbackMasterSchemaResponse) Descriptor() ([]byte, []int)
  • func (*RollbackMasterSchemaResponse) ProtoMessage()
  • func (x *RollbackMasterSchemaResponse) ProtoReflect() protoreflect.Message
  • func (x *RollbackMasterSchemaResponse) Reset()
  • func (x *RollbackMasterSchemaResponse) String() string
• type UnimplementedMigrationMySQLServiceServer
  • func (*UnimplementedMigrationMySQLServiceServer) MigrateAllMasterSchema(context.Context, *MigrateAllMasterSchemaRequest) (*MigrateAllMasterSchemaResponse, error)
  • func (*UnimplementedMigrationMySQLServiceServer) RollbackMasterSchema(context.Context, *RollbackMasterSchemaRequest) (*RollbackMasterSchemaResponse, error)

Variables

var File_proto_migration_mysql_service_proto protoreflect.FileDescriptor

Functions

func RegisterMigrationMySQLServiceServer

func RegisterMigrationMySQLServiceServer(s *grpc.Server, srv MigrationMySQLServiceServer)

Types

type MigrateAllMasterSchemaRequest

type MigrateAllMasterSchemaRequest struct {
	// contains filtered or unexported fields
}

func (*MigrateAllMasterSchemaRequest) Descriptor

func (*MigrateAllMasterSchemaRequest) Descriptor() ([]byte, []int)

Deprecated: Use MigrateAllMasterSchemaRequest.ProtoReflect.Descriptor instead.

func (*MigrateAllMasterSchemaRequest) ProtoMessage

func (*MigrateAllMasterSchemaRequest) ProtoMessage()

func (*MigrateAllMasterSchemaRequest) ProtoReflect

func (x *MigrateAllMasterSchemaRequest) ProtoReflect() protoreflect.Message

func (*MigrateAllMasterSchemaRequest) Reset

func (x *MigrateAllMasterSchemaRequest) Reset()

func (*MigrateAllMasterSchemaRequest) String

func (x *MigrateAllMasterSchemaRequest) String() string

type MigrateAllMasterSchemaResponse

type MigrateAllMasterSchemaResponse struct {
	// contains filtered or unexported fields
}

func (*MigrateAllMasterSchemaResponse) Descriptor

func (*MigrateAllMasterSchemaResponse) Descriptor() ([]byte, []int)

Deprecated: Use MigrateAllMasterSchemaResponse.ProtoReflect.Descriptor instead.

func (*MigrateAllMasterSchemaResponse) ProtoMessage

func (*MigrateAllMasterSchemaResponse) ProtoMessage()

func (*MigrateAllMasterSchemaResponse) ProtoReflect

func (x *MigrateAllMasterSchemaResponse) ProtoReflect() protoreflect.Message

func (*MigrateAllMasterSchemaResponse) Reset

func (x *MigrateAllMasterSchemaResponse) Reset()

func (*MigrateAllMasterSchemaResponse) String

func (x *MigrateAllMasterSchemaResponse) String() string

type MigrationMySQLServiceClient

type MigrationMySQLServiceClient interface {
	MigrateAllMasterSchema(ctx context.Context, in *MigrateAllMasterSchemaRequest, opts ...grpc.CallOption) (*MigrateAllMasterSchemaResponse, error)
	RollbackMasterSchema(ctx context.Context, in *RollbackMasterSchemaRequest, opts ...grpc.CallOption) (*RollbackMasterSchemaResponse, error)
}

MigrationMySQLServiceClient is the client API for MigrationMySQLService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMigrationMySQLServiceClient

func NewMigrationMySQLServiceClient(cc grpc.ClientConnInterface) MigrationMySQLServiceClient

type MigrationMySQLServiceServer

type MigrationMySQLServiceServer interface {
	MigrateAllMasterSchema(context.Context, *MigrateAllMasterSchemaRequest) (*MigrateAllMasterSchemaResponse, error)
	RollbackMasterSchema(context.Context, *RollbackMasterSchemaRequest) (*RollbackMasterSchemaResponse, error)
}

MigrationMySQLServiceServer is the server API for MigrationMySQLService service.

type RollbackMasterSchemaRequest

type RollbackMasterSchemaRequest struct {
	Step int64 `protobuf:"varint,1,opt,name=step,proto3" json:"step"`
	// contains filtered or unexported fields
}

func (*RollbackMasterSchemaRequest) Descriptor

func (*RollbackMasterSchemaRequest) Descriptor() ([]byte, []int)

Deprecated: Use RollbackMasterSchemaRequest.ProtoReflect.Descriptor instead.

func (*RollbackMasterSchemaRequest) GetStep

func (x *RollbackMasterSchemaRequest) GetStep() int64

func (*RollbackMasterSchemaRequest) ProtoMessage

func (*RollbackMasterSchemaRequest) ProtoMessage()

func (*RollbackMasterSchemaRequest) ProtoReflect

func (x *RollbackMasterSchemaRequest) ProtoReflect() protoreflect.Message

func (*RollbackMasterSchemaRequest) Reset

func (x *RollbackMasterSchemaRequest) Reset()

func (*RollbackMasterSchemaRequest) String

func (x *RollbackMasterSchemaRequest) String() string

type RollbackMasterSchemaResponse

type RollbackMasterSchemaResponse struct {
	// contains filtered or unexported fields
}

func (*RollbackMasterSchemaResponse) Descriptor

func (*RollbackMasterSchemaResponse) Descriptor() ([]byte, []int)

Deprecated: Use RollbackMasterSchemaResponse.ProtoReflect.Descriptor instead.

func (*RollbackMasterSchemaResponse) ProtoMessage

func (*RollbackMasterSchemaResponse) ProtoMessage()

func (*RollbackMasterSchemaResponse) ProtoReflect

func (x *RollbackMasterSchemaResponse) ProtoReflect() protoreflect.Message

func (*RollbackMasterSchemaResponse) Reset

func (x *RollbackMasterSchemaResponse) Reset()

func (*RollbackMasterSchemaResponse) String

func (x *RollbackMasterSchemaResponse) String() string

type UnimplementedMigrationMySQLServiceServer

type UnimplementedMigrationMySQLServiceServer struct {
}

UnimplementedMigrationMySQLServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMigrationMySQLServiceServer) MigrateAllMasterSchema

func (*UnimplementedMigrationMySQLServiceServer) MigrateAllMasterSchema(context.Context, *MigrateAllMasterSchemaRequest) (*MigrateAllMasterSchemaResponse, error)

func (*UnimplementedMigrationMySQLServiceServer) RollbackMasterSchema

func (*UnimplementedMigrationMySQLServiceServer) RollbackMasterSchema(context.Context, *RollbackMasterSchemaRequest) (*RollbackMasterSchemaResponse, error)