server

Documentation

Index

• Variables
• func Run(cliCtx *cli.Context, cliApp *cli.App, configPath string, ...) error
• type APIServer
  • func (api *APIServer) CreateIntegrationTables() error
  • func (api *APIServer) GetMetrics() *metrics.APIMetrics
  • func (api *APIServer) ReloadConfig(w http.ResponseWriter, command string) (*config.Config, error)
  • func (api *APIServer) Restart() error
  • func (api *APIServer) ResumeOperationsAfterRestart() error
  • func (api *APIServer) RunWatch(cliCtx *cli.Context)
  • func (api *APIServer) Stop() error
  • func (api *APIServer) UpdateBackupMetrics(ctx context.Context, onlyLocal bool) error
• type CallbackResponse

Variables

var (
	ErrAPILocked = errors.New("another operation is currently running")
)

Functions

func Run

func Run(cliCtx *cli.Context, cliApp *cli.App, configPath string, clickhouseBackupVersion string) error

Run - expose CLI commands as REST API

Types

type APIServer

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

func (*APIServer) CreateIntegrationTables

func (api *APIServer) CreateIntegrationTables() error

func (*APIServer) GetMetrics

func (api *APIServer) GetMetrics() *metrics.APIMetrics

func (*APIServer) ReloadConfig

func (api *APIServer) ReloadConfig(w http.ResponseWriter, command string) (*config.Config, error)

func (*APIServer) Restart

func (api *APIServer) Restart() error

func (*APIServer) ResumeOperationsAfterRestart

func (api *APIServer) ResumeOperationsAfterRestart() error

func (*APIServer) RunWatch

func (api *APIServer) RunWatch(cliCtx *cli.Context)

func (*APIServer) Stop

func (api *APIServer) Stop() error

Stop cancel all running commands, @todo think about graceful period

func (*APIServer) UpdateBackupMetrics

func (api *APIServer) UpdateBackupMetrics(ctx context.Context, onlyLocal bool) error

type CallbackResponse

type CallbackResponse struct {
	Status string `json:"status"`
	Error  string `json:"error"`
}

CallbackResponse is the response that is returned to callers