sourceApi

type DatabaseRequest struct {
	Name         string `yaml:"name" json:"name" validate:"required,max=63,id" binding:"required,max=63,id" help:"Name of the database"`
	Owner        string `yaml:"owner" json:"owner" validate:"required,max=63,id" binding:"required,max=63,id" help:"Owner of the database"`
	PasswordFile string `yaml:"password_file" json:"-" validate:"required,file" binding:"-" help:"Path to the password file of the database owner"`
	Password     string `yaml:"-" json:"password" binding:"required,min=8,max=256" help:"Password of the database owner"`

	InstanceName string `` /* 137-byte string literal not displayed */
	MigrateFrom  string `` /* 155-byte string literal not displayed */
	BackupPath   string `yaml:"backup_path" json:"-" validate:"omitempty,file" binding:"-" help:"Path to the backup file"`
}

type DatabaseSource struct {
	*DatabaseRequest

	Type SourceType `yaml:"-"`

	DatabaseSourceStatus
}

type DatabaseSourceStatus struct {
	ExpectState SourceState `yaml:"-"`
	State       SourceState `yaml:"-"`
	UpdatedAt   time.Time   `yaml:"-"`

	RetryDelay int `yaml:"-"`
	RetryTimes int `yaml:"-"`

	LastErrorMsg    string    `yaml:"-"`
	LastScheduledAt time.Time `yaml:"-"`
	NextScheduleAt  time.Time `yaml:"-"`
}

type SourceAdder interface {
	AddDatabaseSource(source *DatabaseSource) error
}

type SourceGetter interface {
	IsReady(name string, instName string) bool
	GetSource(name string) *DatabaseSource
}

type SourceHandler interface {
	SourceAdder
	SourceRemover
	SourceGetter
}

type SourceRemover interface {
	MarkDatabaseSourceIdle(name string) error
}

type SourceState string

type SourceType string