server

Documentation

Index

• Constants
• Variables
• func WalkerDir(dir string, index *cache.Index, p *progress.Progress, logger *zap.Logger) (progress.Stat, int64, error)
• func WalkerItem(index *cache.Index, p *progress.Progress, logger *zap.Logger) (progress.Stat, error)
• type Option
  • func WithAddr(addr string) Option
  • func WithBackupClient(c *backupapi.Client) Option
  • func WithBroker(b broker.Broker) Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithNumGoroutine(num int) Option
  • func WithPublishTopics(topics ...string) Option
  • func WithSubscribeTopics(topics ...string) Option
• type Server
  • func New(opts ...Option) (*Server, error)
  • func (s *Server) DeleteRecoveryPoints(w http.ResponseWriter, r *http.Request)
  • func (s *Server) ListAction(w http.ResponseWriter, r *http.Request)
  • func (s *Server) ListBackup(w http.ResponseWriter, r *http.Request)
  • func (s *Server) ListRecoveryPoints(w http.ResponseWriter, r *http.Request)
  • func (s *Server) NewStorageVault(storageVault backupapi.StorageVault, actionID string, ...) (storage_vault.StorageVault, error)
  • func (s *Server) RequestBackup(w http.ResponseWriter, r *http.Request)
  • func (s *Server) RequestRestore(w http.ResponseWriter, r *http.Request)
  • func (s *Server) Run() error
  • func (s *Server) StopAction(w http.ResponseWriter, r *http.Request)
  • func (s *Server) SyncConfig(w http.ResponseWriter, r *http.Request)
  • func (s *Server) UpgradeAgent(w http.ResponseWriter, r *http.Request)
  • func (s *Server) Version(w http.ResponseWriter, r *http.Request)

Constants

const (
	BACKUP_FAILED_PATH = "backup_failed"
)

const (
	PERCENT_PROCESS = 0.2
)

Variables

var Version = "dev"

Functions

func WalkerDir

func WalkerDir(dir string, index *cache.Index, p *progress.Progress, logger *zap.Logger) (progress.Stat, int64, error)

func WalkerItem

func WalkerItem(index *cache.Index, p *progress.Progress, logger *zap.Logger) (progress.Stat, error)

Types

type Option

type Option func(s *Server) error

func WithAddr

func WithAddr(addr string) Option

WithAddr returns an Option which set the server listening address.

func WithBackupClient

func WithBackupClient(c *backupapi.Client) Option

WithBackupClient returns an Option which set the backup client for Server.

func WithBroker

func WithBroker(b broker.Broker) Option

WithBroker returns an Option which set the server broker for async messaging.

func WithLogger

func WithLogger(logger *zap.Logger) Option

WithLogger returns an Option which set the logger for Server.

func WithNumGoroutine

func WithNumGoroutine(num int) Option

WithLogger returns an Option which set the logger for Server.

func WithPublishTopics

func WithPublishTopics(topics ...string) Option

WithPublishTopics returns an Option which set the server topic that server broker will publish message.

func WithSubscribeTopics

func WithSubscribeTopics(topics ...string) Option

WithSubscribeTopics returns an Option which set the subscribeTopics that server broker will subscribe to.

type Server

type Server struct {
	Addr string
	// contains filtered or unexported fields
}

Server defines parameters for running BizFly Backup HTTP server.

func New

func New(opts ...Option) (*Server, error)

New creates new server instance.

func (*Server) DeleteRecoveryPoints

func (s *Server) DeleteRecoveryPoints(w http.ResponseWriter, r *http.Request)

func (*Server) ListAction

func (s *Server) ListAction(w http.ResponseWriter, r *http.Request)

func (*Server) ListBackup

func (s *Server) ListBackup(w http.ResponseWriter, r *http.Request)

func (*Server) ListRecoveryPoints

func (s *Server) ListRecoveryPoints(w http.ResponseWriter, r *http.Request)

func (*Server) NewStorageVault

func (s *Server) NewStorageVault(storageVault backupapi.StorageVault, actionID string, limitUpload, limitDownload int) (storage_vault.StorageVault, error)

func (*Server) RequestBackup

func (s *Server) RequestBackup(w http.ResponseWriter, r *http.Request)

func (*Server) RequestRestore

func (s *Server) RequestRestore(w http.ResponseWriter, r *http.Request)

func (*Server) Run

func (s *Server) Run() error

func (*Server) StopAction

func (s *Server) StopAction(w http.ResponseWriter, r *http.Request)

func (*Server) SyncConfig

func (s *Server) SyncConfig(w http.ResponseWriter, r *http.Request)

func (*Server) UpgradeAgent

func (s *Server) UpgradeAgent(w http.ResponseWriter, r *http.Request)

func (*Server) Version

func (s *Server) Version(w http.ResponseWriter, r *http.Request)