gcpsql

type APIError struct {
	Reason  string
	Message string
	Status  int
}

type BackupRun struct {
	Error           *OperationError `json:"error,omitempty"`
	EndTime         string          `json:"endTime"`
	SelfLink        string          `json:"selfLink"`
	Type            string          `json:"type"`
	BackupKind      string          `json:"backupKind"`
	Description     string          `json:"description,omitempty"`
	EnqueuedTime    string          `json:"enqueuedTime"`
	Status          string          `json:"status"`
	WindowStartTime string          `json:"windowStartTime"`
	StartTime       string          `json:"startTime"`
	Instance        string          `json:"instance"`
	Kind            string          `json:"kind"`
	Location        string          `json:"location"`
	DatabaseVersion string          `json:"databaseVersion"`
	TimeZone        string          `json:"timeZone"`
	ID              string          `json:"id"`
}

type CertInsertResult struct {
	Operation *Operation
	CA        *SslCert
	Cert      *SslCert
	Key       string
}

type CloneInput struct {
	DestinationInstanceName string   `json:"destinationInstanceName"`
	DestinationProject      string   `json:"destinationProject"`
	PointInTime             string   `json:"pointInTime"`
	PitrTimestampMs         string   `json:"pitrTimestampMs"`
	DatabaseNames           []string `json:"databaseNames"`
}

type ConfigProvider interface {
	GetGCPSQLSettings() Settings
}

type ConnectSettings struct {
	Kind            string      `json:"kind"`
	ServerCaCert    *SslCert    `json:"serverCaCert,omitempty"`
	DatabaseVersion string      `json:"databaseVersion"`
	BackendType     string      `json:"backendType"`
	Region          string      `json:"region"`
	Endpoint        string      `json:"gopherstackEndpoint,omitempty"`
	IPAddresses     []IPMapping `json:"ipAddresses,omitempty"`
}

type Database struct {
	Kind      string `json:"kind"`
	Name      string `json:"name"`
	Instance  string `json:"instance"`
	Project   string `json:"project"`
	Charset   string `json:"charset,omitempty"`
	Collation string `json:"collation,omitempty"`
	Etag      string `json:"etag"`
	SelfLink  string `json:"selfLink"`
	System    bool   `json:"-"`
}

type DatabaseInput struct {
	Name      string `json:"name"`
	Charset   string `json:"charset"`
	Collation string `json:"collation"`
}

type DumpOptions struct {
	Markers  bool
	Portable bool
}

type Engine interface {
	// Endpoint is the host and published port clients connect to.
	Endpoint() (string, int)
	CreateDatabase(ctx context.Context, name, charset, collation string) error
	DropDatabase(ctx context.Context, name string) error
	ListDatabases(ctx context.Context) ([]string, error)
	UpsertUser(ctx context.Context, u UserSpec) error
	DropUser(ctx context.Context, name, host string) error
	// Restart applies flags (persisted in the data directory) and restarts the database.
	Restart(ctx context.Context, flags []Flag) error
	Stop(ctx context.Context) error
	Start(ctx context.Context) error
	// Dump returns a logical SQL dump of dbs.
	Dump(ctx context.Context, dbs []string, opts DumpOptions) ([]byte, error)
	// Restore runs a SQL file; db is the default database when the file carries no switch lines.
	Restore(ctx context.Context, db string, data []byte) error
	Query(ctx context.Context, db, query string) ([][]string, error)
	InsertRows(ctx context.Context, db, table string, columns []string, rows [][]string) error
	Close(ctx context.Context)
}

type ExportInput struct {
	CSV       *struct{ SelectQuery string } `json:"csvExportOptions"`
	FileType  string                        `json:"fileType"`
	URI       string                        `json:"uri"`
	Databases []string                      `json:"databases"`
}

type Flag struct {
	Name  string
	Value string
}

type FlagInfo struct {
	Name                string   `json:"name"`
	Type                string   `json:"type"`
	Kind                string   `json:"kind"`
	MinValue            string   `json:"minValue,omitempty"`
	MaxValue            string   `json:"maxValue,omitempty"`
	AppliesTo           []string `json:"appliesTo"`
	AllowedStringValues []string `json:"allowedStringValues,omitempty"`
	RequiresRestart     bool     `json:"requiresRestart"`
}

type Handler struct {
	Backend *InMemoryBackend

	Port int
	// contains filtered or unexported fields
}

type IPMapping struct {
	Type      string `json:"type"`
	IPAddress string `json:"ipAddress"`
}

type ImportInput struct {
	CSV *struct {
		Table   string   `json:"table"`
		Columns []string `json:"columns"`
	} `json:"csvImportOptions"`
	FileType string `json:"fileType"`
	URI      string `json:"uri"`
	Database string `json:"database"`
}

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

type Instance struct {
	Settings                   map[string]any `json:"settings,omitempty"`
	ServerCaCert               *SslCert       `json:"serverCaCert,omitempty"`
	Kind                       string         `json:"kind"`
	State                      string         `json:"state"`
	DatabaseVersion            string         `json:"databaseVersion"`
	Etag                       string         `json:"etag"`
	InstanceType               string         `json:"instanceType"`
	Project                    string         `json:"project"`
	ServiceAccountEmailAddress string         `json:"serviceAccountEmailAddress,omitempty"`
	BackendType                string         `json:"backendType"`
	SelfLink                   string         `json:"selfLink"`
	ConnectionName             string         `json:"connectionName"`
	Name                       string         `json:"name"`
	Region                     string         `json:"region"`
	GceZone                    string         `json:"gceZone,omitempty"`
	CreateTime                 string         `json:"createTime"`
	MaintenanceVersion         string         `json:"maintenanceVersion,omitempty"`
	SQLNetworkArchitecture     string         `json:"sqlNetworkArchitecture,omitempty"`
	GopherstackEndpoint        string         `json:"gopherstackEndpoint,omitempty"`
	MasterInstanceName         string         `json:"masterInstanceName,omitempty"`
	ReplicaConfiguration       map[string]any `json:"replicaConfiguration,omitempty"`
	IPAddresses                []IPMapping    `json:"ipAddresses,omitempty"`
	ReplicaNames               []string       `json:"replicaNames,omitempty"`
}

type InstanceInput struct {
	Settings           map[string]any `json:"settings"`
	Name               string         `json:"name"`
	Region             string         `json:"region"`
	DatabaseVersion    string         `json:"databaseVersion"`
	RootPassword       string         `json:"rootPassword"`
	InstanceType       string         `json:"instanceType"`
	MasterInstanceName string         `json:"masterInstanceName"`
	MaintenanceVersion string         `json:"maintenanceVersion"`
}

type LaunchSpec struct {
	Replica     *ReplicaSource
	Recovery    *Recovery
	ID          string
	Project     string
	Version     string
	Password    string
	MemoryBytes int64
	NanoCPUs    int64
	Kind        dbKind
	ServerID    uint32
	Persist     bool
	Fresh       bool
}

type Launcher interface {
	Launch(ctx context.Context, spec LaunchSpec) (Engine, error)
}

type ObjectStore interface {
	ReadObject(bucket, name string) ([]byte, error)
	WriteObject(bucket, name string, data []byte, contentType string) error
}

type Operation struct {
	Error         *OperationErrors `json:"error,omitempty"`
	ExportContext map[string]any   `json:"exportContext,omitempty"`
	ImportContext map[string]any   `json:"importContext,omitempty"`
	BackupContext map[string]any   `json:"backupContext,omitempty"`
	Kind          string           `json:"kind"`
	Name          string           `json:"name"`
	OperationType string           `json:"operationType"`
	Status        string           `json:"status"`
	TargetID      string           `json:"targetId"`
	TargetLink    string           `json:"targetLink"`
	TargetProject string           `json:"targetProject"`
	SelfLink      string           `json:"selfLink"`
	User          string           `json:"user,omitempty"`
	InsertTime    string           `json:"insertTime"`
	StartTime     string           `json:"startTime,omitempty"`
	EndTime       string           `json:"endTime,omitempty"`
	// contains filtered or unexported fields
}

type OperationError struct {
	Kind    string `json:"kind"`
	Code    string `json:"code"`
	Message string `json:"message"`
}

type OperationErrors struct {
	Kind   string           `json:"kind"`
	Errors []OperationError `json:"errors"`
}

type Provider struct{}

type Purger interface {
	Purge(ctx context.Context)
}

type Recoverer interface {
	// EnablePITR starts archiving and returns the earliest time a recovery can target.
	EnablePITR(ctx context.Context, dbs []string) (time.Time, error)
	// DisablePITR stops archiving.
	DisablePITR(ctx context.Context) error
	// PrepareRecovery makes everything up to at recoverable and describes how a new engine starts from it.
	PrepareRecovery(ctx context.Context, at time.Time) (Recovery, error)
	// ApplyRecovery finishes a recovery on a freshly launched engine.
	ApplyRecovery(ctx context.Context, rec Recovery) error
}

type Recovery struct {
	At     time.Time
	Source *ReplicaSource
	Volume string
	// FromFile and FromPos, UntilFile and UntilPos bound the MySQL binary log range a clone replays from Source.
	FromFile  string
	UntilFile string
	Script    []byte
	FromPos   uint64
	UntilPos  uint64
}

type RecoveryTimes struct {
	Kind                 string `json:"kind"`
	EarliestRecoveryTime string `json:"earliestRecoveryTime"`
	LatestRecoveryTime   string `json:"latestRecoveryTime"`
}

type ReplicaSource struct {
	Network   string
	NetworkID string
	Host      string
	Password  string
	Port      int
}

type Replicator interface {
	// ReplicationSource readies the engine as a replication source and says how a replica reaches it.
	ReplicationSource(ctx context.Context) (ReplicaSource, error)
	// AttachReplica starts replication from src; seed is a source dump for engines that cannot copy the data
	// themselves.
	AttachReplica(ctx context.Context, src ReplicaSource, seed []byte) error
	// ReplicaSeed returns the dump a MySQL replica starts from; PostgreSQL replicas copy the data themselves.
	ReplicaSeed(ctx context.Context, dbs []string) ([]byte, error)
	// Promote detaches a replica from its source and makes it writable.
	Promote(ctx context.Context) error
	// SetReplication pauses (false) or resumes (true) replication on a replica.
	SetReplication(ctx context.Context, on bool) error
	ReplicationStatus(ctx context.Context) (dbrepl.Status, error)
}

type RestoreBackupInput struct {
	BackupRunID json.Number `json:"backupRunId"`
	InstanceID  string      `json:"instanceId"`
	Project     string      `json:"project"`
}

type Settings struct {
	Engine string `` //nolint:lll // config struct tags are intentionally verbose
	/* 219-byte string literal not displayed */
	Port int `` //nolint:lll // config struct tags are intentionally verbose
	/* 208-byte string literal not displayed */
	StartupTimeout time.Duration `` //nolint:lll // config struct tags are intentionally verbose
	/* 194-byte string literal not displayed */
}

type SslCert struct {
	Kind             string `json:"kind"`
	CertSerialNumber string `json:"certSerialNumber,omitempty"`
	Cert             string `json:"cert,omitempty"`
	CommonName       string `json:"commonName,omitempty"`
	Sha1Fingerprint  string `json:"sha1Fingerprint,omitempty"`
	Instance         string `json:"instance,omitempty"`
	CreateTime       string `json:"createTime,omitempty"`
	ExpirationTime   string `json:"expirationTime,omitempty"`
	SelfLink         string `json:"selfLink,omitempty"`
}

type TierInfo struct {
	Tier      string   `json:"tier"`
	Kind      string   `json:"kind"`
	RAM       string   `json:"RAM"`
	DiskQuota string   `json:"DiskQuota"`
	Region    []string `json:"region"`
}

type User struct {
	PasswordPolicy map[string]any `json:"passwordPolicy,omitempty"`
	Kind           string         `json:"kind"`
	Name           string         `json:"name"`
	Host           string         `json:"host,omitempty"`
	Instance       string         `json:"instance"`
	Project        string         `json:"project"`
	Type           string         `json:"type,omitempty"`
	Etag           string         `json:"etag"`
	DatabaseRoles  []string       `json:"databaseRoles,omitempty"`
}

type UserInput struct {
	PasswordPolicy map[string]any `json:"passwordPolicy"`
	Name           string         `json:"name"`
	Host           string         `json:"host"`
	Password       string         `json:"password"`
	Type           string         `json:"type"`
	DatabaseRoles  []string       `json:"databaseRoles"`
}

type UserSpec struct {
	Name     string
	Host     string
	Password string
}

type VolumeRemover interface {
	RemoveVolumes(ctx context.Context)
}

type VolumeSweeper interface {
	SweepVolumes(ctx context.Context, keep map[string]bool)
}