Documentation ¶
Index ¶
Constants ¶
View Source
const QueueFullTimeoutMs = 100
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SimpleReplication ¶
type SimpleReplication struct { CurrLog sdk.ReplLog NextLog sdk.ReplLog OldLog sdk.ReplLog // contains filtered or unexported fields }
func NewSimpleReplication ¶
func NewSimpleReplication(cfg *config.Config) *SimpleReplication
func (*SimpleReplication) Add ¶
func (s *SimpleReplication) Add(item sdk.ReplItem)
TODO remove unnessasery copy of []bytes here
func (*SimpleReplication) Close ¶
func (s *SimpleReplication) Close()
func (*SimpleReplication) Start ¶
func (s *SimpleReplication) Start()
Click to show internal directories.
Click to hide internal directories.