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()
Source Files
Click to show internal directories.
Click to hide internal directories.