Documentation
¶
Overview ¶
Package heavyserver contains methods for processing synchronization tasks on heavy node.
Index ¶
- type Sync
- func (s *Sync) Reset(ctx context.Context, jetID core.RecordID, pn core.PulseNumber) error
- func (s *Sync) Start(ctx context.Context, jetID core.RecordID, pn core.PulseNumber) error
- func (s *Sync) Stop(ctx context.Context, jetID core.RecordID, pn core.PulseNumber) error
- func (s *Sync) Store(ctx context.Context, jetID core.RecordID, pn core.PulseNumber, kvs []core.KV) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Sync ¶
type Sync struct { ReplicaStorage storage.ReplicaStorage DBContext storage.DBContext sync.Mutex // contains filtered or unexported fields }
Sync provides methods for syncing records to heavy storage.
Click to show internal directories.
Click to hide internal directories.