server

Documentation

Index

• type Option
  • func WithAddr(addr string) Option
  • func WithBackupClient(c *backupapi.Client) Option
  • func WithBroker(b broker.Broker) Option
  • func WithPublishTopic(topic string) Option
  • func WithSubscribeTopics(topics ...string) Option
• type Server
  • func New(opts ...Option) (*Server, error)
  • func (s *Server) DownloadRecoveryPoint(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) 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) SyncConfig(w http.ResponseWriter, r *http.Request)
  • func (s *Server) UpgradeAgent(w http.ResponseWriter, r *http.Request)

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 WithPublishTopic

func WithPublishTopic(topic string) Option

WithPublishTopic 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) DownloadRecoveryPoint

func (s *Server) DownloadRecoveryPoint(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) 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) SyncConfig

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

func (*Server) UpgradeAgent

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