Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

sharded

package

Go to main page

Versions in this module

v1

v1.8.1

Jun 27, 2022

v1.8.0

Jun 8, 2022

Changes in this version

type Cluster

+ func (c *Cluster) DistributedTransactionsPhys(bcp Backuper, col string)

v1.7.0

Apr 14, 2022

Changes in this version

type Cluster

+ func (c *Cluster) DistributedCommit(restoreTo primitive.Timestamp)

+ func (c *Cluster) DistributedTrxPhysical()

+ func (c *Cluster) LogicalBackup() string

+ func (c *Cluster) LogicalRestore(bcpName string)

+ func (c *Cluster) OplogReplay()

+ func (c *Cluster) PITRestoreCT(t primitive.Timestamp)

+ func (c *Cluster) PhysicalBackup() string

+ func (c *Cluster) PhysicalRestore(bcpName string)

+ func (c *Cluster) Reconnect()

+ func (c *Cluster) ReplayOplog(a, b time.Time)

+ type Physical struct

+ func NewPhysical(c *Cluster) *Physical

+ func (s *Physical) Backup()

+ func (s *Physical) Restore()

+ func (s *Physical) WaitDone()

+ func (s *Physical) WaitSnapshot()

+ func (s *Physical) WaitStarted()

v1.6.1

Nov 3, 2021

v1.6.0

Aug 12, 2021

Changes in this version

type Cluster

+ func (c *Cluster) Flush() error

+ func (c *Cluster) FlushStorage() error

+ func (c *Cluster) Timeseries()

v1.5.0

May 11, 2021

Changes in this version

type Cluster

+ func (c *Cluster) LeaderLag()

+ func (c *Cluster) SetBallastData(amount int64)

v1.4.1

Jan 27, 2021

v1.4.0

Dec 23, 2020

v1.3.4

Nov 17, 2020

v1.3.3

Nov 3, 2020

v1.3.2

Oct 12, 2020

Changes in this version

+ type Backuper interface

+ Backup func()

+ Restore func()

+ WaitDone func()

+ WaitSnapshot func()

+ WaitStarted func()

type Cluster

+ func (c *Cluster) DistributedTrxPITR()

+ func (c *Cluster) DistributedTrxSnapshot()

+ func (c *Cluster) PITRbasic()

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

+ type Pitr struct

+ 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 struct

+ 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()

v1.3.1

Sep 1, 2020

v1.3.0

Aug 24, 2020

v1.2.1

Jul 24, 2020

v1.2.0

May 12, 2020

Changes in this version

type Cluster

+ func (c *Cluster) BackupCancellation(storage string)

+ func (c *Cluster) BackupDelete(storage string)

+ func (c *Cluster) BackupNotDeleteRunning()

v1.1.3

Apr 8, 2020

v1.1.2

Mar 16, 2020

v1.1.1

Jan 29, 2020

Changes in this version

+ type Cluster struct

+ 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) BackupWaitDone(bcpName string)

+ func (c *Cluster) ClockSkew()

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

+ func (c *Cluster) DeleteBallast()

+ func (c *Cluster) DistributedTransactions()

+ func (c *Cluster) GenerateBallastData(amount int)

+ func (c *Cluster) NetworkCut()

+ func (c *Cluster) RestartAgents()

+ func (c *Cluster) Restore(bcpName string)

+ func (c *Cluster) ServerVersion() string

+ type ClusterConf struct

+ Configsrv string

+ ConfigsrvRsName string

+ DockerSocket string

+ Mongos string

+ Shards map[string]string