sharded

Documentation

Index

• type Backuper
• type Cluster
  • func New(cfg ClusterConf) *Cluster
  • func (c *Cluster) ApplyConfig(file string)
  • func (c *Cluster) Backup() string
  • func (c *Cluster) BackupAndRestore()
  • func (c *Cluster) BackupBoundsCheck()
  • func (c *Cluster) BackupCancellation(storage string)
  • func (c *Cluster) BackupDelete(storage string)
  • func (c *Cluster) BackupNotDeleteRunning()
  • func (c *Cluster) BackupWaitDone(bcpName string)
  • func (c *Cluster) ClockSkew()
  • func (c *Cluster) DataChecker() (check func())
  • func (c *Cluster) DeleteBallast()
  • func (c *Cluster) DistributedTransactions(bcp Backuper, col string)
  • func (c *Cluster) DistributedTrxPITR()
  • func (c *Cluster) DistributedTrxSnapshot()
  • func (c *Cluster) GenerateBallastData(amount int)
  • func (c *Cluster) NetworkCut()
  • func (c *Cluster) PITRbasic()
  • func (c *Cluster) PITRestore(t time.Time)
  • func (c *Cluster) RestartAgents()
  • func (c *Cluster) Restore(bcpName string)
  • func (c *Cluster) ServerVersion() string
• type ClusterConf
• type Pitr
  • func NewPitr(c *Cluster) *Pitr
  • func (p *Pitr) Backup()
  • func (p *Pitr) Restore()
  • func (p *Pitr) WaitDone()
  • func (p *Pitr) WaitSnapshot()
  • func (p *Pitr) WaitStarted()
• type Snapshot
  • func NewSnapshot(c *Cluster) *Snapshot
  • func (s *Snapshot) Backup()
  • func (s *Snapshot) Restore()
  • func (s *Snapshot) WaitDone()
  • func (s *Snapshot) WaitSnapshot()
  • func (s *Snapshot) WaitStarted()

Types

type Backuper

type Backuper interface {
	Backup()
	Restore()
	WaitStarted()
	WaitSnapshot()
	WaitDone()
}

type Cluster

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

func New

func New(cfg ClusterConf) *Cluster

func (*Cluster) ApplyConfig

func (c *Cluster) ApplyConfig(file string)

func (*Cluster) Backup

func (c *Cluster) Backup() string

func (*Cluster) BackupAndRestore

func (c *Cluster) BackupAndRestore()

func (*Cluster) BackupBoundsCheck

func (c *Cluster) BackupBoundsCheck()

func (*Cluster) BackupCancellation

func (c *Cluster) BackupCancellation(storage string)

func (*Cluster) BackupDelete

func (c *Cluster) BackupDelete(storage string)

func (*Cluster) BackupNotDeleteRunning

func (c *Cluster) BackupNotDeleteRunning()

func (*Cluster) BackupWaitDone

func (c *Cluster) BackupWaitDone(bcpName string)

func (*Cluster) ClockSkew

func (c *Cluster) ClockSkew()

func (*Cluster) DataChecker

func (c *Cluster) DataChecker() (check func())

func (*Cluster) DeleteBallast

func (c *Cluster) DeleteBallast()

func (*Cluster) DistributedTransactions

func (c *Cluster) DistributedTransactions(bcp Backuper, col string)

func (*Cluster) DistributedTrxPITR

func (c *Cluster) DistributedTrxPITR()

func (*Cluster) DistributedTrxSnapshot

func (c *Cluster) DistributedTrxSnapshot()

func (*Cluster) GenerateBallastData

func (c *Cluster) GenerateBallastData(amount int)

func (*Cluster) NetworkCut

func (c *Cluster) NetworkCut()

func (*Cluster) PITRbasic

func (c *Cluster) PITRbasic()

func (*Cluster) PITRestore

func (c *Cluster) PITRestore(t time.Time)

func (*Cluster) RestartAgents

func (c *Cluster) RestartAgents()

RestartAgents restarts agents during backup. Currently restarts agents on all shards. Also consider restarting

only one shard and/or configsrv, but see https://jira.percona.com/browse/PBM-406?focusedCommentId=248029&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-248029

func (*Cluster) Restore

func (c *Cluster) Restore(bcpName string)

func (*Cluster) ServerVersion

func (c *Cluster) ServerVersion() string

type ClusterConf

type ClusterConf struct {
	Configsrv       string
	Mongos          string
	Shards          map[string]string
	DockerSocket    string
	ConfigsrvRsName string
}

type Pitr

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

func NewPitr

func NewPitr(c *Cluster) *Pitr

func (*Pitr) Backup

func (p *Pitr) Backup()

func (*Pitr) Restore

func (p *Pitr) Restore()

func (*Pitr) WaitDone

func (p *Pitr) WaitDone()

func (*Pitr) WaitSnapshot

func (p *Pitr) WaitSnapshot()

func (*Pitr) WaitStarted

func (p *Pitr) WaitStarted()

type Snapshot

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

func NewSnapshot

func NewSnapshot(c *Cluster) *Snapshot

func (*Snapshot) Backup

func (s *Snapshot) Backup()

func (*Snapshot) Restore

func (s *Snapshot) Restore()

func (*Snapshot) WaitDone

func (s *Snapshot) WaitDone()

func (*Snapshot) WaitSnapshot

func (s *Snapshot) WaitSnapshot()

func (*Snapshot) WaitStarted

func (s *Snapshot) WaitStarted()