migrate

Documentation

Index

• type Agent
  • func New(ctx context.Context, sc *Context, config *MigrationConfig, k8sConn bool) (*Agent, error)
  • func (a *Agent) Do(ctx context.Context) error
• type Context
  • func NewContext(ctx context.Context, restConfig *rest.Config) (*Context, error)
  • func (c *Context) Start(ctx context.Context) error
• type MigrationConfig

Types

type Agent

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

func New

func New(ctx context.Context, sc *Context, config *MigrationConfig, k8sConn bool) (*Agent, error)

func (*Agent) Do

func (a *Agent) Do(ctx context.Context) error

type Context

type Context struct {
	Batch *batch.Factory
	Apps  *apps.Factory
	Auth  *rbac.Factory
	Core  *core.Factory
	K8s   kubernetes.Interface
	Apply apply.Apply
}

func NewContext

func NewContext(ctx context.Context, restConfig *rest.Config) (*Context, error)

func (*Context) Start

func (c *Context) Start(ctx context.Context) error

type MigrationConfig

type MigrationConfig struct {
	KubeConfig          string
	DataDir             string
	Snapshot            string
	EtcdS3Endpoint      string
	EtcdS3EndpointCA    string
	EtcdS3SkipSSLVerify bool
	EtcdS3AccessKey     string
	EtcdS3SecretKey     string
	EtcdS3Region        string
	EtcdS3BucketName    string
	EtcdS3Folder        string
	NodeName            string
	DisableETCDRestore  bool
	RegistriesTLS       cli.StringSlice
}