Documentation
¶
Index ¶
- Constants
- func CreateTar(ctx context.Context, w io.Writer, files []string, client s3wrapper.API, ...) error
- func DeleteTestDB(db *gorm.DB, dbName string)
- func GenerateError(id int32, err error) *models.Error
- func GenerateErrorResponder(err error) middleware.Responder
- func GenerateErrorResponderWithDefault(err error, defaultCode int32) middleware.Responder
- func GenerateInternalFromError(err error) *models.Error
- func GetCurrentHostName(host *models.Host) (string, error)
- func GetEventSeverityFromHostStatus(status string) string
- func GetHostnameForMsg(host *models.Host) string
- func InitializeDBTest()
- func PrepareTestDB(dbName string, extrasSchemas ...interface{}) *gorm.DB
- func TarAwsFiles(ctx context.Context, tarName string, files []string, client s3wrapper.API, ...) error
- func TerminateDBTest()
- type ApiErrorResponse
- type Cluster
- type DBContext
Constants ¶
View Source
const MinMasterHostsNeededForInstallation = 3
Variables ¶
This section is empty.
Functions ¶
func CreateTar ¶
func CreateTar(ctx context.Context, w io.Writer, files []string, client s3wrapper.API, continueOnError bool) error
continueOnError is set when running as stream, error is doing nothing when it happens cause we in the middle of stream and 200 was already returned
func DeleteTestDB ¶
func GenerateErrorResponder ¶
func GenerateErrorResponder(err error) middleware.Responder
func GenerateErrorResponderWithDefault ¶
func GenerateErrorResponderWithDefault(err error, defaultCode int32) middleware.Responder
func GetHostnameForMsg ¶
func InitializeDBTest ¶
func InitializeDBTest()
func PrepareTestDB ¶
func TarAwsFiles ¶
func TarAwsFiles(ctx context.Context, tarName string, files []string, client s3wrapper.API, log logrus.FieldLogger) error
Tar given files in s3 bucket. We open pipe for reading from aws and writing archived back to it while zipping them. It creates stream by using io.pipe
func TerminateDBTest ¶
func TerminateDBTest()
Types ¶
type ApiErrorResponse ¶
type ApiErrorResponse struct {
// contains filtered or unexported fields
}
func NewApiError ¶
func NewApiError(statusCode int32, err error) *ApiErrorResponse
func (*ApiErrorResponse) Error ¶
func (a *ApiErrorResponse) Error() string
func (*ApiErrorResponse) StatusCode ¶
func (a *ApiErrorResponse) StatusCode() int32
func (*ApiErrorResponse) WriteResponse ¶
func (a *ApiErrorResponse) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)
type Cluster ¶
type Cluster struct {
models.Cluster
// The pull secret that obtained from the Pull Secret page on the Red Hat OpenShift Cluster Manager site.
PullSecret string `json:"pull_secret" gorm:"type:TEXT"`
// The compute hash value of the http-proxy, https-proxy and no-proxy attributes, used internally to indicate
// if the proxy settings were changed while downloading ISO
ProxyHash string `json:"proxy_hash"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.