Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Checkpointer ¶
type Checkpointer struct {
}
func (Checkpointer) Begin ¶
func (p Checkpointer) Begin() error
func (Checkpointer) DoneC ¶
func (p Checkpointer) DoneC() chan<- k.Record
func (Checkpointer) End ¶
func (p Checkpointer) End()
func (Checkpointer) GetStartSequence ¶
func (p Checkpointer) GetStartSequence(string) string
func (Checkpointer) Release ¶
func (p Checkpointer) Release(shardID string) error
func (Checkpointer) Sync ¶
func (p Checkpointer) Sync()
func (Checkpointer) TryAcquire ¶
func (p Checkpointer) TryAcquire(shardID string) error
Source Files
Click to show internal directories.
Click to hide internal directories.