app

Documentation

Index

• Variables
• func GetCAPodName(dbPath string) string
• func GetCAReplayerPodYaml(inputDataPath, dockerHubUser string, now time.Time) (string, error)
• func GetSRPodName(dbPath string) string
• func GetSRReplayerPodYaml(inputDataPath, dockerHubUser string, now time.Time) (string, error)
• func GetShootAdminKubeclient(ctx context.Context, mode gsh.ExecutionMode) (*kubernetes.Clientset, error)
• func ListAllCAReportPaths(dir string) (caReportPaths []string, err error)
• func ListAllDBPaths(dir string) (dbPaths []string, err error)
• func ReadFilePart(w http.ResponseWriter, filePart *multipart.FileHeader) (data []byte, ok bool)
• type DefaultApp
  • func New(parentCtx context.Context, params Params) (*DefaultApp, error)
  • func (a *DefaultApp) Close() error
  • func (a *DefaultApp) GenerateCompareReport(caReportPath, srReportPath string) error
  • func (a *DefaultApp) GenerateCompareReports() error
  • func (a *DefaultApp) GetDatabase(w http.ResponseWriter, r *http.Request)
  • func (a *DefaultApp) GetLogFile(w http.ResponseWriter, r *http.Request)
  • func (a *DefaultApp) GetReport(w http.ResponseWriter, r *http.Request)
  • func (a *DefaultApp) ListAllLogFiles(w http.ResponseWriter, r *http.Request)
  • func (a *DefaultApp) ListDatabases(w http.ResponseWriter, r *http.Request)
  • func (a *DefaultApp) ListLogFiles(w http.ResponseWriter, r *http.Request)
  • func (a *DefaultApp) ListReports(w http.ResponseWriter, r *http.Request)
  • func (a *DefaultApp) PutReport(w http.ResponseWriter, r *http.Request)
  • func (a *DefaultApp) RunCAReplay(dbPath string) error
  • func (a *DefaultApp) RunCAReplays() error
  • func (a *DefaultApp) RunSRReplay(caReportPath string) error
  • func (a *DefaultApp) RunSRReplays() error
  • func (a *DefaultApp) Start() error
  • func (a *DefaultApp) StartCAReplayLoop()
  • func (a *DefaultApp) StartGenCompareReportsLoop()
  • func (a *DefaultApp) StartSRReplayLoop()
  • func (a *DefaultApp) UploadLogs(w http.ResponseWriter, r *http.Request)
  • func (a *DefaultApp) UploadReports(w http.ResponseWriter, r *http.Request)
• type Params

Variables

var ReportFileExts = sets.New(".html", ".js", ".json", ".css", ".pdf", ".md")

Functions

func GetCAPodName

func GetCAPodName(dbPath string) string

func GetCAReplayerPodYaml

func GetCAReplayerPodYaml(inputDataPath, dockerHubUser string, now time.Time) (string, error)

func GetSRPodName

func GetSRPodName(dbPath string) string

func GetSRReplayerPodYaml

func GetSRReplayerPodYaml(inputDataPath, dockerHubUser string, now time.Time) (string, error)

func GetShootAdminKubeclient

func GetShootAdminKubeclient(ctx context.Context, mode gsh.ExecutionMode) (*kubernetes.Clientset, error)

func ListAllCAReportPaths

func ListAllCAReportPaths(dir string) (caReportPaths []string, err error)

ListAllCAReportPaths lists reports like live_cds-prod_bs-g-peu_ca-replay-1.json in the given dir.

func ListAllDBPaths

func ListAllDBPaths(dir string) (dbPaths []string, err error)

func ReadFilePart

func ReadFilePart(w http.ResponseWriter, filePart *multipart.FileHeader) (data []byte, ok bool)

Types

type DefaultApp

type DefaultApp struct {
	io.Closer
	// contains filtered or unexported fields
}

func New

func New(parentCtx context.Context, params Params) (*DefaultApp, error)

func (*DefaultApp) Close

func (a *DefaultApp) Close() error

func (*DefaultApp) GenerateCompareReport

func (a *DefaultApp) GenerateCompareReport(caReportPath, srReportPath string) error

func (*DefaultApp) GenerateCompareReports

func (a *DefaultApp) GenerateCompareReports() error

func (*DefaultApp) GetDatabase

func (a *DefaultApp) GetDatabase(w http.ResponseWriter, r *http.Request)

func (*DefaultApp) GetLogFile

func (a *DefaultApp) GetLogFile(w http.ResponseWriter, r *http.Request)

func (*DefaultApp) GetReport

func (a *DefaultApp) GetReport(w http.ResponseWriter, r *http.Request)

func (*DefaultApp) ListAllLogFiles

func (a *DefaultApp) ListAllLogFiles(w http.ResponseWriter, r *http.Request)

func (*DefaultApp) ListDatabases

func (a *DefaultApp) ListDatabases(w http.ResponseWriter, r *http.Request)

func (*DefaultApp) ListLogFiles

func (a *DefaultApp) ListLogFiles(w http.ResponseWriter, r *http.Request)

func (*DefaultApp) ListReports

func (a *DefaultApp) ListReports(w http.ResponseWriter, r *http.Request)

func (*DefaultApp) PutReport

func (a *DefaultApp) PutReport(w http.ResponseWriter, r *http.Request)

func (*DefaultApp) RunCAReplay

func (a *DefaultApp) RunCAReplay(dbPath string) error

func (*DefaultApp) RunCAReplays

func (a *DefaultApp) RunCAReplays() error

func (*DefaultApp) RunSRReplay

func (a *DefaultApp) RunSRReplay(caReportPath string) error

func (*DefaultApp) RunSRReplays

func (a *DefaultApp) RunSRReplays() error

func (*DefaultApp) Start

func (a *DefaultApp) Start() error

func (*DefaultApp) StartCAReplayLoop

func (a *DefaultApp) StartCAReplayLoop()

func (*DefaultApp) StartGenCompareReportsLoop

func (a *DefaultApp) StartGenCompareReportsLoop()

func (*DefaultApp) StartSRReplayLoop

func (a *DefaultApp) StartSRReplayLoop()

func (*DefaultApp) UploadLogs

func (a *DefaultApp) UploadLogs(w http.ResponseWriter, r *http.Request)

func (*DefaultApp) UploadReports

func (a *DefaultApp) UploadReports(w http.ResponseWriter, r *http.Request)

type Params

type Params struct {
	DBDir         string
	ReportsDir    string
	DockerHubUser string
	Mode          gsh.ExecutionMode
}