migrate

Documentation

Index

• Variables
• func WaitSQLAdminOp(ctx context.Context, sql *sqladmin.Service, project string, operation string, ...) error
• type Op
  • func NewOp(ctx context.Context, srcProject, srcInstance, dstProject, dstInstance string, ...) (*Op, error)
  • func (op *Op) PostFlight(ctx context.Context, postflight []PostFlight) []error
  • func (op *Op) Preflight(ctx context.Context, preflight []Preflight) []error
  • func (op *Op) Prepopulate(ctx context.Context, postflight []PostFlight) []error
  • func (op *Op) Run(ctx context.Context, preflight []Preflight, postflight []PostFlight) []error
• type PostFlight
• type PostFlightSQLAdmin
  • func (p *PostFlightSQLAdmin) Check(op *Op) error
  • func (p *PostFlightSQLAdmin) Name() string
  • func (p *PostFlightSQLAdmin) Prepopulate(op *Op) error
• type Preflight
• type PreflightStatus
  • func (p PreflightStatus) Check(op *Op) error
  • func (p PreflightStatus) Name() string
• type PreflightVersion
  • func (p PreflightVersion) Check(op *Op) error
  • func (p PreflightVersion) Name() string

Variables

var (
	ErrPostFlight            = errors.New("postflight_error")
	ErrPostFlightMissingDB   = fmt.Errorf("%w - missing database in target cloudsql instance", ErrPostFlight)
	ErrPostFlightMissingUser = fmt.Errorf("%w - missing user in target cloudsql instance", ErrPostFlight)
)

var (
	ErrPreflight                = errors.New("preflight_error")
	ErrPreflightVersionMismatch = fmt.Errorf("%w - mismatch database version", ErrPreflight)
	ErrPreflightStatus          = fmt.Errorf("%w - instance is not running", ErrPreflight)
)

Functions

func WaitSQLAdminOp

func WaitSQLAdminOp(ctx context.Context, sql *sqladmin.Service, project string, operation string, interval time.Duration) error

Types

type Op

type Op struct {
	Svc *sqladmin.Service
	Src *sqladmin.DatabaseInstance
	Dst *sqladmin.DatabaseInstance
}

func NewOp

func NewOp(ctx context.Context, srcProject, srcInstance, dstProject, dstInstance string, opts ...option.ClientOption) (*Op, error)

func (*Op) PostFlight

func (op *Op) PostFlight(ctx context.Context, postflight []PostFlight) []error

func (*Op) Preflight

func (op *Op) Preflight(ctx context.Context, preflight []Preflight) []error

func (*Op) Prepopulate

func (op *Op) Prepopulate(ctx context.Context, postflight []PostFlight) []error

func (*Op) Run

func (op *Op) Run(ctx context.Context, preflight []Preflight, postflight []PostFlight) []error

type PostFlight

type PostFlight interface {
	Name() string
	Prepopulate(op *Op) error
	Check(op *Op) error
}

type PostFlightSQLAdmin

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

func (*PostFlightSQLAdmin) Check

func (p *PostFlightSQLAdmin) Check(op *Op) error

func (*PostFlightSQLAdmin) Name

func (p *PostFlightSQLAdmin) Name() string

func (*PostFlightSQLAdmin) Prepopulate

func (p *PostFlightSQLAdmin) Prepopulate(op *Op) error

type Preflight

type Preflight interface {
	Name() string
	Check(op *Op) error
}

type PreflightStatus

type PreflightStatus struct{}

func (PreflightStatus) Check

func (p PreflightStatus) Check(op *Op) error

func (PreflightStatus) Name

func (p PreflightStatus) Name() string

type PreflightVersion

type PreflightVersion struct{}

func (PreflightVersion) Check

func (p PreflightVersion) Check(op *Op) error

func (PreflightVersion) Name

func (p PreflightVersion) Name() string