Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SnapshotTask ¶
type SnapshotTask struct { Table systemcatalog.BaseTable Chunk *systemcatalog.Chunk Xld *pgtypes.XLogData SnapshotName *string // contains filtered or unexported fields }
type Snapshotter ¶
type Snapshotter struct {
// contains filtered or unexported fields
}
func NewSnapshotter ¶
func NewSnapshotter( partitionCount uint8, snapshotBatchSize int, stateStorageManager statestorage.Manager, sideChannel sidechannel.SideChannel, taskManager task.TaskManager, publicationManager publication.PublicationManager, typeManager pgtypes.TypeManager, statsService *stats.Service, ) (*Snapshotter, error)
func NewSnapshotterFromConfig ¶ added in v0.4.0
func NewSnapshotterFromConfig( c *config.Config, stateStorageManager statestorage.Manager, sideChannel sidechannel.SideChannel, taskManager task.TaskManager, publicationManager publication.PublicationManager, typeManager pgtypes.TypeManager, statsService *stats.Service, ) (*Snapshotter, error)
func (*Snapshotter) EnqueueSnapshot ¶
func (s *Snapshotter) EnqueueSnapshot( t SnapshotTask, ) error
func (*Snapshotter) StartSnapshotter ¶
func (s *Snapshotter) StartSnapshotter()
func (*Snapshotter) StopSnapshotter ¶
func (s *Snapshotter) StopSnapshotter()
Click to show internal directories.
Click to hide internal directories.