server

package

Go to main page

Versions in this module

v0

v0.5.0

Jun 14, 2019

Changes in this version

+ const AfterBalancerStartEvent

+ const AfterBalancerStopEvent

+ const BeforeBalancerStartEvent

+ const BeforeBalancerStopEvent

+ const WaitForever

type MessagesServer

+ func (s *MessagesServer) BalancerStatus() *pb.BalancerStatus

v0.4.0

May 16, 2019

Changes in this version

+ const BackupFinishedEvent

+ const BackupStartedEvent

+ const EventBackupFinish

+ const EventOplogFinish

+ const EventRestoreFinish

type BackupMetadata

+ func (b *BackupMetadata) JSON() ([]byte, error)

+ func (b *BackupMetadata) LastOplogTs() int64

+ func (b *BackupMetadata) NamePrefix() string

+ func (b *BackupMetadata) SetLastOplogTs(ts int64)

type Client

+ func (c *Client) GetCmdLineOpts() (*pb.CmdLineOpts, error)

+ func (c *Client) GetMongoDBVersion() (string, error)

+ func (c *Client) RestoreBackupCheck(backup *pb.RestoreBackupCheck, name, storageName string) (pb.RestoreBackupCheckResponse, error)

type MessagesServer

+ func (s *MessagesServer) AddError(err error)

+ func (s *MessagesServer) AllServersCmdLineOpts() ([]*pb.Server, error)

+ func (s *MessagesServer) WaitForEvent(name string, timeout time.Duration) (interface{}, error)

+ func (s *MessagesServer) WriteServerBackupMetadata(filename string) error

+ type RestoreSource struct

+ Client *Client

+ Host string

+ Port string

v0.3.0

Feb 14, 2019

Changes in this version

type Client

+ func (c *Client) GetStoragesInfo() ([]*pb.StorageInfo, error)

type MessagesServer

+ func (s *MessagesServer) LastBackupErrors() []error

+ func (s *MessagesServer) ListStorages() (map[string]StorageEntry, error)

+ type StorageEntry struct

+ DifferClients []string

+ MatchClients []string

+ StorageInfo *pb.StorageInfo

v0.2.1

Jan 12, 2019

v0.2.0

Jan 9, 2019

v0.1.0

Dec 18, 2018

Changes in this version

+ const EVENT_BACKUP_FINISH

+ const EVENT_OPLOG_FINISH

+ const EVENT_RESTORE_FINISH

+ var ClientAlreadyExistsError = fmt.Errorf("Client ID already registered")

+ var Timeout = 10000 * time.Millisecond

+ var UnknownClientID = fmt.Errorf("Unknown client ID")

+ type BackupMetadata struct

+ func LoadMetadataFromFile(name string) (*BackupMetadata, error)

+ func NewBackupMetadata(opts *pb.StartBackup) *BackupMetadata

+ func (b *BackupMetadata) AddReplicaset(clusterID, replName, replUUID, dbBackupName, oplogBackupName string) error

+ func (b *BackupMetadata) Metadata() *pb.BackupMetadata

+ func (b *BackupMetadata) RemoveReplicaset(replName string) error

+ func (b *BackupMetadata) WriteMetadataToFile(name string) error

+ type Client struct

+ ClusterID string

+ ID string

+ LastCommandSent string

+ LastSeen time.Time

+ NodeName string

+ NodeType pb.NodeType

+ ReplicasetName string

+ ReplicasetUUID string

+ ReplicasetVersion int32

+ func (c *Client) CanRestoreBackup(backupType pb.BackupType, destinationType pb.DestinationType, ...) (pb.CanRestoreBackupResponse, error)

+ func (c *Client) GetBackupSource() (string, error)

+ func (c *Client) GetStatus() (pb.Status, error)

+ func (c *Client) Status() pb.Status

+ type MessagesServer struct

+ func NewMessagesServer(workDir string, logger *logrus.Logger) *MessagesServer

+ func NewMessagesServerWithClientLogging(workDir string, logger *logrus.Logger) *MessagesServer

+ func (s *MessagesServer) BackupSourceByReplicaset() (map[string]*Client, error)

+ func (s *MessagesServer) BackupSourceNameByReplicaset() (map[string]string, error)

+ func (s *MessagesServer) Clients() map[string]Client

+ func (s *MessagesServer) ClientsByReplicaset() map[string][]Client

+ func (s *MessagesServer) DBBackupFinished(ctx context.Context, msg *pb.DBBackupFinishStatus) (*pb.DBBackupFinishedAck, error)

+ func (s *MessagesServer) IsShardedSystem() bool

+ func (s *MessagesServer) LastBackupMetadata() *BackupMetadata

+ func (s *MessagesServer) LastOplogTs() int64

+ func (s *MessagesServer) ListBackups() (map[string]pb.BackupMetadata, error)

+ func (s *MessagesServer) Logging(stream pb.Messages_LoggingServer) error

+ func (s *MessagesServer) MessagesChat(stream pb.Messages_MessagesChatServer) error

+ func (s *MessagesServer) OplogBackupFinished(ctx context.Context, msg *pb.OplogBackupFinishStatus) (*pb.OplogBackupFinishedAck, error)

+ func (s *MessagesServer) RefreshClients() error

+ func (s *MessagesServer) ReplicasetsRunningDBBackup() map[string]*Client

+ func (s *MessagesServer) ReplicasetsRunningOplogBackup() map[string]*Client

+ func (s *MessagesServer) ReplicasetsRunningRestore() map[string]*Client

+ func (s *MessagesServer) RestoreBackUp(bm *pb.BackupMetadata, skipUsersAndRoles bool) error

+ func (s *MessagesServer) RestoreBackupFromMetadataFile(filename string, skipUsersAndRoles bool) error

+ func (s *MessagesServer) RestoreCompleted(ctx context.Context, msg *pb.RestoreComplete) (*pb.RestoreCompletedAck, error)

+ func (s *MessagesServer) RestoreSourcesByReplicaset(bm *pb.BackupMetadata) (map[string]restoreSource, error)

+ func (s *MessagesServer) StartBackup(opts *pb.StartBackup) error

+ func (s *MessagesServer) StartBalancer() error

+ func (s *MessagesServer) Stop()

+ func (s *MessagesServer) StopBalancer() error

+ func (s *MessagesServer) StopOplogTail() error

+ func (s *MessagesServer) ValidateReplicasetAgents() error

+ func (s *MessagesServer) WaitBackupFinish()

+ func (s *MessagesServer) WaitOplogBackupFinish()

+ func (s *MessagesServer) WaitRestoreFinish()

+ func (s *MessagesServer) WorkDir() string

+ func (s *MessagesServer) WriteBackupMetadata(filename string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL