Documentation
¶
Overview ¶
Package commiter contains implementations of committers.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Instant ¶
type Instant struct {
// contains filtered or unexported fields
}
Instant Commiter adds commit after every single received commit
func NewInstant ¶
type IntervalCommitter ¶ added in v1.0.2
type IntervalCommitter struct {
// contains filtered or unexported fields
}
IntervalCommitter adds commit at given intervals.
func NewIntervalCommitter ¶ added in v1.0.2
type MaxBufferCommitter ¶ added in v1.0.2
type MaxBufferCommitter struct {
// contains filtered or unexported fields
}
MaxBufferCommitter adds commit after buffer is filled. If it's not filled for a long time, it adds commit after a specified interval.
func NewMaxBufferCommitter ¶ added in v1.0.2
func NewMaxBufferCommitter(headManager thead.Manager, messageStorage storage.MessageStorage, pinner sentinel.Pinner, ipnsManager ipns.Manager, ticker *clock.Ticker, maxBufferSize int) *MaxBufferCommitter
NewMaxBufferCommitter returns a new instance of MaxBufferCommitter.
Source Files
Click to show internal directories.
Click to hide internal directories.