The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SegmentFetcher ¶
type SegmentFetcher interface {
SynchronizeSegment(name string, till *int64) error
SynchronizeSegments() error
SegmentNames() []interface{}
}
SegmentFetcher interface
func NewSegmentFetcher ¶
func NewSegmentFetcher( splitStorage storage.SplitStorage, segmentStorage storage.SegmentStorage, segmentFetcher service.SegmentFetcher, metricsWrapper *storage.MetricWrapper, logger logging.LoggerInterface, ) SegmentFetcher
NewSegmentFetcher creates new segment synchronizer for processing segment updates
type SegmentFetcherSimple ¶
type SegmentFetcherSimple struct {
// contains filtered or unexported fields
}
SegmentFetcherSimple struct for segment sync
func (*SegmentFetcherSimple) SegmentNames ¶
func (s *SegmentFetcherSimple) SegmentNames() []interface{}
SegmentNames returns all segments
func (*SegmentFetcherSimple) SynchronizeSegment ¶
func (s *SegmentFetcherSimple) SynchronizeSegment(name string, till *int64) error
SynchronizeSegment syncs segment
func (*SegmentFetcherSimple) SynchronizeSegments ¶
func (s *SegmentFetcherSimple) SynchronizeSegments() error
SynchronizeSegments syncs segments at once
Source Files
Click to show internal directories.
Click to hide internal directories.