migration

type Empty struct {
}

type HealthCheckResponse struct {
	Status HealthCheckResponse_Status `protobuf:"varint,1,opt,name=status,enum=migration.HealthCheckResponse_Status" json:"status,omitempty"`
}

type HealthCheckResponse_Status int32

type MigrateResponse struct {
	MigratingTo string                     `protobuf:"bytes,1,opt,name=migrating_to,json=migratingTo" json:"migrating_to,omitempty"`
	Address     string                     `protobuf:"bytes,2,opt,name=address" json:"address,omitempty"`
	CreatedAt   *google_protobuf.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
}

type MigrationClient interface {
	HealthCheck(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	Pause(ctx context.Context, in *PauseRequest, opts ...grpc.CallOption) (*PauseResponse, error)
	Resume(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ResumeResponse, error)
	Migrate(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MigrateResponse, error)
	Unmigrate(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*UnmigrateResponse, error)
}

type MigrationConfig struct {
	*logrus.Logger
	Etcd               etcdClient
	EtcdMasterKey      string
	Clients            []MigrationClient
	Locker             locker
	HealthCheckTimeout time.Duration
	LockTimeout        time.Duration
	PauseTimeout       time.Duration
	PauseExpiry        time.Duration
	PacemakerTimeout   time.Duration
}

type MigrationServer interface {
	HealthCheck(context.Context, *Empty) (*HealthCheckResponse, error)
	Pause(context.Context, *PauseRequest) (*PauseResponse, error)
	Resume(context.Context, *Empty) (*ResumeResponse, error)
	Migrate(context.Context, *Empty) (*MigrateResponse, error)
	Unmigrate(context.Context, *Empty) (*UnmigrateResponse, error)
}

type PauseRequest struct {
	Timeout int32 `protobuf:"varint,1,opt,name=timeout" json:"timeout,omitempty"`
	Expiry  int32 `protobuf:"varint,2,opt,name=expiry" json:"expiry,omitempty"`
}

type PauseResponse struct {
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
	ExpiresAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt" json:"expires_at,omitempty"`
}

type ResumeResponse struct {
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
}

type UnmigrateResponse struct {
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
}